gemercheung 2 年 前
コミット
ffb274db91
2 ファイル変更19 行追加0 行削除
  1. 10 0
      src/room/room.service.ts
  2. 9 0
      src/socket/socket.gateway.ts

+ 10 - 0
src/room/room.service.ts

@@ -225,6 +225,16 @@ export class RoomService {
       socket.broadcast.to(RoomId).emit('paint', message);
     }
   }
+  /**
+   *  房间同步楼层大通道
+   * @param message
+   */
+  async handleSyncFloorAction(socket: Socket, message: any) {
+    if (socket.data?.user) {
+      const { RoomId } = socket.data?.user;
+      socket.broadcast.to(RoomId).emit('sync-floor', message);
+    }
+  }
 
   /**
    *  房间T人

+ 9 - 0
src/socket/socket.gateway.ts

@@ -172,6 +172,15 @@ export class SocketGateway
     await this.roomService.handleExitAction(socket, message);
   }
 
+  // 订阅同步楼层事件
+  @SubscribeMessage('sync-floor')
+  async handleSyncFloor(
+    @ConnectedSocket() socket: Socket,
+    @MessageBody() message: any,
+  ): Promise<void> {
+    await this.roomService.handleSyncFloorAction(socket, message);
+  }
+
   @SubscribeMessage('active-status')
   async handleActive(@ConnectedSocket() socket: Socket) {
     const sockets = await this.server.fetchSockets();