Ticket #12625: remotestream.patch

modules/stream/handler.pl

@@ -12 +12 @@
 
     require "modules/$Path[0]/tv.pl";
 
-    unless ($filename) {
+
+    if (!defined $filename and !defined $dlurl) {
         print header(),
-              "$basename does not exist in any recognized storage group directories for this host.";
+           "$basename does not exist in any recognized storage group directories.";
         exit;
     }
 
+# if recording was found remote, get it from there
+    if($dlurl){
+        require "modules/$Path[0]/stream_remote.pl";
+        exit 0;
+    }
+
 # ASX mode?
     if ($ENV{'REQUEST_URI'} =~ /\.asx$/i) {
         require "modules/$Path[0]/stream_asx.pl";

new file modules/stream/stream_remote.pl

@@ +1 @@
+#!/usr/bin/perl
+
+# MythWeb Streaming/Download module
+
+# CGI already defines a head function, so skip it here
+use LWP::Simple qw(!head);
+
+# determine suffix if possibile
+    my $suffix = '';
+    if ($basename =~ /\.mpe?g2?$/) {
+        $suffix = '.mpg';
+    }
+    elsif ($basename =~ /\.nuv$/) {
+        $suffix = '.nuv';
+    }
+    elsif ($basename =~ /\.mkv$/) {
+        $suffix = '.mkv';
+    }
+
+
+# Build filename
+    my $name = $basename;
+    if ($name =~ /^\d+_\d+\.\w+$/) {
+        if ($title =~ /\w/) {
+            $name = $title;
+            $name .= sprintf(" - %dx%02d", $season, $episode) if $season and $episode;
+            if ($subtitle =~ /\w/) {
+                $name .= " - $subtitle";
+            }
+        }
+        $name .= $suffix;
+    }
+
+
+# Retrieve header to determine size and type
+    my ($type, $size) = LWP::Simple::head("$dlurl");
+
+    unless ($type and $size){
+        print header(),
+            "$basename could not be retrieved from remote backend";
+        exit 0;
+    }
+
+# Set the new header
+    print header(-type  => $type,
+                 -Content_length   => $size,
+                 -Content_disposition => " attachment; filename=\"$name\"",
+                );
+
+
+
+# Passthrough the requested file
+    my $status = getprint("$dlurl");
+
+#not sure how to report any error ($status!=200) after header was written.
+
+    1;

modules/stream/tv.pl

@@ -24 +24 @@
     }
 
 # Get the basename from the database
-    my $sh = $dbh->prepare('SELECT basename, title, subtitle, endtime-starttime, season, episode
+    my $sh = $dbh->prepare('SELECT basename, title, subtitle, endtime-starttime, season, episode, hostname
                               FROM recorded
                              WHERE starttime=FROM_UNIXTIME(?)
                                    AND recorded.chanid   = ?');
     $sh->execute($starttime, $chanid);
-    our ($basename, $title, $subtitle, $runtime, $season, $episode) = $sh->fetchrow_array();
+    our ($basename, $title, $subtitle, $runtime, $season, $episode, $hostname) = $sh->fetchrow_array();
     $sh->finish;
 
 # No match?
@@ -50 +50 @@
     }
     $sh->finish;
 
+# if no local file is found, prepare url to retrieve it via owning backend
+    our $dlurl;
+    unless($filename){
+
+      my $sh = $dbh->prepare('SELECT data
+                               FROM settings
+                               WHERE settings.value = "BackendServerIP"
+                                     AND settings.hostname = ?');
+      $sh->execute($hostname);
+      my ($ipaddress) = $sh->fetchrow_array();
+      $sh->finish;
+
+      $sh = $dbh->prepare('SELECT FROM_UNIXTIME(?),data
+                               FROM settings
+                               WHERE settings.value = "BackendStatusPort"
+                                     AND settings.hostname = ?');
+      $sh->execute($starttime, $hostname);
+      my ($sqltime, $port) = $sh->fetchrow_array();
+      $sh->finish;
+
+      $dlurl="http://$ipaddress:$port/Content/GetRecording?ChanId=$chanid&StartTime=$sqltime";
+    }
+
     1;