mirror of
https://github.com/diegosouzapw/OmniRoute.git
synced 2026-08-03 05:45:04 +03:00
feat(search/analytics): add Search tab to analytics dashboard + GET /api/v1/search/analytics
- SearchAnalyticsTab: provider breakdown, cache hit rate, cost summary, KPI cards - /api/v1/search/analytics: query call_logs (request_type='search') for stats - analytics/page.tsx: added 'Search' tab alongside Overview and Evals Closes missing dashboard tracking identified in PR review.
This commit is contained in:
196
src/app/(dashboard)/dashboard/analytics/SearchAnalyticsTab.tsx
Normal file
196
src/app/(dashboard)/dashboard/analytics/SearchAnalyticsTab.tsx
Normal file
@@ -0,0 +1,196 @@
|
||||
/**
|
||||
* Search Analytics Tab
|
||||
*
|
||||
* Shows search request stats from call_logs (request_type = 'search'),
|
||||
* provider breakdown, cache hit rate, and cost summary.
|
||||
*/
|
||||
|
||||
"use client";
|
||||
|
||||
import { useEffect, useState } from "react";
|
||||
|
||||
interface SearchStats {
|
||||
total: number;
|
||||
today: number;
|
||||
cached: number;
|
||||
errors: number;
|
||||
totalCostUsd: number;
|
||||
byProvider: Record<string, { count: number; costUsd: number }>;
|
||||
last24h: Array<{ hour: string; count: number }>;
|
||||
cacheHitRate: number;
|
||||
avgDurationMs: number;
|
||||
}
|
||||
|
||||
function StatCard({
|
||||
icon,
|
||||
label,
|
||||
value,
|
||||
sub,
|
||||
}: {
|
||||
icon: string;
|
||||
label: string;
|
||||
value: string | number;
|
||||
sub?: string;
|
||||
}) {
|
||||
return (
|
||||
<div className="card p-4 flex flex-col gap-1">
|
||||
<div className="flex items-center gap-2 text-text-muted text-sm">
|
||||
<span className="material-symbols-outlined text-[18px]">{icon}</span>
|
||||
{label}
|
||||
</div>
|
||||
<div className="text-2xl font-bold text-text">{value}</div>
|
||||
{sub && <div className="text-xs text-text-muted">{sub}</div>}
|
||||
</div>
|
||||
);
|
||||
}
|
||||
|
||||
function ProviderBar({
|
||||
provider,
|
||||
count,
|
||||
total,
|
||||
costUsd,
|
||||
}: {
|
||||
provider: string;
|
||||
count: number;
|
||||
total: number;
|
||||
costUsd: number;
|
||||
}) {
|
||||
const pct = total > 0 ? Math.round((count / total) * 100) : 0;
|
||||
return (
|
||||
<div className="flex flex-col gap-1">
|
||||
<div className="flex justify-between text-sm">
|
||||
<span className="font-medium text-text">{provider}</span>
|
||||
<span className="text-text-muted">
|
||||
{count} queries · ${costUsd.toFixed(4)}
|
||||
</span>
|
||||
</div>
|
||||
<div className="h-2 rounded-full bg-bg-muted overflow-hidden">
|
||||
<div
|
||||
className="h-full rounded-full bg-primary transition-all"
|
||||
style={{ width: `${pct}%` }}
|
||||
/>
|
||||
</div>
|
||||
<div className="text-xs text-text-muted text-right">{pct}%</div>
|
||||
</div>
|
||||
);
|
||||
}
|
||||
|
||||
export default function SearchAnalyticsTab() {
|
||||
const [stats, setStats] = useState<SearchStats | null>(null);
|
||||
const [loading, setLoading] = useState(true);
|
||||
const [error, setError] = useState<string | null>(null);
|
||||
|
||||
useEffect(() => {
|
||||
fetch("/api/v1/search/analytics")
|
||||
.then((r) => r.json())
|
||||
.then((d) => {
|
||||
setStats(d);
|
||||
setLoading(false);
|
||||
})
|
||||
.catch((e) => {
|
||||
setError(e.message);
|
||||
setLoading(false);
|
||||
});
|
||||
}, []);
|
||||
|
||||
if (loading) {
|
||||
return (
|
||||
<div className="flex items-center justify-center py-16 text-text-muted">
|
||||
<span className="material-symbols-outlined animate-spin mr-2">progress_activity</span>
|
||||
Loading search analytics…
|
||||
</div>
|
||||
);
|
||||
}
|
||||
|
||||
if (error || !stats) {
|
||||
return (
|
||||
<div className="card p-6 text-center text-text-muted">
|
||||
<span className="material-symbols-outlined text-[32px] mb-2 block">search_off</span>
|
||||
{error || "No search data available yet."}
|
||||
<p className="text-xs mt-2">
|
||||
Search requests will appear here after the first search via /v1/search.
|
||||
</p>
|
||||
</div>
|
||||
);
|
||||
}
|
||||
|
||||
const providers = Object.entries(stats.byProvider).sort(([, a], [, b]) => b.count - a.count);
|
||||
|
||||
return (
|
||||
<div className="flex flex-col gap-6">
|
||||
{/* KPI Cards */}
|
||||
<div className="grid grid-cols-2 md:grid-cols-4 gap-4">
|
||||
<StatCard
|
||||
icon="manage_search"
|
||||
label="Total Searches"
|
||||
value={stats.total.toLocaleString()}
|
||||
sub={`${stats.today} today`}
|
||||
/>
|
||||
<StatCard
|
||||
icon="cached"
|
||||
label="Cache Hit Rate"
|
||||
value={`${stats.cacheHitRate}%`}
|
||||
sub={`${stats.cached} cached requests`}
|
||||
/>
|
||||
<StatCard
|
||||
icon="attach_money"
|
||||
label="Total Cost"
|
||||
value={`$${stats.totalCostUsd.toFixed(4)}`}
|
||||
sub="search API costs"
|
||||
/>
|
||||
<StatCard
|
||||
icon="timer"
|
||||
label="Avg Response"
|
||||
value={`${stats.avgDurationMs}ms`}
|
||||
sub={stats.errors > 0 ? `${stats.errors} errors` : "No errors"}
|
||||
/>
|
||||
</div>
|
||||
|
||||
{/* Provider Breakdown */}
|
||||
{providers.length > 0 && (
|
||||
<div className="card p-5">
|
||||
<h3 className="font-semibold text-text mb-4 flex items-center gap-2">
|
||||
<span className="material-symbols-outlined text-primary text-[20px]">hub</span>
|
||||
Provider Breakdown
|
||||
</h3>
|
||||
<div className="flex flex-col gap-4">
|
||||
{providers.map(([prov, data]) => (
|
||||
<ProviderBar
|
||||
key={prov}
|
||||
provider={prov}
|
||||
count={data.count}
|
||||
total={stats.total}
|
||||
costUsd={data.costUsd}
|
||||
/>
|
||||
))}
|
||||
</div>
|
||||
</div>
|
||||
)}
|
||||
|
||||
{/* Empty state */}
|
||||
{stats.total === 0 && (
|
||||
<div className="card p-8 text-center text-text-muted">
|
||||
<span className="material-symbols-outlined text-[48px] mb-3 block text-primary opacity-50">
|
||||
travel_explore
|
||||
</span>
|
||||
<p className="font-medium text-text">No searches yet</p>
|
||||
<p className="text-sm mt-1">
|
||||
Use <code className="bg-bg-muted px-1 rounded">POST /v1/search</code> to start routing
|
||||
web searches.
|
||||
</p>
|
||||
</div>
|
||||
)}
|
||||
|
||||
{/* Free tier note */}
|
||||
<div className="text-xs text-text-muted border border-border rounded-lg p-3 flex items-start gap-2">
|
||||
<span className="material-symbols-outlined text-[16px] text-green-500 mt-0.5">
|
||||
check_circle
|
||||
</span>
|
||||
<span>
|
||||
<strong>Free tier available:</strong> Serper (2,500/mo), Brave (2,000/mo), Exa (1,000/mo),
|
||||
Tavily (1,000/mo) — total 6,500+ free searches/month with automatic failover.
|
||||
</span>
|
||||
</div>
|
||||
</div>
|
||||
);
|
||||
}
|
||||
@@ -3,15 +3,17 @@
|
||||
import { useState, Suspense } from "react";
|
||||
import { UsageAnalytics, CardSkeleton, SegmentedControl } from "@/shared/components";
|
||||
import EvalsTab from "../usage/components/EvalsTab";
|
||||
import SearchAnalyticsTab from "./SearchAnalyticsTab";
|
||||
import { useTranslations } from "next-intl";
|
||||
|
||||
export default function AnalyticsPage() {
|
||||
const [activeTab, setActiveTab] = useState("overview");
|
||||
const t = useTranslations("analytics");
|
||||
|
||||
const tabDescriptions = {
|
||||
const tabDescriptions: Record<string, string> = {
|
||||
overview: t("overviewDescription"),
|
||||
evals: t("evalsDescription"),
|
||||
search: "Search request analytics — provider breakdown, cache hit rate, and cost tracking.",
|
||||
};
|
||||
|
||||
return (
|
||||
@@ -29,6 +31,7 @@ export default function AnalyticsPage() {
|
||||
options={[
|
||||
{ value: "overview", label: t("overview") },
|
||||
{ value: "evals", label: t("evals") },
|
||||
{ value: "search", label: "Search" },
|
||||
]}
|
||||
value={activeTab}
|
||||
onChange={setActiveTab}
|
||||
@@ -40,6 +43,7 @@ export default function AnalyticsPage() {
|
||||
</Suspense>
|
||||
)}
|
||||
{activeTab === "evals" && <EvalsTab />}
|
||||
{activeTab === "search" && <SearchAnalyticsTab />}
|
||||
</div>
|
||||
);
|
||||
}
|
||||
|
||||
103
src/app/api/v1/search/analytics/route.ts
Normal file
103
src/app/api/v1/search/analytics/route.ts
Normal file
@@ -0,0 +1,103 @@
|
||||
/**
|
||||
* GET /api/v1/search/analytics
|
||||
*
|
||||
* Returns search request statistics from call_logs (request_type = 'search').
|
||||
* Includes provider breakdown, cache hit rate, cost summary, and error count.
|
||||
*/
|
||||
|
||||
import { NextResponse } from "next/server";
|
||||
import { getDbInstance } from "@/lib/db/core";
|
||||
import { enforceApiKeyPolicy } from "@/shared/utils/apiKeyPolicy";
|
||||
|
||||
export async function GET(req: Request) {
|
||||
const policy = await enforceApiKeyPolicy(req, "analytics");
|
||||
if (policy.rejection) return policy.rejection;
|
||||
|
||||
try {
|
||||
const db = getDbInstance();
|
||||
|
||||
// Total search requests
|
||||
const totalRow = db
|
||||
.prepare(`SELECT COUNT(*) as cnt FROM call_logs WHERE request_type = 'search'`)
|
||||
.get() as { cnt: number };
|
||||
const total = totalRow?.cnt ?? 0;
|
||||
|
||||
// Today's searches (UTC date)
|
||||
const todayStart = new Date();
|
||||
todayStart.setUTCHours(0, 0, 0, 0);
|
||||
const todayRow = db
|
||||
.prepare(
|
||||
`SELECT COUNT(*) as cnt FROM call_logs WHERE request_type = 'search' AND timestamp >= ?`
|
||||
)
|
||||
.get(todayStart.toISOString()) as { cnt: number };
|
||||
const today = todayRow?.cnt ?? 0;
|
||||
|
||||
// Errors
|
||||
const errRow = db
|
||||
.prepare(
|
||||
`SELECT COUNT(*) as cnt FROM call_logs WHERE request_type = 'search' AND (status >= 400 OR error IS NOT NULL)`
|
||||
)
|
||||
.get() as { cnt: number };
|
||||
const errors = errRow?.cnt ?? 0;
|
||||
|
||||
// Avg duration
|
||||
const durRow = db
|
||||
.prepare(
|
||||
`SELECT AVG(duration) as avg FROM call_logs WHERE request_type = 'search' AND duration > 0`
|
||||
)
|
||||
.get() as { avg: number | null };
|
||||
const avgDurationMs = Math.round(durRow?.avg ?? 0);
|
||||
|
||||
// Per-provider breakdown (provider column stores search provider id)
|
||||
const provRows = db
|
||||
.prepare(
|
||||
`SELECT provider, COUNT(*) as cnt
|
||||
FROM call_logs WHERE request_type = 'search'
|
||||
GROUP BY provider ORDER BY cnt DESC`
|
||||
)
|
||||
.all() as Array<{ provider: string; cnt: number }>;
|
||||
|
||||
// Cost per search provider (matching searchRegistry.ts rates)
|
||||
const COST_PER_QUERY: Record<string, number> = {
|
||||
"serper-search": 0.001,
|
||||
"brave-search": 0.003,
|
||||
"perplexity-search": 0.005,
|
||||
"exa-search": 0.01,
|
||||
"tavily-search": 0.004,
|
||||
};
|
||||
|
||||
const byProvider: Record<string, { count: number; costUsd: number }> = {};
|
||||
let totalCostUsd = 0;
|
||||
for (const row of provRows) {
|
||||
const cost = (COST_PER_QUERY[row.provider] ?? 0.001) * row.cnt;
|
||||
byProvider[row.provider] = { count: row.cnt, costUsd: cost };
|
||||
totalCostUsd += cost;
|
||||
}
|
||||
|
||||
// Cached: very fast responses (< 5ms) indicate cache hits
|
||||
const cachedRow = db
|
||||
.prepare(
|
||||
`SELECT COUNT(*) as cnt FROM call_logs
|
||||
WHERE request_type = 'search' AND duration > 0 AND duration < 5`
|
||||
)
|
||||
.get() as { cnt: number };
|
||||
const cached = cachedRow?.cnt ?? 0;
|
||||
const cacheHitRate = total > 0 ? Math.round((cached / total) * 100) : 0;
|
||||
|
||||
return NextResponse.json({
|
||||
total,
|
||||
today,
|
||||
cached,
|
||||
errors,
|
||||
totalCostUsd,
|
||||
byProvider,
|
||||
cacheHitRate,
|
||||
avgDurationMs,
|
||||
last24h: [],
|
||||
});
|
||||
} catch (err: unknown) {
|
||||
const msg = err instanceof Error ? err.message : String(err);
|
||||
console.error("[/api/v1/search/analytics]", msg);
|
||||
return NextResponse.json({ error: "Internal server error" }, { status: 500 });
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user