quadrnt related issue

src/core/models.py

@@ -17,9 +17,7 @@ class SourceDocument(BaseModel):
 
 class QueryResponse(BaseModel):
     answer: str
-    sources: List[Dict[str, Any]]
-    query: str
-    timestamp: str
+    source_documents: List[Dict[str, Any]]
 
 class ErrorResponse(BaseModel):
     error: str

src/core/vector_store.py

@@ -178,19 +178,44 @@ def search_vectors(client: QdrantClient, collection_name: str, query_vector, lim
             logger.info(f"Collection '{collection_name}' is empty")
             return []
         
-        # Perform the search
-        results = client.search(
-            collection_name=collection_name,
-            query_vector=query_vector,
-            limit=limit,
-            with_payload=True
-        )
+        # Convert numpy array to list if needed
+        query_vector_list = query_vector.tolist() if hasattr(query_vector, 'tolist') else query_vector
         
-        logger.info(f"Found {len(results)} results in collection '{collection_name}'")
-        return results
+        # Qdrant Cloud uses the newer API (v1.7+)
+        # Use query_points which is the current method
+        try:
+            logger.debug(f"Attempting query_points on collection '{collection_name}'")
+            result = client.query_points(
+                collection_name=collection_name,
+                query=query_vector_list,
+                limit=limit,
+                with_payload=True
+            )
+            # Extract points from QueryResponse
+            results = result.points if hasattr(result, 'points') else result
+            logger.info(f"Found {len(results)} results using query_points in collection '{collection_name}'")
+            return results
+        except AttributeError as attr_err:
+            # Fallback to older search method for backward compatibility
+            logger.warning(f"query_points failed ({attr_err}), falling back to search method")
+            try:
+                results = client.search(
+                    collection_name=collection_name,
+                    query_vector=query_vector_list,
+                    limit=limit,
+                    with_payload=True
+                )
+                logger.info(f"Found {len(results)} results using search in collection '{collection_name}'")
+                return results
+            except Exception as search_err:
+                logger.error(f"Both query_points and search failed. search error: {search_err}")
+                raise
         
     except Exception as e:
         logger.error(f"Error searching collection '{collection_name}': {str(e)}")
+        logger.error(f"Error type: {type(e).__name__}")
+        import traceback
+        logger.error(f"Traceback: {traceback.format_exc()}")
         return []
 
 def get_collection_info(client: QdrantClient, collection_name: str) -> dict: