<?php
declare(strict_types=1);

/**
 * The video worker (#402): converts uploaded videos, one after the other, for as long as it runs.
 *
 *   php tools/video-worker.php [datadir]          keeps watching the queue
 *   php tools/video-worker.php [datadir] --once   converts what waits now, then stops
 *
 * On stein2 it runs in the container `feuerwerk-video` (tools/video/), in CI beside the PHP
 * server (tools/ci/serve.sh). Both need ffmpeg and ffprobe on the PATH.
 */

require __DIR__ . '/../api/lib/AtomicFile.php';
require __DIR__ . '/../api/lib/OriginalName.php';
require __DIR__ . '/../api/lib/UserStore.php';
require __DIR__ . '/../api/lib/HashedFileStore.php';
require __DIR__ . '/../api/lib/VideoFormat.php';
require __DIR__ . '/../api/lib/VideoQueue.php';
require __DIR__ . '/../api/lib/VideoStore.php';
require __DIR__ . '/../api/lib/VideoWorker.php';

$args = array_slice($argv, 1);
$once = in_array('--once', $args, true);
$paths = array_values(array_filter($args, static fn(string $a): bool => $a !== '--once'));
$data = $paths[0] ?? dirname(__DIR__) . '/data';

$store = new VideoStore("{$data}/videos");
$worker = new VideoWorker($store, "{$data}/videos");
$interrupted = $store->queue()->requeueInterrupted();
fwrite(STDERR, "[video-worker] watching {$data}/videos/queue" . ($interrupted > 0 ? ", {$interrupted} interrupted job(s) queued again" : '') . "\n");

while (true) {
    $job = $store->queue()->next();
    if ($job !== null) {
        $file = "{$job['folder']}/{$job['hash']}.mp4";
        $started = microtime(true);
        $worker->runOnce();
        $record = $store->record($file);
        $status = $record === null ? 'deleted' : ($record['status'] . ($record['status'] === 'failed' ? ": {$record['error']}" : ''));
        fwrite(STDERR, sprintf("[video-worker] %s %s in %.1f s\n", $file, $status, microtime(true) - $started));
        continue;
    }
    if ($once) {
        break;
    }
    sleep(1);
}