[BE] feat#205 실제 퀴즈셋 가져오기

BE/src/common/constants/redis-key.constant.ts

@@ -8,6 +8,7 @@ export const REDIS_KEY = {
   ROOM_TIMER: (gameId: string) => `Room:${gameId}:Timer`,
   ROOM_QUIZ_SET: (gameId: string) => `Room:${gameId}:QuizSet`,
   PLAYER: (playerId: string) => `Player:${playerId}`,
+  QUIZSET_ID: (quizSetId: number) => `Quizset:${quizSetId}`,
 
   ACTIVE_ROOMS: 'ActiveRooms' // 활성화된 방 목록을 저장하는 Set (핀번호 중복 체크하기 위함)
 };

BE/src/game/game.module.ts

@@ -3,12 +3,20 @@ import { GameGateway } from './game.gateway';
 import { GameService } from './service/game.service';
 import { RedisModule } from '@nestjs-modules/ioredis';
 import { GameValidator } from './validations/game.validator';
-import { HttpModule } from '@nestjs/axios';
 import { GameChatService } from './service/game.chat.service';
 import { GameRoomService } from './service/game.room.service';
+import { QuizModule } from '../quiz/quiz.module';
+import { QuizCacheService } from './service/quiz.cache.service';
 
 @Module({
-  imports: [RedisModule, HttpModule],
-  providers: [GameGateway, GameService, GameChatService, GameRoomService, GameValidator]
+  imports: [RedisModule, QuizModule],
+  providers: [
+    GameGateway,
+    GameService,
+    GameChatService,
+    GameRoomService,
+    GameValidator,
+    QuizCacheService
+  ]
 })
 export class GameModule {}

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

@@ -32,8 +32,10 @@ export class GameRoomService {
       isPublicGame: gameConfig.isPublicGame ? '1' : '0',
       isWaiting: '1',
       lastActivityAt: new Date().getTime().toString(),
-      quizSetId: '0',
-      quizCount: '2'
+      quizSetId: '-1', // 미설정시 기본퀴즈를 진행, -1은 기본 퀴즈셋
+      quizCount: '2',
+      quizSetTitle: '기본 퀴즈셋'
+      //todo : 기본 퀴즈셋 title 설정
     });
 
     await this.redis.sadd(REDIS_KEY.ACTIVE_ROOMS, roomId);

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

@@ -7,8 +7,8 @@ import { GameValidator } from '../validations/game.validator';
 import SocketEvents from '../../common/constants/socket-events';
 import { StartGameDto } from '../dto/start-game.dto';
 import { Server } from 'socket.io';
-import { HttpService } from '@nestjs/axios';
 import { mockQuizData } from '../../../test/mocks/quiz-data.mock';
+import { QuizCacheService } from './quiz.cache.service';
 
 @Injectable()
 export class GameService {
@@ -17,8 +17,8 @@ export class GameService {
 
   constructor(
     @InjectRedis() private readonly redis: Redis,
-    private readonly httpService: HttpService,
-    private readonly gameValidator: GameValidator
+    private readonly gameValidator: GameValidator,
+    private readonly quizCacheService: QuizCacheService
   ) {}
 
   async updatePosition(updatePosition: UpdatePositionDto, clientId: string) {
@@ -49,14 +49,19 @@ export class GameService {
 
     this.gameValidator.validatePlayerIsHost(SocketEvents.START_GAME, room, clientId);
 
-    // const getQuizsetURL = `http://localhost:3000/api/quizset/${room.quizSetId}`;
-    //
-    // // REFACTOR: get 대신 Promise를 반환하는 axiosRef를 사용했으나 더 나은 방식이 있는지 확인
-    // const quiz-set = await this.httpService.axiosRef({
-    //   url: getQuizsetURL,
-    //   method: 'GET'
-    // });
-    const quizset = mockQuizData;
+    /**
+     * 퀴즈셋이 설정되어 있지 않으면 기본 퀴즈셋을 사용
+     */
+    const quizset =
+      room.quizSetId === '-1'
+        ? mockQuizData
+        : await this.quizCacheService.getQuizSet(+room.quizSetId);
+
+    //roomKey에 해당하는 room에 quizSetTitle을 quizset.title로 설정
+    await this.redis.hset(roomKey, {
+      quizSetTitle: quizset.title
+    });
+
     this.gameValidator.validateQuizsetCount(
       SocketEvents.START_GAME,
       parseInt(room.quizCount),

BE/src/game/service/quiz.cache.service.ts

@@ -0,0 +1,79 @@
+import { QuizSetData } from '../../InitDB/InitDB.Service';
+import { Injectable, Logger } from '@nestjs/common';
+import { InjectRedis } from '@nestjs-modules/ioredis';
+import { Redis } from 'ioredis';
+import { QuizService } from '../../quiz/quiz.service';
+import { mockQuizData } from '../../../test/mocks/quiz-data.mock';
+import { REDIS_KEY } from '../../common/constants/redis-key.constant';
+
+@Injectable()
+export class QuizCacheService {
+  private readonly quizCache = new Map<string, any>();
+  private readonly logger = new Logger(QuizCacheService.name);
+  private readonly CACHE_TTL = 1000 * 60 * 30; // 30분
+
+  constructor(
+    @InjectRedis() private readonly redis: Redis,
+    private readonly quizService: QuizService
+  ) {}
+
+  /**
+   * Redis 캐시에서 퀴즈셋 조회
+   */
+  private async getFromRedisCache(quizSetId: number) {
+    const cacheKey = REDIS_KEY.QUIZSET_ID(quizSetId);
+    const cachedData = await this.redis.get(cacheKey);
+
+    if (cachedData) {
+      return JSON.parse(cachedData);
+    }
+    return null;
+  }
+
+  /**
+   * Redis 캐시에 퀴즈셋 저장
+   */
+  private async setToRedisCache(quizSetId: number, data: QuizSetData): Promise<void> {
+    const cacheKey = REDIS_KEY.QUIZSET_ID(quizSetId);
+    await this.redis.set(cacheKey, JSON.stringify(data), 'EX', this.CACHE_TTL);
+  }
+
+  /**
+   * 퀴즈셋 데이터 조회 (캐시 활용)
+   */
+  async getQuizSet(quizSetId: number) {
+    // 1. 로컬 메모리 캐시 확인
+    // const localCached = this.quizCache.get(this.getCacheKey(quizSetId));
+    // if (localCached) {
+    //   this.logger.debug(`Quiz ${quizSetId} found in local cache`);
+    //   return localCached;
+    // }
+
+    // 2. Redis 캐시 확인
+    const redisCached = await this.getFromRedisCache(quizSetId);
+    if (redisCached) {
+      this.logger.debug(`Quiz ${quizSetId} found in Redis cache`);
+      // 로컬 캐시에도 저장
+      // this.quizCache.set(REDIS_KEY.QUIZSET_ID(quizSetId), redisCached);
+      return redisCached;
+    }
+
+    // 3. DB에서 조회
+    const quizData = quizSetId === -1 ? mockQuizData : await this.quizService.findOne(quizSetId);
+
+    // 4. 캐시에 저장
+    await this.setToRedisCache(quizSetId, quizData);
+    this.quizCache.set(REDIS_KEY.QUIZSET_ID(quizSetId), quizData);
+
+    return quizData;
+  }
+
+  /**
+   * 캐시 무효화
+   */
+  async invalidateCache(quizSetId: number): Promise<void> {
+    const cacheKey = REDIS_KEY.QUIZSET_ID(quizSetId);
+    this.quizCache.delete(cacheKey);
+    await this.redis.del(cacheKey);
+  }
+}