diff --git a/assist/utils/socketHandlers.js b/assist/utils/socketHandlers.js index 503969c08..f9da17d08 100644 --- a/assist/utils/socketHandlers.js +++ b/assist/utils/socketHandlers.js @@ -191,7 +191,7 @@ async function onUpdateEvent(socket, ...args) { async function onWebrtcAgentHandler(socket, ...args) { if (socket.handshake.query.identity === IDENTITIES.agent) { - const agentIdToConnect = args[0]?.data?.toAgentId; + const agentIdToConnect = args[2]?.toAgentId; logger.debug(`${socket.id} sent webrtc event to agent:${agentIdToConnect}`); if (agentIdToConnect && socket.handshake.sessionData.AGENTS_CONNECTED.includes(agentIdToConnect)) { socket.to(agentIdToConnect).emit(EVENTS_DEFINITION.listen.WEBRTC_AGENT_CALL, args[0]); diff --git a/frontend/app/player/web/assist/Call.ts b/frontend/app/player/web/assist/Call.ts index 303053f9b..5b9c7144a 100644 --- a/frontend/app/player/web/assist/Call.ts +++ b/frontend/app/player/web/assist/Call.ts @@ -50,7 +50,6 @@ export default class Call { private agentIds: string[], ) { socket.on('WEBRTC_AGENT_CALL', (data) => { - console.log('WEBRTC_AGENT_CALL', data); switch (data.type) { case WEBRTC_CALL_AGENT_EVENT_TYPES.OFFER: this.handleOffer(data, true); @@ -236,7 +235,6 @@ export default class Call { socketId?: string; localPeerId?: string; }) { - console.log('ESTABLISHING CONNECTION WITH', remotePeerId, isAgent ? 'AGENT' : 'CLIENT'); try { // Create RTCPeerConnection with client const pc = await this.createPeerConnection({ @@ -252,8 +250,7 @@ export default class Call { // Sending offer if (isAgent) { - console.log('SENDING OFFER TO AGENT', socketId); - this.socket.emit('WEBRTC_AGENT_CALL1', { + this.socket.emit('WEBRTC_AGENT_CALL', { from: localPeerId, offer, toAgentId: socketId, diff --git a/tracker/tracker-assist/src/Assist.ts b/tracker/tracker-assist/src/Assist.ts index 753fe42d8..6dde25e7f 100644 --- a/tracker/tracker-assist/src/Assist.ts +++ b/tracker/tracker-assist/src/Assist.ts @@ -254,7 +254,7 @@ export default class Assist { return } if (args[0] !== 'webrtc_call_ice_candidate') { - app.debug.log("Socket:", ...args, args[2]?.data?.toAgentId); + app.debug.log("Socket:", ...args); }; socket.on('close', (e) => { app.debug.warn('Socket closed:', e);