Refactored

packages/app/src/server/service/socket-io.js

@@ -42,6 +42,7 @@ class SocketIoService {
 
     await this.setupStoreGuestIdEventHandler();
 
+    await this.setupLoginedUserRoomsJoinOnConnection();
     await this.setupDefaultSocketJoinRoomsEventHandler();
   }
 
@@ -127,14 +128,8 @@ class SocketIoService {
     });
   }
 
-  setupDefaultSocketJoinRoomsEventHandler() {
+  setupLoginedUserRoomsJoinOnConnection() {
     this.io.on('connection', (socket) => {
-      // set event handlers for joining rooms
-      socket.on('join:page', ({ pageId }) => {
-        socket.join(getRoomNameWithId(RoomPrefix.PAGE, pageId));
-      });
-
-      // for user rooms
       const user = socket.request.user;
       if (user == null) {
         logger.debug('Socket io: An anonymous user has connected');
@@ -144,6 +139,15 @@ class SocketIoService {
     });
   }
 
+  setupDefaultSocketJoinRoomsEventHandler() {
+    this.io.on('connection', (socket) => {
+      // set event handlers for joining rooms
+      socket.on('join:page', ({ pageId }) => {
+        socket.join(getRoomNameWithId(RoomPrefix.PAGE, pageId));
+      });
+    });
+  }
+
   async checkConnectionLimitsForAdmin(socket, next) {
     const namespaceName = socket.nsp.name;