Merge branch 'dev-be' into fix-be-room-clean

BE/src/game/redis/game-redis-memory.service.ts

@@ -72,7 +72,8 @@ export class GameRedisMemoryService {
    * TTL 관리를 위한 스케줄러
    * 배치 처리로 블로킹 최소화
    */
-  // @Cron(CronExpression.EVERY_SECOND)
+
+  // @Cron(CronExpression.EVERY_MINUTE)
   async manageTTL(): Promise<void> {
     try {
       // SCAN으로 활성 방 목록을 배치로 처리

BE/src/game/redis/subscribers/timer.subscriber.ts

@@ -65,7 +65,7 @@ export class TimerSubscriber extends RedisSubscriber {
       const selectAnswer = this.calculateAnswer(
         player.positionX,
         player.positionY,
-        quizList.length
+        parseInt(quiz.choiceCount)
       );
       // this.logger.verbose(selectAnswer);
 
@@ -167,8 +167,8 @@ export class TimerSubscriber extends RedisSubscriber {
   }
 
   private calculateAnswer(positionX: string, positionY: string, quizLen: number): number {
-    const x = parseFloat(positionX);
-    const y = parseFloat(positionY);
+    const x = parseFloat(positionY);
+    const y = parseFloat(positionX);
 
     // 행의 개수 계산 (2열 고정이므로 총 개수의 절반을 올림)
     const rows = Math.ceil(quizLen / 2);
@@ -177,21 +177,12 @@ export class TimerSubscriber extends RedisSubscriber {
     const rowIndex = Math.floor(y * rows);
 
     // X 좌표로 왼쪽/오른쪽 결정
-    const colIndex = x < 0.5 ? 0 : 1;
+    const colIndex = Math.round(x);
 
     // 최종 선택지 번호 계산
     const answer = rowIndex * 2 + colIndex + 1;
 
     // 실제 선택지 범위를 벗어나지 않도록 보정
     return Math.min(answer, quizLen);
-    // return (
-    //   Math.round(
-    //     parseFloat(positionX) + Math.floor(parseFloat(positionY) * Math.ceil(quizLen / 2))
-    //   ) * 2
-    // );
-    // if (parseFloat(positionY) < 0.5) {
-    //   return parseFloat(positionX) < 0.5 ? 1 : 2;
-    // }
-    // return parseFloat(positionX) < 0.5 ? 3 : 4;
   }
 }

BE/src/game/service/game.room.service.ts

@@ -16,7 +16,7 @@ import { TraceClass } from '../../common/interceptor/SocketEventLoggerIntercepto
 @Injectable()
 export class GameRoomService {
   private readonly logger = new Logger(GameRoomService.name);
-  private readonly PLAYER_GRACE_PERIOD = 10; // 10초
+  private readonly INACTIVE_THRESHOLD = 30 * 60 * 1000; // 30분 30 * 60 * 1000;
 
   constructor(
     @InjectRedis() private readonly redis: Redis,
@@ -213,7 +213,7 @@ export class GameRoomService {
       disconnected: '1',
       disconnectedAt: Date.now().toString()
     });
-    pipeline.expire(REDIS_KEY.PLAYER(clientId), this.PLAYER_GRACE_PERIOD);
+    // pipeline.expire(REDIS_KEY.PLAYER(clientId), this.PLAYER_GRACE_PERIOD);
 
     await pipeline.exec();
 
@@ -231,7 +231,7 @@ export class GameRoomService {
     const remainingPlayers = await this.redis.scard(roomPlayersKey);
 
     // 4. 플레이어 관련 모든 키에 TTL 설정
-    await this.setTTLForPlayerKeys(clientId);
+    // await this.setTTLForPlayerKeys(clientId);
 
     if (remainingPlayers === 0) {
       // 마지막 플레이어가 나간 경우
@@ -256,24 +256,24 @@ export class GameRoomService {
   /**
    * 플레이어 관련 모든 데이터에 TTL 설정
    */
-  private async setTTLForPlayerKeys(clientId: string): Promise<void> {
-    let cursor = '0';
-    const pattern = `Player:${clientId}:*`;
-    const pipeline = this.redis.pipeline();
-
-    do {
-      // SCAN으로 플레이어 관련 키들을 배치로 찾기
-      const [nextCursor, keys] = await this.redis.scan(cursor, 'MATCH', pattern, 'COUNT', 100);
-      cursor = nextCursor;
-
-      // 찾은 모든 키에 TTL 설정
-      for (const key of keys) {
-        pipeline.expire(key, this.PLAYER_GRACE_PERIOD);
-      }
-    } while (cursor !== '0');
-
-    await pipeline.exec();
-  }
+  // private async setTTLForPlayerKeys(clientId: string): Promise<void> {
+  //   let cursor = '0';
+  //   const pattern = `Player:${clientId}:*`;
+  //   const pipeline = this.redis.pipeline();
+  //
+  //   do {
+  //     // SCAN으로 플레이어 관련 키들을 배치로 찾기
+  //     const [nextCursor, keys] = await this.redis.scan(cursor, 'MATCH', pattern, 'COUNT', 100);
+  //     cursor = nextCursor;
+  //
+  //     // 찾은 모든 키에 TTL 설정
+  //     for (const key of keys) {
+  //       pipeline.expire(key, this.PLAYER_GRACE_PERIOD);
+  //     }
+  //   } while (cursor !== '0');
+  //
+  //   await pipeline.exec();
+  // }
 
   async kickRoom(kickRoomDto: KickRoomDto, clientId: string) {
     const { gameId, kickPlayerId } = kickRoomDto;