steven/epq-api
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

IMPL server-side recover message history API

Browse source
This commit is contained in:
Zhongheng Liu 2024-01-02 17:44:24 +02:00
commit fdedd75807
No known key found for this signature in database
2 changed files with 19 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

14
src/main/java/me/imsonmia/epqapi/controller/MessageController.java
View file

@ -1,5 +1,6 @@
package me.imsonmia.epqapi.controller;
import java.time.Instant;
import java.util.ArrayList;
import org.springframework.messaging.handler.annotation.MessageMapping;
@ -24,9 +25,16 @@ public class MessageController {
// Forward message to subscribers of Stomp endpoint
return message;
}
@GetMapping("/chat/history/{from}")
public ArrayList<Message> getMessagesFromTimestamp(@PathVariable(value = "from") Long fromTimestamp) {
return new ArrayList<Message>();
@GetMapping("/api/v1/chat/history/{from}")
public ArrayList<Message> getMessagesFromTimestamp(@PathVariable(value = "from") long fromTimestamp) {
ArrayList<Message> messages = new ArrayList<>();
Instant targetInstant = Instant.ofEpochMilli(fromTimestamp);
for (Message msg : repository.findAll()) {
Instant t = Instant.ofEpochMilli(msg.getTimestamp());
if (t.isBefore(targetInstant)) {continue;}
messages.add(msg);
}
return messages;
}
// @GetMapping("/msg/{id}")
// public ChatMessage getMessageById(@PathVariable(value = "id") Long id) {

8
src/main/java/me/imsonmia/epqapi/model/Message.java
View file

@ -1,5 +1,6 @@
package me.imsonmia.epqapi.model;
import jakarta.persistence.Entity;
import jakarta.persistence.GeneratedValue;
import jakarta.persistence.Id;
@ -14,6 +15,7 @@ public class Message {
private String from;
private String to;
private String content;
private Long timestamp;
public Long getId() {
return id;
}
@ -35,4 +37,10 @@ public class Message {
public void setContent(String content) {
this.content = content;
}
public Long getTimestamp() {
return timestamp;
}
public void setTimestamp(Long timestamp) {
this.timestamp = timestamp;
}
}