<?php
// cron_ride_timeout.php
// 🔥 أُعيدت كتابته بالكامل: كان يعتمد على جدول waitingRides الذي لم يعد
// يُملأ من تدفق add_ride.php الحقيقي (addWaitingRide.php لا يُستدعى من هناك)،
// فكانت الرحلات العالقة بحالة 'waiting' لا تُصفَّر أبداً. الآن يعمل مباشرة
// على جدول ride باستخدام أعمدة date/time المكتوبة فعلياً عند الإنشاء.

require_once __DIR__ . '/../../core/bootstrap.php';
require_once __DIR__ . '/../../functions.php';

error_log("⏰ [Cleanup Cron] Started cleaning old waiting rides...");

$minutesLimit = 15;

try {
    $con = Database::get('main');

    // =========================================================
    // الخطوة 1: جلب الرحلات العالقة (status='waiting' منذ أكثر من 15 دقيقة)
    // =========================================================
    $sqlSelect = "SELECT id, passenger_id FROM ride
                  WHERE status = 'waiting'
                  AND TIMESTAMP(`date`, `time`) < DATE_SUB(NOW(), INTERVAL $minutesLimit MINUTE)";
    $stmtSelect = $con->prepare($sqlSelect);
    $stmtSelect->execute();
    $staleRides = $stmtSelect->fetchAll(PDO::FETCH_ASSOC);

    $updatedCount = 0;

    if (!empty($staleRides)) {
        $sqlUpdate = "UPDATE ride SET status = 'timeout', updated_at = NOW() WHERE id = ? AND status = 'waiting'";
        $stmtUpdate = $con->prepare($sqlUpdate);

        // نسخة أرشيفية (best-effort)
        $con_ride = null;
        try {
            $con_ride = Database::get('ride');
        } catch (Exception $e) {
            error_log("[cron_ride_timeout] Secondary ride DB unavailable: " . $e->getMessage());
        }
        $stmtUpdate2 = $con_ride ? $con_ride->prepare(
            "UPDATE ride SET status = 'timeout', updated_at = NOW() WHERE id = ? AND status = 'waiting'"
        ) : null;

        foreach ($staleRides as $ride) {
            $rideId = $ride['id'];

            $stmtUpdate->execute([$rideId]);
            $updatedCount += $stmtUpdate->rowCount();

            if ($stmtUpdate2) {
                try {
                    $stmtUpdate2->execute([$rideId]);
                } catch (PDOException $e) {
                    error_log("[cron_ride_timeout] Secondary DB update failed for #$rideId: " . $e->getMessage());
                }
            }

            // 🆕 تنظيف Redis + إعلام أي سائقين ما زالوا يرون هذا الطلب على أنه ملغى
            sendToLocationServer('cancel_ride', [
                'ride_id'   => $rideId,
                'driver_id' => 0,
                'reason'    => 'timeout',
            ]);
        }
    }

    // =========================================================
    // الخطوة 2: تنظيف جدول waitingRides القديم (إن وُجدت صفوف فيه من مسار قديم)
    // =========================================================
    $deletedCount = 0;
    try {
        $sqlDelete = "DELETE FROM waitingRides WHERE created_at < DATE_SUB(NOW(), INTERVAL $minutesLimit MINUTE)";
        $stmtDelete = $con->prepare($sqlDelete);
        $stmtDelete->execute();
        $deletedCount = $stmtDelete->rowCount();
    } catch (PDOException $e) {
        error_log("[cron_ride_timeout] waitingRides cleanup skipped: " . $e->getMessage());
    }

    if ($updatedCount > 0 || $deletedCount > 0) {
        $msg = "✅ [Cleanup Cron] Success: Timed out $updatedCount ride(s) in ride table, and cleaned $deletedCount legacy waitingRides row(s).";
        error_log($msg);
        echo json_encode(["status" => "success", "message" => $msg]);
    } else {
        $msg = "💤 [Cleanup Cron] No expired rides found.";
        error_log($msg);
        echo json_encode(["status" => "success", "message" => "Nothing to clean."]);
    }

} catch (PDOException $e) {
    $errorMsg = "❌ [Cleanup Cron] Error: " . $e->getMessage();
    error_log($errorMsg);
    echo json_encode(["status" => "failure", "message" => "An internal error occurred."]);
}
?>