Terugluisteren werkt
This commit is contained in:
@@ -147,28 +147,91 @@ QUERY;
|
||||
return response()->abort(404);
|
||||
}
|
||||
|
||||
$size += filesize($file);
|
||||
$files[] = $file;
|
||||
$size += ($filesize = filesize($file));
|
||||
$files[] = [$file, $filesize];
|
||||
$currentHour->add(\DateInterval::createFromDateString('1 hour'));
|
||||
}
|
||||
|
||||
return new StreamedResponse(function() use($files) {
|
||||
// Open output stream
|
||||
$headers = [
|
||||
'Pragma' => 'public',
|
||||
'Expires' => '-1',
|
||||
'Cache-Control' => 'public,must-revalidate,post-check=0,pre-check=0',
|
||||
'Content-Type' => 'audio/mpeg',
|
||||
'Content-Length' => $size,
|
||||
'Accept-Ranges' => 'bytes'
|
||||
];
|
||||
|
||||
$range = [];
|
||||
if(isset($_SERVER['HTTP_RANGE'])) {
|
||||
list($unit, $rangestr) = explode('=', $_SERVER['HTTP_RANGE'], 2);
|
||||
if($unit == "bytes") {
|
||||
$range = explode('-', $rangestr);
|
||||
$range[1] = (empty($range[1])) ? ($size - 1) : min(abs(intval($range[1])), ($size - 1));
|
||||
$range[0] = (empty($range[0]) || $range[1] < abs(intval($range[0]))) ? 0 : max(abs(intval($range[0])), 0);
|
||||
$range[2] = ($range[1] - $range[0] + 1);
|
||||
|
||||
//if($range[0] > 0 || $range[1] < ($size - 1)) {
|
||||
$headers['Content-Range'] = 'bytes ' . $range[0] . '-' . $range[1] . '/' . $size;
|
||||
$headers['Content-Length'] = $range[2];
|
||||
//}
|
||||
}
|
||||
}
|
||||
|
||||
if($range === null) {
|
||||
// $log = fopen('/tmp/rq.log', 'a');
|
||||
// fwrite($log, "Aborting (416)!\n\n");
|
||||
// fclose($log);
|
||||
response()->abort(416); // Requested Range Not Satisfiable
|
||||
return;
|
||||
}
|
||||
|
||||
return new StreamedResponse(function() use($files, $range) {
|
||||
// $log = fopen('/tmp/rq.log', 'a');
|
||||
// if(!count($range)) {
|
||||
// fwrite($log, "Writing everything.\n");
|
||||
// } else {
|
||||
// fwrite($log, "Writing {$range[2]} bytes ({$range[0]} - {$range[1]})\n");
|
||||
//}
|
||||
$output = fopen('php://output', 'w');
|
||||
foreach($files as $file) {
|
||||
$fp = fopen($file, 'rb');
|
||||
while ($buf = fread($fp, 1024)) {
|
||||
if(count($range) && $range[0] >= $file[1]) {
|
||||
// We have a range and can skip the whole file
|
||||
// fwrite($log, "Skipping all of {$file[0]}.\n");
|
||||
continue;
|
||||
}
|
||||
// else fwrite($log, "File {$file[0]} is {$file[1]} bytes (starting from {$range[0]}).\n");
|
||||
|
||||
$fp = fopen($file[0], 'rb');
|
||||
if(count($range) && $range[0]) {
|
||||
fseek($fp, $range[0]);
|
||||
$range[0] = 0;
|
||||
}
|
||||
|
||||
$maxToRead = count($range) ? min(1024, $range[2]) : 1024;
|
||||
while ($buf = fread($fp, $maxToRead)) {
|
||||
fwrite($output, $buf);
|
||||
if(count($range)) {
|
||||
$maxToRead = min(1024, $range[2]);
|
||||
$bufSize = mb_strlen($buf, '8bit');
|
||||
// $bytes += $bufSize;
|
||||
if(($range[2] -= $bufSize) == 0) {
|
||||
// fwrite($log, "Stopping reading from {$file[0]} because end of range reached.\n");
|
||||
break;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
// fwrite($log, "Wrote $bytes bytes.\n");
|
||||
fclose($fp);
|
||||
|
||||
if(count($range) && $range[2] == 0) {
|
||||
break;
|
||||
}
|
||||
}
|
||||
|
||||
fclose($output);
|
||||
}, 200, [
|
||||
'Content-Type' => 'audio/mpg',
|
||||
'Content-Disposition' => sprintf(
|
||||
'attachment; filename="Radio_6FM_Uitzending_%02d-%02d-%04d_%02du00.MP3"',
|
||||
$day, $month, $year, $hour)
|
||||
]);
|
||||
// fclose($log);
|
||||
}, count($range) ? 206 : 200, $headers);
|
||||
}
|
||||
|
||||
// Provide a streaming file with support for scrubbing
|
||||
|
||||
Reference in New Issue
Block a user