update

Author: khanh1902

server/src/app.ts

@@ -50,9 +50,7 @@ export class App {
       App.io = new Server(server);
 
       App.io.on('connection', (socket) => {
-        const query = socket.handshake.query;
-        const userId = query.userId;
-        socket.join(userId);
+        socketController.handleJoinRoom(socket);
         socketController.handleSocketEvents(socket);
       });
 

server/src/controllers/socket.controller.ts

@@ -11,4 +11,8 @@ export class SocketController {
     public handleSocketEvents(socket: Socket) {
         this.socketService.handleSocketEvents(socket);
     }
+
+    public handleJoinRoom(socket: Socket) {
+        this.socketService.handleJoinRoom(socket);
+    }
 }

server/src/services/socket.service.ts

@@ -44,4 +44,11 @@ export class SocketService {
             await webChannel.postMessageToBot({ userId, message, data: '' })
         }
     }
+
+    public handleJoinRoom(socket: Socket) {
+        const query = socket.handshake.query;
+        const userId = query.userId;
+        socket.join(userId);
+        return socket;
+    }
 }