Fix: Handle memory:// URL for Qdrant with :memory: location

app/infrastructure/external/qdrant_retriever.py

@@ -23,7 +23,12 @@ class QdrantRetriever(IRetriever):
         self.url = url
         self.collection_name = collection_name
         self.vector_size = vector_size
-        self.client = AsyncQdrantClient(url=url, api_key=api_key)
+        
+        # Handle in-memory mode
+        if url.startswith("memory://"):
+            self.client = AsyncQdrantClient(location=":memory:")
+        else:
+            self.client = AsyncQdrantClient(url=url, api_key=api_key)
 
     async def initialize_collection(self) -> None:
         """Initialize Qdrant collection"""
@@ -100,25 +105,29 @@ class QdrantRetriever(IRetriever):
         alpha: float = 0.5,
         filters: Optional[dict] = None,
     ) -> List[RetrievalResult]:
-        """Hybrid search (semantic + keyword)"""
-        # Simplified - in production combine with keyword search
-        raise NotImplementedError("Hybrid search requires integration with keyword search")
+        """Hybrid search (dense + sparse)"""
+        # TODO: Implement hybrid search with BM25
+        raise NotImplementedError("Hybrid search not yet implemented")
 
-    async def upsert_points(
+    async def add_documents(
         self,
-        points: List[Dict],
+        vectors: List[List[float]],
+        documents: List[Dict],
+        ids: Optional[List[str]] = None,
     ) -> None:
-        """Upsert points to collection"""
-        qdrant_points = [
-            PointStruct(
-                id=point["id"],
-                vector=point["vector"],
-                payload=point["payload"],
+        """Add documents to collection"""
+        points = []
+        for i, (vector, doc) in enumerate(zip(vectors, documents)):
+            point_id = ids[i] if ids else str(UUID(int=i))
+            points.append(
+                PointStruct(
+                    id=point_id,
+                    vector=vector,
+                    payload=doc,
+                )
             )
-            for point in points
-        ]
 
         await self.client.upsert(
             collection_name=self.collection_name,
-            points=qdrant_points,
+            points=points,
         )