From 420919d00d767d794c6eda93f293b956488a68af Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=D0=90=D0=BD=D0=B4=D1=80=D0=B5=D0=B9=20=D0=91=D0=B0=D0=B1?= =?UTF-8?q?=D1=83=D1=88=D0=BA=D0=B8=D0=BD?= Date: Wed, 26 Mar 2025 14:18:34 +0100 Subject: [PATCH] changed AGENT_WEBRTC_CALL handling in socket server --- assist/utils/socketHandlers.js | 2 +- frontend/app/player/web/assist/Call.ts | 5 +---- tracker/tracker-assist/src/Assist.ts | 2 +- 3 files changed, 3 insertions(+), 6 deletions(-) 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);