16

2026-04-28 23:43:29 +03:00
parent ff4d81bd97
commit 402fab3a50
6 changed files with 672 additions and 2 deletions
--- a/passenger_socket.php
+++ b/passenger_socket.php
@@ -0,0 +1,116 @@
+<?php
+/**
+ * passenger_socket.php
+ * =====================
+ * WebSocket Server للركاب   — بورت 3030
+ * Internal HTTP Server      — بورت 3031
+ *
+ * الإصلاحات عن النسخة السابقة:
+ *  1. إصلاح بنية الـ closures:
+ *     كان update_driver_location خارج الـ onMessage callback → لا يُنفَّذ أبداً
+ *  2. تحليل الـ payload بشكل صحيح (json_decode للـ nested objects)
+ *  3. Heartbeat يُعاد تشغيله تلقائياً عند إعادة الاتصال
+ *  4. تنظيف البنية العامة
+ */
+
+use Workerman\Worker;
+use PHPSocketIO\SocketIO;
+
+require_once __DIR__ . '/vendor/autoload.php';
+
+$INTERNAL_KEY = trim((string) @file_get_contents('/home/intaleq-rides/.internal_socket_key'));
+
+if (empty($INTERNAL_KEY)) {
+    echo '[CRITICAL] Internal key missing! Exiting.' . PHP_EOL;
+    exit(1);
+}
+
+$PORT          = 3030;
+$INTERNAL_PORT = 3031;
+
+$io = new SocketIO($PORT);
+
+$io->on('workerStart', function () use ($io, $INTERNAL_KEY, $INTERNAL_PORT) {
+
+    $innerHttp = new Worker("http://0.0.0.0:$INTERNAL_PORT");
+
+    $innerHttp->onMessage = function ($connection, $request) use ($io, $INTERNAL_KEY) {
+
+        $headers = $request->header();
+        if (($headers['x-internal-key'] ?? '') !== $INTERNAL_KEY) {
+            $connection->send('Unauthorized');
+            return;
+        }
+
+        $post   = $request->post();
+        $action = trim($post['action'] ?? '');
+
+        if ($action === 'update_ride_status') {
+
+            $passengerId = $post['passenger_id'] ?? null;
+            $rawPayload  = $post['payload']       ?? null;
+
+            if (!$passengerId || !$rawPayload) {
+                $connection->send('Error: Missing passenger_id or payload');
+                return;
+            }
+
+            $payload = is_string($rawPayload)
+                ? (json_decode($rawPayload, true) ?? $rawPayload)
+                : $rawPayload;
+
+            $io->to('passenger_' . $passengerId)->emit('ride_status_change', $payload);
+
+            $connection->send('OK');
+            echo '[' . date('H:i:s') . '] Status update sent to Passenger #' . $passengerId . PHP_EOL;
+
+        } elseif ($action === 'update_driver_location') {
+
+            $passengerId = $post['passenger_id'] ?? null;
+            $rawPayload  = $post['payload']       ?? null;
+
+            if (!$passengerId || !$rawPayload) {
+                $connection->send('Error: Missing passenger_id or payload');
+                return;
+            }
+
+            $payload = is_string($rawPayload)
+                ? (json_decode($rawPayload, true) ?? $rawPayload)
+                : $rawPayload;
+
+            $io->to('passenger_' . $passengerId)->emit('driver_location_update', $payload);
+
+            $connection->send('OK');
+
+        } else {
+            $connection->send('Unknown action: ' . $action);
+        }
+    };
+
+    $innerHttp->listen();
+    echo '[' . date('H:i:s') . "] Internal HTTP started on port $INTERNAL_PORT" . PHP_EOL;
+});
+
+$io->on('connection', function ($socket) {
+
+    $query       = $socket->handshake['query'] ?? [];
+    $passengerId = $query['id'] ?? null;
+
+    if (!$passengerId) {
+        $socket->disconnect();
+        return;
+    }
+
+    $socket->join('passenger_' . $passengerId);
+    echo '[' . date('H:i:s') . "] Passenger Connected: #$passengerId" . PHP_EOL;
+
+    $socket->on('heartbeat', function ($data) {
+        // استقبال النبضة فقط — لا يحتاج رد
+    });
+
+    $socket->on('disconnect', function () use ($passengerId) {
+        echo '[' . date('H:i:s') . "] Passenger Disconnected: #$passengerId" . PHP_EOL;
+    });
+});
+
+Worker::runAll();