<?php
/**
 * Cron Worker for AI Invoice Extraction
 * 
 * Designed to run via cron every minute: * * * * *
 * Processes ALL pending items in the queue, then EXITS.
 * NO infinite loop. NO lock file issues.
 */

declare(strict_types=1);

require_once __DIR__ . '/../bootstrap/init.php';

use App\Core\Database;
use App\Services\InvoiceProcessor;

// Simple lock: prevent overlapping runs
$lockFile = STORAGE_PATH . '/logs/process_batches.lock';

// Check if lock file exists and is stale (older than 5 minutes = dead process)
if (file_exists($lockFile)) {
    $lockAge = time() - filemtime($lockFile);
    if ($lockAge > 300) {
        // Stale lock from a crashed process - remove it
        @unlink($lockFile);
        workerLog("Removed stale lock file (age: {$lockAge}s)");
    } else {
        workerLog("Worker already running (lock age: {$lockAge}s). Exiting.");
        exit(0);
    }
}

// Create lock
file_put_contents($lockFile, getmypid() . "\n" . date('c'));

function workerLog(string $msg): void {
    $line = "[" . date('Y-m-d H:i:s') . "] " . $msg . "\n";
    echo $line;
    // Also write to dedicated log file
    @file_put_contents(STORAGE_PATH . '/logs/worker.log', $line, FILE_APPEND);
}

workerLog("=== Musadaq AI Worker Started ===");

try {
    $db = Database::getInstance();
    $processed = 0;
    $failed = 0;

    // Get ALL pending items (no infinite loop!)
    $stmt = $db->prepare("
        SELECT id FROM invoice_processing_queue
        WHERE status = 'pending'
        ORDER BY created_at ASC
        LIMIT 20
    ");
    $stmt->execute();
    $items = $stmt->fetchAll(\PDO::FETCH_COLUMN);

    if (empty($items)) {
        workerLog("No pending items. Exiting.");
    } else {
        workerLog("Found " . count($items) . " pending item(s).");

        foreach ($items as $queueId) {
            workerLog("Processing Queue ID: $queueId ...");
            
            try {
                $success = InvoiceProcessor::processQueueItem((int)$queueId);
                if ($success) {
                    $processed++;
                    workerLog("  ✓ Queue ID $queueId processed successfully.");
                } else {
                    $failed++;
                    workerLog("  ✗ Queue ID $queueId failed (returned false).");
                }
            } catch (\Throwable $e) {
                $failed++;
                workerLog("  ✗ Queue ID $queueId EXCEPTION: " . $e->getMessage());
            }
        }

        workerLog("=== Worker Done: $processed success, $failed failed ===");
    }

} catch (\Throwable $e) {
    workerLog("FATAL ERROR: " . $e->getMessage() . "\n" . $e->getTraceAsString());
} finally {
    // ALWAYS remove lock file
    @unlink($lockFile);
}