<?php
require_once __DIR__ . '/../../connect.php';

if ($role !== 'admin' && $role !== 'super_admin') {
    http_response_code(403);
    echo json_encode(['error' => 'Unauthorized: Admin access required']);
    exit;
}

// التطبيع عبر normalizePhone() الموحّدة في core/helpers.php (نفس المنطق سابقاً)

// 1. تسجيل بداية الطلب
$phone = filterRequest("phone");
error_log("[MONITOR_RIDE] ---------------- START REQUEST ----------------");
error_log("[MONITOR_RIDE] 1. Received Phone: " . $phone);

// تطبيع الرقم
$phone = normalizePhone($phone);
error_log("[MONITOR_RIDE] 1.5 Normalized Phone: " . $phone);

//------------------------------------------------------------------------
// 1) البحث عن الهاتف أولاً في جدول السائق ثم جدول الراكب
//------------------------------------------------------------------------

$encPhone = $encryptionHelper->encryptData($phone);

// فهرس البحث لكل جدول على حدة (النطاقات معزولة عمداً)
global $blindIndex;
$dBidx = $blindIndex ? $blindIndex->index('driver.phone', $phone) : null;
$pBidx = $blindIndex ? $blindIndex->index('passengers.phone', $phone) : null;
error_log("[MONITOR_RIDE] 2. Encrypted Phone: " . $encPhone);

// Check Driver Table
$driverQuery = $con->prepare("SELECT id AS driverID FROM driver WHERE phone = :phone OR (:bidx IS NOT NULL AND phone_bidx = :bidx) LIMIT 1");
$driverQuery->execute([':phone' => $encPhone, ':bidx' => $dBidx]);
$driver = $driverQuery->fetch(PDO::FETCH_ASSOC);

// Check Passenger Table
$customerQuery = $con->prepare("SELECT id AS customerID FROM passengers WHERE phone = :phone OR (:bidx IS NOT NULL AND phone_bidx = :bidx) LIMIT 1");
$customerQuery->execute([':phone' => $encPhone, ':bidx' => $pBidx]);
$customer = $customerQuery->fetch(PDO::FETCH_ASSOC);

// حدد نوع المستخدم
$userType = '';
$driverID = null;
$customerID = null;

if ($driver) {
    $userType = 'driver';
    $driverID = $driver['driverID'];
    error_log("[MONITOR_RIDE] 3. User Found: Type = DRIVER, ID = " . $driverID);
} elseif ($customer) {
    $userType = 'customer';
    $customerID = $customer['customerID'];
    error_log("[MONITOR_RIDE] 3. User Found: Type = CUSTOMER, ID = " . $customerID);
} else {
    error_log("[MONITOR_RIDE] 3. FAILURE: Phone number not found in Driver or Passenger tables.");
    jsonError("رقم الهاتف غير موجود في النظام.");
    exit;
}

//------------------------------------------------------------------------
// 2) جلب آخر رحلة حالتها نشطة
//------------------------------------------------------------------------

$activeStatuses = "'apply','applied','arrived','begin','accepted','started','claimed','new','nothing','waiting','wait','pending','searching'";

if ($userType == 'driver') {
    error_log("[MONITOR_RIDE] 4. Searching for active ride for Driver ID: " . $driverID);
    $rideQuery = $con->prepare("
        SELECT * FROM ride
        WHERE driver_id = :driverID AND LOWER(status) IN ($activeStatuses)
        ORDER BY id DESC LIMIT 1
    ");
    $rideQuery->execute([':driverID' => $driverID]);
} else {
    error_log("[MONITOR_RIDE] 4. Searching for active ride for Customer ID: " . $customerID);
    $rideQuery = $con->prepare("
        SELECT * FROM ride
        WHERE passenger_id = :customerID AND LOWER(status) IN ($activeStatuses)
        ORDER BY id DESC LIMIT 1
    ");
    $rideQuery->execute([':customerID' => $customerID]);
}

$ride = $rideQuery->fetch(PDO::FETCH_ASSOC);

if (!$ride) {
    error_log("[MONITOR_RIDE] 4. FAILURE: No active ride found.");
    jsonError("لا توجد رحلة نشطة لهذا المستخدم.");
    exit;
} else {
    error_log("[MONITOR_RIDE] 4. SUCCESS: Active Ride Found. Ride ID: " . $ride['id'] . " Status: " . $ride['status']);
}

//------------------------------------------------------------------------
// 3) جلب معلومات السائق من الرحلة
//------------------------------------------------------------------------

$rideDriverID = $ride['driverID'] ?? $ride['driver_id'];
error_log("[MONITOR_RIDE] 5. Fetching info for Driver ID from Ride: " . $rideDriverID);

$driverInfo = null;
if ($rideDriverID) {
    $driverInfoQuery = $con->prepare("
        SELECT id, first_name, last_name, phone
        FROM driver 
        WHERE id = :driverID
        LIMIT 1
    ");

    $driverInfoQuery->execute([':driverID' => $rideDriverID]);
    $driverInfo = $driverInfoQuery->fetch(PDO::FETCH_ASSOC);

    if ($driverInfo) {
        $driverInfo['phone'] = $encryptionHelper->decryptData($driverInfo['phone']);
        $driverInfo['first_name'] = $encryptionHelper->decryptData($driverInfo['first_name']);
        $driverInfo['last_name']  = $encryptionHelper->decryptData($driverInfo['last_name']);
        $fullName = trim(($driverInfo['first_name'] ?? '') . " " . ($driverInfo['last_name'] ?? ''));
        $driverInfo['fullname'] = $fullName ?: "Unknown Driver";
        error_log("[MONITOR_RIDE] 5. Driver Info Found: " . $fullName);
    } else {
        error_log("[MONITOR_RIDE] 5. WARNING: Driver info not found for ID " . $rideDriverID);
    }
}

//------------------------------------------------------------------------
// 4) جلب آخر موقع للسائق من جدول car_locations بشرط الحالة ON
//------------------------------------------------------------------------

error_log("[MONITOR_RIDE] 6. Querying Tracking DB for Driver ID: " . $rideDriverID);

$location = null;
if ($rideDriverID && isset($con_tracking) && $con_tracking) {
    try {
        $locationQuery = $con_tracking->prepare("
            SELECT latitude, longitude, speed, heading, updated_at 
            FROM car_locations
            WHERE driver_id = :driverID AND status = 'ON'
            ORDER BY updated_at DESC LIMIT 1
        ");
        $locationQuery->execute([':driverID' => $rideDriverID]);
        $location = $locationQuery->fetch(PDO::FETCH_ASSOC) ?: null;
    } catch (Throwable $e) {
        error_log("[MONITOR_RIDE] Tracking query exception: " . $e->getMessage());
    }
}

if ($location) {
    error_log("[MONITOR_RIDE] 6. Location Found: Lat=" . $location['latitude'] . " Lng=" . $location['longitude']);
} else {
    error_log("[MONITOR_RIDE] 6. WARNING: No live location found.");
}

//------------------------------------------------------------------------
// 5) تجهيز البيانات للرد
//------------------------------------------------------------------------

$response = [
    "ride_details"    => $ride,
    "driver_details" => $driverInfo,
    "driver_location" => $location ?: "No live location"
];

error_log("[MONITOR_RIDE] 7. Sending Success Response.");
jsonSuccess($response);