add new features like realtime 2026-05-29-17

ride/rides/cancel_ride_by_driver.php

@@ -95,8 +95,28 @@ try {
     }
 
     // ب) FCM (Internal)
+    if (empty($passengerToken) && $passenger_id) {
+        $stmtToken = $con->prepare("SELECT token FROM tokens WHERE passengerID = ? ORDER BY id DESC LIMIT 1");
+        $stmtToken->execute([$passenger_id]);
+        $rawToken = $stmtToken->fetchColumn();
+        if ($rawToken) {
+            $passengerToken = $rawToken;
+            if (!empty($encryptionHelper)) {
+                try {
+                    $decrypted = $encryptionHelper->decryptData($rawToken);
+                    if ($decrypted !== false && !empty($decrypted)) {
+                        $passengerToken = trim($decrypted);
+                    }
+                } catch (Exception $e) {
+                    // Fallback
+                }
+            }
+        }
+    }
+
     if (!empty($passengerToken)) {
         $fcmData = [
+            'category' => 'Cancel Trip from driver',
             'ride_id'  => (string)$rideId
         ];
         

ride/rides/cancel_ride_by_passenger.php

@@ -93,6 +93,9 @@ try {
         curl_close($ch);
 
         // ب) FCM (باستخدام الدالة الجديدة مع فك التشفير)
+        $driverToken = filterRequest("driver_token");
+
+        if (empty($driverToken)) {
             $stmtToken = $con->prepare("SELECT token FROM driverToken WHERE captain_id = ?");
             $stmtToken->execute([$driverId]);
             $rawToken = $stmtToken->fetchColumn();
@@ -111,7 +114,10 @@ try {
                         // في حال الفشل نستخدم الخام
                     }
                 }
+            }
+        }
 
+        if (!empty($driverToken)) {
             // تجهيز البيانات
             $fcmData = [
                 'category' => 'Cancel Trip',

ride/rides/finish_ride_updates.php

@@ -12,6 +12,7 @@ try {
 $rideId    = filterRequest("rideId");    
 $driver_id = filterRequest("driver_id");
 $passengerId=filterRequest("passengerId");
+$passenger_id = $passengerId;
 $newStatus = filterRequest("status");   // "Finished"
 $price     = filterRequest("price");
 $passengerToken = filterRequest("passengerToken");