cron_queue_worker.php

<?php
/**
 * Asynchronous Queue Worker Cron Job
 * 
 * Recommended crontab (every minute):
 * * * * * * cd /path/to/project && php cron_queue_worker.php >> /tmp/queue_cron.log 2>&1
 */

require_once __DIR__ . '/config.php';

use App\Core\Database;
use App\Core\Logger;
use App\Services\QueueWorker;

$db = Database::getInstance();

// Create execution log entry for crontab runs
$logId = null;
$cronJob = $db->row("SELECT id FROM cron_jobs WHERE slug = 'queue-worker'");
if ($cronJob) {
    $db->execute(
        "INSERT INTO cron_execution_logs (cron_job_id, status, started_at, triggered_by) VALUES (:jid, 'running', NOW(), 'crontab')",
        [':jid' => $cronJob['id']]
    );
    $logId = $db->lastInsertId();
    $db->execute(
        "UPDATE cron_jobs SET last_status = 'running', updated_at = NOW() WHERE id = :id",
        [':id' => $cronJob['id']]
    );
}

$startTime = microtime(true);
$hasError = false;
$outputBuffer = '';

Logger::info("Queue worker cron started at " . date('Y-m-d H:i:s'));
$outputBuffer .= "=== Queue Worker Cron ===\n";
$outputBuffer .= "Started: " . date('Y-m-d H:i:s') . "\n\n";

try {
    // Instantiate and run the worker
    $worker = new QueueWorker();
    $worker->run();
    $outputBuffer .= "Queue worker executed successfully.\n";
} catch (\Throwable $e) {
    $hasError = true;
    Logger::error("Queue worker cron failed: " . $e->getMessage());
    $outputBuffer .= "Error: " . $e->getMessage() . "\n" . $e->getTraceAsString() . "\n";
}

$duration = round(microtime(true) - $startTime, 2);
$outputBuffer .= "\nFinished: " . date('Y-m-d H:i:s') . "\n";
$outputBuffer .= "Duration: {$duration}s\n";

if ($cronJob && $logId) {
    $db->execute(
        "UPDATE cron_execution_logs SET status = :status, finished_at = NOW(), duration_seconds = :duration, output = :output, error_message = :err WHERE id = :id",
        [
            ':status' => $hasError ? 'failed' : 'success',
            ':duration' => $duration,
            ':output' => $outputBuffer,
            ':err' => $hasError ? 'Queue worker execution encountered an error.' : null,
            ':id' => $logId
        ]
    );
    $db->execute(
        "UPDATE cron_jobs SET last_status = :status, last_run_at = NOW(), updated_at = NOW() WHERE id = :id",
        [
            ':status' => $hasError ? 'failed' : 'success',
            ':id' => $cronJob['id']
        ]
    );
}

echo $outputBuffer;
if ($hasError) {
    exit(1);
}
exit(0);