mirror of
https://github.com/DanielnetoDotCom/YouPHPTube
synced 2025-10-03 01:39:24 +02:00
791 lines
30 KiB
PHP
791 lines
30 KiB
PHP
<?php
|
|
|
|
use Amp\Deferred;
|
|
use Amp\Loop;
|
|
|
|
require_once __DIR__ . '/functions.php';
|
|
|
|
//pkill -9 -f "rw_timeout.*6196bac40f89f" //When -f is set, the full command line is used for pattern matching.
|
|
/**
|
|
* This file intent to restream your lives, you can copy this file in any server with FFMPEG
|
|
* Make sure you add the correct path to this file on the Live plugin restreamerURL parameter
|
|
*
|
|
* If you want to restream to Facebook, make sure your FFMPEG is compiled with openssl support
|
|
* On Ubuntu you can install like this:
|
|
* apt-get -y install build-essential libwebp-dev autoconf automake cmake libtool git checkinstall nasm yasm libass-dev libfreetype6-dev libsdl2-dev libtool libva-dev libvdpau-dev libvorbis-dev libxcb1-dev libxcb-shm0-dev libxcb-xfixes0-dev pkg-config texinfo wget zlib1g-dev libchromaprint-dev frei0r-plugins-dev ladspa-sdk libcaca-dev libcdio-paranoia-dev libcodec2-dev libfontconfig1-dev libfreetype6-dev libfribidi-dev libgme-dev libgsm1-dev libjack-dev libmodplug-dev libmp3lame-dev libopencore-amrnb-dev libopencore-amrwb-dev libopenjp2-7-dev libopenmpt-dev libopus-dev libpulse-dev librsvg2-dev librubberband-dev librtmp-dev libshine-dev libsmbclient-dev libsnappy-dev libsoxr-dev libspeex-dev libssh-dev libtesseract-dev libtheora-dev libtwolame-dev libv4l-dev libvo-amrwbenc-dev libvpx-dev libwavpack-dev libwebp-dev libx264-dev libx265-dev libxvidcore-dev libxml2-dev libzmq3-dev libzvbi-dev liblilv-dev libmysofa-dev libopenal-dev opencl-dev gnutls-dev libfdk-aac-dev
|
|
* git clone https://git.ffmpeg.org/ffmpeg.git ffmpeg && cd ffmpeg
|
|
* ./configure --enable-libwebp --disable-shared --enable-static --enable-pthreads --enable-gpl --enable-nonfree --enable-libass --enable-libfdk-aac --enable-libfreetype --enable-libmp3lame --enable-libopus --enable-libvorbis --enable-libvpx --enable-libx264 --enable-filters --enable-openssl --enable-runtime-cpudetect --extra-version=patrickz
|
|
* make
|
|
* make install
|
|
*/
|
|
// optional you can change the log file location here
|
|
$logFileLocation = '/var/www/tmp/';
|
|
|
|
/**
|
|
* $separateRestreams if it is set to true the script will use one FFMPEG command/process for each restream, otherwise will use only one for all streams
|
|
* all in one FFMPEG command will save you CPU and other resources, but will make harder to find issues
|
|
*/
|
|
$separateRestreams = true;
|
|
|
|
// optional you can change the default FFMPEG
|
|
//$ffmpegBinary = '/usr/bin/ffmpeg';
|
|
$ffmpegBinary = '/usr/local/bin/ffmpeg';
|
|
|
|
/*
|
|
* DO NOT EDIT AFTER THIS LINE
|
|
*/
|
|
|
|
if (!file_exists($ffmpegBinary)) {
|
|
$ffmpegBinary = '/usr/bin/ffmpeg';
|
|
if (!file_exists($ffmpegBinary)) {
|
|
$ffmpegBinary = '/usr/local/bin/ffmpeg';
|
|
}
|
|
}
|
|
|
|
$global_timeLimit = 300;
|
|
|
|
ini_set("memory_limit", -1);
|
|
ini_set('default_socket_timeout', $global_timeLimit);
|
|
set_time_limit($global_timeLimit);
|
|
ini_set('max_execution_time', $global_timeLimit);
|
|
ini_set("memory_limit", "-1");
|
|
|
|
$logFileLocation = rtrim($logFileLocation, "/") . '/';
|
|
|
|
header('Content-Type: application/json');
|
|
|
|
$isATest = false;
|
|
|
|
$logFile = $logFileLocation . "ffmpeg_restreamer_{users_id}_" . date("Y-m-d-h-i-s") . ".log";
|
|
|
|
$configFile = dirname(__FILE__) . '/../../../videos/configuration.php';
|
|
|
|
if (file_exists($configFile)) {
|
|
$doNotIncludeConfig = 1;
|
|
include_once $configFile;
|
|
$streamerURL = $global['webSiteRootURL'];
|
|
error_log("Restreamer.json.php is using local configuration");
|
|
} else {
|
|
require_once __DIR__ . "/../../../objects/functionsStandAlone.php";
|
|
}
|
|
|
|
if (empty($streamerURL)) {
|
|
die('streamerURL not defined');
|
|
}
|
|
|
|
require_once __DIR__ . "/../../../vendor/autoload.php";
|
|
|
|
if (!empty($_REQUEST['tokenForAction'])) {
|
|
$obj = new stdClass();
|
|
$obj->error = true;
|
|
$obj->msg = '';
|
|
$obj->time = time();
|
|
$obj->modified = 0;
|
|
$obj->secondsAgo = -1;
|
|
$obj->isActive = false;
|
|
$json = verifyTokenForAction($_REQUEST['tokenForAction']);
|
|
//var_dump($json);exit;
|
|
if (!empty($json) && isset($json->error) && empty($json->error)) {
|
|
$obj->error = false;
|
|
error_log("Restreamer.json.php token verified " . json_encode($json));
|
|
switch ($json->action) {
|
|
case 'log':
|
|
$obj->logName = str_replace($logFileLocation, '', $json->logFile);
|
|
$obj->logName = preg_replace('/[^a-z0-9_.-]/i', '', $obj->logName);
|
|
if (!empty($obj->logName)) {
|
|
$logFile = $logFileLocation . $obj->logName;
|
|
if (file_exists($logFile)) {
|
|
$obj->modified = @filemtime($logFile);
|
|
$obj->secondsAgo = $obj->time - $obj->modified;
|
|
$obj->isActive = $obj->secondsAgo < 10;
|
|
}
|
|
}
|
|
|
|
echo json_encode($obj);
|
|
exit;
|
|
break;
|
|
case 'stop':
|
|
$obj->killIfIsRunning = killIfIsRunning($json);
|
|
$obj->logName = str_replace($logFileLocation, '', $json->logFile);
|
|
$obj->logName = preg_replace('/[^a-z0-9_.-]/i', '', $obj->logName);
|
|
$logFile = $logFileLocation . $obj->logName;
|
|
unlink($logFile);
|
|
echo json_encode($obj);
|
|
exit;
|
|
break;
|
|
case 'start':
|
|
$robj = $json;
|
|
$robj->type = 'start';
|
|
break;
|
|
}
|
|
} else {
|
|
if (empty($json)) {
|
|
$error = '';
|
|
} else {
|
|
$error = $json->msg;
|
|
}
|
|
//var_dump(!empty($json), isset($json->error), empty($json->error), $json, $_REQUEST['tokenForAction']);exit;
|
|
$obj->msg = 'ERROR on verifyTokenForAction: ' . $json->msg;
|
|
die(json_encode($obj));
|
|
}
|
|
}
|
|
|
|
|
|
error_log("Restreamer.json.php start {$streamerURL}");
|
|
$whichffmpeg = whichffmpeg();
|
|
if ($whichffmpeg !== $ffmpegBinary) {
|
|
error_log("Restreamer.json.php WARNING you are using a different FFMPEG $whichffmpeg!==$ffmpegBinary");
|
|
}
|
|
|
|
$isCommandLine = php_sapi_name() === 'cli';
|
|
|
|
function _addLastSlash($word)
|
|
{
|
|
return $word . (_hasLastSlash($word) ? "" : "/");
|
|
}
|
|
|
|
function _hasLastSlash($word)
|
|
{
|
|
return substr($word, -1) === '/';
|
|
}
|
|
|
|
function _getLiveKey($token)
|
|
{
|
|
global $streamerURL, $isATest;
|
|
|
|
$obj = new stdClass();
|
|
$obj->error = true;
|
|
$obj->msg = '';
|
|
$obj->newRestreamsDestination = '';
|
|
$obj->content = '';
|
|
|
|
if ($isATest) {
|
|
return $obj;
|
|
}
|
|
|
|
$getKeyURL = "{$streamerURL}plugin/Live/view/Live_restreams/getLiveKey.json.php?token={$token}";
|
|
|
|
$obj->content = file_get_contents($getKeyURL);
|
|
if (!empty($obj->content)) {
|
|
$json = json_decode($obj->content);
|
|
if (!empty($json) && $json->error === false) {
|
|
if (!empty($json->stream_key) && !empty($json->stream_url)) {
|
|
$newRestreamsDestination = _addLastSlash($json->stream_url) . $json->stream_key;
|
|
$obj->newRestreamsDestination = $newRestreamsDestination;
|
|
$obj->live_url = $json->live_url;
|
|
error_log("Restreamer.json.php _getLiveKey found $newRestreamsDestination live_url={$obj->live_url}");
|
|
$obj->error = false;
|
|
}
|
|
} else if (!empty($json->rawData)) {
|
|
$rawData = json_decode($json->rawData);
|
|
$obj->msg = $rawData->message;
|
|
error_log("Restreamer.json.php _getLiveKey URL=$getKeyURL rawData {$json->rawData}");
|
|
} else if (!empty($json->msg)) {
|
|
$obj->msg = $json->msg;
|
|
error_log("Restreamer.json.php _getLiveKey URL=$getKeyURL msg " . json_encode($json->msg));
|
|
} else {
|
|
error_log("Restreamer.json.php _getLiveKey URL=$getKeyURL unknown " . json_encode($json));
|
|
}
|
|
}
|
|
return $obj;
|
|
}
|
|
|
|
$errorMessages = array();
|
|
|
|
if (!$isCommandLine) { // not command line
|
|
if (empty($robj)) {
|
|
$request = file_get_contents("php://input");
|
|
error_log("Restreamer.json.php php://input {$request}");
|
|
if (!empty($request)) {
|
|
$robj = json_decode($request);
|
|
$robj->type = 'decoded from request';
|
|
}
|
|
}
|
|
if (!empty($robj)) {
|
|
if (!empty($robj->test)) {
|
|
$isATest = true;
|
|
error_log("***Restreamer.json.php this is a test");
|
|
}
|
|
//var_dump($robj->restreamsToken);exit;
|
|
if (!empty($robj->restreamsToken)) {
|
|
$robj->restreamsToken = _object_to_array($robj->restreamsToken);
|
|
$robj->restreamsDestinations = _object_to_array($robj->restreamsDestinations);
|
|
$robj->live_url = array();
|
|
error_log("***Restreamer.json.php using restreamsToken " . json_encode($robj->restreamsToken));
|
|
//var_dump($robj->restreamsToken, $robj->restreamsDestinations);exit;
|
|
if (empty($isATest)) {
|
|
foreach ($robj->restreamsToken as $key => $token) {
|
|
|
|
$liveKey = _getLiveKey($token);
|
|
if (isset($liveKey->live_url)) {
|
|
$robj->live_url[$key] = $liveKey->live_url;
|
|
}
|
|
if (empty($liveKey->error)) {
|
|
$newRestreamsDestination = $liveKey->newRestreamsDestination;
|
|
} else {
|
|
error_log("Restreamer.json.php ERROR try again in 3 seconds " . json_encode($liveKey));
|
|
sleep(3);
|
|
$liveKey = _getLiveKey($token);
|
|
if (isset($liveKey->live_url)) {
|
|
$robj->live_url[$key] = $liveKey->live_url;
|
|
}
|
|
if (empty($liveKey->error)) {
|
|
$newRestreamsDestination = $liveKey->newRestreamsDestination;
|
|
} else {
|
|
if (!is_string($liveKey->msg)) {
|
|
$msg = json_encode($liveKey->msg);
|
|
} else {
|
|
$msg = ($liveKey->msg);
|
|
}
|
|
$errorMessages[] = nl2br($msg);
|
|
if (!empty($liveKey->content)) {
|
|
$jsonInfo = json_decode($liveKey->content);
|
|
if (!empty($jsonInfo)) {
|
|
if (!empty($jsonInfo->msg)) {
|
|
if (!is_string($jsonInfo->msg)) {
|
|
$msg = json_encode($jsonInfo->msg);
|
|
} else {
|
|
$msg = ($jsonInfo->msg);
|
|
}
|
|
$errorMessages[] = nl2br($msg);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
if (empty($newRestreamsDestination)) {
|
|
error_log("Restreamer.json.php ERROR " . json_encode($liveKey));
|
|
unset($robj->restreamsDestinations[$key]);
|
|
} else {
|
|
$robj->restreamsDestinations[$key] = $newRestreamsDestination;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
//var_dump($isATest, $robj);exit;
|
|
if (empty($robj)) {
|
|
$robj = new stdClass();
|
|
$robj->type = 'empty';
|
|
$robj->token = '';
|
|
|
|
// Check if running from the command line
|
|
if (php_sapi_name() === 'cli') {
|
|
$robj->m3u8 = @$argv[1];
|
|
$robj->restreamsDestinations = [@$argv[2]];
|
|
$robj->users_id = 'commandline';
|
|
$robj->logFile = @$argv[3];
|
|
} else {
|
|
// Fallback to URL parameters
|
|
$robj->m3u8 = isset($_REQUEST['m3u8']) ? $_REQUEST['m3u8'] : '';
|
|
$robj->restreamsDestinations = isset($_REQUEST['destinations']) ? explode(',', $_REQUEST['destinations']) : [];
|
|
$robj->users_id = isset($_REQUEST['user_id']) ? $_REQUEST['user_id'] : 'web';
|
|
$robj->logFile = isset($_REQUEST['logFile']) ? $_REQUEST['logFile'] : '';
|
|
}
|
|
|
|
$robj->responseToken = '';
|
|
}
|
|
|
|
$obj = new stdClass();
|
|
$obj->error = true;
|
|
$obj->msg = implode(PHP_EOL, $errorMessages);
|
|
$obj->streamerURL = $streamerURL;
|
|
$obj->type = $robj->type;
|
|
$obj->token = $robj->token;
|
|
$obj->pid = [];
|
|
$obj->logFile = str_replace('{users_id}', $robj->users_id, $logFile);
|
|
|
|
if (empty($robj->restreamsDestinations) || !is_array($robj->restreamsDestinations)) {
|
|
$errorMessages[] = "There are no restreams Destinations";
|
|
$obj->msg = implode('<br>', $errorMessages);
|
|
error_log("Restreamer.json.php ERROR {$obj->msg}");
|
|
die(json_encode($obj));
|
|
}
|
|
error_log("Restreamer.json.php Found " . count($robj->restreamsDestinations) . " destinations: " . json_encode($robj->restreamsDestinations));
|
|
|
|
if (!$isCommandLine) {
|
|
// check the token
|
|
if (empty($obj->token)) {
|
|
$errorMessages[] = "Token is empty";
|
|
$obj->msg = implode(PHP_EOL, $errorMessages);
|
|
error_log("Restreamer.json.php ERROR {$obj->msg}");
|
|
die(json_encode($obj));
|
|
}
|
|
|
|
$verifyTokenURL = "{$obj->streamerURL}plugin/Live/verifyToken.json.php?token={$obj->token}";
|
|
|
|
error_log("Restreamer.json.php verifying token {$verifyTokenURL}");
|
|
|
|
$arrContextOptions = [
|
|
"ssl" => [
|
|
"verify_peer" => false,
|
|
"verify_peer_name" => false,
|
|
],
|
|
];
|
|
|
|
$content = file_get_contents($verifyTokenURL, false, stream_context_create($arrContextOptions));
|
|
|
|
//error_log("Restreamer.json.php verification respond content {$content}");
|
|
$json = json_decode($content);
|
|
|
|
if (empty($json)) {
|
|
$errorMessages[] = "Could not verify token";
|
|
$obj->msg = implode(PHP_EOL, $errorMessages);
|
|
error_log("Restreamer.json.php empty json ERROR {$obj->msg} ({$verifyTokenURL}) ");
|
|
die(json_encode($obj));
|
|
} elseif (!empty($json->error)) {
|
|
$errorMessages[] = "Token is invalid";
|
|
$obj->msg = implode(PHP_EOL, $errorMessages);
|
|
error_log("Restreamer.json.php json error ERROR {$obj->msg} ({$verifyTokenURL}) " . json_encode($json));
|
|
die(json_encode($obj));
|
|
}
|
|
}
|
|
$robj->logFile = $obj->logFile;
|
|
//var_dump($robj);exit;
|
|
if (function_exists('_mysql_close')) {
|
|
_mysql_close();
|
|
}
|
|
session_write_close();
|
|
error_log("Restreamer.json.php starting async ");
|
|
Loop::run(function () {
|
|
global $robj;
|
|
runRestream($robj)->onResolve(function (Throwable $error = null, $result = null) {
|
|
if ($error) {
|
|
error_log("Restreamer.json.php runRestream: asyncOperation1 fail -> " . $error->getMessage());
|
|
} else {
|
|
error_log("Restreamer.json.php runRestream: asyncOperation1 result -> " . json_encode($result));
|
|
}
|
|
});
|
|
});
|
|
error_log("Restreamer.json.php finish async ");
|
|
$obj->error = false;
|
|
die(json_encode($obj));
|
|
|
|
function runRestream($robj)
|
|
{
|
|
$m3u8 = $robj->m3u8;
|
|
error_log("runRestream " . json_encode($robj));
|
|
$restreamsDestinations = $robj->restreamsDestinations;
|
|
$logFile = $robj->logFile;
|
|
$users_id = $robj->users_id;
|
|
$responseToken = $robj->responseToken;
|
|
global $separateRestreams;
|
|
killIfIsRunning($robj);
|
|
$pid = array();
|
|
$deferred = new Deferred();
|
|
if (empty($separateRestreams)) {
|
|
error_log("Restreamer.json.php runRestream all in one command ");
|
|
$pid[] = startRestream($m3u8, $restreamsDestinations, $logFile, $robj);
|
|
} else {
|
|
error_log("Restreamer.json.php runRestream separateRestreams " . count($restreamsDestinations));
|
|
foreach ($restreamsDestinations as $key => $value) {
|
|
sleep(5);
|
|
$robj->live_restreams_id = $key;
|
|
$host = clearCommandURL(parse_url($value, PHP_URL_HOST));
|
|
$pid[] = startRestream($m3u8, [$value], str_replace(".log", "_{$key}_{$robj->liveTransmitionHistory_id}_{$host}.log", $logFile), $robj);
|
|
}
|
|
}
|
|
$deferred->resolve($pid);
|
|
return $deferred->promise();
|
|
}
|
|
|
|
function notifyStreamer($robj)
|
|
{
|
|
global $streamerURL;
|
|
$restreamerURL = (isset($_SERVER['HTTPS']) && $_SERVER['HTTPS'] === 'on' ? "https" : "http") . "://$_SERVER[HTTP_HOST]$_SERVER[REQUEST_URI]";
|
|
$m3u8 = $robj->m3u8;
|
|
error_log("notifyStreamer " . json_encode($robj));
|
|
$restreamsDestinations = $robj->restreamsDestinations;
|
|
$logFile = $robj->logFile;
|
|
$users_id = $robj->users_id;
|
|
$responseToken = $robj->responseToken;
|
|
|
|
$data_string = json_encode(
|
|
array(
|
|
'm3u8' => $m3u8,
|
|
'restreamsDestinations' => $restreamsDestinations,
|
|
'logFile' => $logFile,
|
|
'users_id' => $users_id,
|
|
'responseToken' => $responseToken,
|
|
'restreamerURL' => $restreamerURL,
|
|
'live_restreams_id' => $robj->live_restreams_id,
|
|
'live_url' => $robj->live_url,
|
|
)
|
|
);
|
|
error_log("Restreamer.json.php notifyStreamer {$data_string}");
|
|
|
|
$url = "{$streamerURL}plugin/Live/view/Live_restreams_logs/add.json.php";
|
|
return postToURL($url, $data_string);
|
|
}
|
|
|
|
function verifyTokenForAction($token)
|
|
{
|
|
global $streamerURL;
|
|
$data_string = json_encode(array('token' => $token));
|
|
error_log("Restreamer.json.php verifyTokenForAction {$data_string}");
|
|
|
|
$url = "{$streamerURL}plugin/Live/view/Live_restreams/verifyTokenForAction.json.php";
|
|
//var_dump($url);//exit;
|
|
return postToURL($url, $data_string);
|
|
}
|
|
|
|
function postToURL($url, $data_string, $timeLimit = 10)
|
|
{
|
|
global $global_timeLimit;
|
|
try {
|
|
set_time_limit($timeLimit);
|
|
//open connection
|
|
$ch = curl_init();
|
|
curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, $timeLimit);
|
|
curl_setopt($ch, CURLOPT_TIMEOUT, $timeLimit / 2); //timeout in seconds
|
|
//set the url, number of POST vars, POST data
|
|
curl_setopt($ch, CURLOPT_URL, $url);
|
|
curl_setopt($ch, CURLOPT_FOLLOWLOCATION, true);
|
|
//curl_setopt($ch, CURLOPT_HEADER, true);
|
|
curl_setopt($ch, CURLOPT_CUSTOMREQUEST, "POST");
|
|
curl_setopt($ch, CURLOPT_POSTFIELDS, $data_string);
|
|
curl_setopt($ch, CURLOPT_POSTREDIR, 3);
|
|
curl_setopt($ch, CURLOPT_POST, 1);
|
|
//curl_setopt($ch, CURLOPT_POSTFIELDS, $data_string);
|
|
curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, 0);
|
|
curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, 0);
|
|
//curl_setopt($ch, CURLOPT_CUSTOMREQUEST, "POST");
|
|
curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
|
|
curl_setopt($ch, CURLOPT_AUTOREFERER, true);
|
|
curl_setopt($ch, CURLOPT_VERBOSE, 1);
|
|
curl_setopt(
|
|
$ch,
|
|
CURLOPT_HTTPHEADER,
|
|
[
|
|
'Content-Type: application/json',
|
|
'Content-Length: ' . strlen($data_string),
|
|
]
|
|
);
|
|
//$info = curl_getinfo($ch, CURLINFO_HTTP_CODE);
|
|
$output = curl_exec($ch);
|
|
curl_close($ch);
|
|
set_time_limit($global_timeLimit);
|
|
//var_dump($url, $data_string, $output);//exit;
|
|
return json_decode($output);
|
|
} catch (Exception $exc) {
|
|
error_log("Restreamer.json.php postToURL ERROR " . $exc->getTraceAsString());
|
|
}
|
|
set_time_limit($global_timeLimit);
|
|
return false;
|
|
}
|
|
|
|
function clearCommandURL($url)
|
|
{
|
|
return preg_replace('/[^0-9a-z:.\/_&?=-]/i', "", $url);
|
|
}
|
|
|
|
function _isURL200($url, $forceRecheck = false)
|
|
{
|
|
global $global_timeLimit;
|
|
set_time_limit(5);
|
|
error_log("_isURL200 checking URL {$url}");
|
|
|
|
// Create a stream context that ignores SSL certificate verification
|
|
$context = stream_context_create(array(
|
|
"ssl" => array(
|
|
"verify_peer" => false,
|
|
"verify_peer_name" => false,
|
|
),
|
|
));
|
|
|
|
// Use the created context with file_get_contents
|
|
$headers = @get_headers($url, 1, $context);
|
|
if (!is_array($headers)) {
|
|
$headers = [$headers];
|
|
}
|
|
|
|
$result = false;
|
|
foreach ($headers as $value) {
|
|
if (
|
|
strpos($value, '200') ||
|
|
strpos($value, '302') ||
|
|
strpos($value, '304')
|
|
) {
|
|
$result = true;
|
|
break;
|
|
} else {
|
|
error_log('_isURL200: ' . $value);
|
|
}
|
|
}
|
|
set_time_limit($global_timeLimit);
|
|
|
|
return $result;
|
|
}
|
|
|
|
function _make_path($path)
|
|
{
|
|
$created = false;
|
|
if (substr($path, -1) !== DIRECTORY_SEPARATOR) {
|
|
$path = pathinfo($path, PATHINFO_DIRNAME);
|
|
}
|
|
if (!is_dir($path)) {
|
|
$created = mkdir($path, 0755, true);
|
|
if (!$created) {
|
|
error_log('_make_path: could not create the dir ' . json_encode($path));
|
|
}
|
|
} else {
|
|
$created = true;
|
|
}
|
|
return $created;
|
|
}
|
|
|
|
function startRestream($m3u8, $restreamsDestinations, $logFile, $robj, $tries = 1)
|
|
{
|
|
global $ffmpegBinary, $isATest;
|
|
$m3u8 = str_replace('vlu.me', 'live', $m3u8);
|
|
if (empty($restreamsDestinations)) {
|
|
error_log("Restreamer.json.php startRestream ERROR empty restreamsDestinations");
|
|
return false;
|
|
}
|
|
|
|
$restream = isRestreamRuning($robj->live_restreams_id, $robj->liveTransmitionHistory_id);
|
|
if (!empty($restream)) {
|
|
error_log("Restreamer.json.php startRestream ERROR it is already running " . json_encode($restream));
|
|
return false;
|
|
} else {
|
|
error_log("Restreamer.json.php startRestream success " . json_encode(array($robj->live_restreams_id, $robj->liveTransmitionHistory_id)));
|
|
}
|
|
|
|
$m3u8 = _addQueryStringParameter($m3u8, 'live_restreams_id', $robj->live_restreams_id);
|
|
$m3u8 = _addQueryStringParameter($m3u8, 'liveTransmitionHistory_id', $robj->liveTransmitionHistory_id);
|
|
|
|
$m3u8 = clearCommandURL($m3u8);
|
|
|
|
if ($tries === 1) {
|
|
sleep(3);
|
|
}
|
|
if (!$isATest && function_exists('_isURL200') && !_isURL200($m3u8, true)) {
|
|
if ($tries > 20) {
|
|
error_log("Restreamer.json.php startRestream tried too many times, we could not find your stream URL");
|
|
return false;
|
|
}
|
|
if ($tries === 1) {
|
|
error_log("Restreamer.json.php startRestream " . json_encode(debug_backtrace(DEBUG_BACKTRACE_IGNORE_ARGS, 5)));
|
|
}
|
|
error_log("Restreamer.json.php startRestream URL ($m3u8) is NOT ready. trying again ({$tries})");
|
|
sleep($tries);
|
|
return startRestream($m3u8, $restreamsDestinations, $logFile, $robj, $tries + 1);
|
|
}
|
|
|
|
error_log("Restreamer.json.php startRestream _isURL200 tries= " . json_encode($tries));
|
|
|
|
// Check FFmpeg version
|
|
$ffmpegVersionOutput = [];
|
|
exec("$ffmpegBinary -version", $ffmpegVersionOutput);
|
|
preg_match('/ffmpeg version ([0-9]+)\./', $ffmpegVersionOutput[0] ?? '', $matches);
|
|
$ffmpegMajorVersion = isset($matches[1]) ? (int)$matches[1] : 0;
|
|
|
|
// Disable reconnect_on_network_error for FFmpeg versions below 6
|
|
$disableReconnectOnNetworkError = ($ffmpegMajorVersion < 6);
|
|
|
|
$userAgent = 'AVideoRestreamer';
|
|
|
|
$FFMPEGcommand = "{$ffmpegBinary} -re -rw_timeout 60000000 -reconnect 1 -reconnect_streamed 1 -reconnect_delay_max 30 -y";
|
|
|
|
// Check if $m3u8 is a URL
|
|
if (filter_var($m3u8, FILTER_VALIDATE_URL)) {
|
|
$FFMPEGcommand .= " -user_agent \"{$userAgent}\"";
|
|
}
|
|
|
|
// Add the input and preset options
|
|
$FFMPEGcommand .= " -i \"{$m3u8}\" -preset veryfast";
|
|
|
|
$FFMPEGComplement = " -max_muxing_queue_size 2048 " // Increased the muxing queue size for stability
|
|
. '{audioConfig}'
|
|
. "-c:v libx264 "
|
|
. "-pix_fmt yuv420p "
|
|
. "-r 30 -g 60 "
|
|
. "-tune zerolatency "
|
|
. "-x264-params \"nal-hrd=cbr\" " // Ensure constant bitrate for compatibility with social media platforms
|
|
. "-b:v 6000k " // Set constant video bitrate
|
|
. "-minrate 6000k -maxrate 6000k -bufsize 12000k " // Increased buffer size for better handling of network fluctuations
|
|
. "-preset veryfast "
|
|
. "-f flv "
|
|
. "-fflags +genpts " // Ensure smooth playback
|
|
. "-strict -2 " // Allow non-compliant AAC audio
|
|
. "-reconnect 1 " // Enable reconnection in case of a broken pipe
|
|
. "-reconnect_at_eof 1 " // Stop reconnecting at the end of file/input data
|
|
. "-reconnect_streamed 1 " // Disable reconnect for non-seekable streams
|
|
. "-reconnect_delay_max 30 " // Maximum delay between reconnection attempts
|
|
. ($disableReconnectOnNetworkError ? "" : "-reconnect_on_network_error 1 ") // Retry on network errors only if supported
|
|
. "-probesize 50M " // Increased probing size to handle larger HLS segments
|
|
. "-analyzeduration 200M " // Increase analysis duration to handle network issues
|
|
. "-rtmp_buffer 20000 " // Increased RTMP buffer size for smoother streaming
|
|
. "-rtmp_live live " // Ensure RTMP live streaming mode
|
|
. "{tls_verify} " // Disable SSL/TLS certificate validation (optional, based on your trust in the source)
|
|
. "\"{restreamsDestinations}\"";
|
|
|
|
if (count($restreamsDestinations) > 1) {
|
|
$command = $FFMPEGcommand;
|
|
foreach ($restreamsDestinations as $value) {
|
|
$audioConfig = getAudioConfiguration($value);
|
|
$value = clearCommandURL($value);
|
|
$tls_verify = preg_match("/rtmps:/i", $value) ? "-tls_verify 0 " : "";
|
|
$command .= str_replace(array('{audioConfig}', '{restreamsDestinations}', '{tls_verify}'), array($audioConfig, $value, $tls_verify), $FFMPEGComplement);
|
|
}
|
|
} else {
|
|
$audioConfig = getAudioConfiguration($restreamsDestinations[0]);
|
|
$tls_verify = preg_match("/rtmps:/i", $restreamsDestinations[0]) ? "-tls_verify 0 " : "";
|
|
$command = $FFMPEGcommand;
|
|
$command .= str_replace(array('{audioConfig}', '{restreamsDestinations}', '{tls_verify}'), array($audioConfig, $restreamsDestinations[0], $tls_verify), $FFMPEGComplement);
|
|
}
|
|
|
|
if (empty($command) || !preg_match("/-f flv/i", $command)) {
|
|
error_log("Restreamer.json.php startRestream ERROR command is empty ");
|
|
} else {
|
|
error_log("Restreamer.json.php startRestream startRestream, check the file ($logFile) for the log");
|
|
_make_path($logFile);
|
|
file_put_contents($logFile, $command . PHP_EOL);
|
|
if (empty($isATest)) {
|
|
exec('nohup ' . $command . ' 2>> ' . $logFile . ' > /dev/null &');
|
|
}
|
|
error_log("Restreamer.json.php startRestream finish");
|
|
}
|
|
|
|
$robj->logFile = $logFile;
|
|
notifyStreamer($robj);
|
|
return true;
|
|
}
|
|
|
|
function getAudioConfiguration($source)
|
|
{
|
|
if (preg_match("/facebook.com/i", $source)) {
|
|
$audioConfig = '-c:a copy -bsf:a aac_adtstoasc -ac 1 -ar 44100 -b:a 128k ';
|
|
} else if (preg_match("/youtube.com/i", $source)) {
|
|
$audioConfig = '-c:a aac -b:a 128k ';
|
|
} else {
|
|
$audioConfig = '-c:a copy ';
|
|
}
|
|
|
|
return $audioConfig;
|
|
}
|
|
|
|
$isOpenSSLEnabled = null;
|
|
|
|
function isOpenSSLEnabled()
|
|
{
|
|
global $isOpenSSLEnabled, $ffmpegBinary;
|
|
if (isset($isOpenSSLEnabled)) {
|
|
return $isOpenSSLEnabled;
|
|
}
|
|
exec("{$ffmpegBinary} 2>&1", $output, $return_var);
|
|
foreach ($output as $value) {
|
|
if (preg_match("/configuration:.*--enable-openssl/i", $value)) {
|
|
$isOpenSSLEnabled = true;
|
|
return $isOpenSSLEnabled;
|
|
}
|
|
}
|
|
$isOpenSSLEnabled = false;
|
|
return $isOpenSSLEnabled;
|
|
}
|
|
|
|
function whichffmpeg()
|
|
{
|
|
exec("which ffmpeg 2>&1", $output, $return_var);
|
|
return @$output[0];
|
|
}
|
|
|
|
function getProcess($robj)
|
|
{
|
|
$m3u8 = $robj->m3u8;
|
|
$m3u8 = clearCommandURL($m3u8);
|
|
$liveTransmitionHistory_id = intval($robj->liveTransmitionHistory_id);
|
|
$live_restreams_id = intval($robj->live_restreams_id);
|
|
|
|
if (!empty($live_restreams_id)) {
|
|
$m3u8 .= ".*live_restreams_id={$live_restreams_id}";
|
|
}
|
|
if (!empty($liveTransmitionHistory_id)) {
|
|
$m3u8 .= ".*liveTransmitionHistory_id={$liveTransmitionHistory_id}";
|
|
}
|
|
|
|
global $ffmpegBinary;
|
|
exec("ps -ax 2>&1", $output, $return_var);
|
|
//error_log("Restreamer.json.php:getProcess ". json_encode($output));
|
|
$pattern = "/^([0-9]+).*" . replaceSlashesForPregMatch($ffmpegBinary) . ".*" . replaceSlashesForPregMatch($m3u8) . "/i";
|
|
foreach ($output as $value) {
|
|
//error_log("Restreamer.json.php:getProcess {$pattern}");
|
|
if (preg_match($pattern, trim($value), $matches)) {
|
|
error_log("Restreamer.json.php:getProcess found " . json_encode($value));
|
|
return $matches;
|
|
}
|
|
}
|
|
error_log("Restreamer.json.php:getProcess NOT found {$pattern}");
|
|
return false;
|
|
}
|
|
|
|
function killIfIsRunning($robj)
|
|
{
|
|
$process = getProcess($robj);
|
|
//error_log("Restreamer.json.php killIfIsRunning checking if there is a process running for {$m3u8} ");
|
|
if (!empty($process)) {
|
|
error_log("Restreamer.json.php killIfIsRunning there is a process running " . json_encode($process));
|
|
$pid = intval($process[1]);
|
|
if (!empty($pid)) {
|
|
error_log("Restreamer.json.php killIfIsRunning killing {$pid} ");
|
|
exec("kill -9 {$pid} 2>&1", $output, $return_var);
|
|
sleep(1);
|
|
}
|
|
return true;
|
|
} else {
|
|
//error_log("Restreamer.json.php killIfIsRunning there is not a process running for {$command} ");
|
|
}
|
|
return false;
|
|
}
|
|
|
|
function replaceSlashesForPregMatch($str)
|
|
{
|
|
return str_replace('/', '.', $str);
|
|
}
|
|
|
|
function _object_to_array($obj)
|
|
{
|
|
//only process if it's an object or array being passed to the function
|
|
if (is_object($obj) || is_array($obj)) {
|
|
$ret = (array) $obj;
|
|
foreach ($ret as &$item) {
|
|
//recursively process EACH element regardless of type
|
|
$item = _object_to_array($item);
|
|
}
|
|
return $ret;
|
|
}
|
|
//otherwise (i.e. for scalar values) return without modification
|
|
else {
|
|
return $obj;
|
|
}
|
|
}
|
|
|
|
function _addQueryStringParameter($url, $varname, $value)
|
|
{
|
|
$parsedUrl = parse_url($url);
|
|
if (empty($parsedUrl['host'])) {
|
|
return "";
|
|
}
|
|
$query = [];
|
|
|
|
if (isset($parsedUrl['query'])) {
|
|
parse_str($parsedUrl['query'], $query);
|
|
}
|
|
$query[$varname] = $value;
|
|
$path = $parsedUrl['path'] ?? '';
|
|
$query = !empty($query) ? '?' . http_build_query($query) : '';
|
|
|
|
$port = '';
|
|
if (!empty($parsedUrl['port']) && $parsedUrl['port'] != '80') {
|
|
$port = ":{$parsedUrl['port']}";
|
|
}
|
|
|
|
if (empty($parsedUrl['scheme'])) {
|
|
$scheme = '';
|
|
} else {
|
|
$scheme = "{$parsedUrl['scheme']}:";
|
|
}
|
|
return $scheme . '//' . $parsedUrl['host'] . $port . $path . $query;
|
|
}
|