File not found.
'; + + $md = file_get_contents($path); + + // Substitute `$VAR_NAME` markers with live conf values + $md = preg_replace_callback('/`\$([A-Z0-9_]+)`/', function($m) use ($vars) { + $key = $m[1]; + return isset($vars[$key]) + ? '' . htmlspecialchars($vars[$key]) . ''
+ : '$' . htmlspecialchars($key) . '';
+ }, $md);
+
+ // Render markdown
+ if (file_exists(PARSEDOWN_PATH)) {
+ require_once PARSEDOWN_PATH;
+ $pd = new Parsedown();
+ $pd->setSafeMode(true);
+ return $pd->text($md);
+ }
+
+ // Fallback: plain preformatted text
+ return '' . htmlspecialchars($md) . ''; +} diff --git a/Plugin/usr/local/emhttp/plugins/varaverk/include/monitor.php b/Plugin/usr/local/emhttp/plugins/varaverk/include/monitor.php new file mode 100644 index 0000000..8ed8fa3 --- /dev/null +++ b/Plugin/usr/local/emhttp/plugins/varaverk/include/monitor.php @@ -0,0 +1,121 @@ +/dev/null'); + $containers = []; + foreach (explode("\n", trim($out ?? '')) as $line) { + if (!$line) continue; + $c = json_decode($line, true); + if ($c) $containers[] = $c; + } + return $containers; +} + +function vv_docker_stopped(): array { + $out = shell_exec('docker ps -a --filter "status=exited" --filter "status=created" --format \'{"name":"{{.Names}}","status":"{{.Status}}"}\' 2>/dev/null'); + $containers = []; + foreach (explode("\n", trim($out ?? '')) as $line) { + if (!$line) continue; + $c = json_decode($line, true); + if ($c) $containers[] = $c; + } + return $containers; +} + +function vv_gpu_stats(): array { + $out = shell_exec('nvidia-smi --query-gpu=name,memory.used,memory.total,utilization.gpu,temperature.gpu --format=csv,noheader,nounits 2>/dev/null'); + if (!$out) return ['available' => false]; + + $parts = array_map('trim', explode(',', $out)); + return [ + 'available' => true, + 'name' => $parts[0] ?? '', + 'memory_used' => (int)($parts[1] ?? 0), + 'memory_total' => (int)($parts[2] ?? 0), + 'utilization' => (int)($parts[3] ?? 0), + 'temperature' => (int)($parts[4] ?? 0), + ]; +} + +function vv_gpu_processes(): array { + $out = shell_exec('nvidia-smi --query-compute-apps=pid,used_gpu_memory,name --format=csv,noheader,nounits 2>/dev/null'); + $procs = []; + foreach (explode("\n", trim($out ?? '')) as $line) { + if (!$line) continue; + $parts = array_map('trim', explode(',', $line)); + $procs[] = [ + 'pid' => $parts[0] ?? '', + 'memory_mb' => $parts[1] ?? '', + 'name' => $parts[2] ?? '', + ]; + } + return $procs; +} + +function vv_system_resources(): array { + // RAM + $mem = []; + foreach (file('/proc/meminfo') ?: [] as $line) { + if (preg_match('/^(MemTotal|MemAvailable):\s+(\d+)/', $line, $m)) + $mem[$m[1]] = (int)$m[2]; + } + + // CPU (1-second sample) + $cpu = (int)trim(shell_exec("top -bn1 | grep 'Cpu(s)' | awk '{print $2}' | cut -d. -f1") ?: '0'); + + // Disk — ramdisk + cache + $ramdisk = vv_df('/mnt/ramdisk_transcodes'); + $cache = vv_df('/mnt/cache'); + + return [ + 'ram_total_mb' => (int)(($mem['MemTotal'] ?? 0) / 1024), + 'ram_free_mb' => (int)(($mem['MemAvailable'] ?? 0) / 1024), + 'cpu_percent' => $cpu, + 'ramdisk' => $ramdisk, + 'cache' => $cache, + ]; +} + +function vv_df(string $path): array { + $out = shell_exec("df -BM --output=size,used,avail '$path' 2>/dev/null | tail -1"); + if (!$out) return ['available' => false, 'path' => $path]; + $parts = preg_split('/\s+/', trim($out)); + return [ + 'available' => true, + 'path' => $path, + 'size_mb' => (int)$parts[0], + 'used_mb' => (int)$parts[1], + 'free_mb' => (int)$parts[2], + ]; +} + +function vv_fallback_state(): array { + // State file written by fallback.sh + $stateFile = '/tmp/fallback_state.db'; + if (!file_exists($stateFile)) return ['state' => 'UNKNOWN']; + $raw = []; + foreach (file($stateFile) ?: [] as $line) { + [$k, $v] = array_pad(explode('=', trim($line), 2), 2, ''); + $raw[trim($k)] = trim($v); + } + return [ + 'state' => $raw['state'] ?? 'UNKNOWN', + 'failover_start' => $raw['failover_start'] ?? '0', + 'tier2_started' => $raw['tier2_started'] ?? 'false', + 'tier3_started' => $raw['tier3_started'] ?? 'false', + 'tier4_started' => $raw['tier4_started'] ?? 'false', + ]; +} + +function vv_transcode_sessions(): array { + // Read from transcode state file written by transcode_manager.sh + $stateFile = '/tmp/transcode_state.db'; + if (!file_exists($stateFile)) return []; + $raw = []; + foreach (file($stateFile) ?: [] as $line) { + [$k, $v] = array_pad(explode('=', trim($line), 2), 2, ''); + $raw[trim($k)] = trim($v); + } + return $raw; +} diff --git a/Plugin/usr/local/emhttp/plugins/varaverk/include/scheduler.php b/Plugin/usr/local/emhttp/plugins/varaverk/include/scheduler.php new file mode 100644 index 0000000..d057df3 --- /dev/null +++ b/Plugin/usr/local/emhttp/plugins/varaverk/include/scheduler.php @@ -0,0 +1,98 @@ + $id, + 'enabled' => $enabled, + 'cron' => $cron, + 'updated' => date('c'), + ]; + if (!vv_schedule_save($schedule)) return false; + return vv_cron_rebuild($schedule); +} + +function vv_cron_rebuild(array $schedule): bool { + $lines = ["# Varaverk — managed by plugin, do not edit manually"]; + $lines[] = "# Regenerated: " . date('Y-m-d H:i:s'); + $lines[] = ""; + + $scriptsDir = SCRIPTS_DIR; + foreach ($schedule as $entry) { + if (empty($entry['enabled']) || empty($entry['cron']) || empty($entry['id'])) continue; + $script = "$scriptsDir/{$entry['id']}"; + $cron = $entry['cron']; + $lines[] = "$cron " . CRON_USER . " bash \"$script\" >> /var/log/varaverk/jobs.log 2>&1"; + } + $lines[] = ""; + + return file_put_contents(CRON_FILE, implode("\n", $lines)) !== false; +} + +// Walk the scripts repo and return the job tree: +// orchestrators as top-level, individual scripts as children +function vv_job_tree(): array { + $scriptsDir = SCRIPTS_DIR; + $schedule = vv_schedule_load(); + + // Orchestrators are in Orchestrators/ and their children are all scripts they call + // For now: walk top-level folders, treat *_management.sh or *_maintenance.sh as orchs + $orchPattern = "$scriptsDir/Orchestrators/*.sh"; + $orchs = []; + + foreach (glob($orchPattern) ?: [] as $path) { + $id = 'Orchestrators/' . basename($path); + $entry = $schedule[$id] ?? ['enabled' => false, 'cron' => '']; + $orchs[] = [ + 'id' => $id, + 'label' => basename($path, '.sh'), + 'type' => 'orchestrator', + 'enabled' => (bool)($entry['enabled'] ?? false), + 'cron' => $entry['cron'] ?? '', + 'children' => vv_script_children($path, $schedule), + ]; + } + return $orchs; +} + +// Parse an orchestrator script to find which child scripts it calls +function vv_script_children(string $orchPath, array $schedule): array { + $scriptsDir = SCRIPTS_DIR; + $content = file_get_contents($orchPath) ?: ''; + $children = []; + + // Match: bash "path/to/script.sh" or source path/to/script.sh + preg_match_all('/(?:bash|source|\.)\s+"?([^"\s]+\.sh)"?/m', $content, $m); + foreach ($m[1] as $rel) { + // Normalise relative paths + $rel = ltrim(str_replace($scriptsDir . '/', '', $rel), './'); + $id = $rel; + $entry = $schedule[$id] ?? ['enabled' => false, 'cron' => '']; + $children[] = [ + 'id' => $id, + 'label' => basename($rel, '.sh'), + 'type' => 'script', + 'enabled' => (bool)($entry['enabled'] ?? false), + 'cron' => $entry['cron'] ?? '', + ]; + } + return $children; +} diff --git a/Plugin/usr/local/emhttp/plugins/varaverk/js/varaverk.js b/Plugin/usr/local/emhttp/plugins/varaverk/js/varaverk.js new file mode 100644 index 0000000..ef48c86 --- /dev/null +++ b/Plugin/usr/local/emhttp/plugins/varaverk/js/varaverk.js @@ -0,0 +1,9 @@ +// Varaverk — shared JS utilities +// Page-specific JS lives inline in each page partial. + +// Flash a status element briefly then fade +function vvFlashStatus(el, msg, ok) { + el.textContent = msg; + el.style.color = ok ? '#4caf50' : '#f44336'; + setTimeout(() => { el.textContent = ''; }, 3000); +} diff --git a/Plugin/usr/local/emhttp/plugins/varaverk/pages/config.php b/Plugin/usr/local/emhttp/plugins/varaverk/pages/config.php new file mode 100644 index 0000000..a1e31b5 --- /dev/null +++ b/Plugin/usr/local/emhttp/plugins/varaverk/pages/config.php @@ -0,0 +1,54 @@ + + +
No configuration files found.
+ + +
+ Values shown in green are live from your conf files.
+ Orange means the variable was not found.
+
Select a document from the sidebar.
+ +| Name | Status | Image |
|---|---|---|
| Loading... | ||
Orchestrators run their child scripts in the correct order. + Disable an orchestrator and enable individual scripts below it to run them + in isolation for debugging or testing.
+ + +