13

ride/rides/add_ride.php

@@ -13,7 +13,44 @@ try {
     printFailure("Database connection failed");
     exit;
 }
+// =================================================================================
+// 🛠️ دالة مساعدة: إرسال الرحلة لسوق السائقين (Marketplace Broadcast)
+// =================================================================================
+function broadcastRideToMarket($rideId, $lat, $lng, $payloadData) {
+    $url = getenv('LOCATION_SOCKET_URL'); 
+    $keyPath = getenv('INTERNAL_SOCKET_KEY_PATH');
+    $INTERNAL_KEY = $keyPath && file_exists($keyPath) ? trim(file_get_contents($keyPath)) : '';
 
+    $marketPayload = [
+        'id'            => (string)$rideId,
+        'start_lat'     => $lat,
+        'start_lng'     => $lng,
+        'price'         => $payloadData[2],  
+        'carType'       => $payloadData[31], 
+        'startName'     => $payloadData[29], 
+        'endName'       => $payloadData[30], 
+        'distance'      => $payloadData[11], 
+        'duration'      => $payloadData[15], 
+        'passengerRate' => $payloadData[33], 
+    ];
+
+    $postData = [
+        'action'  => 'market_new_ride', 
+        'payload' => $marketPayload
+    ];
+
+    $ch = curl_init();
+    curl_setopt($ch, CURLOPT_URL, $url);
+    curl_setopt($ch, CURLOPT_POST, 1);
+    curl_setopt($ch, CURLOPT_POSTFIELDS, http_build_query($postData));
+    curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
+    curl_setopt($ch, CURLOPT_TIMEOUT_MS, 200); 
+    if ($INTERNAL_KEY) {
+        curl_setopt($ch, CURLOPT_HTTPHEADER, ["x-internal-key: $INTERNAL_KEY"]);
+    }
+    curl_exec($ch);
+    curl_close($ch);
+}
 error_log("[add_ride] Request started. passenger_id=" . ($_POST['passenger_id'] ?? '?'));
 
 // ── 1. Input ───────────────────────────────────────────────────