Merge pull request #14 from boostcampwm-2024/refactor/#11

refactor: Add test:joinRoom event for Artillery load testing

Author: ssum1ra

server/src/game/game.gateway.ts

@@ -47,6 +47,23 @@ export class GameGateway implements OnGatewayDisconnect {
     this.server.to(client.id).emit('joinedRoom', { room, roomSettings, playerId: player.playerId, players });
   }
 
+  @SubscribeMessage('test:joinRoom')
+  async handleTestJoinRoom(
+    @ConnectedSocket() client: Socket,
+    @MessageBody() data: { roomId: string; playerId: string },
+  ) {
+    const { room, roomSettings, player, players } = await this.gameService.testJoinRoom(data.roomId, data.playerId);
+
+    client.data.playerId = player.playerId;
+    client.data.roomId = room.roomId;
+
+    await client.join(room.roomId);
+
+    client.to(room.roomId).emit('playerJoined', { room, roomSettings, players });
+
+    this.server.to(client.id).emit('joinedRoom', { room, roomSettings, playerId: player.playerId, players });
+  }
+
   @SubscribeMessage('reconnect')
   async handleReconnect(@ConnectedSocket() client: Socket, @MessageBody() data: { roomId: string; playerId: string }) {
     const { roomId, playerId } = data;
@@ -90,6 +107,8 @@ export class GameGateway implements OnGatewayDisconnect {
 
   @SubscribeMessage('gameStart')
   async handleGameStart(@ConnectedSocket() client: Socket) {
+    console.log('Game Start');
+
     const { playerId, roomId } = client.data;
     if (!playerId || !roomId) throw new BadRequestException('Room ID and Player ID are required');
 

server/src/game/game.service.ts

@@ -140,6 +140,45 @@ export class GameService {
     return `${adj} ${noun}`;
   }
 
+  async testJoinRoom(roomId: string, playerId: string) {
+    const [room, roomSettings, players] = await Promise.all([
+      this.gameRepository.getRoom(roomId),
+      this.gameRepository.getRoomSettings(roomId),
+      this.gameRepository.getRoomPlayers(roomId),
+    ]);
+
+    if (!room) throw new RoomNotFoundException();
+    if (room.status === RoomStatus.GUESSING || room.status === RoomStatus.DRAWING) {
+      throw new GameAlreadyStartedException('Cannot join room while game is in progress');
+    }
+    if (!roomSettings) throw new RoomNotFoundException('Room settings not found');
+    if (players.length >= roomSettings.maxPlayers) {
+      throw new RoomFullException('Room is full');
+    }
+
+    const nickname = this.generateNickname();
+    const player: Player = {
+      playerId,
+      role: null,
+      status: PlayerStatus.NOT_PLAYING,
+      nickname,
+      profileImage: `https://api.dicebear.com/9.x/pixel-art/svg?seed=${nickname}`,
+      score: 0,
+    };
+
+    const isFirstPlayer = players.length === 0;
+    if (isFirstPlayer) {
+      room.hostId = playerId;
+      await this.gameRepository.updateRoom(roomId, { hostId: playerId });
+    }
+
+    await this.gameRepository.addPlayerToRoom(roomId, playerId, player);
+
+    const updatedPlayers = [player, ...players].reverse();
+
+    return { room, roomSettings, player, players: updatedPlayers };
+  }
+
   async reconnect(roomId: string, playerId: string) {
     const [room, roomSettings, players] = await Promise.all([
       this.gameRepository.getRoom(roomId),