Update src/agentcore/intents_search.py

src/agentcore/intents_search.py

@@ -17,11 +17,7 @@ from pydantic import BaseModel, ConfigDict, Field
 from src.config import get_settings, LIBBEE_VERSION
 
 from src.agentcore.models import ClientStatePayload, SearchContextPayload
-from src.agentcore.scholarly import (
-    _openalex_search,
-    _semantic_scholar_search,
-    enrich_papers_with_oa,
-)
+from src.agentcore.scholarly import fetch_evidence_panel
 from src.agentcore.constants import (
     ALT_TERMS_RE,
     CURRENT_YEAR,
@@ -582,55 +578,9 @@ async def _research_snapshot(context: SearchContextPayload, model: str) -> Tuple
         f'Search PRIMO for: {_escape(topic)} →</a>'
     )
 
-    # ── Open-evidence panel (OpenAlex → Semantic Scholar → Unpaywall/Crossref) ──
-    papers: List[dict] = []
-    try:
-        papers = await _openalex_search(topic, limit=6)
-        if not papers:
-            papers = await _semantic_scholar_search(topic, limit=6)
-        if papers:
-            papers = await enrich_papers_with_oa(papers, max_lookups=5)
-    except Exception as exc:
-        logger.warning(f"Evidence panel skipped for '{topic}': {exc}")
-        papers = []
-
-    if papers:
-        rows = ""
-        for paper in papers[:5]:
-            _t = _escape(str(paper.get("title") or "Untitled"))
-            _y = _escape(str(paper.get("year") or "n.d."))
-            _v = _escape(str(paper.get("venue") or ""))
-            _c = paper.get("cited_by_count")
-            _link = paper.get("link") or (f"https://doi.org/{paper['doi']}" if paper.get("doi") else "")
-            _oa = paper.get("oa_pdf_url") or ""
-            _bits = [b for b in (_y, _v) if b]
-            if isinstance(_c, int) and _c > 0:
-                _bits.append(f"{_c:,} citations")
-            _meta = " · ".join(_bits)
-            _title_html = (
-                f'<a href="{_escape(_link)}" target="_blank" style="color:#003366;font-weight:600">{_t}</a>'
-                if _link else f'<span style="font-weight:600">{_t}</span>'
-            )
-            _oa_html = (
-                f' · <a href="{_escape(_oa)}" target="_blank" '
-                f'style="color:#047857;font-weight:700">🔓 OA full text</a>'
-                if _oa else ""
-            )
-            rows += (
-                f'<div style="margin:7px 0;padding-left:2px;font-size:.84rem;line-height:1.55">'
-                f'{_title_html}<br>'
-                f'<span style="color:#6b7280;font-size:.78rem">{_meta}{_oa_html}</span></div>'
-            )
-        answer += (
-            '<div style="margin-top:16px;padding:12px 14px;border:1px solid #d1fae5;'
-            'border-radius:10px;background:#f0fdf9">'
-            '<div style="font-weight:700;color:#065f46;font-size:.86rem;margin-bottom:4px">'
-            '🔎 Open scholarly evidence</div>'
-            '<div style="font-size:.76rem;color:#047857;margin-bottom:8px">'
-            'Top open-index results (OpenAlex / Semantic Scholar) with legal open-access '
-            'links via Unpaywall where available.</div>'
-            f'{rows}</div>'
-        )
+    # Shared open-evidence panel (see scholarly.fetch_evidence_panel)
+    papers, panel_html = await fetch_evidence_panel(topic)
+    answer += panel_html
 
     answer += _ai_tools_footer(context)
     return answer, papers, []
@@ -903,8 +853,13 @@ async def _run_search_mode(
     source_url = _primo_clean_url(context)
     topic = _escape(context.display_topic or context.topic)
 
-    # 3-sentence topic intro
-    intro = await _topic_intro(context.display_topic or context.topic, model)
+    # 3-sentence topic intro AND the open-evidence panel, fetched concurrently:
+    # the panel's network time hides inside the intro's LLM latency instead of
+    # adding to it. Both degrade independently if they fail.
+    intro, (papers, panel_html) = await asyncio.gather(
+        _topic_intro(context.display_topic or context.topic, model),
+        fetch_evidence_panel(context.display_topic or context.topic),
+    )
 
     answer = _search_trace_block(question, context)
     if intro:
@@ -920,9 +875,10 @@ async def _run_search_mode(
         f'💡 Inside PRIMO you can filter by <strong>Articles</strong>, <strong>Books</strong>, '
         f'<strong>Peer Reviewed</strong>, date range, and more.</div>'
     )
+    answer += panel_html
     answer += _ai_tools_footer(context)
 
-    return answer, [], [], source_url
+    return answer, papers, [], source_url
 
 
 def _sort_and_trim_contexts(contexts: List[SearchContextPayload]) -> List[SearchContextPayload]: