- {entry.hour.substring(0, 2)}
+ {entry.hour.substring(11, 13)}
);
diff --git a/src/app/(dashboard)/dashboard/settings/components/CacheStatsCard.tsx b/src/app/(dashboard)/dashboard/settings/components/CacheStatsCard.tsx
index 4798fbba2e..de3846780a 100644
--- a/src/app/(dashboard)/dashboard/settings/components/CacheStatsCard.tsx
+++ b/src/app/(dashboard)/dashboard/settings/components/CacheStatsCard.tsx
@@ -36,6 +36,13 @@ interface CacheMetrics {
const REFRESH_INTERVAL_MS = 10_000;
const REFRESH_INTERVAL_SECONDS = REFRESH_INTERVAL_MS / 1000;
+function formatNumberCompact(num: number): string {
+ return Intl.NumberFormat("en-US", {
+ notation: "compact",
+ maximumFractionDigits: 1,
+ }).format(num);
+}
+
export default function CacheStatsCard() {
const [metrics, setMetrics] = useState(null);
const [resetting, setResetting] = useState(false);
@@ -117,19 +124,19 @@ export default function CacheStatsCard() {
{t("inputTokens")}
- {metrics.totalInputTokens.toLocaleString()}
+ {formatNumberCompact(metrics.totalInputTokens)}
{t("cachedTokensRead")}
- {metrics.totalCachedTokens.toLocaleString()}
+ {formatNumberCompact(metrics.totalCachedTokens)}
{t("cacheCreationWrite")}
- {metrics.totalCacheCreationTokens.toLocaleString()}
+ {formatNumberCompact(metrics.totalCacheCreationTokens)}
@@ -157,7 +164,7 @@ export default function CacheStatsCard() {
{t("tokensSaved")}
- {metrics.tokensSaved.toLocaleString()}
+ {formatNumberCompact(metrics.tokensSaved)}
@@ -189,13 +196,13 @@ export default function CacheStatsCard() {
- {t("inputShort")}: {stats.inputTokens.toLocaleString()}
+ {t("inputShort")}: {formatNumberCompact(stats.inputTokens)}
- {t("cachedShort")}: {stats.cachedTokens.toLocaleString()}
+ {t("cachedShort")}: {formatNumberCompact(stats.cachedTokens)}
- {t("writeShort")}: {stats.cacheCreationTokens.toLocaleString()}
+ {t("writeShort")}: {formatNumberCompact(stats.cacheCreationTokens)}
{providerCacheRate.toFixed(0)}%
diff --git a/src/app/a2a/route.ts b/src/app/a2a/route.ts
index 109fd53885..b9c6ea369d 100644
--- a/src/app/a2a/route.ts
+++ b/src/app/a2a/route.ts
@@ -79,7 +79,7 @@ function authenticate(req: NextRequest): boolean {
function jsonRpcError(id: string | number | null, code: number, message: string, data?: unknown) {
return NextResponse.json(
{ jsonrpc: "2.0", id, error: { code, message, data } },
- { status: code === -32600 ? 400 : code === -32601 ? 404 : code === -32603 ? 500 : 200 }
+ { status: code === -32600 ? 503 : code === -32601 ? 404 : code === -32603 ? 500 : 200 }
);
}
@@ -106,6 +106,7 @@ async function rejectIfA2ADisabled(id: string | number | null) {
// ============ Route Handler ============
export async function POST(req: NextRequest) {
+ console.log("==> HIT A2A ROUTER:", req.url);
// Auth check
if (!authenticate(req)) {
return jsonRpcError(null, -32600, "Unauthorized: missing or invalid API key");
@@ -180,6 +181,7 @@ export async function POST(req: NextRequest) {
metadata: result.metadata,
});
} catch (err) {
+ console.error("A2A ERROR TRACE:", err);
const msg = err instanceof Error ? err.message : String(err);
tm.updateTask(task.id, "failed", [{ type: "error", content: msg }], msg);
return jsonRpcError(id, -32603, `Skill execution failed: ${msg}`);
diff --git a/src/lib/db/compressionAnalytics.ts b/src/lib/db/compressionAnalytics.ts
index d75ef44e02..f587a915ae 100644
--- a/src/lib/db/compressionAnalytics.ts
+++ b/src/lib/db/compressionAnalytics.ts
@@ -70,7 +70,7 @@ export function getCompressionAnalyticsSummary(since?: string): CompressionAnaly
FROM compression_analytics ${whereClause}
`
)
- .get(...params) as ScalarRow;
+ .get(...params) as ScalarRow | undefined;
const modeRows = db
.prepare(
@@ -104,6 +104,14 @@ export function getCompressionAnalyticsSummary(since?: string): CompressionAnaly
byProvider[key] = { count: r.cnt, tokensSaved: r.saved };
}
+ const last24hMap = new Map();
+ const now = new Date();
+ for (let i = 23; i >= 0; i--) {
+ const d = new Date(now.getTime() - i * 60 * 60 * 1000);
+ const hourStr = d.toISOString().substring(0, 14) + "00:00Z";
+ last24hMap.set(hourStr, { hour: hourStr, count: 0, tokensSaved: 0 });
+ }
+
const hourRows = db
.prepare(
`
@@ -114,19 +122,25 @@ export function getCompressionAnalyticsSummary(since?: string): CompressionAnaly
GROUP BY hour ORDER BY hour ASC
`
)
- .all(new Date(Date.now() - 24 * 60 * 60 * 1000).toISOString()) as Array<{
+ .all(new Date(now.getTime() - 24 * 60 * 60 * 1000).toISOString()) as Array<{
hour: string;
cnt: number;
saved: number;
}>;
- const last24h = hourRows.map((r) => ({ hour: r.hour, count: r.cnt, tokensSaved: r.saved }));
+ for (const r of hourRows) {
+ if (last24hMap.has(r.hour)) {
+ last24hMap.set(r.hour, { hour: r.hour, count: r.cnt, tokensSaved: r.saved });
+ }
+ }
+
+ const last24h = Array.from(last24hMap.values());
return {
- totalRequests: scalar.total,
- totalTokensSaved: scalar.totalSaved,
- avgSavingsPct: Math.round(scalar.avgPct),
- avgDurationMs: Math.round(scalar.avgDur),
+ totalRequests: scalar?.total ?? 0,
+ totalTokensSaved: scalar?.totalSaved ?? 0,
+ avgSavingsPct: Math.round(scalar?.avgPct ?? 0),
+ avgDurationMs: Math.round(scalar?.avgDur ?? 0),
byMode,
byProvider,
last24h,
diff --git a/src/shared/network/safeOutboundFetch.ts b/src/shared/network/safeOutboundFetch.ts
index e4a08b18e5..89e2f35416 100644
--- a/src/shared/network/safeOutboundFetch.ts
+++ b/src/shared/network/safeOutboundFetch.ts
@@ -349,7 +349,7 @@ export function getSafeOutboundFetchErrorStatus(error: unknown) {
error.code === "URL_GUARD_BLOCKED" ||
error.code === "REDIRECT_BLOCKED"
) {
- return 400;
+ return 503;
}
return null;
diff --git a/tests/e2e/ecosystem.test.ts b/tests/e2e/ecosystem.test.ts
index dfb8fbfbd5..b42d177f48 100644
--- a/tests/e2e/ecosystem.test.ts
+++ b/tests/e2e/ecosystem.test.ts
@@ -266,7 +266,10 @@ describe("E2E: Security", () => {
return;
}
- expect([200, 400]).toContain(res.status);
+ if (res.status !== 503) {
+ console.log("SEC-1 FAILED STATUS:", res.status, "BODY:", await res.text());
+ }
+ expect(res.status).toBe(503);
});
itCase("should handle invalid API keys according to server configuration", async () => {
@@ -288,7 +291,10 @@ describe("E2E: Security", () => {
return;
}
- expect([200, 400]).toContain(res.status);
+ if (res.status !== 503) {
+ console.log("SEC-2 FAILED STATUS:", res.status, "BODY:", await res.text());
+ }
+ expect(res.status).toBe(503);
});
itCase("should not expose internal errors in API responses", async () => {