Weekly value report
- Server-generated summary across installations and registry state.
+ Rollup-backed summary across usage, maintenance, and drift signals.
+ {data.weeklyValueReport ? (
+
+ 0 ? "degraded" : "ready"}
+ >
+ Rollups{" "}
+ {data.weeklyValueReport.freshness.latestRollupDay ??
+ data.weeklyValueReport.freshness.status}
+
+
+ Drift · {data.upstreamDrift?.status ?? "unknown"}
+
+
+ ) : null}
{data.weeklyReport.map((line) => (
- · {line}
))}
-
-
- Drift · {data.upstreamDrift?.status ?? "unknown"}
-
-
+ {data.weeklyValueReport?.warnings.length ? (
+
+ {data.weeklyValueReport.warnings.slice(0, 3).map((warning) => (
+ - · {warning}
+ ))}
+
+ ) : null}
diff --git a/src/api/routes.ts b/src/api/routes.ts
index 79dcf2b17c..921ae4a5ad 100644
--- a/src/api/routes.ts
+++ b/src/api/routes.ts
@@ -122,6 +122,7 @@ import {
LATEST_RECOMMENDED_MCP_VERSION,
MINIMUM_SUPPORTED_MCP_VERSION,
} from "../services/mcp-compatibility";
+import { buildWeeklyValueReport, generateWeeklyValueReport, loadWeeklyValueReport } from "../services/weekly-value-report";
import { loadOrComputeIssueQualityResponse } from "../services/issue-quality";
import { loadOrComputeBurdenForecastResponse } from "../services/burden-forecast";
import {
@@ -161,10 +162,8 @@ import type {
JsonValue,
ProductUsageOutcome,
ProductUsageSurface,
- RegistrySnapshot,
RepoSyncSegmentRecord,
RepositoryRecord,
- ScoringModelSnapshotRecord,
} from "../types";
import { errorMessage, nowIso } from "../utils/json";
@@ -787,6 +786,22 @@ export function createApp() {
getProductUsageRollupStatus(c.env),
summarizeMcpCompatibilityAdoption(c.env, usageSince),
]);
+ const weeklyValueReport = buildWeeklyValueReport({
+ generatedAt: nowIso(),
+ variant: "operator",
+ days: 7,
+ repositories,
+ installations,
+ health,
+ registry,
+ scoring,
+ upstreamDrift,
+ usageSummary,
+ usageRollups,
+ usageRollupStatus,
+ activeSessions,
+ digestSubscriptions,
+ });
const installedRepos = repositories.filter((repo) => repo.isInstalled).length;
const registeredRepos = repositories.filter((repo) => repo.isRegistered).length;
return c.json({
@@ -808,7 +823,8 @@ export function createApp() {
{ label: "Registered coverage", value: registeredRepos, spark: sparklineFromCounts(registeredRepos, Math.max(repositories.length, 1)) },
{ label: "Installed coverage", value: installedRepos, spark: sparklineFromCounts(installedRepos, Math.max(repositories.length, 1)) },
],
- weeklyReport: buildOperatorWeeklyReport({ repositories, installations, health, registry, scoring, upstreamDrift }),
+ weeklyReport: weeklyValueReport.summary,
+ weeklyValueReport,
usageSummary,
usageRollups,
usageRollupStatus,
@@ -835,6 +851,15 @@ export function createApp() {
return c.json({ generatedAt: nowIso(), status, rollups });
});
+ app.get("/v1/app/analytics/weekly-value-report", async (c) => {
+ const variant = c.req.query("variant") === "operator" ? "operator" : "public";
+ const allowedRoles: ControlPanelRoleName[] = variant === "operator" ? ["operator"] : ["miner", "maintainer", "owner", "operator"];
+ const forbidden = await requireAppRole(c, allowedRoles);
+ if (forbidden) return forbidden;
+ const days = Math.max(1, Math.min(31, Number(c.req.query("days") ?? 7) || 7));
+ return c.json(await loadWeeklyValueReport(c.env, { variant, days }));
+ });
+
app.get("/v1/app/commands", async (c) =>
c.json({
generatedAt: nowIso(),
@@ -1758,6 +1783,15 @@ export function createApp() {
return c.json({ ok: true, status: "queued", day, days }, 202);
});
+ app.post("/v1/internal/jobs/generate-weekly-value-report", async (c) => {
+ const body = await c.req.json().catch(() => ({}));
+ const days = Number.isFinite(Number(body?.days)) ? Math.max(1, Math.min(31, Math.round(Number(body.days)))) : undefined;
+ const variant = body?.variant === "public" ? "public" : "operator";
+ const message: JobMessage = { type: "generate-weekly-value-report", requestedBy: "api", variant, ...(days === undefined ? {} : { days }) };
+ await c.env.JOBS.send(message);
+ return c.json({ ok: true, status: "queued", variant, days }, 202);
+ });
+
app.post("/v1/internal/jobs/repair-data-fidelity", async (c) => {
const message: JobMessage = { type: "repair-data-fidelity", requestedBy: "api" };
await c.env.JOBS.send(message);
@@ -1778,6 +1812,13 @@ export function createApp() {
return c.json(await rollupProductUsageDaily(c.env, { ...(day ? { day } : {}), ...(days === undefined ? {} : { days }) }));
});
+ app.post("/v1/internal/jobs/generate-weekly-value-report/run", async (c) => {
+ const body = await c.req.json().catch(() => ({}));
+ const days = Number.isFinite(Number(body?.days)) ? Math.max(1, Math.min(31, Math.round(Number(body.days)))) : undefined;
+ const variant = body?.variant === "public" ? "public" : "operator";
+ return c.json(await generateWeeklyValueReport(c.env, { variant, ...(days === undefined ? {} : { days }) }));
+ });
+
app.post("/v1/internal/jobs/refresh-installation-health/run", async (c) => {
return c.json(await refreshInstallationHealth(c.env));
});
@@ -2053,26 +2094,6 @@ function buildDigestItems(args: {
return items;
}
-function buildOperatorWeeklyReport(args: {
- repositories: RepositoryRecord[];
- installations: Awaited