fix(api): search product field, max_hops, evidence coalesce, sources, stats

ai/connection_mapper.py

@@ -32,7 +32,7 @@ class ConnectionMapper:
             rows = session.run(
                 """
                 MATCH path = shortestPath(
-                  (a {id:$a})-[*1..5]-(b {id:$b})
+                  (a {id:$a})-[*1..$hops]-(b {id:$b})
                 )
                 RETURN [n IN nodes(path) | {id:n.id, name:n.name,
                         label:labels(n)[0]}] AS nodes,
@@ -40,7 +40,7 @@ class ConnectionMapper:
                        length(path) AS hops
                 LIMIT 10
                 """,
-                a=entity_a, b=entity_b
+                a=entity_a, b=entity_b, hops=max_hops
             ).data()
 
         paths = []
@@ -102,7 +102,7 @@ class ConnectionMapper:
                 """
                 MATCH (n {id:$id})-[r]-(m)
                 RETURN type(r) AS rel, labels(m)[0] AS node_type,
-                       m.name AS name, m.id AS mid,
+                       coalesce(m.name, m.title, m.product, m.item_desc, m.id) AS name, m.id AS mid,
                        m.state AS state
                 LIMIT 30
                 """,

api/routes/search.py

@@ -43,6 +43,7 @@ LABEL_QUERIES = {
         "WHERE toLower(coalesce(n.item_desc,'')) CONTAINS toLower($q) "
         "   OR toLower(coalesce(n.buyer_org,'')) CONTAINS toLower($q) "
         "   OR toLower(coalesce(n.order_id,'')) CONTAINS toLower($q) "
+        "   OR toLower(coalesce(n.product,'')) CONTAINS toLower($q) "
         "RETURN n.id AS id, coalesce(n.item_desc, n.order_id) AS name, "
         "       null AS state, null AS party LIMIT $limit"),
     "ministry": ("Ministry",
@@ -118,8 +119,8 @@ def search_entities(
                     results=results[:limit],
                     generated_at=datetime.now().isoformat(),
                 )
-        except Exception:
-            pass  # Fulltext index not ready — fall through to label-by-label
+        except Exception as ft_err:
+            logger.debug(f"[Search] Full-text index unavailable: {type(ft_err).__name__}")
 
     with driver.session() as session:
         if filter_type in ("all", ""):

api/routes/sources.py

@@ -44,8 +44,8 @@ def sources_summary(driver=Depends(get_db)):
             rows = s.run(
                 """
                 MATCH (n)
-                WHERE n.source IS NOT NULL
-                RETURN n.source AS source, count(*) AS total
+                WHERE n.source IS NOT NULL OR n.dataset IS NOT NULL
+                RETURN coalesce(n.dataset, n.source) AS source, count(*) AS total
                 ORDER BY total DESC
                 """
             ).data()