-
-
- speed
-
-
Rate Limiting
+
+
+
+ speed
+
+
Rate Limiting
+
+ {editMode ? (
+
+
+
+
+ ) : (
+
+ )}
@@ -235,22 +199,34 @@ function RateLimitOverviewCard({ rateLimitStatus, defaults }) {
-
+
Default Safety Net
-
-
{defaults?.requestsPerMinute ?? "β"}
-
RPM
-
-
-
{formatMs(defaults?.minTimeBetweenRequests)}
-
Min Gap
-
-
-
{defaults?.concurrentRequests ?? "β"}
-
Max Concurrent
-
+ {[
+ { key: "requestsPerMinute", label: "RPM", suffix: "" },
+ { key: "minTimeBetweenRequests", label: "Min Gap", suffix: "ms", format: formatMs },
+ { key: "concurrentRequests", label: "Max Concurrent", suffix: "" },
+ ].map(({ key, label, format }) => (
+
+ {editMode ? (
+
+ setDraft((prev) => ({ ...prev, [key]: parseInt(e.target.value) || 0 }))
+ }
+ className="w-full px-2 py-1 text-lg font-bold rounded bg-white/10 border border-white/20"
+ />
+ ) : (
+
+ {format ? format(defaults?.[key]) : (defaults?.[key] ?? "β")}
+
+ )}
+
{label}
+
+ ))}
@@ -281,6 +257,270 @@ function RateLimitOverviewCard({ rateLimitStatus, defaults }) {
);
}
+// βββ Circuit Breaker Card ββββββββββββββββββββββββββββββββββββββββββββββββ
+function CircuitBreakerCard({ breakers, onReset, loading }) {
+ const activeBreakers = breakers.filter((b) => b.state !== "CLOSED");
+ const totalBreakers = breakers.length;
+
+ return (
+
+
+
+
+
+ electrical_services
+
+
Circuit Breakers
+
+
+
+ {activeBreakers.length > 0
+ ? `${activeBreakers.length} tripped`
+ : `${totalBreakers} healthy`}
+
+ {activeBreakers.length > 0 && (
+
+ )}
+
+
+
+ {breakers.length === 0 ? (
+
+ No circuit breakers active yet. They are created automatically when requests flow
+ through the combo pipeline.
+
+ ) : (
+
+ {breakers.map((b) => {
+ const style = STATE_STYLES[b.state] || STATE_STYLES.CLOSED;
+ return (
+
+
+
+ {style.icon}
+
+ {b.name.replace("combo:", "")}
+
+
+ {b.failureCount > 0 && (
+
+ {b.failureCount} failure{b.failureCount !== 1 ? "s" : ""}
+
+ )}
+
+ {style.label}
+
+
+
+ );
+ })}
+
+ )}
+
+ );
+}
+
+// βββ Policies Panel (from Security tab) ββββββββββββββββββββββββββββββββββ
+function PoliciesCard() {
+ const [data, setData] = useState(null);
+ const [loading, setLoading] = useState(true);
+ const [unlocking, setUnlocking] = useState(null);
+ const notify = useNotificationStore();
+
+ const fetchPolicies = useCallback(async () => {
+ try {
+ const res = await fetch("/api/policies");
+ if (res.ok) {
+ const json = await res.json();
+ setData(json);
+ }
+ } catch {
+ // silent
+ } finally {
+ setLoading(false);
+ }
+ }, []);
+
+ useEffect(() => {
+ fetchPolicies();
+ const interval = setInterval(fetchPolicies, 15000);
+ return () => clearInterval(interval);
+ }, [fetchPolicies]);
+
+ const handleUnlock = async (identifier) => {
+ setUnlocking(identifier);
+ try {
+ const res = await fetch("/api/policies", {
+ method: "POST",
+ headers: { "Content-Type": "application/json" },
+ body: JSON.stringify({ action: "unlock", identifier }),
+ });
+ if (res.ok) {
+ notify.success(`Unlocked: ${identifier}`);
+ await fetchPolicies();
+ } else {
+ notify.error("Failed to unlock");
+ }
+ } catch {
+ notify.error("Failed to unlock");
+ } finally {
+ setUnlocking(null);
+ }
+ };
+
+ const circuitBreakers = data?.circuitBreakers || [];
+ const lockedIds = data?.lockedIdentifiers || [];
+ const hasIssues = circuitBreakers.some((cb) => cb.state !== "closed") || lockedIds.length > 0;
+
+ if (loading) {
+ return (
+
+
+ policy
+ Loading policies...
+
+
+ );
+ }
+
+ return (
+
+
+
+
+
+ policy
+
+
Policies & Locked Identifiers
+
+ {hasIssues && (
+
+ )}
+
+
+ {!hasIssues ? (
+
+
+ verified_user
+
+
+
+ All systems operational β no lockouts or tripped breakers
+
+
+
+ ) : (
+ <>
+ {/* Circuit Breakers */}
+ {circuitBreakers.filter((cb) => cb.state !== "closed").length > 0 && (
+
+
Circuit Breakers
+
+ {circuitBreakers
+ .filter((cb) => cb.state !== "closed")
+ .map((cb, i) => {
+ const status = CB_STATUS[cb.state] || CB_STATUS.open;
+ return (
+
+
+
+ {status.icon}
+
+
+ {cb.name || cb.provider || "Unknown"}
+
+
+ {status.label}
+
+ {cb.failures > 0 && (
+
+ {cb.failures} failures
+
+ )}
+
+
+ );
+ })}
+
+
+ )}
+
+ {/* Locked Identifiers */}
+ {lockedIds.length > 0 && (
+
+
Locked Identifiers
+
+ {lockedIds.map((id, i) => {
+ const identifier = typeof id === "string" ? id : id.identifier || id.id;
+ return (
+
+
+
+ lock
+
+ {identifier}
+ {typeof id === "object" && id.lockedAt && (
+
+ since {new Date(id.lockedAt).toLocaleString()}
+
+ )}
+
+
+
+ );
+ })}
+
+
+ )}
+
+ )}
+
+ );
+}
+
// βββ Main Resilience Tab βββββββββββββββββββββββββββββββββββββββββββββββββ
export default function ResilienceTab() {
const [data, setData] = useState(null);
@@ -340,6 +580,23 @@ export default function ResilienceTab() {
}
};
+ const handleSaveDefaults = async (defaults) => {
+ try {
+ setSaving(true);
+ const res = await fetch("/api/resilience", {
+ method: "PATCH",
+ headers: { "Content-Type": "application/json" },
+ body: JSON.stringify({ defaults }),
+ });
+ if (!res.ok) throw new Error("Save failed");
+ await loadData();
+ } catch (err) {
+ setError(err.message);
+ } finally {
+ setSaving(false);
+ }
+ };
+
if (loading && !data) {
return (
@@ -365,20 +622,27 @@ export default function ResilienceTab() {
return (
-
+ {/* 1. Provider Profiles (resilience settings by auth type) */}
-
+ {/* 3. Circuit Breakers (combo pipeline) */}
+
+ {/* 4. Policies & Locked Identifiers (from previous Security tab) */}
+
);
}
diff --git a/src/app/(dashboard)/dashboard/settings/components/RoutingTab.tsx b/src/app/(dashboard)/dashboard/settings/components/RoutingTab.tsx
index 3336d3ee2b..5c75932dc8 100644
--- a/src/app/(dashboard)/dashboard/settings/components/RoutingTab.tsx
+++ b/src/app/(dashboard)/dashboard/settings/components/RoutingTab.tsx
@@ -13,6 +13,19 @@ const STRATEGIES = [
},
{ value: "round-robin", label: "Round Robin", desc: "Cycle through all accounts", icon: "loop" },
{ value: "p2c", label: "P2C", desc: "Pick 2 random, use the healthier one", icon: "balance" },
+ { value: "random", label: "Random", desc: "Random account each request", icon: "shuffle" },
+ {
+ value: "least-used",
+ label: "Least Used",
+ desc: "Pick least recently used account",
+ icon: "low_priority",
+ },
+ {
+ value: "cost-optimized",
+ label: "Cost Opt",
+ desc: "Prefer cheapest available account",
+ icon: "savings",
+ },
];
export default function RoutingTab() {
@@ -76,7 +89,7 @@ export default function RoutingTab() {
Routing Strategy
-
+
{STRATEGIES.map((s) => (
-
);
}
diff --git a/src/app/(dashboard)/dashboard/settings/page.tsx b/src/app/(dashboard)/dashboard/settings/page.tsx
index cf63a13834..a84e6dc28b 100644
--- a/src/app/(dashboard)/dashboard/settings/page.tsx
+++ b/src/app/(dashboard)/dashboard/settings/page.tsx
@@ -74,6 +74,7 @@ export default function SettingsPage() {
+
)}
@@ -88,12 +89,7 @@ export default function SettingsPage() {
{activeTab === "resilience" &&
}
- {activeTab === "advanced" && (
-
- )}
+ {activeTab === "advanced" &&
}
{activeTab === "compliance" &&
}
diff --git a/src/app/api/cli-tools/claude-settings/route.ts b/src/app/api/cli-tools/claude-settings/route.ts
index 87f898bcc5..a0cf27ec95 100644
--- a/src/app/api/cli-tools/claude-settings/route.ts
+++ b/src/app/api/cli-tools/claude-settings/route.ts
@@ -9,6 +9,7 @@ import {
getCliRuntimeStatus,
} from "@/shared/services/cliRuntime";
import { createBackup } from "@/shared/services/backupService";
+import { saveCliToolLastConfigured, deleteCliToolLastConfigured } from "@/lib/db/cliToolState";
// Get claude settings path based on OS
const getClaudeSettingsPath = () => getCliPrimaryConfigPath("claude");
@@ -121,6 +122,13 @@ export async function POST(request: Request) {
// Write new settings
await fs.writeFile(settingsPath, JSON.stringify(newSettings, null, 2));
+ // Persist last-configured timestamp
+ try {
+ saveCliToolLastConfigured("claude");
+ } catch {
+ /* non-critical */
+ }
+
return NextResponse.json({
success: true,
message: "Settings updated successfully",
@@ -184,6 +192,13 @@ export async function DELETE() {
// Write updated settings
await fs.writeFile(settingsPath, JSON.stringify(currentSettings, null, 2));
+ // Clear last-configured timestamp
+ try {
+ deleteCliToolLastConfigured("claude");
+ } catch {
+ /* non-critical */
+ }
+
return NextResponse.json({
success: true,
message: "Settings reset successfully",
diff --git a/src/app/api/cli-tools/cline-settings/route.ts b/src/app/api/cli-tools/cline-settings/route.ts
index 03e397c1af..418233fe39 100644
--- a/src/app/api/cli-tools/cline-settings/route.ts
+++ b/src/app/api/cli-tools/cline-settings/route.ts
@@ -6,6 +6,7 @@ import path from "path";
import os from "os";
import { ensureCliConfigWriteAllowed, getCliRuntimeStatus } from "@/shared/services/cliRuntime";
import { createBackup } from "@/shared/services/backupService";
+import { saveCliToolLastConfigured, deleteCliToolLastConfigured } from "@/lib/db/cliToolState";
const CLINE_DATA_DIR = path.join(os.homedir(), ".cline", "data");
const GLOBAL_STATE_PATH = path.join(CLINE_DATA_DIR, "globalState.json");
@@ -151,6 +152,13 @@ export async function POST(request: Request) {
await fs.writeFile(SECRETS_PATH, JSON.stringify(secrets, null, 2));
+ // Persist last-configured timestamp
+ try {
+ saveCliToolLastConfigured("cline");
+ } catch {
+ /* non-critical */
+ }
+
return NextResponse.json({
success: true,
message: "Cline settings applied successfully!",
@@ -210,6 +218,13 @@ export async function DELETE() {
delete secrets.openAiApiKey;
await fs.writeFile(SECRETS_PATH, JSON.stringify(secrets, null, 2));
+ // Clear last-configured timestamp
+ try {
+ deleteCliToolLastConfigured("cline");
+ } catch {
+ /* non-critical */
+ }
+
return NextResponse.json({
success: true,
message: "OmniRoute settings removed from Cline",
diff --git a/src/app/api/cli-tools/codex-settings/route.ts b/src/app/api/cli-tools/codex-settings/route.ts
index dd799d992f..bb01c0cb62 100644
--- a/src/app/api/cli-tools/codex-settings/route.ts
+++ b/src/app/api/cli-tools/codex-settings/route.ts
@@ -9,6 +9,7 @@ import {
getCliRuntimeStatus,
} from "@/shared/services/cliRuntime";
import { createMultiBackup } from "@/shared/services/backupService";
+import { saveCliToolLastConfigured, deleteCliToolLastConfigured } from "@/lib/db/cliToolState";
const getCodexConfigPath = () => getCliConfigPaths("codex").config;
const getCodexAuthPath = () => getCliConfigPaths("codex").auth;
@@ -201,6 +202,13 @@ export async function POST(request: Request) {
authData.OPENAI_API_KEY = apiKey;
await fs.writeFile(authPath, JSON.stringify(authData, null, 2));
+ // Persist last-configured timestamp
+ try {
+ saveCliToolLastConfigured("codex");
+ } catch {
+ /* non-critical */
+ }
+
return NextResponse.json({
success: true,
message: "Codex settings applied successfully!",
@@ -270,6 +278,13 @@ export async function DELETE() {
/* No auth file */
}
+ // Clear last-configured timestamp
+ try {
+ deleteCliToolLastConfigured("codex");
+ } catch {
+ /* non-critical */
+ }
+
return NextResponse.json({
success: true,
message: "OmniRoute settings removed successfully",
diff --git a/src/app/api/cli-tools/droid-settings/route.ts b/src/app/api/cli-tools/droid-settings/route.ts
index e95f95f4c9..de0c72d15c 100644
--- a/src/app/api/cli-tools/droid-settings/route.ts
+++ b/src/app/api/cli-tools/droid-settings/route.ts
@@ -9,6 +9,7 @@ import {
getCliRuntimeStatus,
} from "@/shared/services/cliRuntime";
import { createBackup } from "@/shared/services/backupService";
+import { saveCliToolLastConfigured, deleteCliToolLastConfigured } from "@/lib/db/cliToolState";
const getDroidSettingsPath = () => getCliPrimaryConfigPath("droid");
const getDroidDir = () => path.dirname(getDroidSettingsPath());
@@ -132,6 +133,13 @@ export async function POST(request: Request) {
// Write settings
await fs.writeFile(settingsPath, JSON.stringify(settings, null, 2));
+ // Persist last-configured timestamp
+ try {
+ saveCliToolLastConfigured("droid");
+ } catch {
+ /* non-critical */
+ }
+
return NextResponse.json({
success: true,
message: "Factory Droid settings applied successfully!",
@@ -184,6 +192,13 @@ export async function DELETE() {
// Write updated settings
await fs.writeFile(settingsPath, JSON.stringify(settings, null, 2));
+ // Clear last-configured timestamp
+ try {
+ deleteCliToolLastConfigured("droid");
+ } catch {
+ /* non-critical */
+ }
+
return NextResponse.json({
success: true,
message: "OmniRoute settings removed successfully",
diff --git a/src/app/api/cli-tools/kilo-settings/route.ts b/src/app/api/cli-tools/kilo-settings/route.ts
index 359965cfd3..38a1feceda 100644
--- a/src/app/api/cli-tools/kilo-settings/route.ts
+++ b/src/app/api/cli-tools/kilo-settings/route.ts
@@ -6,6 +6,7 @@ import path from "path";
import os from "os";
import { ensureCliConfigWriteAllowed, getCliRuntimeStatus } from "@/shared/services/cliRuntime";
import { createBackup } from "@/shared/services/backupService";
+import { saveCliToolLastConfigured, deleteCliToolLastConfigured } from "@/lib/db/cliToolState";
const KILO_DATA_DIR = path.join(os.homedir(), ".local", "share", "kilo");
const AUTH_PATH = path.join(KILO_DATA_DIR, "auth.json");
@@ -175,6 +176,13 @@ export async function POST(request) {
// VS Code settings not writable β not a problem for CLI
}
+ // Persist last-configured timestamp
+ try {
+ saveCliToolLastConfigured("kilo");
+ } catch {
+ /* non-critical */
+ }
+
return NextResponse.json({
success: true,
message: "Kilo Code settings applied successfully!",
@@ -233,6 +241,13 @@ export async function DELETE() {
/* ignore */
}
+ // Clear last-configured timestamp
+ try {
+ deleteCliToolLastConfigured("kilo");
+ } catch {
+ /* non-critical */
+ }
+
return NextResponse.json({
success: true,
message: "OmniRoute settings removed from Kilo Code",
diff --git a/src/app/api/cli-tools/openclaw-settings/route.ts b/src/app/api/cli-tools/openclaw-settings/route.ts
index 1b9004c22d..ca6d370e1c 100644
--- a/src/app/api/cli-tools/openclaw-settings/route.ts
+++ b/src/app/api/cli-tools/openclaw-settings/route.ts
@@ -9,6 +9,7 @@ import {
getCliRuntimeStatus,
} from "@/shared/services/cliRuntime";
import { createBackup } from "@/shared/services/backupService";
+import { saveCliToolLastConfigured, deleteCliToolLastConfigured } from "@/lib/db/cliToolState";
const getOpenClawSettingsPath = () => getCliPrimaryConfigPath("openclaw");
const getOpenClawDir = () => path.dirname(getOpenClawSettingsPath());
@@ -132,6 +133,13 @@ export async function POST(request: Request) {
// Write settings
await fs.writeFile(settingsPath, JSON.stringify(settings, null, 2));
+ // Persist last-configured timestamp
+ try {
+ saveCliToolLastConfigured("openclaw");
+ } catch {
+ /* non-critical */
+ }
+
return NextResponse.json({
success: true,
message: "Open Claw settings applied successfully!",
@@ -189,6 +197,13 @@ export async function DELETE() {
// Write updated settings
await fs.writeFile(settingsPath, JSON.stringify(settings, null, 2));
+ // Clear last-configured timestamp
+ try {
+ deleteCliToolLastConfigured("openclaw");
+ } catch {
+ /* non-critical */
+ }
+
return NextResponse.json({
success: true,
message: "OmniRoute settings removed successfully",
diff --git a/src/app/api/cli-tools/status/route.ts b/src/app/api/cli-tools/status/route.ts
index 8b091d1136..1a535a8628 100644
--- a/src/app/api/cli-tools/status/route.ts
+++ b/src/app/api/cli-tools/status/route.ts
@@ -2,6 +2,7 @@
import { NextResponse } from "next/server";
import { getCliRuntimeStatus, CLI_TOOL_IDS } from "@/shared/services/cliRuntime";
+import { getAllCliToolLastConfigured } from "@/lib/db/cliToolState";
/**
* GET /api/cli-tools/status
@@ -58,6 +59,18 @@ export async function GET() {
})
);
+ // Merge last-configured timestamps from SQLite
+ try {
+ const lastConfigured = getAllCliToolLastConfigured();
+ for (const [toolId, timestamp] of Object.entries(lastConfigured)) {
+ if (statuses[toolId]) {
+ statuses[toolId].lastConfiguredAt = timestamp;
+ }
+ }
+ } catch {
+ /* non-critical */
+ }
+
return NextResponse.json(statuses);
} catch (error) {
console.log("Error fetching CLI tool statuses:", error);
diff --git a/src/app/api/resilience/route.ts b/src/app/api/resilience/route.ts
index d9fc16b1b0..95ec96f26a 100644
--- a/src/app/api/resilience/route.ts
+++ b/src/app/api/resilience/route.ts
@@ -9,8 +9,7 @@ export async function GET() {
// Dynamic imports for open-sse modules
const { getAllCircuitBreakerStatuses } =
await import("@/../../src/shared/utils/circuitBreaker");
- const { getAllRateLimitStatus } =
- await import("@omniroute/open-sse/services/rateLimitManager");
+ const { getAllRateLimitStatus } = await import("@omniroute/open-sse/services/rateLimitManager");
const { PROVIDER_PROFILES, DEFAULT_API_LIMITS } =
await import("@omniroute/open-sse/config/constants");
@@ -20,7 +19,7 @@ export async function GET() {
return NextResponse.json({
profiles: settings.providerProfiles || PROVIDER_PROFILES,
- defaults: DEFAULT_API_LIMITS,
+ defaults: { ...DEFAULT_API_LIMITS, ...(settings.rateLimitDefaults || {}) },
circuitBreakers,
rateLimitStatus,
});
@@ -34,46 +33,78 @@ export async function GET() {
}
/**
- * PATCH /api/resilience β Update provider resilience profiles
+ * PATCH /api/resilience β Update provider resilience profiles and/or rate limit defaults
*/
export async function PATCH(request) {
try {
const body = await request.json();
- const { profiles } = body;
+ const { profiles, defaults } = body;
- if (!profiles || typeof profiles !== "object") {
- return NextResponse.json({ error: "Invalid profiles payload" }, { status: 400 });
+ if (!profiles && !defaults) {
+ return NextResponse.json({ error: "Must provide profiles or defaults" }, { status: 400 });
}
- // Validate profile shape
- for (const [key, profile] of Object.entries(profiles)) {
- if (!["oauth", "apikey"].includes(key)) {
- return NextResponse.json({ error: `Invalid profile key: ${key}` }, { status: 400 });
+ // Validate profiles if provided
+ if (profiles) {
+ if (typeof profiles !== "object") {
+ return NextResponse.json({ error: "Invalid profiles payload" }, { status: 400 });
}
- const required = [
- "transientCooldown",
- "rateLimitCooldown",
- "maxBackoffLevel",
- "circuitBreakerThreshold",
- "circuitBreakerReset",
- ];
- for (const field of required) {
- if (typeof profile[field] !== "number" || profile[field] < 0) {
+ for (const [key, profile] of Object.entries(profiles)) {
+ if (!["oauth", "apikey"].includes(key)) {
+ return NextResponse.json({ error: `Invalid profile key: ${key}` }, { status: 400 });
+ }
+ const required = [
+ "transientCooldown",
+ "rateLimitCooldown",
+ "maxBackoffLevel",
+ "circuitBreakerThreshold",
+ "circuitBreakerReset",
+ ];
+ for (const field of required) {
+ if (typeof profile[field] !== "number" || profile[field] < 0) {
+ return NextResponse.json(
+ { error: `Invalid ${key}.${field}: must be a non-negative number` },
+ { status: 400 }
+ );
+ }
+ }
+ }
+ }
+
+ // Validate defaults if provided
+ if (defaults) {
+ if (typeof defaults !== "object") {
+ return NextResponse.json({ error: "Invalid defaults payload" }, { status: 400 });
+ }
+ const validKeys = ["requestsPerMinute", "minTimeBetweenRequests", "concurrentRequests"];
+ for (const key of validKeys) {
+ if (
+ defaults[key] !== undefined &&
+ (typeof defaults[key] !== "number" || defaults[key] < 1)
+ ) {
return NextResponse.json(
- { error: `Invalid ${key}.${field}: must be a non-negative number` },
+ { error: `Invalid defaults.${key}: must be a positive number` },
{ status: 400 }
);
}
}
}
- await updateSettings({ providerProfiles: profiles });
+ const updates: Record
= {};
+ if (profiles) updates.providerProfiles = profiles;
+ if (defaults) updates.rateLimitDefaults = defaults;
- return NextResponse.json({ ok: true, profiles });
+ await updateSettings(updates);
+
+ return NextResponse.json({
+ ok: true,
+ ...(profiles ? { profiles } : {}),
+ ...(defaults ? { defaults } : {}),
+ });
} catch (err) {
console.error("[API] PATCH /api/resilience error:", err);
return NextResponse.json(
- { error: err.message || "Failed to save resilience profiles" },
+ { error: err.message || "Failed to save resilience settings" },
{ status: 500 }
);
}
diff --git a/src/lib/db/cliToolState.ts b/src/lib/db/cliToolState.ts
new file mode 100644
index 0000000000..3bf28fd0b5
--- /dev/null
+++ b/src/lib/db/cliToolState.ts
@@ -0,0 +1,123 @@
+/**
+ * CLI Tool State Persistence
+ *
+ * Stores last-configured timestamps and initial config snapshots
+ * for CLI tools in the key_value table.
+ *
+ * Namespaces:
+ * - cliToolLastConfig: ISO timestamp of last configuration
+ * - cliToolInitialConfig: JSON snapshot of pre-OmniRoute configuration
+ *
+ * @module lib/db/cliToolState
+ */
+
+import { getDbInstance, isBuildPhase, isCloud } from "./core";
+
+// ββββββββββββββββ Last Configured Timestamp ββββββββββββββββ
+
+/**
+ * Save last-configured timestamp for a CLI tool.
+ */
+export function saveCliToolLastConfigured(
+ toolId: string,
+ timestamp: string = new Date().toISOString()
+) {
+ if (isBuildPhase || isCloud) return;
+ const db = getDbInstance();
+ db.prepare("INSERT OR REPLACE INTO key_value (namespace, key, value) VALUES (?, ?, ?)").run(
+ "cliToolLastConfig",
+ toolId,
+ JSON.stringify(timestamp)
+ );
+}
+
+/**
+ * Get last-configured timestamp for a CLI tool.
+ * @returns ISO timestamp string or null if never configured.
+ */
+export function getCliToolLastConfigured(toolId: string): string | null {
+ if (isBuildPhase || isCloud) return null;
+ const db = getDbInstance();
+ const row: any = db
+ .prepare("SELECT value FROM key_value WHERE namespace = ? AND key = ?")
+ .get("cliToolLastConfig", toolId);
+ return row ? JSON.parse(row.value) : null;
+}
+
+/**
+ * Get all CLI tool last-configured timestamps.
+ * @returns Record
+ */
+export function getAllCliToolLastConfigured(): Record {
+ if (isBuildPhase || isCloud) return {};
+ const db = getDbInstance();
+ const rows: any[] = db
+ .prepare("SELECT key, value FROM key_value WHERE namespace = ?")
+ .all("cliToolLastConfig");
+ const result: Record = {};
+ for (const row of rows) {
+ result[row.key] = JSON.parse(row.value);
+ }
+ return result;
+}
+
+/**
+ * Delete last-configured timestamp for a CLI tool.
+ */
+export function deleteCliToolLastConfigured(toolId: string) {
+ if (isBuildPhase || isCloud) return;
+ const db = getDbInstance();
+ db.prepare("DELETE FROM key_value WHERE namespace = ? AND key = ?").run(
+ "cliToolLastConfig",
+ toolId
+ );
+}
+
+// ββββββββββββββββ Initial Config Snapshot ββββββββββββββββ
+
+/**
+ * Save the initial (pre-OmniRoute) config snapshot for a CLI tool.
+ * Only saves if no snapshot exists yet (first-time only).
+ * @returns true if saved, false if snapshot already exists.
+ */
+export function saveCliToolInitialConfig(toolId: string, config: Record): boolean {
+ if (isBuildPhase || isCloud) return false;
+ const db = getDbInstance();
+ // Only save if not already stored
+ const existing: any = db
+ .prepare("SELECT value FROM key_value WHERE namespace = ? AND key = ?")
+ .get("cliToolInitialConfig", toolId);
+ if (existing) return false;
+
+ db.prepare("INSERT OR REPLACE INTO key_value (namespace, key, value) VALUES (?, ?, ?)").run(
+ "cliToolInitialConfig",
+ toolId,
+ JSON.stringify(config)
+ );
+ return true;
+}
+
+/**
+ * Get the initial config snapshot for a CLI tool.
+ * @returns Config object or null if no snapshot exists.
+ */
+export function getCliToolInitialConfig(toolId: string): Record | null {
+ if (isBuildPhase || isCloud) return null;
+ const db = getDbInstance();
+ const row: any = db
+ .prepare("SELECT value FROM key_value WHERE namespace = ? AND key = ?")
+ .get("cliToolInitialConfig", toolId);
+ return row ? JSON.parse(row.value) : null;
+}
+
+/**
+ * Delete the initial config snapshot for a CLI tool.
+ */
+export function deleteCliToolInitialConfig(toolId: string) {
+ if (isBuildPhase || isCloud) return;
+ const db = getDbInstance();
+ db.prepare("DELETE FROM key_value WHERE namespace = ? AND key = ?").run(
+ "cliToolInitialConfig",
+ toolId
+ );
+}
diff --git a/src/shared/components/UsageAnalytics.tsx b/src/shared/components/UsageAnalytics.tsx
index 852743828c..e3345fdb3b 100644
--- a/src/shared/components/UsageAnalytics.tsx
+++ b/src/shared/components/UsageAnalytics.tsx
@@ -1,6 +1,6 @@
"use client";
-import { useState, useEffect, useCallback } from "react";
+import { useState, useEffect, useCallback, useMemo } from "react";
import Card from "./Card";
import { CardSkeleton } from "./Loading";
import { fmtCompact as fmt, fmtFull, fmtCost } from "@/shared/utils/formatting";
@@ -15,6 +15,8 @@ import {
WeeklySquares7d,
ModelTable,
ProviderCostDonut,
+ ModelOverTimeChart,
+ ProviderTable,
} from "./analytics";
// ============================================================================
@@ -55,11 +57,37 @@ export default function UsageAnalytics() {
{ value: "all", label: "All" },
];
+ const topModel = useMemo(() => {
+ const models = analytics?.byModel || [];
+ return models.length > 0 ? models[0].model : "β";
+ }, [analytics]);
+
+ const topProvider = useMemo(() => {
+ const providers = analytics?.byProvider || [];
+ return providers.length > 0 ? providers[0].provider : "β";
+ }, [analytics]);
+
+ const busiestDay = useMemo(() => {
+ const wp = analytics?.weeklyPattern || [];
+ if (!wp.length) return "β";
+ const max = wp.reduce((a, b) => (a.avgTokens > b.avgTokens ? a : b), wp[0]);
+ return max.avgTokens > 0 ? max.day : "β";
+ }, [analytics]);
+
+ const providerCount = useMemo(() => {
+ return (analytics?.byProvider || []).length;
+ }, [analytics]);
+
if (loading && !analytics) return ;
if (error) return Error: {error};
const s = analytics?.summary || {};
+ // ββ Derived insight values ββ
+ const avgTokensPerReq = s.totalRequests > 0 ? Math.round(s.totalTokens / s.totalRequests) : 0;
+ const costPerReq = s.totalRequests > 0 ? s.totalCost / s.totalRequests : 0;
+ const ioRatio = s.completionTokens > 0 ? (s.promptTokens / s.completionTokens).toFixed(1) : "β";
+
return (
{/* Header + Time Range */}
@@ -85,7 +113,7 @@ export default function UsageAnalytics() {