Merge pull request #85 from boostcampwm-2024/fix/socket

[BE] 소켓 분리 작업 추가

BE/src/websocket/base-socket.service.ts

@@ -6,7 +6,6 @@ import { SocketTokenService } from './socket-token.service';
 @Injectable()
 export abstract class BaseSocketService implements OnModuleInit {
   protected socket: WebSocket;
-  protected abstract tradeHandler: Record<string, (data: string) => void>;
   protected socketConnectionKey: string;
 
   constructor(
@@ -30,11 +29,13 @@ export abstract class BaseSocketService implements OnModuleInit {
           : JSON.stringify(event.data);
       if (data.length < 2) return;
 
-      (this.tradeHandler[data[1]] as (data) => void)(data[3]);
+      const dataList = data[3].split('^');
+      this.handleSocketData(dataList);
     };
   }
 
   protected abstract handleSocketOpen(): void;
+  protected abstract handleSocketData(dataList): void;
 
   protected registerCode(trId: string, trKey: string) {
     this.socket.send(

BE/src/websocket/stock-index-socket.service.ts

@@ -4,10 +4,6 @@ import { BaseSocketService } from './base-socket.service';
 
 @Injectable()
 export class StockIndexSocketService extends BaseSocketService {
-  protected tradeHandler = {
-    H0UPCNT0: this.handleStockIndexValue.bind(this),
-  };
-
   private STOCK_CODE = {
     '0001': 'KOSPI',
     '1001': 'KOSDAQ',
@@ -22,15 +18,14 @@ export class StockIndexSocketService extends BaseSocketService {
     this.registerCode('H0UPCNT0', '3003'); // KSQ150
   }
 
-  private handleStockIndexValue(responseData: string) {
-    const responseList = responseData.split('^');
+  protected handleSocketData(dataList: string[]) {
     this.socketGateway.sendStockIndexValueToClient(
-      this.STOCK_CODE[responseList[0]],
+      this.STOCK_CODE[dataList[0]],
       new StockIndexValueElementDto(
-        responseList[2],
-        responseList[4],
-        responseList[9],
-        responseList[3],
+        dataList[2],
+        dataList[4],
+        dataList[9],
+        dataList[3],
       ),
     );
   }