auto suggestion fix

app/routers/helper_router.py

@@ -71,21 +71,18 @@ async def auto_suggestions(query: str = Query(..., min_length=1)):
     """
     Fetch search suggestions for a query string.
     """
-    cache_key = f"suggestions:{query.lower()}"
-
-    async def fetch_from_db():
-        return await fetch_suggestions_service(query)
-
+   
     try:
-        suggestions = await get_or_set_cache(cache_key, fetch_from_db)
+        suggestions = await fetch_suggestions_service(query=query)
+
         return suggestions
     except Exception as e:
         raise HTTPException(status_code=500, detail=f"Error in fetching suggestions: {str(e)}")
+
     
 @router.get("/suggestions-list", response_model=List[str])
 async def suggestions_list(
-    category: Optional[str] = Query(None, description="Category to filter suggestions (e.g., 'Salon')")
-):
+    category: Optional[str] = Query(None, description="Category to filter suggestions (e.g., 'Salon')")):
     """
     Fetch search suggestions based on optional category.
     """
@@ -94,7 +91,7 @@ async def suggestions_list(
         cache_key += f":{category.lower()}"
 
     async def fetch_from_db():
-        return await fetch_suggestions_service(category)
+        return await fetch_suggestions_service(category=category.lower())
 
     try:
         suggestions = await get_or_set_cache(cache_key, fetch_from_db)

app/services/helper_service.py

@@ -196,32 +196,26 @@ async def fetch_filters_and_sort_service() -> Dict[str, List]:
     return results[0] if results else {"filters": [], "sort_options": []}
 
 
+async def fetch_suggestions_service(query: Optional[str] = None, category: Optional[str] = None) -> List[str]:
+    """
+    Fetch suggestions from the `auto_suggestions` collection based on an optional query and category.
 
+    Args:
+        query (Optional[str]): Partial or full query string for matching suggestions.
+        category (Optional[str]): Category to filter suggestions.
 
-async def fetch_suggestions_service(query: str) -> List[str]:
+    Returns:
+        List[str]: A list of suggestion strings.
+    """
+    pipeline = []
 
-    pipeline = [
-        {
+    # Add query filter if query is provided
+    if query:
+        pipeline.append({
             "$match": {
                 "suggestion": {"$regex": query, "$options": "i"}  # Case-insensitive partial match
             }
-        },
-        {
-            "$project": {"_id": 0, "suggestion": 1}  # Only fetch the `suggestion` field
-        },
-        {
-            "$limit": 10  # Limit the results to 10
-        }
-    ]
-    
-    results = await execute_query("auto_suggestions", pipeline)
-    return [doc["suggestion"] for doc in results] if results else []
-    
-async def fetch_suggestions_service(category: Optional[str]) -> List[str]:
-    """
-    Fetch suggestions based on optional category.
-    """
-    pipeline = []
+        })
 
     # Add category filter if category is provided
     if category:
@@ -237,14 +231,17 @@ async def fetch_suggestions_service(category: Optional[str]) -> List[str]:
             "$project": {"_id": 0, "suggestion": 1}  # Only fetch the `suggestion` field
         },
         {
-            "$limit": 50  # Limit the results to 10
+            "$limit": 50  # Limit the results to 50
         }
     ])
 
+    logger.info(f"Executing pipeline: {pipeline}")
+
     # Execute the query and return the suggestions
     results = await execute_query("auto_suggestions", pipeline)
     return [doc["suggestion"] for doc in results] if results else []
 
+
 async def fetch_live_at_service() -> List[Dict[str, Any]]:
     """
     Fetch live locations (countries and cities) from the database.