fix: 修正第 8 章情景记忆示例未使用 query 参数的问题

content/ch08-long-term-memory.md

@@ -543,6 +543,7 @@ await client.store.put_item(
 Deep Agents 的 Checkpointer 天然支持情景记忆——每次对话都被完整持久化。要让过去的对话变得可搜索，可以包装一个搜索工具：
 
 ```python
+from langchain_core.messages import convert_to_messages
 from langgraph_sdk import get_client
 from langchain.tools import tool, ToolRuntime
 
@@ -560,19 +561,35 @@ def current_user_id(runtime: ToolRuntime) -> str:
 
 @tool
 async def search_past_conversations(query: str, runtime: ToolRuntime) -> str:
-    """搜索过去的对话以获取相关上下文。"""
+    """在该用户过去的对话中查找包含关键词 query 的消息。按字面匹配，找不到时换用同义词、英文或更短的关键词再搜。"""
+    keyword = query.strip().lower()
+    if not keyword:
+        return "query 不能为空，请传入要查找的关键词后重新调用。"
     user_id = current_user_id(runtime)
+    current_thread = runtime.config.get("configurable", {}).get("thread_id")
     threads = await client.threads.search(
         metadata={"user_id": user_id},
         limit=5,
+        sort_by="updated_at",
+        sort_order="desc",
     )
-    results = []
+    hits = []
     for thread in threads:
-        history = await client.threads.get_history(thread_id=thread["thread_id"])
-        results.append(history)
-    return str(results)
+        if thread["thread_id"] == current_thread:
+            continue  # 跳过正在进行的对话
+        state = await client.threads.get_state(thread_id=thread["thread_id"])
+        for message in convert_to_messages(state["values"].get("messages", [])):
+            text = message.text  # 只取文本块的正文，跳过图片、reasoning 等内容块
+            pos = text.lower().find(keyword)
+            if pos >= 0:
+                # 关键词前后各取约 150 个字符，想多保留前后文可以调整这个偏移量
+                start = max(pos - 150, 0)
+                hits.append(f"[{thread['thread_id']}] {message.type}: {text[start:start + 300]}")
+    return "\n".join(hits[:10]) or f"没有找到包含“{query}”的过去对话。"
 ```
 
+`threads.search()` 只能按元数据、状态等条件筛选线程，不接受文本查询，所以这里在客户端按关键词匹配消息正文。结果只保留前 10 条，每条以关键词为中心截取 300 个字符，避免把大量历史放进上下文。本示例只实现了关键词匹配。
+
 这对执行复杂多步任务的 Agent 尤为有用——比如代码 Agent 可以回溯上次调试过程，直接跳到可能的根因。
 
 ### 后台记忆整合（Background Consolidation）
@@ -605,7 +622,7 @@ def current_user_id(runtime: ToolRuntime) -> str:
 
 
 @tool
-async def search_recent_conversations(query: str, runtime: ToolRuntime) -> str:
+async def search_recent_conversations(runtime: ToolRuntime) -> str:
     """读取该用户最近更新的至多 20 个线程中，过去 6 小时更新过的对话。"""
     user_id = current_user_id(runtime)
     since = datetime.now(timezone.utc) - timedelta(hours=6)