fix: Convert memory backends to async/await (#2185)

Merging PR #2185 - All tests passing (133+), CI green, philosophy grade 10/10

Author: rysweet

src/amplihack/memory/backends/__init__.py

@@ -16,7 +16,6 @@
 import logging
 import os
 from enum import Enum
-from pathlib import Path
 from typing import Any
 
 from .base import BackendCapabilities, MemoryBackend
@@ -100,10 +99,10 @@ def create_backend(backend_type: str | BackendType | None = None, **config: Any)
             logger.info(f"Kùzu not available ({e}), using SQLite backend")
 
     # Create backend instance
+    # Note: Caller must call await backend.initialize() after creation
     if backend_type == BackendType.SQLITE:
         db_path = config.get("db_path")
         backend = SQLiteBackend(db_path=db_path)
-        backend.initialize()
         return backend
 
     if backend_type == BackendType.KUZU:
@@ -116,7 +115,6 @@ def create_backend(backend_type: str | BackendType | None = None, **config: Any)
 
         db_path = config.get("db_path")
         backend = KuzuBackend(db_path=db_path)
-        backend.initialize()
         return backend
 
     raise ValueError(f"Unknown backend type: {backend_type}")

src/amplihack/memory/backends/base.py

@@ -54,15 +54,15 @@ def get_capabilities(self) -> BackendCapabilities:
         """
         ...
 
-    def initialize(self) -> None:
+    async def initialize(self) -> None:
         """Initialize backend (create schema, indexes, etc).
 
         MUST be called before first use.
         Should be idempotent (safe to call multiple times).
         """
         ...
 
-    def store_memory(self, memory: MemoryEntry) -> bool:
+    async def store_memory(self, memory: MemoryEntry) -> bool:
         """Store a memory entry.
 
         Args:
@@ -75,7 +75,7 @@ def store_memory(self, memory: MemoryEntry) -> bool:
         """
         ...
 
-    def retrieve_memories(self, query: MemoryQuery) -> list[MemoryEntry]:
+    async def retrieve_memories(self, query: MemoryQuery) -> list[MemoryEntry]:
         """Retrieve memories matching the query.
 
         Args:
@@ -88,7 +88,7 @@ def retrieve_memories(self, query: MemoryQuery) -> list[MemoryEntry]:
         """
         ...
 
-    def get_memory_by_id(self, memory_id: str) -> MemoryEntry | None:
+    async def get_memory_by_id(self, memory_id: str) -> MemoryEntry | None:
         """Get a specific memory by ID.
 
         Args:
@@ -101,7 +101,7 @@ def get_memory_by_id(self, memory_id: str) -> MemoryEntry | None:
         """
         ...
 
-    def delete_memory(self, memory_id: str) -> bool:
+    async def delete_memory(self, memory_id: str) -> bool:
         """Delete a memory entry.
 
         Args:
@@ -114,7 +114,7 @@ def delete_memory(self, memory_id: str) -> bool:
         """
         ...
 
-    def cleanup_expired(self) -> int:
+    async def cleanup_expired(self) -> int:
         """Remove expired memory entries.
 
         Returns:
@@ -124,7 +124,7 @@ def cleanup_expired(self) -> int:
         """
         ...
 
-    def get_session_info(self, session_id: str) -> SessionInfo | None:
+    async def get_session_info(self, session_id: str) -> SessionInfo | None:
         """Get information about a session.
 
         Args:
@@ -137,7 +137,7 @@ def get_session_info(self, session_id: str) -> SessionInfo | None:
         """
         ...
 
-    def list_sessions(self, limit: int | None = None) -> list[SessionInfo]:
+    async def list_sessions(self, limit: int | None = None) -> list[SessionInfo]:
         """List all sessions ordered by last accessed.
 
         Args:
@@ -150,7 +150,7 @@ def list_sessions(self, limit: int | None = None) -> list[SessionInfo]:
         """
         ...
 
-    def get_stats(self) -> dict[str, Any]:
+    async def get_stats(self) -> dict[str, Any]:
         """Get database statistics.
 
         Returns:
@@ -160,7 +160,7 @@ def get_stats(self) -> dict[str, Any]:
         """
         ...
 
-    def close(self) -> None:
+    async def close(self) -> None:
         """Close backend connection and cleanup resources.
 
         Should be idempotent (safe to call multiple times).