From a6f16031a85c2afa0748a6e55d90f54278cedb04 Mon Sep 17 00:00:00 2001
From: Alexander Zavorotynskiy <zavorotynskiy@pm.me>
Date: Tue, 6 Jun 2023 13:35:13 +0200
Subject: [PATCH] fix(assist): fixed more typos in copy-pastes

---
 ee/assist/servers/websocket-cluster.js | 12 ++++++------
 ee/assist/servers/websocket.js         |  4 ++--
 2 files changed, 8 insertions(+), 8 deletions(-)

diff --git a/ee/assist/servers/websocket-cluster.js b/ee/assist/servers/websocket-cluster.js
index 9d027467a..4a92403d4 100644
--- a/ee/assist/servers/websocket-cluster.js
+++ b/ee/assist/servers/websocket-cluster.js
@@ -258,8 +258,8 @@ const findSessionSocketId = async (io, roomId, tabId) => {
 async function sessions_agents_count(io, socket) {
     let c_sessions = 0, c_agents = 0;
     const rooms = await getAvailableRooms(io);
-    if (rooms.has(socket.peerId)) {
-        const connected_sockets = await io.in(socket.peerId).fetchSockets();
+    if (rooms.has(socket.roomId)) {
+        const connected_sockets = await io.in(socket.roomId).fetchSockets();
 
         for (let item of connected_sockets) {
             if (item.handshake.query.identity === IDENTITIES.session) {
@@ -278,8 +278,8 @@ async function sessions_agents_count(io, socket) {
 async function get_all_agents_ids(io, socket) {
     let agents = [];
     const rooms = await getAvailableRooms(io);
-    if (rooms.has(socket.peerId)) {
-        const connected_sockets = await io.in(socket.peerId).fetchSockets();
+    if (rooms.has(socket.roomId)) {
+        const connected_sockets = await io.in(socket.roomId).fetchSockets();
         for (let item of connected_sockets) {
             if (item.handshake.query.identity === IDENTITIES.agent) {
                 agents.push(item.id);
@@ -345,7 +345,7 @@ module.exports = {
                     debug && console.log(`notifying new session about agent-existence`);
                     let agents_ids = await get_all_agents_ids(io, socket);
                     io.to(socket.id).emit(EVENTS_DEFINITION.emit.AGENTS_CONNECTED, agents_ids);
-                    socket.to(socket.peerId).emit(EVENTS_DEFINITION.emit.SESSION_RECONNECTED, socket.id);
+                    socket.to(socket.roomId).emit(EVENTS_DEFINITION.emit.SESSION_RECONNECTED, socket.id);
                 }
 
             } else if (c_sessions <= 0) {
@@ -355,7 +355,7 @@ module.exports = {
             await socket.join(socket.roomId);
             const rooms = await getAvailableRooms(io);
             if (rooms.has(socket.roomId)) {
-                let connectedSockets = await io.in(socket.peerId).fetchSockets();
+                let connectedSockets = await io.in(socket.roomId).fetchSockets();
                 debug && console.log(`${socket.id} joined room:${socket.roomId}, as:${socket.identity}, members:${connectedSockets.length}`);
             }
             if (socket.identity === IDENTITIES.agent) {
diff --git a/ee/assist/servers/websocket.js b/ee/assist/servers/websocket.js
index 81d56dde0..0cc897318 100644
--- a/ee/assist/servers/websocket.js
+++ b/ee/assist/servers/websocket.js
@@ -248,8 +248,8 @@ async function sessions_agents_count(io, socket) {
 async function get_all_agents_ids(io, socket) {
     let agents = [];
     const rooms = await getAvailableRooms(io);
-    if (rooms.get(socket.peerId)) {
-        const connected_sockets = await io.in(socket.peerId).fetchSockets();
+    if (rooms.get(socket.roomId)) {
+        const connected_sockets = await io.in(socket.roomId).fetchSockets();
         for (let item of connected_sockets) {
             if (item.handshake.query.identity === IDENTITIES.agent) {
                 agents.push(item.id);