src/portal-convergence.ts

Functions

Imports

It imports src/env.ts, src/ops-feed.ts, src/ops-types/views.ts, src/portal-auth.ts, src/site-convergence.ts. Imported by src/routes.ts.

Source

1import type { Env } from "./env";
2import { OPS_RETURN_TO } from "./ops-feed";
3import type { PortalConvergence } from "./ops-types/views";
4import { portalGate } from "./portal-auth";
5import { readConvergence } from "./site-convergence";
6
7// The Portal's convergence view: GET /portal/api/convergence (job_09e5f6cbf782). Each site
8// that opted into Capsid calling its operator API, read live (src/site-convergence.ts).
9// It calls only the site's read (sync_status) and its public health route, and reads the
10// site Worker's secret names from Cloudflare; a repair is the site_repair control, never
11// this route. A route, not a tool, so no grant is checked here
12// (one enforcement point, test/route-gates.test.ts): it answers to portalGate, and src/scope.ts lists it among the
13// routes gated some other way.
14
15export const PORTAL_CONVERGENCE_PATH = "/portal/api/convergence";
16
17/** GET /portal/api/convergence: every opted-in site's convergence, read now. */
18export async function handlePortalConvergence(request: Request, env: Env, now: Date = new Date(), fetchImpl: typeof fetch = fetch): Promise<Response> {
19  const gate = await portalGate(request, env, now, OPS_RETURN_TO);
20  if (!gate.ok) return gate.response;
21  const body: PortalConvergence = { generated: now.toISOString(), sites: await readConvergence(env, fetchImpl, now) };
22  return new Response(JSON.stringify(body), { headers: { "Content-Type": "application/json", "Cache-Control": "no-store" } });
23}