Oinktube/plugin/Live/standAloneFiles/control.json.php

<?php

/**
 * This file intent to control some features from NGINX based on the control module https://github.com/arut/nginx-rtmp-module/wiki/Control-module
 *
 * This file suppose to sit on the same server as the live stream, and for security reasons you may want to setup your control module in a different port, listning only localhost o port 8080
 *
  http {
    ...
    server {
        listen       8080;
        server_name  localhost;
        location /control {
            rtmp_control all;
        }
    }
  }
 * For more information please check this https://github.com/WWBN/AVideo/wiki/Live-Plugin#control
 */

$streamerURL = "http://192.168.0.2/YouPHPTube/"; // change it to your streamer URL
$record_path = "/var/www/tmp/"; //update this URL
$controlServer = "http://localhost:8080/";

/*
 * DO NOT EDIT AFTER THIS LINE
 */


header('Content-Type: application/json');
$configFile = '../../../videos/configuration.php';

if (file_exists($configFile)) {
    include_once $configFile;
    $streamerURL = $global['webSiteRootURL'];
    $live = AVideoPlugin::getObjectDataIfEnabled('Live');
    if (empty($live)) {
        return false;
    }
    $controlServer = $live->controlServer;
    $controlServer = addLastSlash($controlServer);
}

if (!empty($_REQUEST['streamerURL'])) {
    $streamerURL = $_REQUEST['streamerURL'];
}

error_log("Control.json.php start ".json_encode($_REQUEST));

$obj = new stdClass();
$obj->error = true;
$obj->msg = "";
$obj->streamerURL = $streamerURL;
$obj->token = $_REQUEST['token'];
$obj->command = $_REQUEST['command'];
$obj->app = $_REQUEST['app'];
$obj->name = $_REQUEST['name'];
$obj->response = "";
$obj->requestedURL = "";

if (!preg_match('/^live/i', $obj->app)) {
    $obj->app = 'live';
}

// check the token
if (empty($obj->token)) {
    $obj->msg = "Token is empty";
    error_log("Control.json.php ERROR {$obj->msg}");
    die(json_encode($obj));
}
if (empty($obj->command)) {
    $obj->msg = "command is empty";
    error_log("Control.json.php ERROR {$obj->msg}");
    die(json_encode($obj));
}
if (empty($obj->name)) {
    $obj->msg = "name is empty";
    error_log("Control.json.php ERROR {$obj->msg}");
    die(json_encode($obj));
}

$verifyTokenURL = "{$obj->streamerURL}plugin/Live/verifyToken.json.php?token={$obj->token}";

error_log("Control.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("Control.json.php verification respond content {$content}");
$json = json_decode($content);

if (empty($json)) {
    $obj->msg = "Could not verify token";
    error_log("Control.json.php ERROR {$obj->msg} ({$verifyTokenURL}) ");
    die(json_encode($obj));
} elseif (!empty($json->error)) {
    $obj->msg = "Token is invalid";
    error_log("Control.json.php ERROR {$obj->msg} ({$verifyTokenURL}) " . json_encode($json));
    die(json_encode($obj));
}
error_log("Control.json.php token is correct");
/*
ignore_user_abort(true);
ob_start();
header("Connection: close");
@header("Content-Length: " . ob_get_length());
ob_end_flush();
flush();
*/

switch ($obj->command) {
    case "record_start":
        //http://server.com/control/record/start|stop?srv=SRV&app=APP&name=NAME&rec=REC
        $obj->requestedURL = "{$controlServer}control/record/start?app={$obj->app}&name={$obj->name}&rec=video";
        $obj->response = @file_get_contents($obj->requestedURL);
        $obj->error = false;
        break;
    case "record_stop":
        //http://server.com/control/record/start|stop?srv=SRV&app=APP&name=NAME&rec=REC
        $obj->requestedURL = "{$controlServer}control/record/stop?app={$obj->app}&name={$obj->name}&rec=video";
        $obj->response = @file_get_contents($obj->requestedURL);
        $obj->error = false;
        break;
    case "drop_publisher":
        //http://server.com/control/drop/publisher|subscriber|client?srv=SRV&app=APP&name=NAME&addr=ADDR&clientid=CLIENTID
        $obj->requestedURL = "{$controlServer}control/drop/publisher?app={$obj->app}&name={$obj->name}";
        $obj->response = @file_get_contents($obj->requestedURL);
        $obj->error = false;
        break;
    case "is_recording":
        $tolerance = 10; // 10 seconds
        $obj->response = false;
        // check the last file change time, if is less then x seconds it is recording
        $files = glob("$record_path/{$obj->name}*.flv");
        foreach ($files as $value) {
            if (time()<=filemtime($value)+$tolerance) {
                $obj->response = true;
                break;
            }
        }
        $obj->error = false;
        break;

    default:
        $obj->msg = "Command is invalid ($obj->command)";
        die(json_encode($obj));
        break;
}


error_log("Control.json.php finish " . json_encode($obj));
die(json_encode($obj));