Update src/api/admin.py

src/api/admin.py

@@ -259,10 +259,17 @@ tr:last-child td{{border-bottom:none}}
 </div>
 
 <div class="card">
-  <h2>📋 Recent Queries (last 50)</h2>
+  <h2>📈 Cloudflare Analytics (Persistent)</h2>
+  <div class="stat-grid" id="cfStatsGrid"><div style="color:#6b7280;font-size:.84rem">Loading from Cloudflare D1…</div></div>
+  <div style="margin-top:14px" id="cfToolsTable"><div style="color:#6b7280;font-size:.84rem">Loading tool breakdown…</div></div>
+</div>
+
+<div class="card">
+  <h2>📋 Recent Queries (Cloudflare D1)</h2>
   <div id="recentTable" style="overflow-x:auto"><div style="color:#6b7280;font-size:.84rem">Loading…</div></div>
 </div>
 
+
 <div class="card">
   <h2>🔌 System Status</h2>
   <div id="sysStatus"><div style="color:#6b7280;font-size:.84rem">Loading…</div></div>
@@ -270,18 +277,62 @@ tr:last-child td{{border-bottom:none}}
 
 </div>
 <script>
+const WORKER_URL = "https://steep-haze-e1f8.nikeshn.workers.dev";
+
 async function loadStats(){{
   try{{
     const r=await fetch('/admin/metrics');
     const d=await r.json();
     document.getElementById('statsGrid').innerHTML=`
-      <div class="stat"><div class="val">${{d.agent_requests||0}}</div><div class="lbl">Agent Requests</div></div>
-      <div class="stat"><div class="val">${{d.search_requests||0}}</div><div class="lbl">Search Requests</div></div>
-      <div class="stat"><div class="val">${{d.follow_up_hits||0}}</div><div class="lbl">Follow-up Hits</div></div>
-      <div class="stat"><div class="val">${{d.search_handoffs||0}}</div><div class="lbl">Snapshots</div></div>
-      <div class="stat"><div class="val">${{d.feedback_total||0}}</div><div class="lbl">Feedback</div></div>
+      <div class="stat"><div class="val">${{d.agent_requests||0}}</div><div class="lbl">Requests (session)</div></div>
+      <div class="stat"><div class="val">${{d.search_requests||0}}</div><div class="lbl">Searches (session)</div></div>
+      <div class="stat"><div class="val">${{d.follow_up_hits||0}}</div><div class="lbl">Follow-ups (session)</div></div>
+      <div class="stat"><div class="val">${{d.feedback_total||0}}</div><div class="lbl">Feedback (session)</div></div>
     `;
-  }}catch(e){{document.getElementById('statsGrid').innerHTML='<span style="color:#dc2626">Analytics unavailable</span>';}}
+  }}catch(e){{document.getElementById('statsGrid').innerHTML='<span style="color:#dc2626">Local metrics unavailable</span>';}}
+}}
+
+async function loadCFAnalytics(){{
+  try{{
+    const r=await fetch(WORKER_URL+'/analytics');
+    const d=await r.json();
+    if(d.error) throw new Error(d.error);
+    document.getElementById('cfStatsGrid').innerHTML=`
+      <div class="stat"><div class="val">${{d.total||0}}</div><div class="lbl">Total Queries</div></div>
+      <div class="stat"><div class="val">${{d.today||0}}</div><div class="lbl">Today</div></div>
+      <div class="stat"><div class="val">${{d.week||0}}</div><div class="lbl">This Week</div></div>
+      <div class="stat"><div class="val">${{(d.avg_time||0).toFixed(2)}}s</div><div class="lbl">Avg Response</div></div>
+      <div class="stat"><div class="val">${{d.errors||0}}</div><div class="lbl">Errors</div></div>
+    `;
+    const tools=(d.tools||[]).slice(0,15);
+    let rows=tools.map(t=>`<tr><td>${{t.tool_used||"unknown"}}</td><td>${{t.c}}</td></tr>`).join('');
+    document.getElementById('cfToolsTable').innerHTML=rows
+      ?`<table><thead><tr><th>Intent:Tool</th><th>Count</th></tr></thead><tbody>${{rows}}</tbody></table>`
+      :'<span style="color:#6b7280;font-size:.84rem">No data yet.</span>';
+  }}catch(e){{
+    document.getElementById('cfStatsGrid').innerHTML='<span style="color:#dc2626">Cloudflare D1 unavailable: '+e.message+'</span>';
+  }}
+}}
+
+async function loadRecentQueries(){{
+  try{{
+    const r=await fetch(WORKER_URL+'/analytics/recent');
+    const d=await r.json();
+    if(d.error) throw new Error(d.error);
+    const rows=(d.results||[]).map(q=>`<tr>
+      <td style="white-space:nowrap;font-size:.74rem">${{q.timestamp||""}}</td>
+      <td style="max-width:280px;word-break:break-word">${{(q.question||"").substring(0,100)}}</td>
+      <td>${{q.tool_used||""}}</td>
+      <td>${{q.model||""}}</td>
+      <td style="white-space:nowrap">${{(q.response_time||0).toFixed(2)}}s</td>
+      <td>${{q.result_count||0}}</td>
+    </tr>`).join('');
+    document.getElementById('recentTable').innerHTML=rows
+      ?`<table><thead><tr><th>Time</th><th>Question</th><th>Tool</th><th>Model</th><th>Time</th><th>Results</th></tr></thead><tbody>${{rows}}</tbody></table>`
+      :'<span style="color:#6b7280;font-size:.84rem">No queries logged yet.</span>';
+  }}catch(e){{
+    document.getElementById('recentTable').innerHTML='<span style="color:#dc2626">Could not load: '+e.message+'</span>';
+  }}
 }}
 
 async function loadMetrics(){{
@@ -296,7 +347,7 @@ async function loadMetrics(){{
       .map(([k,v])=>`<tr><td style="color:#dc2626">${{k}}</td><td>${{v}}</td><td style="color:#6b7280">error</td></tr>`).join('');
     document.getElementById('metricsTable').innerHTML=rows
       ?`<table><thead><tr><th>Key</th><th>Count</th><th>Type</th></tr></thead><tbody>${{rows}}</tbody></table>`
-      :'<span style="color:#6b7280;font-size:.84rem">No data yet.</span>';
+      :'<span style="color:#6b7280;font-size:.84rem">No session data yet — resets on deploy.</span>';
   }}catch(e){{document.getElementById('metricsTable').innerHTML='<span style="color:#dc2626">Could not load metrics</span>';}}
 }}
 
@@ -351,36 +402,14 @@ async function loadStatus(){{
   }}
 }}
 
-async function loadRecentQueries(){{
-  try{{
-    const r=await fetch('/admin/queries?limit=50');
-    const d=await r.json();
-    const rows=(d.queries||[]).map(q=>`<tr>
-      <td style="white-space:nowrap">${{q.timestamp||''}}</td>
-      <td style="max-width:260px;word-break:break-word">${{(q.question||'').substring(0,100)}}</td>
-      <td>${{q.intent||''}}</td>
-      <td>${{q.tool||''}}</td>
-      <td>${{q.model||''}}</td>
-      <td style="white-space:nowrap">${{(q.response_time||0).toFixed(2)}}s</td>
-      <td>${{q.result_count||0}}</td>
-    </tr>`).join('');
-    document.getElementById('recentTable').innerHTML=rows
-      ?`<table><thead><tr>
-          <th>Time</th><th>Question</th><th>Intent</th>
-          <th>Tool</th><th>Model</th><th>Time</th><th>Results</th>
-        </tr></thead><tbody>${{rows}}</tbody></table>`
-      :'<span style="color:#6b7280;font-size:.84rem">No queries logged yet — queries appear after users interact with LibBee.</span>';
-  }}catch(e){{
-    document.getElementById('recentTable').innerHTML='<span style="color:#dc2626">Could not load recent queries</span>';
-  }}
-}}
-
 loadStats();
+loadCFAnalytics();
+loadRecentQueries();
 loadMetrics();
 loadRAGInfo();
-loadRecentQueries();
 loadStatus();
 setInterval(loadStatus, 30000);
+setInterval(loadCFAnalytics, 60000);
 setInterval(loadRecentQueries, 60000);
 </script>
 </body></html>""")
@@ -467,16 +496,6 @@ async def metrics(request: Request):
         return {"error": str(e)}
 
 
-@router.get("/queries")
-async def recent_queries(request: Request, limit: int = 50):
-    _require_session(request)
-    try:
-        from app import get_metrics_service
-        return {"queries": get_metrics_service().recent_queries(limit=min(limit, 200))}
-    except Exception as e:
-        return {"queries": [], "error": str(e)}
-
-
 @router.get("/status")
 async def system_status(request: Request):
     _require_session(request)