MessageType 추가

Author: bumooo

api/src/main/java/com/mbtips/common/enums/WebSocketMessageType.java

@@ -0,0 +1,7 @@
+package com.mbtips.common.enums;
+
+public enum WebSocketMessageType {
+    SUCCESS,
+    DUPLICATE_NICKNAME
+
+}

api/src/main/java/com/mbtips/common/handler/WebSocketChatHandler.java

@@ -2,6 +2,7 @@
 
 import com.fasterxml.jackson.databind.ObjectMapper;
 import com.mbtips.common.constant.Constant;
+import com.mbtips.common.enums.WebSocketMessageType;
 import com.mbtips.common.exception.CustomException;
 import com.mbtips.domain.openChat.exception.OpenChatException;
 import com.mbtips.openChat.application.dto.OpenChatDto;
@@ -52,9 +53,12 @@ public void afterConnectionEstablished(WebSocketSession session) throws IOExcept
         Map<String, String> queryParamMap = this.parseQueryParam(query);
         log.info("queryParamMap : {}", queryParamMap);
         long openChatId = Long.parseLong(queryParamMap.get(OPEN_CHAT_ID));
-        log.info("openChatId : {}", openChatId);
         if (this.checkNickname(openChatId, queryParamMap.get(NICKNAME))) {
-            OpenChatMessageDto openChatMessageDto = new OpenChatMessageDto(2, null, OpenChatException.DUPLICATED_NICKNAME.getMessage(), openChatId);
+            OpenChatMessageDto openChatMessageDto = OpenChatMessageDto.builder()
+                    .type(WebSocketMessageType.DUPLICATE_NICKNAME)
+                    .message(OpenChatException.DUPLICATED_NICKNAME.getMessage())
+                    .openChatId(openChatId)
+                    .build();
             session.sendMessage(new TextMessage(objectMapper.writeValueAsString(openChatMessageDto)));
             throw new CustomException(OpenChatException.DUPLICATED_NICKNAME);
         }
@@ -71,7 +75,6 @@ public void afterConnectionEstablished(WebSocketSession session) throws IOExcept
     @Override
     public void handleMessage(WebSocketSession session, WebSocketMessage<?> message) throws Exception {
         String payload = (String) message.getPayload();
-        log.info("message.payload : {}", payload);
         OpenChatMessageDto openChatMessageDto = objectMapper.readValue(payload, OpenChatMessageDto.class);
         log.info("openChatMessageDto.toString() : {}", openChatMessageDto.toString());
         Set<WebSocketSession> webSocketSessions = webSocketSessionMap.get(openChatMessageDto.openChatId());
@@ -117,7 +120,6 @@ public void afterConnectionClosed(WebSocketSession session, CloseStatus status)
     private Map<String, String> parseQueryParam(String query) {
         HashMap<String, String> queryParamMap = new HashMap<>();
         String[] pairs = query.split("&");
-        log.info("parseQueryParam.pairs: {}", Arrays.toString(pairs));
         Arrays.stream(pairs).forEach(pair -> {
             String[] kv = pair.split("=", 2);
             if (kv.length == 2) {

api/src/main/java/com/mbtips/openChat/application/dto/OpenChatMessageDto.java

@@ -1,7 +1,13 @@
 package com.mbtips.openChat.application.dto;
 
+import com.mbtips.common.enums.WebSocketMessageType;
+import com.mbtips.common.mbtiinfo.MbtiType;
+import lombok.Builder;
+
+@Builder
 public record OpenChatMessageDto (
-        int type,
+        WebSocketMessageType type,
+        MbtiType mbti,
         String nickname,
         String message,
         long openChatId