Fix Qdrant Cloud connection logic

scripts/build_index.py

@@ -627,7 +627,10 @@ def main():
             # Initialize Qdrant store
             console.print("\n[bold cyan]Initializing Qdrant Store...[/bold cyan]")
             try:
-                qdrant_manager = QdrantStoreManager()
+                qdrant_manager = QdrantStoreManager(
+                    url=settings.qdrant_url,
+                    api_key=settings.qdrant_api_key,
+                )
                 qdrant_manager.initialize_collection(recreate=args.recreate_collection)
             except Exception as e:
                 console.print(f"[bold red]Failed to initialize Qdrant: {e}[/bold red]")

src/api/main.py

@@ -179,6 +179,8 @@ async def lifespan(app: FastAPI):
         app_state.qdrant_manager = QdrantStoreManager(
             collection_name=app_state.settings.qdrant_collection_name,
             path=app_state.settings.qdrant_path,
+            url=app_state.settings.qdrant_url,
+            api_key=app_state.settings.qdrant_api_key,
             embedding_dim=app_state.embedding_client.embedding_dim,
         )
 

src/vectorstore/qdrant_store.py

@@ -97,7 +97,9 @@ class QdrantStoreManager:
         self,
         collection_name: Optional[str] = None,
         path: Optional[str] = None,
-        embedding_dim: int = 768,  # Default for nomic-embed-text
+        url: Optional[str] = None,
+        api_key: Optional[str] = None,
+        embedding_dim: int = 768,  # Default for nomic-embed-text/all-mpnet
         batch_size: int = 100,
     ):
         """
@@ -106,21 +108,30 @@ class QdrantStoreManager:
         Args:
             collection_name: Name of the collection (default: from settings)
             path: Path to Qdrant storage (default: from settings)
+            url: Qdrant server URL (for remote Qdrant)
+            api_key: Qdrant API key (for Qdrant Cloud)
             embedding_dim: Dimension of dense embeddings
             batch_size: Batch size for bulk operations
         """
         self.collection_name = collection_name or settings.qdrant_collection_name
         self.path = Path(path or settings.qdrant_path)
+        self.url = url or settings.qdrant_url
+        self.api_key = api_key or settings.qdrant_api_key
         self.embedding_dim = embedding_dim
         self.batch_size = batch_size
 
-        # Create storage directory
-        self.path.mkdir(parents=True, exist_ok=True)
+        # Create storage directory (only if local)
+        if not self.url:
+            self.path.mkdir(parents=True, exist_ok=True)
 
-        # Initialize Qdrant client (local/persistent mode)
+        # Initialize Qdrant client
         try:
-            self.client = QdrantClient(path=str(self.path))
-            logger.info(f"Initialized Qdrant client at {self.path}")
+            if self.url:
+                self.client = QdrantClient(url=self.url, api_key=self.api_key)
+                logger.info(f"Initialized Qdrant client at {self.url} (remote)")
+            else:
+                self.client = QdrantClient(path=str(self.path))
+                logger.info(f"Initialized Qdrant client at {self.path} (local)")
         except Exception as e:
             logger.error(f"Failed to initialize Qdrant client: {e}")
             raise