Tweak some available fields

Author: abrookins

README.md

@@ -270,8 +270,8 @@ python -m pytest
 ```
 
 ## Known Issues
-- The MCP server from the Python MCP SDK often refuses to shut down with Control-C if it's connected to a client
 - All background tasks run as async coroutines in the same process as the REST API server, using Starlette's `BackgroundTask`
+- ~~The MCP server from the Python MCP SDK often refuses to shut down with Control-C if it's connected to a client~~
 
 ### Contributing
 1. Fork the repository

agent_memory_server/long_term_memory.py

@@ -196,26 +196,32 @@ async def search_long_term_memories(
     results = []
 
     for doc in search_result.docs:
-        topics = safe_get(doc, "topics", [])
-        if isinstance(topics, str):
-            topics: list[str] = topics.split(",")  # type: ignore
-
-        entities = safe_get(doc, "entities", [])
-        if isinstance(entities, str):
-            entities: list[str] = entities.split(",")  # type: ignore
+        # NOTE: Because this may not be obvious. We index hashes, and we extract
+        # topics and entities separately from main long-term indexing. However,
+        # when we store the topics and entities, we store them as comma-separated
+        # strings in the hash. Our search index picks these up and indexes them
+        # in TAG fields, and we get them back as comma-separated strings.
+        doc_topics = safe_get(doc, "topics", [])
+        if isinstance(doc_topics, str):
+            doc_topics = doc_topics.split(",")  # type: ignore
+
+        doc_entities = safe_get(doc, "entities", [])
+        if isinstance(doc_entities, str):
+            doc_entities = doc_entities.split(",")  # type: ignore
 
         results.append(
             LongTermMemoryResult(
                 id_=safe_get(doc, "id_"),
                 text=safe_get(doc, "text", ""),
                 dist=float(safe_get(doc, "vector_distance", 0)),
                 created_at=int(safe_get(doc, "created_at", 0)),
+                updated_at=int(safe_get(doc, "updated_at", 0)),
                 last_accessed=int(safe_get(doc, "last_accessed", 0)),
                 user_id=safe_get(doc, "user_id"),
                 session_id=safe_get(doc, "session_id"),
                 namespace=safe_get(doc, "namespace"),
-                topics=topics,
-                entities=entities,
+                topics=doc_topics,
+                entities=doc_entities,
             )
         )
     total_results = search_result.total

agent_memory_server/messages.py

@@ -73,17 +73,6 @@ async def get_session_memory(
 
         # Parse JSON
         msg_dict = json.loads(msg_raw)
-
-        # Convert comma-separated strings back to lists for topics and entities
-        if "topics" in msg_dict:
-            msg_dict["topics"] = (
-                msg_dict["topics"].split(",") if msg_dict["topics"] else []
-            )
-        if "entities" in msg_dict:
-            msg_dict["entities"] = (
-                msg_dict["entities"].split(",") if msg_dict["entities"] else []
-            )
-
         memory_messages.append(MemoryMessage(**msg_dict))
 
     kwargs = {