Update playlist live playback

objects/functionsFFMPEG.php

@@ -687,6 +687,39 @@ function testFFMPEGRemote()
     }
 }
 
+function listFFMPEGRemote($keyword = '')
+{
+    $url = buildFFMPEGRemoteURL(['list' => 1, 'keyword' => $keyword, 'microtime' => microtime(true)]);
+    if ($url) {
+        _error_log("listFFMPEGRemote: URL $url");
+        return json_decode(url_get_contents($url));
+    } else {
+        return false;
+    }
+}
+
+function killFFMPEGRemote($pid)
+{
+    $url = buildFFMPEGRemoteURL(['kill' => $pid, 'microtime' => microtime(true)]);
+    if ($url) {
+        _error_log("killFFMPEGRemote: URL $url");
+        return json_decode(url_get_contents($url));
+    } else {
+        return false;
+    }
+}
+
+function isKeywordRunningFFMPEGRemote($keyword)
+{
+    $url = buildFFMPEGRemoteURL(['isKeywordRunning' => $keyword, 'microtime' => microtime(true)]);
+    if ($url) {
+        _error_log("isKeywordRunningFFMPEGRemote: URL $url");
+        return json_decode(url_get_contents($url));
+    } else {
+        return false;
+    }
+}
+
 function deleteFolderFFMPEGRemote($videoFilename)
 {
     $url = buildFFMPEGRemoteURL(['deleteFolder' => $videoFilename]);

plugin/API/ffmpeg.php

@@ -0,0 +1,139 @@
+<?php
+global $global, $config;
+if (!isset($global['systemRootPath'])) {
+    require_once '../../videos/configuration.php';
+}
+if (!User::isAdmin()) {
+    forbiddenPage('Admin only');
+}
+
+require_once $global['systemRootPath'] . 'plugin/API/API.php';
+$plugin = AVideoPlugin::loadPluginIfEnabled("API");
+if (empty($plugin)) {
+    forbiddenPage('API Plugin disabled');
+}
+$obj = AVideoPlugin::getObjectData("API");
+
+
+$_page = new Page(array('FFMPEG'));
+
+?>
+<div class="container">
+    <div class="panel panel-default">
+        <div class="panel-heading"><?php echo __('FFmpeg Process Manager'); ?> </div>
+        <div class="panel-body">
+
+            <table class="table table-bordered table-striped" id="processTable">
+                <thead>
+                    <tr>
+                        <th>PID</th>
+                        <th>Command</th>
+                        <th>CPU (%)</th>
+                        <th>Memory (%)</th>
+                        <th>Running Time</th>
+                        <th>Running Time (s)</th>
+                        <th>Action</th>
+                    </tr>
+                </thead>
+                <tbody>
+                    <!-- Data will be loaded here -->
+                </tbody>
+            </table>
+        </div>
+        <div class="panel-footer">
+            <button id="refreshBtn" class="btn btn-primary btn-block"><?php echo __('Refresh List'); ?></button>
+        </div>
+    </div>
+</div>
+
+<script>
+    $(document).ready(function() {
+        var loadProcessesModal = getPleaseWait();
+
+        function loadProcesses() {
+            loadProcessesModal.showPleaseWait();
+
+            $.ajax({
+                url: webSiteRootURL + "plugin/API/list.ffmpeg.json.php",
+                type: "GET",
+                dataType: "json",
+                success: function(data) {
+                    let tableBody = $("#processTable tbody");
+                    tableBody.empty();
+
+                    if (data.error || !data.list || data.list.length === 0) {
+                        tableBody.append("<tr><td colspan='7' class='text-center'>No FFmpeg processes running</td></tr>");
+                        return;
+                    }
+
+                    $.each(data.list, function(index, process) {
+                        let row = `<tr>
+                            <td>${process.pid}</td>
+                            <td style="word-break: break-word;">${process.command}</td>
+                            <td>${process.cpu_usage}</td>
+                            <td>${process.memory_usage}</td>
+                            <td>${process.running_time}</td>
+                            <td>${process.running_time_seconds}</td>
+                            <td>
+                                <button class="btn btn-danger btn-sm kill-btn btn-block" data-pid="${process.pid}">Kill</button>
+                            </td>
+                        </tr>`;
+                        tableBody.append(row);
+                    });
+                    loadProcessesModal.hidePleaseWait();
+                },
+                complete: function(resp) {
+                    response = resp.responseJSON
+                    avideoResponse(response);
+                    loadProcessesModal.hidePleaseWait();
+                }
+            });
+
+        }
+
+
+        // Load process list on page load
+        loadProcesses();
+
+        // Refresh button
+        $("#refreshBtn").click(function() {
+            loadProcesses();
+        });
+
+        // Handle process kill button click
+        $(document).on("click", ".kill-btn", function() {
+            let pid = $(this).data("pid");
+
+            avideoConfirm("Are you sure you want to kill process " + pid + "?").then(response => {
+                if (response) {
+                    modal.showPleaseWait();
+
+                    $.ajax({
+                        url: webSiteRootURL + "plugin/API/kill.ffmpeg.json.php",
+                        type: "POST",
+                        data: {
+                            pid: pid
+                        },
+                        dataType: "json",
+                        success: function(response) {
+                            avideoResponse(response);
+                            loadProcesses(); // Refresh the list after a successful kill
+                            modal.hidePleaseWait();
+                        },
+                        complete: function(resp) {
+                            response = resp.responseJSON
+                            avideoResponse(response);
+                            modal.hidePleaseWait();
+                        }
+                    });
+
+                } else {
+                    return false;
+                }
+            });
+        });
+    });
+</script>
+<?php
+$_page->print();
+?>

plugin/API/kill.ffmpeg.json.php

@@ -0,0 +1,18 @@
+<?php
+$configFile = __DIR__.'/../../videos/configuration.php';
+require_once $configFile;
+header('Content-Type: application/json');
+
+if(!User::isAdmin()){
+    forbiddenPage('Must be admin');
+}
+
+$pid = intval($_REQUEST['pid']);
+
+if(empty($pid)){
+    forbiddenPage('PID is invalid');
+}
+
+$obj = killFFMPEGRemote($pid);
+
+die(json_encode($obj));

plugin/API/list.ffmpeg.json.php

@@ -0,0 +1,12 @@
+<?php
+$configFile = __DIR__.'/../../videos/configuration.php';
+require_once $configFile;
+header('Content-Type: application/json');
+
+if(!User::isAdmin()){
+    forbiddenPage('Must be admin');
+}
+
+$obj = listFFMPEGRemote();
+
+die(json_encode($obj));

plugin/API/pluginMenu.html

@@ -1,2 +1,3 @@
 <button onclick="avideoModalIframeLarge(webSiteRootURL +'plugin/API/info.php');" class="btn btn-primary btn-sm btn-xs btn-block"><i class="fas fa-info-circle"></i> Info</button>
-<button onclick="avideoAlertAJAX(webSiteRootURL +'plugin/API/check.ffmpeg.json.php');" class="btn btn-primary btn-sm btn-xs btn-block"><i class="fas fa-terminal"></i> Test Remote FFmpeg</button>
+<button onclick="avideoModalIframeLarge(webSiteRootURL +'plugin/API/ffmpeg.php');" class="btn btn-primary btn-sm btn-xs btn-block"><i class="fa fa-bolt"></i> FFmpeg Process</button>
+<button onclick="avideoAlertAJAX(webSiteRootURL +'plugin/API/check.ffmpeg.json.php');" class="btn btn-primary btn-sm btn-xs btn-block"><i class="fas fa-terminal"></i> Test Remote FFmpeg</button>

plugin/API/standAlone/ffmpeg.json.php

@@ -47,7 +47,7 @@
  * - **Command Validation:**
  *   - Ensures the `ffmpegCommand` starts with `ffmpeg` or an allowed path (`/usr/bin/ffmpeg`, `/bin/ffmpeg`).
  *   - Sanitizes the command by removing potentially dangerous characters (`;`, `&`, `|`, `` ` ``, `<`, `>`).
- * 
+ *
  * - **Kill Process by Keyword:** Allows stopping a previously started process by providing a `keyword`.
  *
  * Output:
@@ -165,7 +165,7 @@ if (!empty($matches)) {
         _error_log($msg);
 
         echo json_encode([
-            'error' => true, 
+            'error' => true,
             'msg' => $msg,
             'directory' => $directory,
         ]);
@@ -214,6 +214,25 @@ if (!empty($codeToExec->test)) {
         'isActive' => $isActive,
     ]);
     exit;
+} else if (!empty($codeToExec->list)) {
+    _error_log("List mode triggered");
+    $list = listFFmpegProcesses($codeToExec->keyword);
+    echo json_encode([
+        'error' => false,
+        'msg' => '',
+        'list' => $list,
+    ]);
+    exit;
+} else if (!empty($codeToExec->kill) && is_numeric($codeToExec->kill)) {
+    _error_log("kill mode triggered");
+    $kill = killFFmpegProcess($codeToExec->kill);
+    echo json_encode([
+        'error' => empty($kill),
+        'msg' => '',
+        'kill' => $kill,
+        'pid' => $codeToExec->kill,
+    ]);
+    exit;
 } else if (!empty($codeToExec->stop) && !empty($keyword)) {
     _error_log("Stop mode triggered for keyword: $keyword");
 
@@ -314,6 +333,31 @@ if (!empty($codeToExec->test)) {
         'unlink' => $unlink,
     ]);
     exit;
+}else if (!empty($codeToExec->isKeywordRunning)) {
+    _error_log("Checking for running FFmpeg process with keyword: $codeToExec->isKeywordRunning");
+
+    $list = listFFmpegProcesses($codeToExec->isKeywordRunning);
+
+    // If a process is found, return the full command
+    if (!empty($list)) {
+        echo json_encode([
+            'error' => false,
+            'msg' => 'FFmpeg process found',
+            'isRunning' => true,
+            'list' => $list,
+            'keyword' => $codeToExec->isKeywordRunning,
+        ]);
+        exit;
+    }
+
+    // No process found
+    echo json_encode([
+        'error' => true,
+        'msg' => 'No FFmpeg process found with the given keyword',
+        'isRunning' => false,
+        'keyword' => $codeToExec->isKeywordRunning,
+    ]);
+    exit;
 }
 
 if (empty($ffmpegCommand)) {
@@ -352,6 +396,8 @@ if (!empty($keyword)) {
     //sleep(5);
 }
 
+//$ffmpegCommand = fixConcatFfmpegCommand($ffmpegCommand);
+
 $ffmpegCommand = addKeywordToFFmpegCommand($ffmpegCommand, $keyword);
 
 $ffmpegCommand .= " > {$logFile} ";

plugin/API/standAlone/functions.php

@@ -80,3 +80,102 @@ function sanitizeFFmpegCommand($command)
     _error_log("Sanitization failed: Command does not start with an allowed prefix");
     return '';
 }
+
+
+function convertElapsedTimeToSeconds($elapsedTime)
+{
+    $timeParts = explode('-', $elapsedTime);
+
+    if (count($timeParts) == 2) {
+        // Format: DD-HH:MM:SS
+        list($days, $hms) = $timeParts;
+        $days = intval($days) * 86400; // Convert days to seconds
+    } else {
+        // Format: HH:MM:SS
+        $days = 0;
+        $hms = $timeParts[0];
+    }
+
+    list($hours, $minutes, $seconds) = array_pad(explode(':', $hms), 3, '00');
+
+    return $days + (intval($hours) * 3600) + (intval($minutes) * 60) + intval($seconds);
+}
+
+function listFFmpegProcesses($keyword = '')
+{
+    $command = "ps -eo pid,etime,%cpu,%mem,cmd | grep '[f]fmpeg'"; // Get PID, elapsed time, CPU & memory usage
+
+    if (!empty($keyword)) {
+        $command .= " | grep '$keyword'";
+    }
+
+    exec($command, $output, $status);
+
+    $processes = [];
+    foreach ($output as $line) {
+        preg_match('/^\s*(\d+)\s+([\d:-]+)\s+([\d.]+)\s+([\d.]+)\s+(.+)$/', $line, $matches);
+        if (!empty($matches)) {
+            $runningTime = $matches[2]; // Original elapsed time format
+            $runningTimeSeconds = convertElapsedTimeToSeconds($runningTime);
+
+            $processes[] = [
+                'pid' => intval($matches[1]),
+                'running_time' => $runningTime, // Formatted time (e.g., 02:15:30 or 1-12:45:20)
+                'running_time_seconds' => $runningTimeSeconds, // Time in seconds
+                'cpu_usage' => floatval($matches[3]), // CPU usage percentage
+                'memory_usage' => floatval($matches[4]), // Memory usage percentage
+                'command' => $matches[5] // Full command line
+            ];
+        }
+    }
+    return $processes;
+}
+
+function killFFmpegProcess($pid)
+{
+    if (!is_numeric($pid) || $pid <= 0) {
+        return [
+            'error' => true,
+            'msg' => 'Invalid PID'
+        ];
+    }
+
+    $killCommand = "kill -9 " . escapeshellarg($pid);
+    exec($killCommand, $output, $status);
+
+    return [
+        'error' => $status !== 0,
+        'msg' => $status === 0 ? "Process $pid killed successfully." : "Failed to kill process $pid.",
+        'killCommand' => $killCommand,
+        'output' => $output,
+        'status' => $status
+    ];
+}
+
+
+/*
+function fixConcatFfmpegCommand($ffmpegCommand) {
+    $pattern = '/concat=([^\s]+)/';
+
+    if (preg_match($pattern, $ffmpegCommand, $matches)) {
+        $concatFiles = explode('|', $matches[1]);
+        $fixedFiles = [];
+
+        foreach ($concatFiles as $file) {
+            if (preg_match('/^https?:\/\//', $file)) {
+                $localFile = getTmpDir().'concat_'.uniqid();
+                $data = url_get_contents($file);
+                file_put_contents($localFile, $data);
+                $fixedFiles[] = $localFile;
+            } else {
+                $fixedFiles[] = $file;
+            }
+        }
+
+        $newConcat = implode('|', $fixedFiles);
+        $ffmpegCommand = str_replace($matches[1], $newConcat, $ffmpegCommand);
+    }
+
+    return $ffmpegCommand;
+}
+*/

plugin/PlayLists/PlayLists.php

@@ -334,7 +334,7 @@ class PlayLists extends PluginAbstract
             if (empty($obj->useOldPlayList)) {
                 //$url = $global['webSiteRootURL'] . "plugin/PlayLists/player.php?playlists_id=" . $playlists_id;
                 $url = $global['webSiteRootURL'] . "play/" . $playlists_id;
-            } else {                
+            } else {
                 $url = PlayLists::getURL($playlists_id);
             }
         }
@@ -909,7 +909,13 @@ class PlayLists extends PluginAbstract
             $labelText = '';
         }
 
-        return "<button class=\"{$class}\" onclick=\"avideoModalIframe('$liveLink');\" data-toggle=\"tooltip\" title=\"$label\" ><i class=\"fas fa-broadcast-tower\"></i> $labelText</button>";
+        $btn = "<button class=\"{$class}\" onclick=\"avideoModalIframe('$liveLink');\" data-toggle=\"tooltip\" title=\"$label\" ><i class=\"fas fa-broadcast-tower\"></i> $labelText</button>";
+        if(AVideoPlugin::isEnabledByName('VideoPlaylistScheduler')){
+            $liveLink = "{$global['webSiteRootURL']}plugin/VideoPlaylistScheduler/playLiveInLoop.php";
+            $liveLink = addQueryStringParameter($liveLink, 'playlists_id', $playlists_id);
+            $btn .= "<button class=\"{$class}\" onclick=\"avideoModalIframe('{$liveLink}');\" data-toggle=\"tooltip\" title=\"$label Loop\" ><i class=\"fa-solid fa-infinity\"></i> $labelText</button>";
+        }
+        return $btn;
     }
 
     static function getVideosIdFromPlaylist($playlists_id)
@@ -1150,7 +1156,7 @@ class PlayLists extends PluginAbstract
             }
         }
         $plURL = "{$global['webSiteRootURL']}program/{$playlist_id}/{$count}/" . urlencode(cleanURLName($PLChannelName)) . '/' . urlencode(cleanURLName($plName)) . '/' . urlencode(cleanURLName($current_video_clean_title));
-        
+
         return $plURL;
         */
     }
@@ -1247,7 +1253,7 @@ class PlayListPlayer
                 return $playListObj->getName();
             }
         } else if (!empty($this->tags_id)) {
-            //require_once $global['systemRootPath'] . 'plugin/VideoTags/Objects/Tags.php';            
+            //require_once $global['systemRootPath'] . 'plugin/VideoTags/Objects/Tags.php';
             AVideoPlugin::getObjectData("VideoTags");
             $tag = new Tags($this->tags_id);
             return $tag->getName();
@@ -1280,7 +1286,7 @@ class PlayListPlayer
               array_unshift($videos, $videoSerie);
               }
               }
-             * 
+             *
              */
         } else if (!empty($this->tags_id)) {
             global $_plt_getVideos;