Safemobile/mediasoup
21
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

LINXD-2850: Add handler on icestatechange failed/disconnected to send 'connection-failed' event to participants

Browse Source
This commit is contained in:
Sergiu Toma 2025-03-12 09:31:36 +02:00
parent 4f044555ba
commit 642dba8dac
1 changed files with 10 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
app.js
View File

@ -542,6 +542,15 @@ const isInitiator = (callId, socketId) => {
return videoCalls[callId]?.initiatorSocket?.id === socketId; return videoCalls[callId]?.initiatorSocket?.id === socketId;
}; };
const emitToParticipants = (callId, event, message) => {
try {
videoCalls[callId].receiverSocket.emit(event, message);
videoCalls[callId].initiatorSocket.emit(event, message);
} catch (error) {
console.error(`[emitToParticipants] | ERROR | callId: ${callId} | error: ${error.message}`);
}
}
/* /*
- Called from at event 'createWebRtcTransport' and assigned to the consumer or producer transport - Called from at event 'createWebRtcTransport' and assigned to the consumer or producer transport
- It will return parameters, these are required for the client to create the RecvTransport - It will return parameters, these are required for the client to create the RecvTransport
@ -584,6 +593,7 @@ const createWebRtcTransportLayer = async (callId, callback) => {
console.log(`[ICE STATE CHANGE] callId: ${callId} | State: ${iceState}`); console.log(`[ICE STATE CHANGE] callId: ${callId} | State: ${iceState}`);
if (iceState === 'failed' || iceState === 'disconnected') { if (iceState === 'failed' || iceState === 'disconnected') {
console.warn(`⚠️ ICE failure detected for callId: ${callId}! Possible UDP blockage.`); console.warn(`⚠️ ICE failure detected for callId: ${callId}! Possible UDP blockage.`);
emitToParticipants(callId, 'connection-failed', { callId });
} }
}); });