jan/openreplay
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

fix(backend): fixed typo in message broadcast

Browse source
This commit is contained in:
Alexander Zavorotynskiy 2023-06-02 11:40:18 +02:00 • committed by nick-delirium
parent 9eebd6f935
commit d0706b2dac
1 changed files with 2 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
assist/servers/websocket.js
View file

@ -257,6 +257,7 @@ module.exports = {
socket.on(EVENTS_DEFINITION.listen.ERROR, err => errorHandler(EVENTS_DEFINITION.listen.ERROR, err));
debug && console.log(`WS started:${socket.id}, Query:${JSON.stringify(socket.handshake.query)}`);
socket._connectedAt = new Date();
socket.peerId = socket.handshake.query.peerId;
socket.roomId = extractRoomId(socket.peerId);
socket.tabId = extractTabId(socket.peerId);
@ -333,7 +334,7 @@ module.exports = {
if (socket.identity === IDENTITIES.session) {
debug && console.log(`received event:${eventName}, from:${socket.identity}, sending message to room:${socket.roomId}`);
// TODO: emit message to all agents in the room (except tabs)
socket.to(socket.peerId).emit(eventName, args[0]);
socket.to(socket.roomId).emit(eventName, args[0]);
} else {
debug && console.log(`received event:${eventName}, from:${socket.identity}, sending message to session of room:${socket.roomId}`);
// TODO: new message structure: {meta: {tabId: string::id}, data: xxx -> args[0]}