diff --git a/utilities/servers/websocket.js b/utilities/servers/websocket.js index abe3cc9a7..669345a8b 100644 --- a/utilities/servers/websocket.js +++ b/utilities/servers/websocket.js @@ -181,6 +181,9 @@ module.exports = { if (io.sockets.adapter.rooms.get(socket.peerId)) { console.log(`${socket.id} joined room:${socket.peerId}, as:${socket.identity}, size:${io.sockets.adapter.rooms.get(socket.peerId).size}`); } + if (socket.identity === IDENTITIES.agent) { + socket.to(socket.peerId).emit(socket.id, NEW_AGENT_MESSAGE); + } socket.on('disconnect', async () => { // console.log(`${socket.id} disconnected from ${socket.peerId}, waiting ${wsReconnectionTimeout / 1000}s before checking remaining`); @@ -223,9 +226,6 @@ module.exports = { } }); - if (socket.identity === IDENTITIES.agent) { - socket.to(socket.peerId).emit(NEW_AGENT_MESSAGE); - } }); console.log("WS server started") }