Merge branch 'main' into feat-graph-node-mem0

Author: yuluo-yx

community/memories/spring-ai-alibaba-starter-memory-mem0/src/main/java/com/alibaba/cloud/ai/memory/mem0/core/Mem0MemoryStore.java

@@ -38,8 +38,7 @@
 
 /**
  * @author miaoyumeng
- * @date 2025/06/24 14:28
- * @description TODO
+ * @since 2025/06/24 14:28
  */
 public class Mem0MemoryStore implements InitializingBean, VectorStore {
 

pom.xml

@@ -229,7 +229,7 @@
 
         <!-- Nacos -->
         <nacos2.version>2.5.1</nacos2.version>
-        <nacos3.version>3.0.2</nacos3.version>
+        <nacos3.version>3.0.3</nacos3.version>
         <nacos-client-mse-extension.version>1.0.4</nacos-client-mse-extension.version>
         <spring-alibaba-nacos-config.version>2023.0.1.3</spring-alibaba-nacos-config.version>
 

spring-ai-alibaba-deepresearch/pom.xml

@@ -5,7 +5,7 @@
     <modelVersion>4.0.0</modelVersion>
     <groupId>com.alibaba.cloud.ai</groupId>
     <artifactId>spring-ai-alibaba-deepresearch</artifactId>
-    <version>0.1.0</version>
+    <version>0.1.0-SNAPSHOT</version>
     <name>Spring AI Alibaba Deep Research</name>
 
     <properties>

spring-ai-alibaba-deepresearch/src/main/java/com/alibaba/cloud/ai/example/deepresearch/serializer/DeepResearchStateSerializer.java

@@ -20,6 +20,7 @@
 import com.alibaba.cloud.ai.graph.state.AgentStateFactory;
 import com.fasterxml.jackson.annotation.JsonAutoDetect;
 import com.fasterxml.jackson.annotation.PropertyAccessor;
+import com.fasterxml.jackson.core.type.TypeReference;
 import com.fasterxml.jackson.databind.MapperFeature;
 import com.fasterxml.jackson.databind.ObjectMapper;
 import com.fasterxml.jackson.databind.json.JsonMapper;
@@ -31,6 +32,7 @@
 import java.io.ObjectInput;
 import java.io.ObjectOutput;
 import java.nio.charset.StandardCharsets;
+import java.util.Map;
 
 public class DeepResearchStateSerializer extends PlainTextStateSerializer {
 
@@ -73,8 +75,8 @@ public String contentType() {
 	}
 
 	@Override
-	public void write(OverAllState object, ObjectOutput out) throws IOException {
-		String json = objectMapper.writeValueAsString(object);
+	public void writeData(Map<String, Object> data, ObjectOutput out) throws IOException {
+		String json = objectMapper.writeValueAsString(data);
 
 		// 这边修改的原因在于，序列化长度限制的问题，当数据量过大时，可能会导致序列化失败。修改`DeepResearchStateSerializer`使用字节数组方式避免UTF长度限制
 		byte[] jsonBytes = json.getBytes(StandardCharsets.UTF_8);
@@ -83,14 +85,15 @@ public void write(OverAllState object, ObjectOutput out) throws IOException {
 	}
 
 	@Override
-	public OverAllState read(ObjectInput in) throws IOException {
+	public Map<String, Object> readData(ObjectInput in) throws IOException {
 
 		// 这边修改的原因在于，序列化长度限制的问题，当数据量过大时，可能会导致序列化失败。修改`DeepResearchStateSerializer`使用字节数组方式避免UTF长度限制
 		int length = in.readInt();
 		byte[] jsonBytes = new byte[length];
 		in.readFully(jsonBytes);
 		String json = new String(jsonBytes, StandardCharsets.UTF_8);
-		return objectMapper.readValue(json, OverAllState.class);
+		return objectMapper.readValue(json, new TypeReference<Map<String, Object>>() {
+		});
 	}
 
 }

spring-ai-alibaba-graph-core/pom.xml

@@ -43,6 +43,11 @@
     </properties>
 
     <dependencies>
+        <dependency>
+            <groupId>io.projectreactor</groupId>
+            <artifactId>reactor-core</artifactId>
+        </dependency>
+
         <dependency>
             <groupId>io.github.a2asdk</groupId>
             <artifactId>a2a-java-reference-server</artifactId>

spring-ai-alibaba-graph-core/src/main/java/com/alibaba/cloud/ai/graph/CompileConfig.java

@@ -39,6 +39,10 @@
  */
 public class CompileConfig {
 
+	// ================================================================================================================
+	// Configuration Fields
+	// ================================================================================================================
+
 	private SaverConfig saverConfig = new SaverConfig().register(SaverEnum.MEMORY.getValue(), new MemorySaver());
 
 	private Deque<GraphLifecycleListener> lifecycleListeners = new LinkedBlockingDeque<>(25);
@@ -56,6 +60,10 @@ public class CompileConfig {
 
 	private Store store;
 
+	// ================================================================================================================
+	// Getter Methods
+	// ================================================================================================================
+
 	/**
 	 * Returns the current state of the thread release flag.
 	 *
@@ -142,6 +150,10 @@ public void setStore(Store store) {
 		this.store = store;
 	}
 
+	// ================================================================================================================
+	// Builder Methods
+	// ================================================================================================================
+
 	/**
 	 * Returns a new instance of the builder with default configuration settings.
 	 * @return A new Builder instance.
@@ -297,6 +309,10 @@ public CompileConfig build() {
 
 	}
 
+	// ================================================================================================================
+	// Constructors
+	// ================================================================================================================
+
 	/**
 	 * Default constructor used internally to create a new configuration with default
 	 * settings. Made private to ensure all instances are created through the builder