重构: 需要进一步抽象出一个Conversation的接口

Author: workwind

src/main/java/com/xiaozhi/dialogue/llm/memory/ChatMemoryStore.java

@@ -10,6 +10,7 @@
 
 /**
  * 聊天记忆接口
+ * TODO 需要进一步抽象出一个Conversation的接口
  * 负责管理聊天历史记录
  */
 public interface ChatMemoryStore {

src/main/java/com/xiaozhi/dialogue/llm/memory/DatabaseChatMemory.java

@@ -33,7 +33,7 @@ public class DatabaseChatMemory  {
     private TtsServiceFactory ttsService;
 
     public void addMessage(String deviceId, String sessionId, String sender, String content, Integer roleId, String messageType, String audioPath) {
-        // TODO 异步虚拟线程处理持久化。
+        // 异步虚拟线程处理持久化。
         Thread.startVirtualThread(() -> {
             try {
                 SysMessage message = new SysMessage();

src/main/java/com/xiaozhi/dialogue/llm/memory/MessageWindowChatMemory.java

@@ -50,41 +50,6 @@ public void clearMessages(String deviceId) {
         systemMessageCache.keySet().removeIf(key -> key.startsWith(deviceId + ":"));
     }
 
-    // todo 在get时处理缩容。
-    private List<Message> process(List<Message> memoryMessages, List<Message> newMessages) {
-        List<Message> processedMessages = new ArrayList<>();
-
-        Set<Message> memoryMessagesSet = new HashSet<>(memoryMessages);
-        boolean hasNewSystemMessage = newMessages.stream()
-                .filter(SystemMessage.class::isInstance)
-                .anyMatch(message -> !memoryMessagesSet.contains(message));
-
-        memoryMessages.stream()
-                .filter(message -> !(hasNewSystemMessage && message instanceof SystemMessage))
-                .forEach(processedMessages::add);
-
-        processedMessages.addAll(newMessages);
-
-        if (processedMessages.size() <= this.maxMessages) {
-            return processedMessages;
-        }
-
-        int messagesToRemove = processedMessages.size() - this.maxMessages;
-
-        List<Message> trimmedMessages = new ArrayList<>();
-        int removed = 0;
-        for (Message message : processedMessages) {
-            if (message instanceof SystemMessage || removed >= messagesToRemove) {
-                trimmedMessages.add(message);
-            }
-            else {
-                removed++;
-            }
-        }
-
-        return trimmedMessages;
-    }
-
     @Override
     public String getSystemMessage(String deviceId, Integer roleId) {