From fcf2cb5b85dd86d3692076ab24468c5577f4bce6 Mon Sep 17 00:00:00 2001
From: jinddings <pjm2476@gmail.com>
Date: Tue, 3 Dec 2024 18:01:42 +0900
Subject: [PATCH] =?UTF-8?q?=F0=9F=94=A7=20fix=20:=20=EC=9B=B9=EC=86=8C?=
 =?UTF-8?q?=EC=BC=93=20=EC=97=B0=EA=B2=B0=20=EC=B4=88=EA=B3=BC=EC=8B=9C=20?=
 =?UTF-8?q?error=20=EB=B0=9C=EC=83=9D?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 BE/src/common/websocket/base-socket.domain-service.ts | 9 ++++++++-
 1 file changed, 8 insertions(+), 1 deletion(-)

diff --git a/BE/src/common/websocket/base-socket.domain-service.ts b/BE/src/common/websocket/base-socket.domain-service.ts
index 527bf9ff..2b3f9f00 100644
--- a/BE/src/common/websocket/base-socket.domain-service.ts
+++ b/BE/src/common/websocket/base-socket.domain-service.ts
@@ -45,11 +45,18 @@ export class BaseSocketDomainService implements OnModuleInit {
 
       if (data.length < 2) {
         const json = JSON.parse(data[0]);
-        if (json.body)
+        if (json.body) {
           this.logger.log(
             `한국투자증권 웹소켓 연결: ${json.body.msg1}`,
             json.header.tr_id,
           );
+
+          if (json.body.msg1 === 'MAX SUBSCRIBE OVER') {
+            throw new InternalServerErrorException(
+              '한국투자증권 웹소켓 연결: MAX SUBSCRIBE OVER',
+            );
+          }
+        }
         if (json.header.tr_id === 'PINGPONG')
           this.socket.pong(JSON.stringify(json));
         return;