Update src/api/agent.py

src/api/agent.py

@@ -1600,7 +1600,8 @@ async def _search_primo_catalog(context: SearchContextPayload, limit: int = 5) -
         boolean = clean_topic or context.topic
     result = await search_primo(
         SearchRequest(
-            query=boolean,
+            query=context.topic,      # plain topic as q= fallback
+            boolean_query=boolean,    # FIX: boolean goes here so _boolean_to_primo_params() fires
             source="primo",
             limit=limit,
             peer_reviewed=context.peer_reviewed,
@@ -2400,7 +2401,7 @@ async def _research_snapshot(context: SearchContextPayload, model: str) -> Tuple
 
     # Parallel fetch: OpenAlex (fast, free) + PRIMO
     papers, (primo_result, primo_url) = await _asyncio.gather(
-        _openalex_search(topic, limit=8),
+        _openalex_search(context.ai_tool_query or context.topic, limit=8),  # FIX: use richer natural query
         _search_primo_catalog(context, limit=6),
     )
 
@@ -2832,7 +2833,7 @@ async def _run_search_mode(
         if use_openalex:
             (result, source_url), oa_papers = await _aio.gather(
                 _search_pubmed_articles(context, limit=6),
-                _openalex_search(context.topic, limit=5),
+                _openalex_search(context.ai_tool_query or context.topic, limit=5),  # FIX: use richer natural query
             )
         else:
             result, source_url = await _search_pubmed_articles(context, limit=6)
@@ -2842,7 +2843,7 @@ async def _run_search_mode(
         if use_openalex:
             (result, source_url), oa_papers = await _aio.gather(
                 _search_primo_catalog(context, limit=6),
-                _openalex_search(context.topic, limit=5),
+                _openalex_search(context.ai_tool_query or context.topic, limit=5),  # FIX: use richer natural query
             )
         else:
             result, source_url = await _search_primo_catalog(context, limit=6)