<?php

declare(strict_types=1);

/**
 * LLMpool Worker CLI Script
 * This script processes the AI generation queue.
 */

require_once __DIR__ . '/../vendor/autoload.php';

// Load configuration from root .env
\App\Utils\Config::load(__DIR__ . '/../.env');

use App\Services\LLMpool;

// Ensure this script is only run from CLI
if (php_sapi_name() !== 'cli') {
	die("This script can only be run from the command line." . PHP_EOL);
}

// Parse arguments
$isLoop = in_array('--loop', $argv);
$loopInterval = 5; // seconds

$lockFile = sys_get_temp_dir() . '/webwizard_worker.lock';
$fp = fopen($lockFile, 'w');

if (!flock($fp, LOCK_EX | LOCK_NB)) {
	die("[" . date('Y-m-d H:i:s') . "] Worker is already running. Skipping." . PHP_EOL);
}

if ($isLoop) {
	echo "[" . date('Y-m-d H:i:s') . "] Worker started in loop mode (interval: {$loopInterval}s)" . PHP_EOL;
} else {
	echo "[" . date('Y-m-d H:i:s') . "] Starting LLMpool worker (single run)..." . PHP_EOL;
}

$worker = new LLMpool();

/**
 * Main processing logic encapsulated to avoid duplication
 */
$processCycle = function() use ($worker) {
	echo "[" . date('Y-m-d H:i:s') . "] Cycle started: Processing queue..." . PHP_EOL;
	try {
		$worker->processQueue();
	} catch (Throwable $e) {
		echo "[" . date('Y-m-d H:i:s') . "] FATAL ERROR: " . $e->getMessage() . PHP_EOL;
	}
	echo "[" . date('Y-m-d H:i:s') . "] Cycle finished." . PHP_EOL;
};

// Execution based on mode
if ($isLoop) {
	while (true) {
		$processCycle();
		sleep($loopInterval);
	}
} else {
	$processCycle();
	echo "[" . date('Y-m-d H:i:s') . "] Finished LLMpool worker." . PHP_EOL;
}

// These are only reached in non-loop mode (or if loop is broken by signal)
flock($fp, LOCK_UN);
fclose($fp);
unlink($lockFile);