#199 feat: 채팅 전송 API 추가

Kek-i · Apr 12, 2023 · 58bca91 · 58bca91
1 parent c5599cd
commit 58bca91
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 0 deletions.
diff --git a/src/main/java/com/codepatissier/keki/chat/controller/ChatController.java b/src/main/java/com/codepatissier/keki/chat/controller/ChatController.java
@@ -26,6 +26,11 @@ public void enter(ChatMessage message) throws BaseException {
         chatService.enter(message);
     }
 
+    // 채팅 전송
+    @MessageMapping(value = "/chats/message")
+    public void message(ChatMessage message) throws BaseException{
+        chatService.message(message);
+    }
 
 
 }
diff --git a/src/main/java/com/codepatissier/keki/chat/service/ChatService.java b/src/main/java/com/codepatissier/keki/chat/service/ChatService.java
@@ -22,4 +22,9 @@ public void enter(ChatMessage message) throws BaseException {
         message.setMessage(user.getNickname() + "님이 채팅방에 참여하였습니다.");
         template.convertAndSend("/subscribe/rooms/" + message.getChatRoomId(), message.getMessage());
     }
+
+    public void message(ChatMessage message) throws BaseException {
+        User user = userRepository.findByUserIdxAndStatusEquals(message.getUserIdx(), ACTIVE_STATUS).orElseThrow(() -> new BaseException(INVALID_USER_IDX));
+        template.convertAndSend("/sub/message/" + message.getChatRoomId(), message);
+    }
 }