feat: process remake and write dialect

Signed-off-by: potato <[email protected]>

Author: juntae6942

memory/repository/spring-ai-model-chat-memory-repository-jdbc/src/main/java/org/springframework/ai/chat/memory/repository/jdbc/MysqlChatMemoryRepositoryDialect.java

@@ -44,4 +44,9 @@ public String getDeleteMessagesSql() {
 		return "DELETE FROM SPRING_AI_CHAT_MEMORY WHERE conversation_id = ?";
 	}
 
+	@Override
+	public String getDeleteMessageSql() {
+		return "DELETE FROM SPRING_AI_CHAT_MEMORY WHERE conversation_id = ? AND content = ? AND type = ?";
+	}
+
 }

spring-ai-model/src/main/java/org/springframework/ai/chat/memory/MessageWindowChatMemory.java

@@ -83,18 +83,16 @@ public void clear(String conversationId) {
 	private MessageChanges process(List<Message> memoryMessages, List<Message> newMessages) {
 		Set<Message> originalMessageSet = new LinkedHashSet<>(memoryMessages);
 		List<Message> uniqueNewMessages = newMessages.stream()
-				.filter(msg -> !originalMessageSet.contains(msg))
-				.toList();
-		boolean hasNewSystemMessage = uniqueNewMessages.stream()
-				.anyMatch(SystemMessage.class::isInstance);
+			.filter(msg -> !originalMessageSet.contains(msg))
+			.toList();
+		boolean hasNewSystemMessage = uniqueNewMessages.stream().anyMatch(SystemMessage.class::isInstance);
 
 		List<Message> finalMessages = new ArrayList<>();
-		if(hasNewSystemMessage) {
-			memoryMessages.stream()
-					.filter(msg -> !(msg instanceof SystemMessage))
-					.forEach(finalMessages::add);
+		if (hasNewSystemMessage) {
+			memoryMessages.stream().filter(msg -> !(msg instanceof SystemMessage)).forEach(finalMessages::add);
 			finalMessages.addAll(uniqueNewMessages);
-		} else {
+		}
+		else {
 			finalMessages.addAll(memoryMessages);
 			finalMessages.addAll(uniqueNewMessages);
 		}
@@ -106,7 +104,8 @@ private MessageChanges process(List<Message> memoryMessages, List<Message> newMe
 			for (Message message : finalMessages) {
 				if (message instanceof SystemMessage || removed >= messagesToRemove) {
 					trimmedMessages.add(message);
-				} else {
+				}
+				else {
 					removed++;
 				}
 			}
@@ -115,25 +114,24 @@ private MessageChanges process(List<Message> memoryMessages, List<Message> newMe
 
 		Set<Message> finalMessageSet = new LinkedHashSet<>(finalMessages);
 
-		List<Message> toDelete = originalMessageSet.stream()
-				.filter(m -> !finalMessageSet.contains(m))
-				.toList();
+		List<Message> toDelete = originalMessageSet.stream().filter(m -> !finalMessageSet.contains(m)).toList();
 
-		List<Message> toAdd = finalMessageSet.stream()
-				.filter(m -> !originalMessageSet.contains(m))
-				.toList();
+		List<Message> toAdd = finalMessageSet.stream().filter(m -> !originalMessageSet.contains(m)).toList();
 
 		return new MessageChanges(toDelete, toAdd);
 	}
 
 	private static class MessageChanges {
+
 		final List<Message> toDelete;
+
 		final List<Message> toAdd;
 
 		MessageChanges(List<Message> toDelete, List<Message> toAdd) {
 			this.toDelete = toDelete;
 			this.toAdd = toAdd;
 		}
+
 	}
 
 	public static Builder builder() {