SimpliRide WebSocket API

const socket = io('https://realtime.simpliride.com/trip', { query: { userId: 'user-uuid', userType: 'RIDER' // or 'DRIVER', 'SUPPORT', 'ADMIN' } }); // For drivers, you can also specify vehicle type const driverSocket = io('https://realtime.simpliride.com/driver', { query: { userId: 'driver-uuid', userType: 'DRIVER', vehicleType: 'STANDARD' // SAVER, STANDARD, COMFORT, PRIORITY_PICKUP, XL, PREMIUM, PREMIUM_SUV } });

socket.on('error', (error) => { console.error('Socket error:', error.code, error.message); // error.code: 'RATE_LIMIT', 'FORBIDDEN', 'INVALID_TOKEN', etc. });

wss://realtime.simpliride.com/trip

wss://realtime.simpliride.com/driver

wss://realtime.simpliride.com/chat

wss://realtime.simpliride.com/voice

// === CALLER SIDE === class VoiceCaller { constructor(socket, tripId) { this.socket = socket; this.tripId = tripId; this.peerConnection = null; this.callId = null; } async startCall() { // 1. Get ICE servers const iceServers = await new Promise(resolve => { this.socket.emit('voice:getIceServers', {}, resolve); }); // 2. Create peer connection this.peerConnection = new RTCPeerConnection({ iceServers: iceServers.iceServers }); // 3. Set up ICE candidate handling this.peerConnection.onicecandidate = (event) => { if (event.candidate) { this.socket.emit('voice:ice-candidate', { callId: this.callId, tripId: this.tripId, candidate: event.candidate }); } }; // 4. Handle incoming audio this.peerConnection.ontrack = (event) => { const remoteAudio = document.getElementById('remoteAudio'); remoteAudio.srcObject = event.streams[0]; }; // 5. Add local audio const stream = await navigator.mediaDevices.getUserMedia({ audio: true }); stream.getTracks().forEach(track => { this.peerConnection.addTrack(track, stream); }); // 6. Initiate call const response = await new Promise(resolve => { this.socket.emit('voice:initiate', { tripId: this.tripId }, resolve); }); if (!response.success) { throw new Error(response.error); } this.callId = response.callId; // 7. Create and send offer const offer = await this.peerConnection.createOffer(); await this.peerConnection.setLocalDescription(offer); this.socket.emit('voice:offer', { callId: this.callId, tripId: this.tripId, offer: offer }); // 8. Listen for answer this.socket.on('voice:answer', async (data) => { await this.peerConnection.setRemoteDescription( new RTCSessionDescription(data.answer) ); }); // 9. Listen for ICE candidates this.socket.on('voice:ice-candidate', async (data) => { if (data.candidate) { await this.peerConnection.addIceCandidate( new RTCIceCandidate(data.candidate) ); } }); } endCall() { this.socket.emit('voice:end', { callId: this.callId, tripId: this.tripId, reason: 'NORMAL' }); this.peerConnection?.close(); } } // === CALLEE SIDE === class VoiceCallee { constructor(socket) { this.socket = socket; this.peerConnection = null; // Listen for incoming calls socket.on('voice:incoming', (data) => { this.handleIncomingCall(data); }); } async handleIncomingCall(data) { // Show UI and wait for user action const accepted = await showIncomingCallUI(data); if (!accepted) { this.socket.emit('voice:reject', { callId: data.callId, tripId: data.tripId }); return; } // Accept call this.socket.emit('voice:accept', { callId: data.callId, tripId: data.tripId }); // Set up peer connection (similar to caller) // ...handle voice:offer, create answer, exchange ICE candidates } }

wss://realtime.simpliride.com/support

/api/v1/internal/support-chat

// Connect to support namespace const socket = io('https://realtime.simpliride.com/support', { query: { userId: 'user-uuid', userType: 'RIDER' }, transports: ['websocket'] }); let currentConversationId = null; // Create a new support conversation function createConversation(subject, relatedTripId = null) { socket.emit('support:create-conversation', { subject, priority: 'normal', relatedTripId }, (response) => { if (response.success) { currentConversationId = response.conversationId; joinConversation(currentConversationId); } }); } // Join conversation room function joinConversation(conversationId) { socket.emit('support:join', { conversationId }, (response) => { if (response.success) { loadHistory(conversationId); } }); } // Load message history function loadHistory(conversationId) { socket.emit('support:history', { conversationId, limit: 50 }, (response) => { if (response.success) { displayMessages(response.messages); } }); } // Send a message function sendMessage(content) { socket.emit('support:message', { conversationId: currentConversationId, content }, (response) => { if (response.success) { console.log('Message sent:', response.messageId); } }); } // Listen for incoming messages socket.on('support:message', (message) => { if (message.conversationId === currentConversationId) { displayNewMessage(message); socket.emit('support:read', { conversationId: currentConversationId }); } }); // Listen for admin typing socket.on('support:typing', (data) => { if (data.conversationId === currentConversationId) { showTypingIndicator(data.adminName, data.isTyping); } }); // Listen for status changes socket.on('support:status', (data) => { if (data.conversationId === currentConversationId) { updateConversationStatus(data.status); } }); // Listen for admin assignment socket.on('support:assigned', (data) => { if (data.conversationId === currentConversationId) { showNotification(`${data.adminName} is now handling your request`); } });

// build.gradle implementation 'io.socket:socket.io-client:2.1.0' // Usage import io.socket.client.IO import io.socket.client.Socket import org.json.JSONObject class SocketManager { private lateinit var socket: Socket fun connect(userId: String, userType: String) { val options = IO.Options().apply { query = "userId=$userId&userType=$userType" transports = arrayOf("websocket") reconnection = true reconnectionAttempts = 5 reconnectionDelay = 1000 } socket = IO.socket("https://realtime.simpliride.com/trip", options) socket.on(Socket.EVENT_CONNECT) { Log.d("Socket", "Connected!") } socket.on("trip:request") { args -> val tripRequest = args[0] as JSONObject // Handle new trip request } socket.on("trip:status") { args -> val status = args[0] as JSONObject // Handle status update } socket.connect() } fun acceptTrip(tripId: String, lat: Double, lng: Double) { val data = JSONObject().apply { put("tripId", tripId) put("latitude", lat) put("longitude", lng) } socket.emit("trip:accept", data) { response -> val result = response[0] as JSONObject if (result.getBoolean("success")) { // Trip accepted } } } fun updateLocation(lat: Double, lng: Double, speed: Float?, tripId: String?) { val data = JSONObject().apply { put("latitude", lat) put("longitude", lng) speed?.let { put("speed", it) } tripId?.let { put("tripId", it) } } socket.emit("location:update", data) } fun disconnect() { socket.disconnect() } }

// Package.swift or CocoaPods // pod 'Socket.IO-Client-Swift', '~> 16.0' import SocketIO class SocketManager { private var manager: SocketManager! private var socket: SocketIOClient! func connect(userId: String, userType: String) { manager = SocketManager( socketURL: URL(string: "https://realtime.simpliride.com")!, config: [ .log(true), .compress, .connectParams([ "userId": userId, "userType": userType ]) ] ) socket = manager.socket(forNamespace: "/trip") socket.on(clientEvent: .connect) { data, ack in print("Connected!") } socket.on("trip:request") { [weak self] data, ack in guard let tripRequest = data[0] as? [String: Any] else { return } // Handle new trip request } socket.on("trip:status") { [weak self] data, ack in guard let status = data[0] as? [String: Any] else { return } // Handle status update } socket.connect() } func acceptTrip(tripId: String, location: CLLocationCoordinate2D) { let data: [String: Any] = [ "tripId": tripId, "latitude": location.latitude, "longitude": location.longitude ] socket.emitWithAck("trip:accept", data).timingOut(after: 10) { response in if let result = response[0] as? [String: Any], let success = result["success"] as? Bool, success { // Trip accepted } } } func updateLocation(_ location: CLLocation, tripId: String?) { var data: [String: Any] = [ "latitude": location.coordinate.latitude, "longitude": location.coordinate.longitude, "speed": max(0, location.speed * 3.6), // m/s to km/h "heading": location.course ] if let tripId = tripId { data["tripId"] = tripId } socket.emit("location:update", data) } func disconnect() { socket.disconnect() } }

// npm install socket.io-client import { io, Socket } from 'socket.io-client'; interface TripRequest { tripId: string; riderId: string; riderName: string; pickup: { latitude: number; longitude: number; address: string }; dropoff: { latitude: number; longitude: number; address: string }; estimatedFare: number; } class SimpliRideSocket { private socket: Socket | null = null; connect(userId: string, userType: 'RIDER' | 'DRIVER'): void { this.socket = io('https://realtime.simpliride.com/trip', { query: { userId, userType }, transports: ['websocket'], reconnection: true, reconnectionAttempts: 5, reconnectionDelay: 1000, }); this.socket.on('connect', () => { console.log('Connected to SimpliRide Gateway'); }); this.socket.on('connected', (data) => { console.log('Session established:', data); }); this.socket.on('trip:request', (trip: TripRequest) => { console.log('New trip request:', trip); // Show trip to driver }); this.socket.on('trip:status', (status) => { console.log('Trip status update:', status); // Update UI }); this.socket.on('trip:eta', (eta) => { console.log('ETA update:', eta); }); this.socket.on('driver:location', (location) => { console.log('Driver location:', location); // Update map marker }); this.socket.on('error', (error) => { console.error('Socket error:', error); }); this.socket.on('disconnect', (reason) => { console.log('Disconnected:', reason); }); } subscribeToTrip(tripId: string): Promise<boolean> { return new Promise((resolve) => { this.socket?.emit('trip:subscribe', { tripId }, (response: any) => { resolve(response.success); }); }); } acceptTrip(tripId: string, latitude?: number, longitude?: number): Promise<any> { return new Promise((resolve, reject) => { this.socket?.emit('trip:accept', { tripId, latitude, longitude }, (response: any) => { if (response.success) { resolve(response); } else { reject(new Error(response.error || 'Failed to accept trip')); } }); }); } cancelTrip(tripId: string, reason?: string): void { this.socket?.emit('trip:cancel', { tripId, reason }); } triggerEmergency(tripId: string, type: string, latitude?: number, longitude?: number): void { this.socket?.emit('emergency:trigger', { tripId, type, latitude, longitude }); } disconnect(): void { this.socket?.disconnect(); this.socket = null; } } // Usage const socket = new SimpliRideSocket(); socket.connect('user-id', 'RIDER');

// pubspec.yaml // socket_io_client: ^2.0.3 import 'package:socket_io_client/socket_io_client.dart' as IO; class SocketService { late IO.Socket socket; void connect(String userId, String userType) { socket = IO.io( 'https://realtime.simpliride.com/trip', IO.OptionBuilder() .setTransports(['websocket']) .setQuery({'userId': userId, 'userType': userType}) .enableReconnection() .setReconnectionAttempts(5) .setReconnectionDelay(1000) .build(), ); socket.onConnect((_) { print('Connected to SimpliRide Gateway'); }); socket.on('connected', (data) { print('Session: $data'); }); socket.on('trip:request', (data) { print('New trip request: $data'); // Handle trip request }); socket.on('trip:status', (data) { print('Status update: $data'); }); socket.on('driver:location', (data) { print('Driver location: $data'); // Update map }); socket.onError((error) { print('Socket error: $error'); }); socket.onDisconnect((_) { print('Disconnected'); }); socket.connect(); } Future<bool> subscribeToTrip(String tripId) async { final completer = Completer<bool>(); socket.emitWithAck('trip:subscribe', {'tripId': tripId}, ack: (response) { completer.complete(response['success'] ?? false); }); return completer.future; } void acceptTrip(String tripId, double lat, double lng) { socket.emitWithAck('trip:accept', { 'tripId': tripId, 'latitude': lat, 'longitude': lng, }, ack: (response) { if (response['success']) { print('Trip accepted!'); } }); } void updateLocation(double lat, double lng, {double? speed, String? tripId}) { socket.emit('location:update', { 'latitude': lat, 'longitude': lng, if (speed != null) 'speed': speed, if (tripId != null) 'tripId': tripId, }); } void sendMessage(String tripId, String message) { socket.emit('chat:message', { 'tripId': tripId, 'message': message, }); } void disconnect() { socket.disconnect(); } }