[Refactor] 공용 메시지 브로커 구현 및 적용

apps/backend/src/chat/chat.module.ts

@@ -2,6 +2,7 @@ import { Module } from '@nestjs/common';
 import { ChatController } from './chat.controller';
 import { ChatRepositoryMemory } from './repository/chat.memory.repository';
 import { ChatService } from './chat.service';
+import { ReactiveMessageBroker } from '@web08-booquiz/shared';
 
 @Module({
     controllers: [ChatController],
@@ -15,6 +16,10 @@ import { ChatService } from './chat.service';
             provide: 'ChatRepository',
             useClass: ChatRepositoryMemory,
         },
+        {
+            provide: 'Broker',
+            useClass: ReactiveMessageBroker,
+        }
     ],
     exports: [ChatService],
 })

apps/backend/src/chat/chat.service.ts

@@ -1,16 +1,20 @@
 import { Injectable, Inject, NotFoundException } from '@nestjs/common';
 import { ChatRepositoryMemory } from './repository/chat.memory.repository';
-import {ChatMessage} from "@web08-booquiz/shared";
+import { Broker, ChatMessage, MessageWithTopic, Player } from '@web08-booquiz/shared';
 
 @Injectable()
 export class ChatService {
     constructor(
         @Inject('ChatRepository')
         private readonly chatRepository: ChatRepositoryMemory,
-    ) {}
+        @Inject('Broker')
+        private readonly broker: Broker<MessageWithTopic<'chat' | 'leave', ChatMessage>>
+    ) {
+    }
 
     async set(id: string) {
-        this.chatRepository.set(id);
+        await this.chatRepository.set(id);
+        await this.broker.addPublisher(id);
     }
 
     async get(id: string) {
@@ -20,18 +24,51 @@ export class ChatService {
         return this.chatRepository.get(id);
     }
 
-    async add(id: string, chatMessage: ChatMessage) {
-        if (!(await this.chatRepository.has(id))) {
-            throw new NotFoundException('퀴즈 존에 대한 채팅이 존재하지 않습니다.');
-        }
-        return this.chatRepository.add(id, chatMessage);
+    async delete(id: string) {
+        await this.chatRepository.delete(id);
+        await this.broker.removePublisher(id);
     }
 
-    async has(id: string) {
-        return await this.chatRepository.has(id);
+    async join(chatId: string, player: Player, handleSendMessage: (data: ChatMessage) => void) {
+        const unsubscribe = await this.broker.subscribe(chatId, async (message) => {
+            const { topic, data } = message;
+            const { clientId } = data;
+
+            switch (topic) {
+                case 'chat':
+                    handleSendMessage(data);
+                    return this.add(chatId, data);
+                case 'leave':
+                    if (clientId === player.id) {
+                        return unsubscribe();
+                    }
+            }
+        });
     }
 
-    async delete(id: string) {
-        return this.chatRepository.delete(id);
+    async send(chatId: string, chatMessage: ChatMessage) {
+        await this.broker.publish(chatId, {
+            topic: 'chat',
+            data: chatMessage,
+        });
+    }
+
+    async leave(chatId: string, clientId: string) {
+        await this.broker.publish(chatId, {
+            topic: 'leave',
+            data: {
+                clientId,
+                nickname: '',
+                message: '',
+            },
+        })
+    }
+
+    private async add(id: string, chatMessage: ChatMessage) {
+        if (!(await this.chatRepository.has(id))) {
+            throw new NotFoundException('퀴즈 존에 대한 채팅이 존재하지 않습니다.');
+        }
+
+        await this.chatRepository.add(id, chatMessage);
     }
 }

apps/backend/src/core/SessionWsAdapter.ts

@@ -3,8 +3,12 @@ import { RequestHandler } from 'express';
 import { NestApplication } from '@nestjs/core';
 import { Session } from 'express-session';
 
+export interface SessionWithQuizZone extends Session {
+    quizZoneId?: string;
+}
+
 export interface WebSocketWithSession extends WebSocket {
-    session: Session;
+    session: SessionWithQuizZone;
 }
 
 export class SessionWsAdapter extends WsAdapter {