From f2d3c948bf424c116c151c45b1a0f6f19e3c24d6 Mon Sep 17 00:00:00 2001 From: Zhongheng Liu Date: Tue, 2 Jan 2024 17:31:58 +0200 Subject: Added message database support in repo Started on history fetching with getMapping --- .../epqapi/controller/MessageController.java | 35 ++++++++++++++++++++++ 1 file changed, 35 insertions(+) create mode 100644 src/main/java/me/imsonmia/epqapi/controller/MessageController.java (limited to 'src/main/java/me/imsonmia/epqapi/controller/MessageController.java') diff --git a/src/main/java/me/imsonmia/epqapi/controller/MessageController.java b/src/main/java/me/imsonmia/epqapi/controller/MessageController.java new file mode 100644 index 0000000..781b6ff --- /dev/null +++ b/src/main/java/me/imsonmia/epqapi/controller/MessageController.java @@ -0,0 +1,35 @@ +package me.imsonmia.epqapi.controller; + +import java.util.ArrayList; + +import org.springframework.messaging.handler.annotation.MessageMapping; +import org.springframework.messaging.handler.annotation.SendTo; +import org.springframework.stereotype.Controller; +import org.springframework.web.bind.annotation.GetMapping; +import org.springframework.web.bind.annotation.PathVariable; + +import me.imsonmia.epqapi.model.Message; +import me.imsonmia.epqapi.repository.MessageRepository; + +@Controller +// @RequestMapping("/api/v1") +public class MessageController { + private MessageRepository repository; + @MessageMapping("/chat") + @SendTo("/sub/chat") + public Message messageHandler(Message message) throws Exception { + // Add message to repository + repository.save(message); + + // Forward message to subscribers of Stomp endpoint + return message; + } + @GetMapping("/chat/history/{from}") + public ArrayList getMessagesFromTimestamp(@PathVariable(value = "from") Long fromTimestamp) { + return new ArrayList(); + } + // @GetMapping("/msg/{id}") + // public ChatMessage getMessageById(@PathVariable(value = "id") Long id) { + // return chatMessageRepository.findById(id).get(); + // } +} -- cgit