<?php
// api_get_nearby.php (Updated)
require_once __DIR__ . '/vendor/autoload.php';
use Predis\Client;

header('Content-Type: application/json');

function getInternalKey(): string {
    $envKey = getenv('INTERNAL_SOCKET_KEY');
    if ($envKey) return trim($envKey);
    $path = getenv('INTERNAL_SOCKET_KEY_PATH');
    if ($path && file_exists($path)) return trim((string)@file_get_contents($path));
    if (file_exists(__DIR__ . '/../loction-keys/.internal_socket_key')) return trim((string)@file_get_contents(__DIR__ . '/../loction-keys/.internal_socket_key'));
    if (file_exists('/keys/.internal_socket_key')) return trim((string)@file_get_contents('/keys/.internal_socket_key'));
    if (file_exists('/home/location/.internal_socket_key')) return trim((string)@file_get_contents('/home/location/.internal_socket_key'));
    return '';
}

function getRedisPass(): ?string {
    $envPass = getenv('REDIS_MAIN_PASSWORD') ?: ($_ENV['REDIS_MAIN_PASSWORD'] ?? (getenv('REDIS_PASSWORD') ?: ($_ENV['REDIS_PASSWORD'] ?? null)));
    if ($envPass) return trim($envPass);
    $path = getenv('REDIS_PASS_KEY_PATH');
    if ($path && file_exists($path)) return trim((string)@file_get_contents($path));
    if (file_exists('/keys/.reds_pass_key')) return trim((string)@file_get_contents('/keys/.reds_pass_key'));
    if (file_exists('/home/location/.reds_pass_key')) return trim((string)@file_get_contents('/home/location/.reds_pass_key'));
    return null;
}

$INTERNAL_KEY = getInternalKey();
$PASS_REDIS   = getRedisPass();

$headers = getallheaders();
$receivedKey = $headers['x-internal-key'] ?? $_SERVER['HTTP_X_INTERNAL_KEY'] ?? '';

if (!empty($INTERNAL_KEY) && $receivedKey !== $INTERNAL_KEY) {
    error_log("[api_get_nearby] Unauthorized: receivedKey ($receivedKey) != expectedKey ($INTERNAL_KEY)");
    http_response_code(403);
    echo json_encode(['status' => false, 'msg' => 'Unauthorized']);
    exit;
}

$lat = $_REQUEST['lat'] ?? null;
$lng = $_REQUEST['lng'] ?? null;
$radius = $_REQUEST['radius'] ?? 5;
$limit = $_REQUEST['limit'] ?? 100;

if (!$lat || !$lng) {
    echo json_encode(['status' => false, 'msg' => 'Invalid Coordinates']); exit;
}

try {
    $redisHost = getenv('REDIS_HOST') ?: ($_ENV['REDIS_HOST'] ?? (file_exists('/.dockerenv') ? 'redis' : '127.0.0.1'));
    $redisConfig = [
        'scheme'   => 'tcp',
        'host'     => $redisHost,
        'port'     => 6379,
        'database' => 0
    ];
    if (!empty($PASS_REDIS)) {
        $redisConfig['password'] = $PASS_REDIS;
    }
    $redis = new Client($redisConfig);
    $redis->connect();

    // 🔥 التعديل هنا: إضافة WITHCOORD لجلب الإحداثيات من الريدز مباشرة
    $geoResults = $redis->georadius(
        'geo:drivers:available', 
        $lng, $lat, $radius, 'km', 
        ['WITHDIST' => true, 'WITHCOORD' => true, 'COUNT' => $limit * 2, 'SORT' => 'ASC']
    );

    $validDrivers = [];
    $currentTime = time();
    $max_silence = 300;

    foreach ($geoResults as $res) {
        // هيكل النتيجة مع WITHCOORD يختلف قليلاً
        $d_id   = $res[0]; // ID
        $d_dist = $res[1]; // Distance
        $d_coord= $res[2]; // [0=>lng, 1=>lat] 🔥 الإحداثيات هنا

        $profile = $redis->hgetall("driver:profile:$d_id");
        $lastUpdate = isset($profile['updated_at']) ? (int)$profile['updated_at'] : 0;

        if (empty($profile)) {
            error_log("[api_get_nearby] Driver $d_id skipped: profile is empty in Redis.");
            $redis->zrem('geo:drivers:available', $d_id);
            $redis->zrem('geo:drivers:busy', $d_id);
            continue;
        }

        if (($currentTime - $lastUpdate) > $max_silence) {
            error_log("[api_get_nearby] Driver $d_id skipped: lastUpdate ($lastUpdate) is older than max_silence ($max_silence).");
            $redis->zrem('geo:drivers:available', $d_id);
            $redis->zrem('geo:drivers:busy', $d_id);
            continue;
        }

        // 🆕 فحص driver:public cache (بيانات السائق الثابتة)
        $public = $redis->hgetall("driver:public:$d_id");
        $hasCache = !empty($public) && !empty($public['first_name']);

        $validDrivers[] = $hasCache ? array_merge($public, [
            'id'        => $d_id,
            'driver_id' => $d_id,
            'latitude'  => $d_coord[1],
            'longitude' => $d_coord[0],
            'heading'   => $profile['heading'] ?? $public['heading'] ?? 0,
            'speed'     => $profile['speed'] ?? $public['speed'] ?? 0,
            'distance'  => $d_dist,
            'cached'    => true
        ]) : [
            'id'        => $d_id,
            'driver_id' => $d_id,
            'distance'  => $d_dist,
            'heading'   => $profile['heading'] ?? 0,
            'speed'     => $profile['speed'] ?? 0,
            'latitude'  => $d_coord[1],
            'longitude' => $d_coord[0],
            'cached'    => false
        ];

        if (count($validDrivers) >= $limit) break;
    }

    echo json_encode(['status' => true, 'data' => $validDrivers]);

} catch (Exception $e) {
    echo json_encode(['status' => false, 'msg' => $e->getMessage()]);
}
?>