Merge pull request #240 from NewCodes7/fix-be-multi-process

[BE] fix#239 멀티프로세스로 실행시 endQuizTime이 발생 안 되는 이슈 해결

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

@@ -7,6 +7,7 @@ export const REDIS_KEY = {
   ROOM_CURRENT_QUIZ: (gameId: string) => `Room:${gameId}:CurrentQuiz`,
   ROOM_TIMER: (gameId: string) => `Room:${gameId}:Timer`,
   ROOM_QUIZ_SET: (gameId: string) => `Room:${gameId}:QuizSet`,
+  ROOM_SCORING_COUNT: (gameId: string) => `Room:${gameId}:ScoringCount`,
   PLAYER: (playerId: string) => `Player:${playerId}`,
   QUIZSET_ID: (quizSetId: number) => `Quizset:${quizSetId}`,
 

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

@@ -8,8 +8,6 @@ import SocketEvents from '../../../common/constants/socket-events';
 
 @Injectable()
 export class ScoringSubscriber extends RedisSubscriber {
-  private scoringMap = new Map<string, number>();
-
   constructor(@InjectRedis() redis: Redis) {
     super(redis);
   }
@@ -25,14 +23,19 @@ export class ScoringSubscriber extends RedisSubscriber {
   }
 
   private async handleScoring(gameId: string, completeClientsCount: number, server: Server) {
-    if (!this.scoringMap.has(gameId)) {
-      this.scoringMap[gameId] = 0;
+    const scoringKey = REDIS_KEY.ROOM_SCORING_COUNT(gameId);
+
+    if (!this.redis.exists(scoringKey)) {
+      this.redis.set(scoringKey, 0);
     }
-    this.scoringMap[gameId] += completeClientsCount;
+    this.redis.incrby(scoringKey, completeClientsCount);
 
     const playersCount = await this.redis.scard(REDIS_KEY.ROOM_PLAYERS(gameId));
-    if (this.scoringMap[gameId] >= playersCount) {
+    const scoringCount = await this.redis.get(scoringKey);
+
+    if (parseInt(scoringCount) >= playersCount) {
       await this.completeScoring(gameId, server);
+      this.redis.set(scoringKey, 0);
     }
   }
 

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

@@ -14,7 +14,6 @@ import { RedisSubscriberService } from '../redis/redis-subscriber.service';
 @Injectable()
 export class GameService {
   private readonly logger = new Logger(GameService.name);
-  private scoringMap = new Map<string, number>();
 
   constructor(
     @InjectRedis() private readonly redis: Redis,