fix (chat): ice server config on client side

Author: itsskofficial

src/client/app/chat/page.js

@@ -730,7 +730,7 @@ export default function ChatPage() {
 			)
 			if (!rtcTokenResponse.ok)
 				throw new Error("Could not initiate voice session.")
-			const { rtc_token } = await rtcTokenResponse.json()
+			const { rtc_token, ice_servers } = await rtcTokenResponse.json()
 
 			// Step 3: Create and connect WebRTCClient directly
 			if (webrtcClientRef.current) {
@@ -753,7 +753,8 @@ export default function ChatPage() {
 					}
 				},
 				onAudioLevel: handleAudioLevel,
-				onEvent: handleVoiceEvent
+				onEvent: handleVoiceEvent,
+				iceServers: ice_servers.iceServers
 			})
 			webrtcClientRef.current = client
 

src/client/lib/webrtc-client.js

@@ -10,6 +10,7 @@ export class WebRTCClient {
 		this.animationFrameId = null
 		this.serverUrl =
 			process.env.NEXT_PUBLIC_APP_SERVER_URL || "http://localhost:5000"
+		this.iceServers = options.iceServers || [] // Store iceServers from options
 
 		// --- MODIFICATION: Add a queue for ICE candidates ---
 		this.iceCandidateQueue = []
@@ -33,7 +34,13 @@ export class WebRTCClient {
 		this.iceCandidateQueue = []
 
 		try {
-			this.peerConnection = new RTCPeerConnection()
+			this.peerConnection = new RTCPeerConnection({
+				iceServers: this.iceServers
+			})
+			console.log("Created RTCPeerConnection with config:", {
+				iceServers: this.iceServers
+			})
+
 			console.log("Created RTCPeerConnection:", this.peerConnection)
 
 			// --- MODIFICATION: Queue ICE candidates instead of sending immediately ---

src/server/main/voice/routes.py

@@ -30,7 +30,8 @@ async def initiate_voice_session(
     user_id: str = Depends(PermissionChecker(required_permissions=["read:chat"]))
 ):
     """
-    Generates a short-lived, single-use token for authenticating a WebRTC/WebSocket voice stream.
+    Generates a short-lived, single-use token for authenticating a WebRTC/WebSocket voice stream
+    and provides the necessary ICE server configuration.
     """
     # Clean up expired tokens to prevent the cache from growing indefinitely
     now = time.time()
@@ -43,8 +44,11 @@ async def initiate_voice_session(
     expires_at = now + TOKEN_EXPIRATION_SECONDS
     rtc_token_cache[rtc_token] = {"user_id": user_id, "expires_at": expires_at}
 
+    # Get TURN credentials to send to the client
+    ice_servers_config = get_credentials()
+
     logger.info(f"Initiated voice session for user {user_id} with token {rtc_token}")
-    return {"rtc_token": rtc_token}
+    return {"rtc_token": rtc_token, "ice_servers": ice_servers_config}
 
 
 class MyVoiceChatHandler(ReplyOnPause):