Hamza/intaleq_v3_pure_php
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

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

Browse Source
This commit is contained in:
Hamza-Ayed
2026-05-29 00:49:58 +03:00
parent d2237a54e4
commit 97907bde94
2 changed files with 20 additions and 18 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
ride/call/driver/create_call_session.php
View File

@@ -8,13 +8,13 @@
declare(strict_types=1); declare(strict_types=1);
require_once __DIR__ . '/../../bootstrap/init.php'; require_once __DIR__ . '/../../../connect.php';
require_once __DIR__ . '/../../core/Auth.php';
require_once __DIR__ . '/../../core/Response.php';
require_once __DIR__ . '/../../core/FCM.php';
try { try {
$jwt = authenticateJWT('driver'); if ($role !== 'driver' || empty($user_id)) {
printFailure('Unauthorized access');
exit;
}
$rideId = $_POST['ride_id'] ?? null; $rideId = $_POST['ride_id'] ?? null;
if (!$rideId) { if (!$rideId) {
@@ -30,7 +30,7 @@ try {
WHERE r.id = :rid AND r.driver_id = :did AND r.status IN ('accepted', 'arrived', 'started', 'begin') WHERE r.id = :rid AND r.driver_id = :did AND r.status IN ('accepted', 'arrived', 'started', 'begin')
LIMIT 1 LIMIT 1
"); ");
$stmt->execute([':rid' => $rideId, ':did' => $jwt->user_id]); $stmt->execute([':rid' => $rideId, ':did' => $user_id]);
$ride = $stmt->fetch(); $ride = $stmt->fetch();
if (!$ride) { if (!$ride) {
@@ -48,7 +48,7 @@ try {
$ch = curl_init($url); $ch = curl_init($url);
$payload = json_encode([ $payload = json_encode([
'ride_id' => (string)$rideId, 'ride_id' => (string)$rideId,
'driver_id' => (string)$jwt->user_id, 'driver_id' => (string)$user_id,
'passenger_id' => (string)$passengerId 'passenger_id' => (string)$passengerId
]); ]);
@@ -94,7 +94,7 @@ try {
$passengerTokenRow = $stmtToken->fetch(); $passengerTokenRow = $stmtToken->fetch();
if ($passengerTokenRow && !empty($passengerTokenRow['token'])) { if ($passengerTokenRow && !empty($passengerTokenRow['token'])) {
sendFCMData( sendFcmNotification(
$passengerTokenRow['token'], $passengerTokenRow['token'],
'Incoming Call', 'Incoming Call',
'Incoming WebRTC voice call', 'Incoming WebRTC voice call',
@@ -105,7 +105,8 @@ try {
'caller_avatar' => '', 'caller_avatar' => '',
'ride_id' => (string)$rideId 'ride_id' => (string)$rideId
], ],
'Call' 'Call',
'ding'
); );
} }

19
ride/call/passenger/create_call_session.php
View File

@@ -8,13 +8,13 @@
declare(strict_types=1); declare(strict_types=1);
require_once __DIR__ . '/../../bootstrap/init.php'; require_once __DIR__ . '/../../../connect.php';
require_once __DIR__ . '/../../core/Auth.php';
require_once __DIR__ . '/../../core/Response.php';
require_once __DIR__ . '/../../core/FCM.php';
try { try {
$jwt = authenticateJWT('passenger'); if ($role !== 'passenger' || empty($user_id)) {
printFailure('Unauthorized access');
exit;
}
$rideId = $_POST['ride_id'] ?? null; $rideId = $_POST['ride_id'] ?? null;
if (!$rideId) { if (!$rideId) {
@@ -30,7 +30,7 @@ try {
WHERE r.id = :rid AND r.passenger_id = :pid AND r.status IN ('accepted', 'arrived', 'started', 'begin') WHERE r.id = :rid AND r.passenger_id = :pid AND r.status IN ('accepted', 'arrived', 'started', 'begin')
LIMIT 1 LIMIT 1
"); ");
$stmt->execute([':rid' => $rideId, ':pid' => $jwt->user_id]); $stmt->execute([':rid' => $rideId, ':pid' => $user_id]);
$ride = $stmt->fetch(); $ride = $stmt->fetch();
if (!$ride) { if (!$ride) {
@@ -54,7 +54,7 @@ try {
$payload = json_encode([ $payload = json_encode([
'ride_id' => (string)$rideId, 'ride_id' => (string)$rideId,
'driver_id' => (string)$driverId, 'driver_id' => (string)$driverId,
'passenger_id' => (string)$jwt->user_id 'passenger_id' => (string)$user_id
]); ]);
curl_setopt_array($ch, [ curl_setopt_array($ch, [
@@ -99,7 +99,7 @@ try {
$driverTokenRow = $stmtToken->fetch(); $driverTokenRow = $stmtToken->fetch();
if ($driverTokenRow && !empty($driverTokenRow['token'])) { if ($driverTokenRow && !empty($driverTokenRow['token'])) {
sendFCMData( sendFcmNotification(
$driverTokenRow['token'], $driverTokenRow['token'],
'Incoming Call', 'Incoming Call',
'Incoming WebRTC voice call', 'Incoming WebRTC voice call',
@@ -110,7 +110,8 @@ try {
'caller_avatar' => '', 'caller_avatar' => '',
'ride_id' => (string)$rideId 'ride_id' => (string)$rideId
], ],
'Call' 'Call',
'ding'
); );
} }