Feat: get chat list #102

Hanaemong · Jul 7, 2024 · 2efe4d8 · 2efe4d8
1 parent 57e2c50
commit 2efe4d8
Show file tree

Hide file tree

Showing 4 changed files with 3 additions and 6 deletions.
diff --git a/src/main/java/com/hana/hanalink/chat/controller/ChatController.java b/src/main/java/com/hana/hanalink/chat/controller/ChatController.java
@@ -21,7 +21,7 @@ public class ChatController {
      */
     @MessageMapping("/send")
     public Mono<Void> message(@Payload ChatDto chatDto) {
-        simpMessageSendingOperations.convertAndSend("topic" + chatDto.getRoomId(), chatDto);
+        simpMessageSendingOperations.convertAndSend("/topic/" + chatDto.getRoomId(), chatDto);
         return chatService.saveChat(chatDto.toEntity()).then();
     }
 

diff --git a/src/main/java/com/hana/hanalink/chat/controller/ChatRestController.java b/src/main/java/com/hana/hanalink/chat/controller/ChatRestController.java
@@ -9,9 +9,8 @@
 import org.springframework.web.bind.annotation.RestController;
 import reactor.core.publisher.Flux;
 
-
 @RestController
-@RequestMapping("/chat")
+@RequestMapping("/api/v1/chat")
 @RequiredArgsConstructor
 public class ChatRestController {
     private final ChatService chatService;
@@ -20,4 +19,4 @@ public class ChatRestController {
     public Flux<Chat> getChatsByRoomId(@PathVariable String roomId) {
         return chatService.getChatsByRoomId(roomId);
     }
-}
+}
diff --git a/src/main/java/com/hana/hanalink/chat/repository/ChatRepository.java b/src/main/java/com/hana/hanalink/chat/repository/ChatRepository.java
@@ -9,5 +9,4 @@
 @Repository
 public interface ChatRepository extends ReactiveMongoRepository<Chat, String> {
     Flux<Chat> findByRoomId(String roomId);
-
 }
diff --git a/src/main/java/com/hana/hanalink/chat/service/ChatService.java b/src/main/java/com/hana/hanalink/chat/service/ChatService.java
@@ -24,5 +24,4 @@ public Mono<Chat> saveChat(Chat chat) {
     public Flux<Chat> getChatsByRoomId(String roomId) {
         return chatRepository.findByRoomId(roomId);
     }
-
 }
-Original file line number
+Diff line change
@@ Expand Up / @@ -24,5 +24,4 @@ public Mono<Chat> saveChat(Chat chat) { @@
         public Flux<Chat> getChatsByRoomId(String roomId) {
             return chatRepository.findByRoomId(roomId);
         }
     }