refactor(memory): move _build_query method to base class and simplify logic

- Remove MAX_QUERY_CHARS constant from adbpg and reme_light managers
- Delete old _build_query implementation with character limiting logic
- Add new simplified _build_query in base_memory_manager returning latest user message only
- Update tests to verify the new query building behavior with user messages
- Remove redundant query building implementations from child classes

Author: jinliyl

src/qwenpaw/agents/memory/adbpg_memory_manager.py

@@ -27,7 +27,6 @@
 from ...exceptions import ConfigurationException as ConfigurationError
 
 logger = logging.getLogger(__name__)
-MAX_QUERY_CHARS = 50
 
 
 @memory_registry.register("adbpg")
@@ -337,23 +336,6 @@ async def memory_search(
     # Private helpers
     # ------------------------------------------------------------------
 
-    @staticmethod
-    def _build_query(messages: list[Msg]) -> str:
-        parts = []
-        total = 0
-        for msg in reversed(messages):
-            if msg.role not in {"user", "assistant"}:
-                continue
-            text = (msg.get_text_content() or "").strip()
-            if not text:
-                continue
-            remaining = MAX_QUERY_CHARS - total - (1 if parts else 0)
-            if remaining <= 0:
-                break
-            parts.insert(0, text[-remaining:])
-            total += min(len(text), remaining) + (1 if len(parts) > 1 else 0)
-        return " ".join(parts).strip()
-
     @staticmethod
     def _tool_chunk_text(chunk: ToolChunk) -> str:
         parts = []

src/qwenpaw/agents/memory/base_memory_manager.py

@@ -287,6 +287,16 @@ async def auto_memory_search(
         """
         return None
 
+    @staticmethod
+    def _build_query(messages: list[Msg]) -> str:
+        for msg in reversed(messages):
+            if msg.role != "user":
+                continue
+            text = (msg.get_text_content() or "").strip()
+            if text:
+                return text
+        return ""
+
     async def auto_memory(
         self,
         all_messages: list[Msg],

src/qwenpaw/agents/memory/reme_light_memory_manager.py

@@ -28,7 +28,6 @@
 
 logger = logging.getLogger(__name__)
 
-MAX_QUERY_CHARS = 50
 NO_MEMORY_RESULTS = "(no memory results)"
 INBOX_RESULT_JOB_NAMES = {"auto_memory", "auto_dream", "auto_resource"}
 INBOX_RESULT_HOOK_KEY = "qwenpaw_memory_result_hook"
@@ -471,20 +470,3 @@ async def dream(self, **kwargs: Any) -> None:
         )
         if response is not None and not response.success:
             raise RuntimeError(str(response.answer))
-
-    @staticmethod
-    def _build_query(messages: list[Msg]) -> str:
-        parts = []
-        total = 0
-        for msg in reversed(messages):
-            if msg.role not in {"user", "assistant"}:
-                continue
-            text = (msg.get_text_content() or "").strip()
-            if not text:
-                continue
-            remaining = MAX_QUERY_CHARS - total - (1 if parts else 0)
-            if remaining <= 0:
-                break
-            parts.insert(0, text[-remaining:])
-            total += min(len(text), remaining) + (1 if len(parts) > 1 else 0)
-        return " ".join(parts).strip()

tests/unit/agents/memory/test_base_memory_manager.py

@@ -193,6 +193,42 @@ async def test_worker_task_created(self, manager):
 class TestAutoMemorySearchSanitization:
     """P1: auto_memory input should exclude auto-search blocks only."""
 
+    def test_build_query_uses_latest_user_message_only(self, manager):
+        messages = [
+            Msg(
+                name="user",
+                role="user",
+                content=[TextBlock(text="NVDA 股价")],
+            ),
+            Msg(
+                name="assistant",
+                role="assistant",
+                content=[
+                    TextBlock(
+                        text=("达股价查询：NVDA $195.93 (+0.56%)，" "市值 $4.746T"),
+                    ),
+                ],
+            ),
+            Msg(
+                name="user",
+                role="user",
+                content=[TextBlock(text="台积电股价")],
+            ),
+        ]
+
+        assert manager._build_query(messages) == "台积电股价"
+
+    def test_build_query_returns_empty_without_user_text(self, manager):
+        messages = [
+            Msg(
+                name="assistant",
+                role="assistant",
+                content=[TextBlock(text="memory noise")],
+            ),
+        ]
+
+        assert manager._build_query(messages) == ""
+
     def test_builds_mock_assistant_msg_with_configured_estimated_usage(
         self,
         manager,