<?php

namespace App\Services;

use Illuminate\Support\Facades\Log;

/**
 * خدمة التواصل اللحظي (Socket Communication Service)
 * 
 * الغرض من الملف:
 * التنسيق بين الخادم (PHP) وخوادم الـ Sockets (التي تعمل بـ Node.js) لتحديث التطبيقات فوراً عند وقوع حدث معين.
 * 
 * كيفية العمل:
 * 1. عندما يتم قبول رحلة أو تحديث موقع، يرسل هذا الملف طلباً سريعاً (Async) لخادم السوكت.
 * 2. يقوم خادم السوكت بدوره بتوصيل هذه المعلومة لتطبيق الراكب أو السائق في نفس اللحظة بدون تأخير.
 * 3. يستخدم مفاتيح أمان داخلية (Internal Key) لضمان أن الطلبات قادمة من الخادم الموثوق فقط.
 */
class SocketService
{
    private string $locationServerUrl;
    private string $rideSocketUrl;
    private string $internalKey;

    public function __construct()
    {
        $this->locationServerUrl = config('intaleq.location_server_url');
        $this->rideSocketUrl = config('intaleq.ride_socket_url');
        
        $keyPath = config('intaleq.internal_socket_key_path');
        $this->internalKey = file_exists($keyPath) ? trim(file_get_contents($keyPath)) : '';
    }

    /**
     * Notify passenger via ride socket server
     */
    public function notifyPassenger(string $passengerId, array $payload): void
    {
        $this->sendAsync($this->rideSocketUrl, array_merge($payload, [
            'action' => 'notify_passenger',
            'passenger_id' => $passengerId,
        ]));
    }

    /**
     * Send event to location server (e.g., ride_taken, cancel_ride)
     */
    public function sendToLocationServer(string $event, array $data): void
    {
        $this->sendAsync($this->locationServerUrl, array_merge($data, [
            'action' => $event,
        ]));
    }

    /**
     * Non-blocking HTTP POST (fire and forget with short timeout)
     */
    private function sendAsync(string $url, array $data): void
    {
        try {
            $ch = curl_init($url);
            curl_setopt_array($ch, [
                CURLOPT_RETURNTRANSFER => true,
                CURLOPT_POST => true,
                CURLOPT_POSTFIELDS => http_build_query($data),
                CURLOPT_TIMEOUT_MS => 500,
                CURLOPT_NOSIGNAL => 1,
            ]);

            if ($this->internalKey) {
                curl_setopt($ch, CURLOPT_HTTPHEADER, ["x-internal-key: {$this->internalKey}"]);
            }

            curl_exec($ch);
            curl_close($ch);
        } catch (\Exception $e) {
            Log::warning("[Socket] Failed to send to {$url}: " . $e->getMessage());
        }
    }
}