af03967 · d98f0d0 · 53960d7
@@ -16,4 +16,6 @@
A new `/settings…` page route goes in `src/http/settings_routes.ts` (`settings
State shared between modules through process memory, not the database, is named here. `src/perf/views_report.ts`: `readVisits` holds each scope and window's visits for 15 seconds (dropped by `flushViews`), so a page and its probe share one read; `src/perf/views_store.ts`: the view buffer, flushed every 10 seconds. The traffic sources view's terminal door is `src/tui/screens/trafficview.ts` (palette entry for admins, per-app command for a repository's admins). `src/runs/held.ts`: each dispatcher pass (`src/crew/dispatch.ts`, `pump`) records which queued agent runs it held and why (valve, pace, limit), and vitals (`src/kernel/vitals.ts`) leaves those out of `queue:agent`. A record older than `HELD_FRESH_MS` is ignored, so a stopped dispatcher cannot hide its queue.
`src/perf/loop_worst.ts`: `loopWorst`, the worst event-loop lag of the last 10 s in ten one-second slots, fed by one unref'd 50 ms timer that the first `serve` starts (`startLoopWorst`), and read by every response's `lag;dur` and by `/healthz` asked for JSON (`loopLagMs`). Tests listing a request's phases read `requestTiming` (`test/helpers/request-timing.ts`), which leaves `lag` out.
`src/core/transfer.ts`: the old owner/name pairs a transfer left behind (`repo_redirect`), held per database after the first request reads them and dropped by `transferRepo`, so a request under a path nothing moved from costs no statement (#569).
@@ -1,5 +1,5 @@
# Performance watcher (#7559)
`src/perf/` keeps a capped in-memory record of real requests per route pattern (total, each Server-Timing phase, signed in or out; no paths, ids or queries). `budgets.ts` holds the budgets in words with the number beside them. Once a minute `duty.ts` files one issue per route and phase in the forge's repo when p95 has been over budget for 15 min with 20+ real requests; the finding names the slowest phase, its share and the cache hit rate. `git.ts` keeps the same record for every git process the forge spawns (`git/env.ts`, `git/local.ts`), keyed `git <subcommand>` from a fixed list (never an argument, path or ref; anything else is `git other`), timed from before the spawn gate so a queue counts; a subcommand whose p95 passes its budget the same way (250 ms; 10 s for the pack-moving ones: clone, fetch, push, gc, repack, pack-objects and the like) files one issue naming it, its count, p50 and p95. `loop.ts` names the routes running across an event-loop stall in the `loop` log line; nothing is kept beyond that line.
`src/perf/` keeps a capped in-memory record of real requests per route pattern (total, each Server-Timing phase, signed in or out; no paths, ids or queries). `budgets.ts` holds the budgets in words with the number beside them. Once a minute `duty.ts` files one issue per route and phase in the forge's repo when p95 has been over budget for 15 min with 20+ real requests; the finding names the slowest phase, its share and the cache hit rate. `git.ts` keeps the same record for every git process the forge spawns (`git/env.ts`, `git/local.ts`), keyed `git <subcommand>` from a fixed list (never an argument, path or ref; anything else is `git other`), timed from before the spawn gate so a queue counts; a subcommand whose p95 passes its budget the same way (250 ms; 10 s for the pack-moving ones: clone, fetch, push, gc, repack, pack-objects and the like) files one issue naming it, its count, p50 and p95. `loop.ts` names the routes running across an event-loop stall in the `loop` log line; nothing is kept beyond that line. `loop_worst.ts` keeps the worst event-loop lag of the last 10 s (ten one-second slots fed by the 50 ms sampler) and every response's Server-Timing names it as `lag;dur`; `/healthz` answers it as `loopLagMs` to `Accept: application/json`, so a slow time to first byte with a small `app;dur` reads as a stall outside the handler.
Not yet: a synthetic probe for routes with no traffic (a client-written label would let anyone hide requests; it needs an admin-only door first), live route stats in the terminal and MCP (findings reach both doors as issues), browser timings, 24 h/7 d history, the board page, release before/after.
@@ -210,6 +210,16 @@
export function serverTiming(
  ].join(", ");
}
/**
 * `header` with the worst event-loop lag of the last 10 s appended as
 * `lag;dur=<ms>` (#10288): a request that waited on a loop someone else
 * blocked shows it here, though its own `app` was fast.
 */
export function withLag(header: string, lagMs: number): string {
  if (!Number.isFinite(lagMs) || lagMs < 0) return header;
  return `${header}, lag;dur=${lagMs.toFixed(1)}`;
}
/** One named stretch of a request, in milliseconds. */
export interface Phase {
  readonly name: string;
@@ -87,8 +87,13 @@
export function startDraining(log: Log, why: string, fields: Record<string, numb
 * Liveness: `ping` runs one trivial query against the database. However
 * long it takes, an answer is 200; only a throw is 503, logged when it
 * starts and when it ends.
 *
 * Given `loopLagMs` (the caller asked for JSON), the 200 is
 * `{"ok":true,"loopLagMs":n}`: the worst event-loop lag of the last 10 s
 * (`perf/loop_worst.ts`, #10288). Otherwise it stays the plain `ok` a
 * probe and a stranger hear (#2917).
 */
export function liveResponse(ping: () => unknown, log: Log): Response {
export function liveResponse(ping: () => unknown, log: Log, loopLagMs?: number): Response {
  try {
    ping();
  } catch (error) {
@@ -101,6 +106,8 @@
export function liveResponse(ping: () => unknown, log: Log): Response {
  }
  if (databaseDown) log.info("forge alive again: the database answers");
  databaseDown = false;
  if (loopLagMs !== undefined && Number.isFinite(loopLagMs))
    return Response.json({ ok: true, loopLagMs: Math.round(loopLagMs * 10) / 10 }, { status: 200 });
  return new Response("ok", { status: 200 });
}
@@ -480,6 +480,7 @@
import {
  noteStart,
  takePhases,
  serverTiming,
  withLag,
  takeDbTime,
  type RouteTiming,
} from "../core/route_timing.ts";
@@ -493,6 +494,7 @@
import { appSourcesPage } from "../web/pages/sources.ts";
import { createViewWriter } from "../perf/views_store.ts";
import { createReadWriter, readOf } from "../perf/reads.ts";
import { parseServerTiming } from "../perf/record.ts";
import { currentLoopLag, startLoopWorst } from "../perf/loop_worst.ts";
import { methodOf, noteUsage, roleOf, surfaceOf, takeUsage } from "./usage_tag.ts";
import { bearerChallenge, oauthRoutes } from "./oauth.ts";
import { flushAccess, recordAccess } from "./access_log.ts";
@@ -2357,6 +2359,8 @@
export async function serve(app: App): Promise<Servers> {
  const featureSchedule = startFeatureSchedule(app);
  const pullSchedule = startPullSchedule(app);
  const readWriter = createReadWriter(app.db, readLedger, app.log);
  // The worst event-loop lag of the last 10 s, on every response (#10288).
  startLoopWorst();
  const counted = (
    owner: App,
    request: Request,
@@ -2368,7 +2372,8 @@
export async function serve(app: App): Promise<Servers> {
    finishedStrangerDeep(owner, request);
    try {
      const header = serverTiming(ms, takeDbTime(request), takePhases(request));
      response.headers.set("server-timing", header);
      // `lag` is the loop's, not this request's: kept out of the record's phases.
      response.headers.set("server-timing", withLag(header, currentLoopLag()));
      const end = performance.now();
      const family = familyOf(request.headers.get("user-agent") ?? "");
      perfRecord.add(
@@ -2730,7 +2735,13 @@
async function answerGet(
  if (url.pathname === "/healthz") {
    noteUsage(request, { pattern: "/healthz", role: "anon" });
    const dbStart = performance.now();
    const live = liveResponse(() => app.db.query("select 1").get(), app.log);
    // `Accept: application/json` adds the loop's worst lag of the last 10 s (#10288).
    const wantsJson = (request.headers.get("accept") ?? "").includes("application/json");
    const live = liveResponse(
      () => app.db.query("select 1").get(),
      app.log,
      wantsJson ? currentLoopLag() : undefined,
    );
    noteDbTime(request, performance.now() - dbStart);
    // The release proof learns which release answered, old pod or new; a
    // stranger is told only that one did (#2917).
@@ -0,0 +1,100 @@
/**
 * The worst event-loop lag of the last ten seconds (#10288), written on every
 * response as `lag;dur=<ms>` and told by `/healthz` as `loopLagMs`. A request
 * whose `app;dur` is 4 ms but whose time to first byte is 300 ms waited on a
 * loop blocked by something else; this names how long that block was.
 *
 * Lag is the lateness `kernel/loop_lag.ts` measures: a timer asks to wake
 * every 50 ms, and how much later than asked it wakes is how long the loop
 * was busy. A block of B ms is read as B − (time already waited, 0–50 ms),
 * so at 50 ms the reading undercounts a block by at most one interval.
 *
 * The window is a ring of ten one-second slots, each the worst lag noted in
 * its second: `note` is O(1) (a division, a compare, two array writes) and
 * `worst` reads ten numbers, so a tick costs well under 0.1 ms. A stall
 * stays named for 9–10 s after the wake that saw it, then falls out.
 */
import { LAG_EVERY_MS, startLoopLag } from "../kernel/loop_lag.ts";
/** The window `worst` covers, ms. */
export const LAG_WINDOW_MS = 10_000;
/** One slot of the ring, ms: the window's resolution. */
      
        sentinelcrew
        2d ago
        
      
      The sub-0.1 ms tick cost is only asserted in prose here. Add a test that bounds it (see the review body).
    
export const LAG_SLOT_MS = 1_000;
export interface LoopWorst {
  /** A wake `lateMs` late, seen at `at` (ms, the clock `worst` reads). */
  note(lateMs: number, at: number): void;
  /** The worst lateness noted in the window ending at `at`, ms; 0 when none. */
  worst(at: number): number;
}
export function createLoopWorst(
  windowMs = LAG_WINDOW_MS,
  slotMs = LAG_SLOT_MS,
): LoopWorst {
  const n = Math.max(1, Math.round(windowMs / slotMs));
  // slot[i] is which second (at / slotMs, floored) max[i] holds; -1 is empty.
  const slot = new Float64Array(n).fill(-1);
  const max = new Float64Array(n);
  return {
    note(lateMs, at) {
      if (!Number.isFinite(lateMs) || lateMs < 0 || !Number.isFinite(at)) return;
      const s = Math.floor(at / slotMs);
      const i = ((s % n) + n) % n;
      if (slot[i] !== s) {
        slot[i] = s;
        max[i] = lateMs;
      } else if (lateMs > max[i]!) max[i] = lateMs;
    },
    worst(at) {
      const now = Math.floor(at / slotMs);
      let w = 0;
      for (let i = 0; i < n; i++)
        if (slot[i]! > now - n && slot[i]! <= now && max[i]! > w) w = max[i]!;
      return w;
    },
  };
}
/** The process's one window, fed by `startLoopWorst`'s timer and read by every response. */
export const loopWorst = createLoopWorst();
let sampling: (() => void) | null = null;
/** The clock the window is read on; a test injects one to step ten seconds at once. */
let windowClock: () => number = () => performance.now();
export interface LoopWorstOptions {
  /** The window's clock, ms; lateness is always measured on `performance.now`. */
  readonly clock?: () => number;
  /** How often the timer asks to wake, ms. */
  readonly everyMs?: number;
}
/**
 * Start the one sampler feeding `loopWorst` (idempotent: a second server in
 * the same process shares it). Its timer is unref'd, so it never holds a
 * test or a shutdown open. Returns the stop, which also restores the clock.
 */
export function startLoopWorst(options: LoopWorstOptions = {}): () => void {
  if (sampling === null) {
    if (options.clock !== undefined) windowClock = options.clock;
    const lag = startLoopLag(options.everyMs ?? LAG_EVERY_MS, () => performance.now(), (late) =>
      loopWorst.note(late, windowClock()),
    );
    sampling = lag.stop;
  }
  return stopLoopWorst;
}
/** Stop the sampler, if one runs, and put the window back on `performance.now`. */
export function stopLoopWorst(): void {
  sampling?.();
  sampling = null;
  windowClock = () => performance.now();
}
/** The worst lag of the window ending now, ms, for a header or `/healthz`. */
export function currentLoopLag(): number {
  return loopWorst.worst(windowClock());
}
@@ -6,6 +6,7 @@
import { join } from "node:path";
import { createApp, type App } from "../src/app.ts";
import { serve, type Servers } from "../src/http/server.ts";
import { seedAdmin } from "./helpers/admin.ts";
import { requestTiming } from "./helpers/request-timing.ts";
let dataDir = "";
let app: App, servers: Servers, bearer = "";
@@ -31,7 +32,7 @@
afterAll(async () => {
const basic = `Basic ${btoa("alice:correct-horse-battery")}`;
const phases = (res: Response) =>
  (res.headers.get("server-timing") ?? "").split(", ").map((p) => p.split(";")[0]!).filter((n) => n && n !== "app");
  requestTiming(res).split(", ").map((p) => p.split(";")[0]!).filter((n) => n && n !== "app");
for (const [path, read] of [
  ["/api/v1/tokens", "tokens"],
@@ -6,6 +6,7 @@
import { join } from "node:path";
import { createApp, type App } from "../src/app.ts";
import { serve, type Servers } from "../src/http/server.ts";
import { seedAdmin } from "./helpers/admin.ts";
import { requestTiming } from "./helpers/request-timing.ts";
let dataDir = "";
let app: App, servers: Servers, bearer = "";
@@ -30,7 +31,7 @@
afterAll(async () => {
});
const names = (res: Response) =>
  (res.headers.get("server-timing") ?? "").split(", ").map((p) => p.split(";")[0]!).filter(Boolean);
  requestTiming(res).split(", ").map((p) => p.split(";")[0]!).filter(Boolean);
for (const [path, read] of [["accounts", "accounts"], ["people", "people"], ["invites", "invites"], ["teams", "teams"]] as const) {
  test(`GET /admin/${path} names session, ${read}, render in order`, async () => {
@@ -9,6 +9,7 @@
import { createSession } from "../src/core/sessions.ts";
import { createUser } from "../src/core/users.ts";
import { serve, type Servers } from "../src/http/server.ts";
import { quietLogs } from "./helpers/globals.ts";
import { requestTiming } from "./helpers/request-timing.ts";
quietLogs();
@@ -49,7 +50,7 @@
afterAll(async () => {
async function phases(path: string): Promise<{ status: number; names: string[]; body: string }> {
  const res = await fetch(`${servers.url}${path}`, { headers: { cookie } });
  const body = await res.text();
  const names = (res.headers.get("server-timing") ?? "").split(", ").map((p) => p.split(";")[0]!);
  const names = requestTiming(res).split(", ").map((p) => p.split(";")[0]!);
  return { status: res.status, names: names.slice(names.indexOf("app") + 1), body };
}
@@ -9,6 +9,7 @@
import { createSession } from "../src/core/sessions.ts";
import { createUser } from "../src/core/users.ts";
import { serve, type Servers } from "../src/http/server.ts";
import { quietLogs } from "./helpers/globals.ts";
import { requestTiming } from "./helpers/request-timing.ts";
quietLogs();
@@ -49,7 +50,7 @@
afterAll(async () => {
async function phases(path: string): Promise<{ status: number; names: string[]; body: string }> {
  const res = await fetch(`${servers.url}${path}`, { headers: { cookie } });
  const body = await res.text();
  const names = (res.headers.get("server-timing") ?? "").split(", ").map((p) => p.split(";")[0]!);
  const names = requestTiming(res).split(", ").map((p) => p.split(";")[0]!);
  return { status: res.status, names: names.slice(names.indexOf("app") + 1), body };
}
@@ -11,6 +11,7 @@
import { createSession } from "../src/core/sessions.ts";
import { createUser } from "../src/core/users.ts";
import { serve, type Servers } from "../src/http/server.ts";
import { quietLogs } from "./helpers/globals.ts";
import { requestTiming } from "./helpers/request-timing.ts";
quietLogs();
@@ -61,7 +62,7 @@
afterAll(async () => {
async function phases(path: string): Promise<{ status: number; names: string[]; body: string }> {
  const res = await fetch(`${servers.url}${path}`, { headers: { cookie } });
  const body = await res.text();
  const names = (res.headers.get("server-timing") ?? "").split(", ").map((p) => p.split(";")[0]!);
  const names = requestTiming(res).split(", ").map((p) => p.split(";")[0]!);
  return { status: res.status, names: names.slice(names.indexOf("app") + 1), body };
}
@@ -9,6 +9,7 @@
import { createSession } from "../src/core/sessions.ts";
import { createUser } from "../src/core/users.ts";
import { serve, type Servers } from "../src/http/server.ts";
import { quietLogs } from "./helpers/globals.ts";
import { requestTiming } from "./helpers/request-timing.ts";
quietLogs();
@@ -49,7 +50,7 @@
afterAll(async () => {
async function phases(path: string): Promise<{ status: number; names: string[]; body: string }> {
  const res = await fetch(`${servers.url}${path}`, { headers: { cookie } });
  const body = await res.text();
  const names = (res.headers.get("server-timing") ?? "").split(", ").map((p) => p.split(";")[0]!);
  const names = requestTiming(res).split(", ").map((p) => p.split(";")[0]!);
  return { status: res.status, names: names.slice(names.indexOf("app") + 1), body };
}
@@ -9,6 +9,7 @@
import { createSession } from "../src/core/sessions.ts";
import { createUser } from "../src/core/users.ts";
import { serve, type Servers } from "../src/http/server.ts";
import { quietLogs } from "./helpers/globals.ts";
import { requestTiming } from "./helpers/request-timing.ts";
quietLogs();
@@ -49,7 +50,7 @@
afterAll(async () => {
async function phases(path: string): Promise<{ status: number; names: string[]; body: string }> {
  const res = await fetch(`${servers.url}${path}`, { headers: { cookie } });
  const body = await res.text();
  const names = (res.headers.get("server-timing") ?? "").split(", ").map((p) => p.split(";")[0]!);
  const names = requestTiming(res).split(", ").map((p) => p.split(";")[0]!);
  return { status: res.status, names: names.slice(names.indexOf("app") + 1), body };
}
@@ -8,6 +8,7 @@
import { createSession } from "../src/core/sessions.ts";
import { createUser } from "../src/core/users.ts";
import { serve, type Servers } from "../src/http/server.ts";
import { quietLogs } from "./helpers/globals.ts";
import { requestTiming } from "./helpers/request-timing.ts";
quietLogs();
@@ -46,7 +47,7 @@
afterAll(async () => {
async function phases(path: string): Promise<{ status: number; names: string[]; body: string }> {
  const res = await fetch(`${servers.url}${path}`, { headers: { cookie } });
  const body = await res.text();
  const names = (res.headers.get("server-timing") ?? "").split(", ").map((p) => p.split(";")[0]!);
  const names = requestTiming(res).split(", ").map((p) => p.split(";")[0]!);
  return { status: res.status, names: names.slice(names.indexOf("app") + 1), body };
}
@@ -9,6 +9,7 @@
import { createSession } from "../src/core/sessions.ts";
import { createUser } from "../src/core/users.ts";
import { serve, type Servers } from "../src/http/server.ts";
import { quietLogs } from "./helpers/globals.ts";
import { requestTiming } from "./helpers/request-timing.ts";
quietLogs();
@@ -43,7 +44,7 @@
afterAll(async () => {
async function phases(path: string, withCookie = true): Promise<{ status: number; names: string[]; body: string }> {
  const res = await fetch(`${servers.url}${path}`, { headers: withCookie ? { cookie } : {} });
  const body = await res.text();
  const names = (res.headers.get("server-timing") ?? "").split(", ").map((p) => p.split(";")[0]!);
  const names = requestTiming(res).split(", ").map((p) => p.split(";")[0]!);
  return { status: res.status, names: names.slice(names.indexOf("app") + 1), body };
}
@@ -9,6 +9,7 @@
import { createSession } from "../src/core/sessions.ts";
import { createUser } from "../src/core/users.ts";
import { serve, type Servers } from "../src/http/server.ts";
import { quietLogs } from "./helpers/globals.ts";
import { requestTiming } from "./helpers/request-timing.ts";
quietLogs();
@@ -49,7 +50,7 @@
afterAll(async () => {
async function phases(path: string): Promise<{ status: number; names: string[]; body: string }> {
  const res = await fetch(`${servers.url}${path}`, { headers: { cookie } });
  const body = await res.text();
  const names = (res.headers.get("server-timing") ?? "").split(", ").map((p) => p.split(";")[0]!);
  const names = requestTiming(res).split(", ").map((p) => p.split(";")[0]!);
  return { status: res.status, names: names.slice(names.indexOf("app") + 1), body };
}
@@ -9,6 +9,7 @@
import { createSession } from "../src/core/sessions.ts";
import { createUser } from "../src/core/users.ts";
import { serve, type Servers } from "../src/http/server.ts";
import { quietLogs } from "./helpers/globals.ts";
import { requestTiming } from "./helpers/request-timing.ts";
quietLogs();
@@ -49,7 +50,7 @@
afterAll(async () => {
async function phases(path: string): Promise<{ status: number; names: string[]; body: string }> {
  const res = await fetch(`${servers.url}${path}`, { headers: { cookie } });
  const body = await res.text();
  const names = (res.headers.get("server-timing") ?? "").split(", ").map((p) => p.split(";")[0]!);
  const names = requestTiming(res).split(", ").map((p) => p.split(";")[0]!);
  return { status: res.status, names: names.slice(names.indexOf("app") + 1), body };
}
@@ -10,6 +10,7 @@
import { createSession } from "../src/core/sessions.ts";
import { createUser } from "../src/core/users.ts";
import { serve, type Servers } from "../src/http/server.ts";
import { quietLogs } from "./helpers/globals.ts";
import { requestTiming } from "./helpers/request-timing.ts";
quietLogs();
@@ -50,7 +51,7 @@
afterAll(async () => {
async function phases(path: string): Promise<{ status: number; names: string[]; body: string }> {
  const res = await fetch(`${servers.url}${path}`, { headers: { cookie } });
  const body = await res.text();
  const names = (res.headers.get("server-timing") ?? "").split(", ").map((p) => p.split(";")[0]!);
  const names = requestTiming(res).split(", ").map((p) => p.split(";")[0]!);
  return { status: res.status, names: names.slice(names.indexOf("app") + 1), body };
}
@@ -9,6 +9,7 @@
import { createSession } from "../src/core/sessions.ts";
import { createUser } from "../src/core/users.ts";
import { serve, type Servers } from "../src/http/server.ts";
import { quietLogs } from "./helpers/globals.ts";
import { requestTiming } from "./helpers/request-timing.ts";
quietLogs();
@@ -57,7 +58,7 @@
afterAll(async () => {
async function phases(path: string): Promise<{ status: number; names: string[]; body: string }> {
  const res = await fetch(`${servers.url}${path}`, { headers: { cookie } });
  const body = await res.text();
  const names = (res.headers.get("server-timing") ?? "").split(", ").map((p) => p.split(";")[0]!);
  const names = requestTiming(res).split(", ").map((p) => p.split(";")[0]!);
  return { status: res.status, names: names.slice(names.indexOf("app") + 1), body };
}
@@ -9,6 +9,7 @@
import { createSession } from "../src/core/sessions.ts";
import { createUser } from "../src/core/users.ts";
import { serve, type Servers } from "../src/http/server.ts";
import { quietLogs } from "./helpers/globals.ts";
import { requestTiming } from "./helpers/request-timing.ts";
quietLogs();
@@ -54,7 +55,7 @@
afterAll(async () => {
async function phases(path: string): Promise<{ status: number; names: string[]; body: string }> {
  const res = await fetch(`${servers.url}${path}`, { headers: { cookie } });
  const body = await res.text();
  const names = (res.headers.get("server-timing") ?? "").split(", ").map((p) => p.split(";")[0]!);
  const names = requestTiming(res).split(", ").map((p) => p.split(";")[0]!);
  return { status: res.status, names: names.slice(names.indexOf("app") + 1), body };
}
@@ -9,6 +9,7 @@
import { createSession } from "../src/core/sessions.ts";
import { createUser } from "../src/core/users.ts";
import { serve, type Servers } from "../src/http/server.ts";
import { quietLogs } from "./helpers/globals.ts";
import { requestTiming } from "./helpers/request-timing.ts";
quietLogs();
@@ -49,7 +50,7 @@
afterAll(async () => {
async function phases(path: string): Promise<{ status: number; names: string[]; body: string }> {
  const res = await fetch(`${servers.url}${path}`, { headers: { cookie } });
  const body = await res.text();
  const names = (res.headers.get("server-timing") ?? "").split(", ").map((p) => p.split(";")[0]!);
  const names = requestTiming(res).split(", ").map((p) => p.split(";")[0]!);
  return { status: res.status, names: names.slice(names.indexOf("app") + 1), body };
}
@@ -11,6 +11,7 @@
import { createSession } from "../src/core/sessions.ts";
import { createUser, getUserById } from "../src/core/users.ts";
import { serve, type Servers } from "../src/http/server.ts";
import { quietLogs } from "./helpers/globals.ts";
import { requestTiming } from "./helpers/request-timing.ts";
quietLogs();
@@ -51,7 +52,7 @@
afterAll(async () => {
async function phases(path: string): Promise<{ status: number; names: string[]; body: string }> {
  const res = await fetch(`${servers.url}${path}`, { headers: { cookie } });
  const body = await res.text();
  const names = (res.headers.get("server-timing") ?? "").split(", ").map((p) => p.split(";")[0]!);
  const names = requestTiming(res).split(", ").map((p) => p.split(";")[0]!);
  return { status: res.status, names: names.slice(names.indexOf("app") + 1), body };
}
@@ -10,6 +10,7 @@
import { createSession } from "../src/core/sessions.ts";
import { createUser } from "../src/core/users.ts";
import { serve, type Servers } from "../src/http/server.ts";
import { quietLogs } from "./helpers/globals.ts";
import { requestTiming } from "./helpers/request-timing.ts";
quietLogs();
@@ -52,7 +53,7 @@
afterAll(async () => {
async function phases(path: string): Promise<{ status: number; names: string[]; body: string }> {
  const res = await fetch(`${servers.url}${path}`, { headers: { cookie } });
  const body = await res.text();
  const names = (res.headers.get("server-timing") ?? "").split(", ").map((p) => p.split(";")[0]!);
  const names = requestTiming(res).split(", ").map((p) => p.split(";")[0]!);
  return { status: res.status, names: names.slice(names.indexOf("app") + 1), body };
}
@@ -9,6 +9,7 @@
import { createSession } from "../src/core/sessions.ts";
import { createUser } from "../src/core/users.ts";
import { serve, type Servers } from "../src/http/server.ts";
import { quietLogs } from "./helpers/globals.ts";
import { requestTiming } from "./helpers/request-timing.ts";
quietLogs();
@@ -65,7 +66,7 @@
async function phases(
): Promise<{ status: number; names: string[]; body: string }> {
  const res = await fetch(`${servers.url}${path}`, { headers });
  const body = await res.text();
  const names = (res.headers.get("server-timing") ?? "").split(", ").map((p) => p.split(";")[0]!);
  const names = requestTiming(res).split(", ").map((p) => p.split(";")[0]!);
  return { status: res.status, names: names.slice(names.indexOf("app") + 1), body };
}
@@ -8,6 +8,7 @@
import { createSession } from "../src/core/sessions.ts";
import { createUser } from "../src/core/users.ts";
import { serve, type Servers } from "../src/http/server.ts";
import { quietLogs } from "./helpers/globals.ts";
import { requestTiming } from "./helpers/request-timing.ts";
quietLogs();
@@ -41,7 +42,7 @@
afterAll(async () => {
test("the API explore read names session, explore and render in order", async () => {
  const res = await fetch(`${servers.url}/api/v1/explore`, { headers: { cookie } });
  const body = JSON.parse(await res.text());
  const names = (res.headers.get("server-timing") ?? "").split(", ").map((p) => p.split(";")[0]!);
  const names = requestTiming(res).split(", ").map((p) => p.split(";")[0]!);
  expect(res.status).toBe(200);
  expect(names.slice(names.indexOf("app") + 1)).toEqual(["session", "explore", "render"]);
  expect(Array.isArray(body.items)).toBe(true);
@@ -8,6 +8,7 @@
import { createSession } from "../src/core/sessions.ts";
import { createUser } from "../src/core/users.ts";
import { serve, type Servers } from "../src/http/server.ts";
import { quietLogs } from "./helpers/globals.ts";
import { requestTiming } from "./helpers/request-timing.ts";
quietLogs();
@@ -45,7 +46,7 @@
afterAll(async () => {
async function phases(path: string, withCookie = true) {
  const res = await fetch(`${servers.url}${path}`, { headers: withCookie ? { cookie } : {} });
  const body = await res.text();
  const names = (res.headers.get("server-timing") ?? "").split(", ").map((p) => p.split(";")[0]!);
  const names = requestTiming(res).split(", ").map((p) => p.split(";")[0]!);
  return { status: res.status, names: names.slice(names.indexOf("app") + 1), body };
}
@@ -9,6 +9,7 @@
import { createSession } from "../src/core/sessions.ts";
import { createUser } from "../src/core/users.ts";
import { serve, type Servers } from "../src/http/server.ts";
import { quietLogs } from "./helpers/globals.ts";
import { requestTiming } from "./helpers/request-timing.ts";
quietLogs();
@@ -49,7 +50,7 @@
afterAll(async () => {
async function phases(path: string): Promise<{ status: number; names: string[]; body: string }> {
  const res = await fetch(`${servers.url}${path}`, { headers: { cookie } });
  const body = await res.text();
  const names = (res.headers.get("server-timing") ?? "").split(", ").map((p) => p.split(";")[0]!);
  const names = requestTiming(res).split(", ").map((p) => p.split(";")[0]!);
  return { status: res.status, names: names.slice(names.indexOf("app") + 1), body };
}
@@ -9,6 +9,7 @@
import { createSession } from "../src/core/sessions.ts";
import { createUser } from "../src/core/users.ts";
import { serve, type Servers } from "../src/http/server.ts";
import { quietLogs } from "./helpers/globals.ts";
import { requestTiming } from "./helpers/request-timing.ts";
quietLogs();
@@ -56,7 +57,7 @@
afterAll(async () => {
async function phases(path: string): Promise<{ status: number; names: string[]; body: string }> {
  const res = await fetch(`${servers.url}${path}`, { headers: { cookie } });
  const body = await res.text();
  const names = (res.headers.get("server-timing") ?? "").split(", ").map((p) => p.split(";")[0]!);
  const names = requestTiming(res).split(", ").map((p) => p.split(";")[0]!);
  return { status: res.status, names: names.slice(names.indexOf("app") + 1), body };
}
@@ -8,6 +8,7 @@
import { createSession } from "../src/core/sessions.ts";
import { createUser } from "../src/core/users.ts";
import { serve, type Servers } from "../src/http/server.ts";
import { quietLogs } from "./helpers/globals.ts";
import { requestTiming } from "./helpers/request-timing.ts";
quietLogs();
@@ -46,7 +47,7 @@
afterAll(async () => {
async function phases(path: string): Promise<{ status: number; names: string[]; body: string }> {
  const res = await fetch(`${servers.url}${path}`, { headers: { cookie } });
  const body = await res.text();
  const names = (res.headers.get("server-timing") ?? "").split(", ").map((p) => p.split(";")[0]!);
  const names = requestTiming(res).split(", ").map((p) => p.split(";")[0]!);
  return { status: res.status, names: names.slice(names.indexOf("app") + 1), body };
}
@@ -8,6 +8,7 @@
import { createSession } from "../src/core/sessions.ts";
import { createUser } from "../src/core/users.ts";
import { serve, type Servers } from "../src/http/server.ts";
import { quietLogs } from "./helpers/globals.ts";
import { requestTiming } from "./helpers/request-timing.ts";
quietLogs();
@@ -46,7 +47,7 @@
afterAll(async () => {
async function phases(path: string): Promise<{ status: number; names: string[]; body: string }> {
  const res = await fetch(`${servers.url}${path}`, { headers: { cookie } });
  const body = await res.text();
  const names = (res.headers.get("server-timing") ?? "").split(", ").map((p) => p.split(";")[0]!);
  const names = requestTiming(res).split(", ").map((p) => p.split(";")[0]!);
  return { status: res.status, names: names.slice(names.indexOf("app") + 1), body };
}
@@ -60,6 +61,6 @@
test("the profile read names session, user, render in order", async () => {
test("an anonymous read is a 401 naming session", async () => {
  const res = await fetch(`${servers.url}/api/v1/user`);
  expect(res.status).toBe(401);
  const names = (res.headers.get("server-timing") ?? "").split(", ").map((p) => p.split(";")[0]!);
  const names = requestTiming(res).split(", ").map((p) => p.split(";")[0]!);
  expect(names.slice(names.indexOf("app") + 1)).toEqual(["session"]);
});
@@ -11,6 +11,7 @@
import { createSession } from "../src/core/sessions.ts";
import { createUser } from "../src/core/users.ts";
import { serve, type Servers } from "../src/http/server.ts";
import { quietLogs } from "./helpers/globals.ts";
import { requestTiming } from "./helpers/request-timing.ts";
quietLogs();
@@ -63,7 +64,7 @@
afterAll(async () => {
async function phases(path: string): Promise<{ status: number; names: string[]; body: string }> {
  const res = await fetch(`${servers.url}${path}`, { headers: { cookie } });
  const body = await res.text();
  const names = (res.headers.get("server-timing") ?? "").split(", ").map((p) => p.split(";")[0]!);
  const names = requestTiming(res).split(", ").map((p) => p.split(";")[0]!);
  return { status: res.status, names: names.slice(names.indexOf("app") + 1), body };
}
@@ -9,6 +9,7 @@
import { newFakeState, serveFakeForge, type FakeForge } from "./fake-origin.ts";
import { seedAdmin } from "./helpers/admin.ts";
import { quietLogs } from "./helpers/globals.ts";
import { proveAll } from "./helpers/verified.ts";
import { requestTiming } from "./helpers/request-timing.ts";
quietLogs();
@@ -54,7 +55,7 @@
afterAll(async () => {
async function get(path: string): Promise<{ status: number; names: string[]; body: string }> {
  const res = await fetch(`${servers.url}${path}`, { headers: { authorization: auth } });
  const body = await res.text();
  const names = (res.headers.get("server-timing") ?? "").split(", ").map((p) => p.split(";")[0]!);
  const names = requestTiming(res).split(", ").map((p) => p.split(";")[0]!);
  return { status: res.status, names: names.slice(names.indexOf("app") + 1), body };
}
@@ -9,6 +9,7 @@
import { createToken } from "../src/core/tokens.ts";
import { createUser } from "../src/core/users.ts";
import { serve, type Servers } from "../src/http/server.ts";
import { quietLogs } from "./helpers/globals.ts";
import { requestTiming } from "./helpers/request-timing.ts";
quietLogs();
@@ -51,7 +52,7 @@
afterAll(async () => {
async function phases(path: string): Promise<{ status: number; names: string[]; res: Response }> {
  const res = await fetch(`${servers.url}${path}`, { headers: { authorization: `Bearer ${token}` } });
  await res.text();
  const names = (res.headers.get("server-timing") ?? "").split(", ").map((p) => p.split(";")[0]!);
  const names = requestTiming(res).split(", ").map((p) => p.split(";")[0]!);
  return { status: res.status, names: names.slice(names.indexOf("app") + 1), res };
}
@@ -10,6 +10,7 @@
import { createSession } from "../src/core/sessions.ts";
import { createUser } from "../src/core/users.ts";
import { serve, type Servers } from "../src/http/server.ts";
import { quietLogs } from "./helpers/globals.ts";
import { requestTiming } from "./helpers/request-timing.ts";
quietLogs();
@@ -67,7 +68,7 @@
afterAll(async () => {
async function phases(path: string): Promise<{ status: number; names: string[]; body: string }> {
  const res = await fetch(`${servers.url}${path}`, { headers: { cookie } });
  const body = await res.text();
  const names = (res.headers.get("server-timing") ?? "").split(", ").map((p) => p.split(";")[0]!);
  const names = requestTiming(res).split(", ").map((p) => p.split(";")[0]!);
  return { status: res.status, names: names.slice(names.indexOf("app") + 1), body };
}
@@ -8,6 +8,7 @@
import { createSession } from "../src/core/sessions.ts";
import { createUser } from "../src/core/users.ts";
import { serve, type Servers } from "../src/http/server.ts";
import { quietLogs } from "./helpers/globals.ts";
import { requestTiming } from "./helpers/request-timing.ts";
quietLogs();
@@ -46,7 +47,7 @@
afterAll(async () => {
async function phases(path: string): Promise<{ status: number; names: string[]; body: string }> {
  const res = await fetch(`${servers.url}${path}`, { headers: { cookie } });
  const body = await res.text();
  const names = (res.headers.get("server-timing") ?? "").split(", ").map((p) => p.split(";")[0]!);
  const names = requestTiming(res).split(", ").map((p) => p.split(";")[0]!);
  return { status: res.status, names: names.slice(names.indexOf("app") + 1), body };
}
@@ -9,6 +9,7 @@
import { createSession } from "../src/core/sessions.ts";
import { createUser } from "../src/core/users.ts";
import { serve, type Servers } from "../src/http/server.ts";
import { quietLogs } from "./helpers/globals.ts";
import { requestTiming } from "./helpers/request-timing.ts";
quietLogs();
@@ -49,7 +50,7 @@
afterAll(async () => {
async function phases(path: string): Promise<{ status: number; names: string[]; body: string }> {
  const res = await fetch(`${servers.url}${path}`, { headers: { cookie } });
  const body = await res.text();
  const names = (res.headers.get("server-timing") ?? "").split(", ").map((p) => p.split(";")[0]!);
  const names = requestTiming(res).split(", ").map((p) => p.split(";")[0]!);
  return { status: res.status, names: names.slice(names.indexOf("app") + 1), body };
}
@@ -9,6 +9,7 @@
import { createSession } from "../src/core/sessions.ts";
import { createUser } from "../src/core/users.ts";
import { serve, type Servers } from "../src/http/server.ts";
import { quietLogs } from "./helpers/globals.ts";
import { requestTiming } from "./helpers/request-timing.ts";
quietLogs();
@@ -49,7 +50,7 @@
afterAll(async () => {
async function phases(path: string): Promise<{ status: number; names: string[]; body: string }> {
  const res = await fetch(`${servers.url}${path}`, { headers: { cookie } });
  const body = await res.text();
  const names = (res.headers.get("server-timing") ?? "").split(", ").map((p) => p.split(";")[0]!);
  const names = requestTiming(res).split(", ").map((p) => p.split(";")[0]!);
  return { status: res.status, names: names.slice(names.indexOf("app") + 1), body };
}
@@ -10,6 +10,7 @@
import { createSession } from "../src/core/sessions.ts";
import { createUser } from "../src/core/users.ts";
import { serve, type Servers } from "../src/http/server.ts";
import { quietLogs } from "./helpers/globals.ts";
import { requestTiming } from "./helpers/request-timing.ts";
quietLogs();
@@ -67,7 +68,7 @@
afterAll(async () => {
async function phases(path: string): Promise<{ status: number; names: string[]; body: string }> {
  const res = await fetch(`${servers.url}${path}`, { headers: { cookie } });
  const body = await res.text();
  const names = (res.headers.get("server-timing") ?? "").split(", ").map((p) => p.split(";")[0]!);
  const names = requestTiming(res).split(", ").map((p) => p.split(";")[0]!);
  return { status: res.status, names: names.slice(names.indexOf("app") + 1), body };
}
@@ -9,6 +9,7 @@
import { createSession } from "../src/core/sessions.ts";
import { createUser } from "../src/core/users.ts";
import { serve, type Servers } from "../src/http/server.ts";
import { quietLogs } from "./helpers/globals.ts";
import { requestTiming } from "./helpers/request-timing.ts";
quietLogs();
@@ -49,7 +50,7 @@
afterAll(async () => {
async function phases(path: string): Promise<{ status: number; names: string[]; body: string }> {
  const res = await fetch(`${servers.url}${path}`, { headers: { cookie } });
  const body = await res.text();
  const names = (res.headers.get("server-timing") ?? "").split(", ").map((p) => p.split(";")[0]!);
  const names = requestTiming(res).split(", ").map((p) => p.split(";")[0]!);
  return { status: res.status, names: names.slice(names.indexOf("app") + 1), body };
}
@@ -9,6 +9,7 @@
import { createSession } from "../src/core/sessions.ts";
import { createUser } from "../src/core/users.ts";
import { serve, type Servers } from "../src/http/server.ts";
import { quietLogs } from "./helpers/globals.ts";
import { requestTiming } from "./helpers/request-timing.ts";
quietLogs();
@@ -49,7 +50,7 @@
afterAll(async () => {
async function phases(path: string): Promise<{ status: number; names: string[]; body: string }> {
  const res = await fetch(`${servers.url}${path}`, { headers: { cookie } });
  const body = await res.text();
  const names = (res.headers.get("server-timing") ?? "").split(", ").map((p) => p.split(";")[0]!);
  const names = requestTiming(res).split(", ").map((p) => p.split(";")[0]!);
  return { status: res.status, names: names.slice(names.indexOf("app") + 1), body };
}
@@ -10,6 +10,7 @@
import { createSession } from "../src/core/sessions.ts";
import { createUser } from "../src/core/users.ts";
import { serve, type Servers } from "../src/http/server.ts";
import { quietLogs } from "./helpers/globals.ts";
import { requestTiming } from "./helpers/request-timing.ts";
quietLogs();
@@ -67,7 +68,7 @@
afterAll(async () => {
async function phases(path: string): Promise<{ status: number; names: string[]; body: string }> {
  const res = await fetch(`${servers.url}${path}`, { headers: { cookie } });
  const body = await res.text();
  const names = (res.headers.get("server-timing") ?? "").split(", ").map((p) => p.split(";")[0]!);
  const names = requestTiming(res).split(", ").map((p) => p.split(";")[0]!);
  return { status: res.status, names: names.slice(names.indexOf("app") + 1), body };
}
@@ -13,6 +13,7 @@
import { createUser, type User } from "../src/core/users.ts";
import { serve, type Servers } from "../src/http/server.ts";
import { expectWork, requestStatements } from "./helpers/work.ts";
import { quietLogs } from "./helpers/globals.ts";
import { requestTiming } from "./helpers/request-timing.ts";
quietLogs();
@@ -76,7 +77,7 @@
afterAll(async () => {
async function phases(path: string): Promise<{ status: number; names: string[]; body: string }> {
  const res = await fetch(`${servers.url}${path}`, { headers: { cookie } });
  const body = await res.text();
  const names = (res.headers.get("server-timing") ?? "").split(", ").map((p) => p.split(";")[0]!);
  const names = requestTiming(res).split(", ").map((p) => p.split(";")[0]!);
  return { status: res.status, names: names.slice(names.indexOf("app") + 1), body };
}
@@ -9,6 +9,7 @@
import { createSession } from "../src/core/sessions.ts";
import { createUser } from "../src/core/users.ts";
import { serve, type Servers } from "../src/http/server.ts";
import { quietLogs } from "./helpers/globals.ts";
import { requestTiming } from "./helpers/request-timing.ts";
quietLogs();
@@ -49,7 +50,7 @@
afterAll(async () => {
async function phases(path: string): Promise<{ status: number; names: string[]; body: string }> {
  const res = await fetch(`${servers.url}${path}`, { headers: { cookie } });
  const body = await res.text();
  const names = (res.headers.get("server-timing") ?? "").split(", ").map((p) => p.split(";")[0]!);
  const names = requestTiming(res).split(", ").map((p) => p.split(";")[0]!);
  return { status: res.status, names: names.slice(names.indexOf("app") + 1), body };
}
@@ -8,6 +8,7 @@
import { createSession } from "../src/core/sessions.ts";
import { createUser } from "../src/core/users.ts";
import { serve, type Servers } from "../src/http/server.ts";
import { quietLogs } from "./helpers/globals.ts";
import { requestTiming } from "./helpers/request-timing.ts";
quietLogs();
@@ -46,7 +47,7 @@
afterAll(async () => {
async function phases(path: string): Promise<{ status: number; names: string[]; body: string }> {
  const res = await fetch(`${servers.url}${path}`, { headers: { cookie } });
  const body = await res.text();
  const names = (res.headers.get("server-timing") ?? "").split(", ").map((p) => p.split(";")[0]!);
  const names = requestTiming(res).split(", ").map((p) => p.split(";")[0]!);
  return { status: res.status, names: names.slice(names.indexOf("app") + 1), body };
}
@@ -10,6 +10,7 @@
import { createSession } from "../src/core/sessions.ts";
import { createUser } from "../src/core/users.ts";
import { serve, type Servers } from "../src/http/server.ts";
import { quietLogs } from "./helpers/globals.ts";
import { requestTiming } from "./helpers/request-timing.ts";
quietLogs();
@@ -67,7 +68,7 @@
afterAll(async () => {
async function phases(path: string): Promise<{ status: number; names: string[]; body: string }> {
  const res = await fetch(`${servers.url}${path}`, { headers: { cookie } });
  const body = await res.text();
  const names = (res.headers.get("server-timing") ?? "").split(", ").map((p) => p.split(";")[0]!);
  const names = requestTiming(res).split(", ").map((p) => p.split(";")[0]!);
  return { status: res.status, names: names.slice(names.indexOf("app") + 1), body };
}
@@ -10,6 +10,7 @@
import { createSession } from "../src/core/sessions.ts";
import { createUser } from "../src/core/users.ts";
import { serve, type Servers } from "../src/http/server.ts";
import { quietLogs } from "./helpers/globals.ts";
import { requestTiming } from "./helpers/request-timing.ts";
quietLogs();
@@ -52,7 +53,7 @@
afterAll(async () => {
async function phases(path: string): Promise<{ status: number; names: string[]; body: string }> {
  const res = await fetch(`${servers.url}${path}`, { headers: { cookie } });
  const body = await res.text();
  const names = (res.headers.get("server-timing") ?? "").split(", ").map((p) => p.split(";")[0]!);
  const names = requestTiming(res).split(", ").map((p) => p.split(";")[0]!);
  return { status: res.status, names: names.slice(names.indexOf("app") + 1), body };
}
@@ -8,6 +8,7 @@
import { createSession } from "../src/core/sessions.ts";
import { createUser } from "../src/core/users.ts";
import { serve, type Servers } from "../src/http/server.ts";
import { quietLogs } from "./helpers/globals.ts";
import { requestTiming } from "./helpers/request-timing.ts";
quietLogs();
@@ -46,7 +47,7 @@
afterAll(async () => {
async function phases(path: string): Promise<{ status: number; names: string[]; body: string }> {
  const res = await fetch(`${servers.url}${path}`, { headers: { cookie } });
  const body = await res.text();
  const names = (res.headers.get("server-timing") ?? "").split(", ").map((p) => p.split(";")[0]!);
  const names = requestTiming(res).split(", ").map((p) => p.split(";")[0]!);
  return { status: res.status, names: names.slice(names.indexOf("app") + 1), body };
}
@@ -6,6 +6,7 @@
import { join } from "node:path";
import { createApp, type App } from "../src/app.ts";
import { serve, type Servers } from "../src/http/server.ts";
import { quietLogs } from "./helpers/globals.ts";
import { requestTiming } from "./helpers/request-timing.ts";
quietLogs();
@@ -32,7 +33,7 @@
afterAll(async () => {
async function phases(path: string): Promise<{ status: number; names: string[]; body: string }> {
  const res = await fetch(`${servers.url}${path}`);
  const body = await res.text();
  const names = (res.headers.get("server-timing") ?? "").split(", ").map((p) => p.split(";")[0]!);
  const names = requestTiming(res).split(", ").map((p) => p.split(";")[0]!);
  return { status: res.status, names: names.slice(names.indexOf("app") + 1), body };
}
@@ -9,6 +9,7 @@
import { createSession } from "../src/core/sessions.ts";
import { createUser } from "../src/core/users.ts";
import { serve, type Servers } from "../src/http/server.ts";
import { quietLogs } from "./helpers/globals.ts";
import { requestTiming } from "./helpers/request-timing.ts";
quietLogs();
@@ -54,7 +55,7 @@
afterAll(async () => {
async function phases(path: string): Promise<{ status: number; names: string[]; body: string }> {
  const res = await fetch(`${servers.url}${path}`, { headers: { cookie } });
  const body = await res.text();
  const names = (res.headers.get("server-timing") ?? "").split(", ").map((p) => p.split(";")[0]!);
  const names = requestTiming(res).split(", ").map((p) => p.split(";")[0]!);
  return { status: res.status, names: names.slice(names.indexOf("app") + 1), body };
}
@@ -10,6 +10,7 @@
import { createSession } from "../src/core/sessions.ts";
import { createUser } from "../src/core/users.ts";
import { serve, type Servers } from "../src/http/server.ts";
import { quietLogs } from "./helpers/globals.ts";
import { requestTiming } from "./helpers/request-timing.ts";
quietLogs();
@@ -67,7 +68,7 @@
afterAll(async () => {
async function phases(path: string): Promise<{ status: number; names: string[]; body: string }> {
  const res = await fetch(`${servers.url}${path}`, { headers: { cookie } });
  const body = await res.text();
  const names = (res.headers.get("server-timing") ?? "").split(", ").map((p) => p.split(";")[0]!);
  const names = requestTiming(res).split(", ").map((p) => p.split(";")[0]!);
  return { status: res.status, names: names.slice(names.indexOf("app") + 1), body };
}
@@ -9,6 +9,7 @@
import { createSession } from "../src/core/sessions.ts";
import { createUser } from "../src/core/users.ts";
import { serve, type Servers } from "../src/http/server.ts";
import { quietLogs } from "./helpers/globals.ts";
import { requestTiming } from "./helpers/request-timing.ts";
quietLogs();
@@ -49,7 +50,7 @@
afterAll(async () => {
async function phases(path: string): Promise<{ status: number; names: string[]; body: string }> {
  const res = await fetch(`${servers.url}${path}`, { headers: { cookie } });
  const body = await res.text();
  const names = (res.headers.get("server-timing") ?? "").split(", ").map((p) => p.split(";")[0]!);
  const names = requestTiming(res).split(", ").map((p) => p.split(";")[0]!);
  return { status: res.status, names: names.slice(names.indexOf("app") + 1), body };
}
@@ -9,6 +9,7 @@
import { createSession } from "../src/core/sessions.ts";
import { createUser } from "../src/core/users.ts";
import { serve, type Servers } from "../src/http/server.ts";
import { quietLogs } from "./helpers/globals.ts";
import { requestTiming } from "./helpers/request-timing.ts";
quietLogs();
@@ -49,7 +50,7 @@
afterAll(async () => {
async function phases(path: string): Promise<{ status: number; names: string[]; body: string }> {
  const res = await fetch(`${servers.url}${path}`, { headers: { cookie } });
  const body = await res.text();
  const names = (res.headers.get("server-timing") ?? "").split(", ").map((p) => p.split(";")[0]!);
  const names = requestTiming(res).split(", ").map((p) => p.split(";")[0]!);
  return { status: res.status, names: names.slice(names.indexOf("app") + 1), body };
}
@@ -12,6 +12,7 @@
import { serve, type Servers } from "../src/http/server.ts";
import { writeWave, type Wave } from "../src/story/wave.ts";
import { quietLogs } from "./helpers/globals.ts";
import { mergedPull, waveNaming } from "./helpers/wave-pulls.ts";
import { requestTiming } from "./helpers/request-timing.ts";
quietLogs();
@@ -113,7 +114,7 @@
async function get(path: string, withCookie: boolean | string = true) {
    headers: withCookie === false ? {} : { cookie: withCookie === true ? cookie : withCookie },
  });
  const body = await res.text();
  const names = (res.headers.get("server-timing") ?? "").split(", ").map((p) => p.split(";")[0]!);
  const names = requestTiming(res).split(", ").map((p) => p.split(";")[0]!);
  return { status: res.status, names: names.slice(names.indexOf("app") + 1), body };
}
@@ -8,6 +8,7 @@
import { AppsRuntime } from "../src/apps/runtime.ts";
import { serve, type Servers } from "../src/http/server.ts";
import { seedAdmin } from "./helpers/admin.ts";
import { tokenFor } from "./helpers/tokens.ts";
import { requestTiming } from "./helpers/request-timing.ts";
let dataDir = "";
let app: App, servers: Servers, bearer = "";
@@ -21,7 +22,7 @@
const call = (path: string, init: RequestInit = {}, token = bearer) =>
async function phases(path: string, token = bearer): Promise<{ status: number; names: string[] }> {
  const res = await call(path, {}, token);
  await res.arrayBuffer();
  const all = (res.headers.get("server-timing") ?? "").split(", ").map((p) => p.split(";")[0]!);
  const all = requestTiming(res).split(", ").map((p) => p.split(";")[0]!);
  // The server's own leading `app` (and `db`) entries are not route phases.
  return { status: res.status, names: all.slice(all.indexOf("app") + 1) };
}
@@ -10,6 +10,7 @@
import { createSession } from "../src/core/sessions.ts";
import { createUser } from "../src/core/users.ts";
import { serve, type Servers } from "../src/http/server.ts";
import { quietLogs } from "./helpers/globals.ts";
import { requestTiming } from "./helpers/request-timing.ts";
quietLogs();
@@ -71,7 +72,7 @@
test("a conflicted pull's resolve page names its phases after app, in order", as
  const res = await fetch(`${servers.url}/alice/r/pulls/${number}/resolve`, { headers: { cookie } });
  expect(res.status).toBe(200);
  expect(await res.text()).toContain("Block 1 of 1");
  const parts = (res.headers.get("server-timing") ?? "").split(", ");
  const parts = requestTiming(res).split(", ");
  const names = parts.map((p) => p.split(";")[0]!);
  expect(names.slice(names.indexOf("app") + 1)).toEqual([
    "session", "pull", "checkout", "status", "file", "crew", "render",
@@ -6,6 +6,7 @@
import { join } from "node:path";
import { createApp, type App } from "../src/app.ts";
import { serve, type Servers } from "../src/http/server.ts";
import { seedAdmin } from "./helpers/admin.ts";
import { requestTiming } from "./helpers/request-timing.ts";
let dataDir = "";
let app: App, servers: Servers, bearer = "";
@@ -32,7 +33,7 @@
afterAll(async () => {
async function phases(path: string): Promise<{ status: number; names: string[] }> {
  const res = await fetch(`${servers.url}${path}`, { headers: { authorization: `Bearer ${bearer}` } });
  await res.arrayBuffer();
  const names = (res.headers.get("server-timing") ?? "").split(", ").filter(Boolean).filter((p) => !p.startsWith("app;")).map((p) => p.split(";")[0]!);
  const names = requestTiming(res).split(", ").filter(Boolean).filter((p) => !p.startsWith("app;")).map((p) => p.split(";")[0]!);
  return { status: res.status, names };
}
@@ -8,6 +8,7 @@
import { createApp, type App } from "../src/app.ts";
import { createUser } from "../src/core/users.ts";
import { serve, type Servers } from "../src/http/server.ts";
import { promote } from "./helpers/members.ts";
import { requestTiming } from "./helpers/request-timing.ts";
let dataDir = "";
let app: App, servers: Servers;
@@ -48,7 +49,7 @@
test("a fork one commit ahead reads ahead 1, behind 0, with the parent named", a
  expect(page.items[0]!.updatedAt).not.toBeNull();
  expect(page.next_cursor).toBeNull();
  expect(page.parent).toBeNull(); // the source itself has no parent
  const names = (res.headers.get("server-timing") ?? "").split(", ").map((p) => p.split(";")[0]!).filter((n) => n !== "app");
  const names = requestTiming(res).split(", ").map((p) => p.split(";")[0]!).filter((n) => n !== "app");
  expect(names).toEqual(["session", "forks", "drift", "render"]);
  const down = await fetch(`${servers.url}/api/v1/repos/bob/app/forks`);
  expect(((await down.json()) as { parent: string | null }).parent).toBe("alice/app");
@@ -6,6 +6,7 @@
import { join } from "node:path";
import { createApp, type App } from "../src/app.ts";
import { serve, type Servers } from "../src/http/server.ts";
import { seedAdmin } from "./helpers/admin.ts";
import { requestTiming } from "./helpers/request-timing.ts";
let dataDir = "";
let app: App, servers: Servers, bearer = "";
@@ -30,7 +31,7 @@
afterAll(async () => {
});
const names = (res: Response) =>
  (res.headers.get("server-timing") ?? "").split(", ").map((p) => p.split(";")[0]!).filter((n) => n !== "app");
  requestTiming(res).split(", ").map((p) => p.split(";")[0]!).filter((n) => n !== "app");
test("the forks list names session, forks, render in order", async () => {
  const made = await fetch(`${servers.url}/api/v1/repos`, {
@@ -7,6 +7,7 @@
import { createApp, type App } from "../src/app.ts";
import { createRepo } from "../src/actions/repos.ts";
import { serve, type Servers } from "../src/http/server.ts";
import { seedAdmin } from "./helpers/admin.ts";
import { requestTiming } from "./helpers/request-timing.ts";
let dataDir = "";
let app: App, servers: Servers, bearer = "";
@@ -34,7 +35,7 @@
afterAll(async () => {
});
const names = (res: Response): string[] =>
  (res.headers.get("server-timing") ?? "").split(", ").map((p) => p.split(";")[0]!).filter((n) => n !== "app");
  requestTiming(res).split(", ").map((p) => p.split(";")[0]!).filter((n) => n !== "app");
test("the forks page names session, repository, forks, fork-tree, lineage, drift and render, in order", async () => {
  const res = await fetch(`${servers.url}/alice/notes/forks`, { headers: { authorization: `Bearer ${bearer}` } });
@@ -5,6 +5,7 @@
import { tmpdir } from "node:os";
import { join } from "node:path";
import { createApp, type App } from "../src/app.ts";
import { serve, type Servers } from "../src/http/server.ts";
import { requestTiming } from "./helpers/request-timing.ts";
let dataDir = "";
let app: App, servers: Servers;
@@ -25,7 +26,7 @@
test("the front read names session, front, render in order", async () => {
  const res = await fetch(`${servers.url}/api/v1/front`);
  await res.arrayBuffer();
  expect(res.status).toBe(200);
  const parts = (res.headers.get("server-timing") ?? "").split(", ");
  const parts = requestTiming(res).split(", ");
  const names = parts.map((p) => p.split(";")[0]!).filter((n) => n !== "app");
  expect(names).toEqual(["session", "front", "render"]);
  for (const p of parts) expect(Number(/dur=([\d.]+)/.exec(p)?.[1])).not.toBeNaN();
@@ -6,6 +6,7 @@
import { join } from "node:path";
import { createApp, type App } from "../src/app.ts";
import { serve, type Servers } from "../src/http/server.ts";
import { quietLogs } from "./helpers/globals.ts";
import { requestTiming } from "./helpers/request-timing.ts";
quietLogs();
@@ -30,7 +31,7 @@
async function read(): Promise<string[]> {
  const res = await fetch(`${servers.url}/`, { redirect: "manual" });
  expect(res.status).toBe(200);
  await res.text();
  return (res.headers.get("server-timing") ?? "").split(", ");
  return requestTiming(res).split(", ");
}
test("GET / signed out names session, key, shelf, tiles, render in order and covers the handler's share of app", async () => {
@@ -0,0 +1,11 @@
/**
 * A response's Server-Timing without the loop's `lag` token (#10288): the
 * phases the request itself named, for a test that lists them in order.
 * `lag` is the worst event-loop lag of the last 10 s, not this request's.
 */
export function requestTiming(res: { headers: Headers }): string {
  return (res.headers.get("server-timing") ?? "")
    .split(", ")
    .filter((p) => !p.startsWith("lag;"))
    .join(", ");
}
@@ -6,6 +6,7 @@
import { join } from "node:path";
import { createApp, type App } from "../src/app.ts";
import { serve, type Servers } from "../src/http/server.ts";
import { seedAdmin } from "./helpers/admin.ts";
import { requestTiming } from "./helpers/request-timing.ts";
let dataDir = "";
let app: App, servers: Servers, bearer = "";
@@ -30,7 +31,7 @@
afterAll(async () => {
});
const phases = (res: Response) =>
  (res.headers.get("server-timing") ?? "").split(", ").map((p) => p.split(";")[0]!).filter((n) => n !== "app");
  requestTiming(res).split(", ").map((p) => p.split(";")[0]!).filter((n) => n !== "app");
test("the here read names session, here, render in that order", async () => {
  const res = await fetch(`${servers.url}/api/v1/here?path=/`, { headers: { authorization: `Bearer ${bearer}` } });
@@ -5,6 +5,7 @@
import { assignIssue, openIssue } from "../src/actions/issues.ts";
import { expectWork } from "./helpers/work.ts";
import { statements } from "./helpers/statements.ts";
import { snappyFixture, type SnappyFixture } from "../bench/snappy.ts";
import { requestTiming } from "./helpers/request-timing.ts";
let f: SnappyFixture;
@@ -25,7 +26,7 @@
afterAll(async () => {
async function look(): Promise<{ phases: { name: string; ms: number }[] }> {
  const res = await fetch(`${f.base}/`, { headers: { cookie: f.ownerCookie } });
  await res.arrayBuffer();
  const phases = (res.headers.get("server-timing") ?? "")
  const phases = requestTiming(res)
    .split(", ")
    .map((p) => ({ name: p.split(";")[0]!, ms: Number(/dur=([\d.]+)/.exec(p)?.[1] ?? 0) }));
  return { phases };
@@ -1,6 +1,7 @@
/** A repository's issues list names its Server-Timing phases in order: session, issues, closing, words, labels, render. */
import { afterAll, beforeAll, expect, test } from "bun:test";
import { snappyFixture, type SnappyFixture } from "../bench/snappy.ts";
import { requestTiming } from "./helpers/request-timing.ts";
let f: SnappyFixture;
@@ -19,7 +20,7 @@
for (const who of ["owner", "anonymous"] as const) {
    });
    await res.arrayBuffer();
    expect(res.status).toBe(200);
    const names = (res.headers.get("server-timing") ?? "").split(", ").map((p) => p.split(";")[0]!);
    const names = requestTiming(res).split(", ").map((p) => p.split(";")[0]!);
    expect(names.filter((n) => n !== "app")).toEqual(["session", "issues", "closing", "words", "labels", "render"]);
  });
}
@@ -0,0 +1,128 @@
/**
 * The worst event-loop lag of the last 10 s (#10288): the window by hand,
 * then a real 150 ms block seen as `lag;dur` on the next response and as
 * `loopLagMs` on `/healthz`, and gone once the injected clock steps 10 s.
 */
import { afterAll, beforeAll, describe, expect, test } from "bun:test";
import { mkdtemp, rm } from "node:fs/promises";
import { tmpdir } from "node:os";
import { join } from "node:path";
import { createApp, type App } from "../src/app.ts";
import { withLag } from "../src/core/route_timing.ts";
import { serve, type Servers } from "../src/http/server.ts";
import { createLoopWorst, startLoopWorst, stopLoopWorst } from "../src/perf/loop_worst.ts";
function blockFor(ms: number): void {
  const until = performance.now() + ms;
  while (performance.now() < until) {
    // a synchronous job holding the thread, as the lab's stalls do
  }
}
/** `lag;dur=<n>` out of a Server-Timing header, or null. */
function lagOf(header: string | null): number | null {
  const m = /(?:^|,\s*)lag;dur=([\d.]+)/.exec(header ?? "");
  return m === null ? null : Number(m[1]);
}
describe("the window, by hand", () => {
  test("keeps the worst of the last ten one-second slots", () => {
    const w = createLoopWorst();
    expect(w.worst(0)).toBe(0);
    w.note(3, 100);
    w.note(150, 2_500);
    w.note(7, 2_900);
    w.note(12, 9_000);
    expect(w.worst(9_999)).toBe(150);
    // Second 2 leaves the window when second 12 begins: slots 3..12 remain.
    expect(w.worst(11_999)).toBe(150);
    expect(w.worst(12_000)).toBe(12);
    expect(w.worst(18_999)).toBe(12);
    expect(w.worst(19_000)).toBe(0);
  });
  test("a slot reused a lap later forgets what it held", () => {
    const w = createLoopWorst();
    w.note(300, 1_000);
    w.note(2, 11_000);
    expect(w.worst(11_000)).toBe(2);
  });
  test("refuses what is not a lateness", () => {
    const w = createLoopWorst();
    for (const bad of [-1, Number.NaN, Number.POSITIVE_INFINITY]) w.note(bad, 0);
    w.note(5, Number.NaN);
    expect(w.worst(0)).toBe(0);
  });
  test("a tick (note then worst) costs under 0.1 ms on average over 100k", () => {
    const w = createLoopWorst();
    const ticks = 100_000;
    let sink = 0;
    const t0 = performance.now();
    // Each tick: one wake 50 ms apart on the window clock, then one header read.
    for (let k = 0; k < ticks; k++) {
      w.note(k % 97, k * 50);
      sink += w.worst(k * 50);
    }
    const meanMs = (performance.now() - t0) / ticks;
    expect(sink).toBeGreaterThan(0);
    expect(meanMs).toBeLessThan(0.1);
  });
  test("withLag appends one token and ignores a non-number", () => {
    expect(withLag("app;dur=3.0", 148.26)).toBe("app;dur=3.0, lag;dur=148.3");
    expect(withLag("app;dur=3.0", Number.NaN)).toBe("app;dur=3.0");
  });
});
describe("on every response", () => {
  let dataDir: string;
  let app: App;
  let servers: Servers;
  let skew = 0;
  beforeAll(async () => {
    dataDir = await mkdtemp(join(tmpdir(), "forge-loop-worst-"));
    app = createApp({ dataDir, port: 0 });
    // Wake every 5 ms, so a 150 ms block reads as at least 145; the window
    // reads a clock the test can step.
    stopLoopWorst();
    startLoopWorst({ clock: () => performance.now() + skew, everyMs: 5 });
    servers = await serve(app);
  });
  afterAll(async () => {
    stopLoopWorst();
    servers.stop();
    app.close();
    await rm(dataDir, { recursive: true, force: true });
  });
  test("a 150 ms block shows as lag;dur ≥ 140 on the next response, then falls out", async () => {
    blockFor(150);
    // The overdue wake runs before this one: timers fire in due order.
    await new Promise((r) => setTimeout(r, 0));
    const res = await fetch(`${servers.url}/nope`);
    await res.text();
    const header = res.headers.get("server-timing");
    expect(header).toContain("app;dur=");
    expect(lagOf(header)).toBeGreaterThanOrEqual(140);
    const health = await fetch(`${servers.url}/healthz`, { headers: { accept: "application/json" } });
    const body = (await health.json()) as { ok: boolean; loopLagMs: number };
    expect(body.ok).toBe(true);
    expect(body.loopLagMs).toBeGreaterThanOrEqual(140);
    // A probe asking for nothing still hears the plain `ok` (#2917).
    expect(await (await fetch(`${servers.url}/healthz`)).text()).toBe("ok");
    // Ten seconds on the window's clock with no new wake: nothing is left in it.
    stopLoopWorst();
    startLoopWorst({ clock: () => performance.now() + skew, everyMs: 60_000 });
    skew += 10_000;
    const later = await fetch(`${servers.url}/nope`);
    await later.text();
    expect(lagOf(later.headers.get("server-timing"))).toBe(0);
  });
});
@@ -9,6 +9,7 @@
import { addDependency } from "../src/core/dependencies.ts";
import { createIssue } from "../src/core/issues.ts";
import { serve, type Servers } from "../src/http/server.ts";
import { seedAdmin } from "./helpers/admin.ts";
import { requestTiming } from "./helpers/request-timing.ts";
let dataDir = "";
let app: App, servers: Servers, bearer = "";
@@ -50,7 +51,7 @@
test("the repository map names its phases in order, with durations", async () =>
  expect(res.status).toBe(200);
  const body = (await res.json()) as { ready: unknown[] };
  expect(body.ready.length).toBeGreaterThan(0);
  const parts = (res.headers.get("server-timing") ?? "").split(", ");
  const parts = requestTiming(res).split(", ");
  const names = parts.map((p) => p.split(";")[0]!);
  expect(names.filter((n) => n !== "app")).toEqual(["session", "graph", "marks", "pillars", "asktolive", "held", "render"]);
  for (const p of parts) expect(Number(/dur=([\d.]+)/.exec(p)?.[1])).not.toBeNaN();
@@ -19,6 +19,7 @@
import type { Graph } from "../src/core/dependencies.ts";
import { seedFixture, type Fixture, type Shape } from "../bench/map-home.ts";
import { countStatements } from "../bench/run.ts";
import { quietLogs } from "./helpers/globals.ts";
import { requestTiming } from "./helpers/request-timing.ts";
// `seedFixture` raises the log floor and never lowers it: borrowed for
// this file, and given back to whichever file runs next (#7419).
@@ -275,7 +276,7 @@
describe("/map's Server-Timing names its phases", () => {
      const cookie = who === "owner" ? f.ownerCookie : f.strangerCookie;
      for (const pass of ["cold", "warm"]) {
        const res = await fetch(`${servers.url}/map`, { headers: { cookie } });
        const header = res.headers.get("server-timing") ?? "";
        const header = requestTiming(res);
        const dur = new Map(
          [...header.matchAll(/([a-z-]+);dur=(\d+\.\d)/g)].map((m) => [m[1]!, Number(m[2])]),
        );
@@ -5,6 +5,7 @@
import { tmpdir } from "node:os";
import { join } from "node:path";
import { createApp, type App } from "../src/app.ts";
import { serve, type Servers } from "../src/http/server.ts";
import { requestTiming } from "./helpers/request-timing.ts";
let dataDir = "";
let app: App, servers: Servers;
@@ -25,6 +26,6 @@
test("the forge-wide map names session, graph, render in order", async () => {
  const res = await fetch(`${servers.url}/api/v1/map`);
  await res.arrayBuffer();
  expect(res.status).toBe(200);
  const names = (res.headers.get("server-timing") ?? "").split(", ").map((p) => p.split(";")[0]);
  const names = requestTiming(res).split(", ").map((p) => p.split(";")[0]);
  expect(names.filter((n) => n !== "app")).toEqual(["session", "graph", "render"]);
});
@@ -9,6 +9,7 @@
import { createSession } from "../src/core/sessions.ts";
import { createUser } from "../src/core/users.ts";
import { serve, type Servers } from "../src/http/server.ts";
import { quietLogs } from "./helpers/globals.ts";
import { requestTiming } from "./helpers/request-timing.ts";
quietLogs();
@@ -58,6 +59,6 @@
test("the new pull page names session, compare and render after app", async () =
  const res = await fetch(`${servers.url}/alice/r/pulls/new`, { headers: { cookie } });
  expect(res.status).toBe(200);
  await res.arrayBuffer();
  const names = (res.headers.get("server-timing") ?? "").split(", ").map((p) => p.split(";")[0]!);
  const names = requestTiming(res).split(", ").map((p) => p.split(";")[0]!);
  expect(names.slice(names.indexOf("app") + 1)).toEqual(["session", "compare", "render"]);
});
@@ -7,6 +7,7 @@
import { createApp, type App } from "../src/app.ts";
import { createRepo } from "../src/actions/repos.ts";
import { createUser } from "../src/core/users.ts";
import { serve, type Servers } from "../src/http/server.ts";
import { requestTiming } from "./helpers/request-timing.ts";
setDefaultTimeout(30_000);
@@ -39,7 +40,7 @@
afterAll(async () => {
async function get(path: string, headers: Record<string, string> = {}) {
  const res = await fetch(servers.url + path, { headers });
  await res.arrayBuffer();
  const names = (res.headers.get("server-timing") ?? "")
  const names = requestTiming(res)
    .split(", ")
    .map((p) => /^([a-z-]+);/.exec(p)?.[1])
    .filter((n): n is string => n !== undefined && n !== "app");
@@ -6,6 +6,7 @@
import { join } from "node:path";
import { createApp, type App } from "../src/app.ts";
import { serve, type Servers } from "../src/http/server.ts";
import { seedAdmin } from "./helpers/admin.ts";
import { requestTiming } from "./helpers/request-timing.ts";
let dataDir = "";
let app: App, servers: Servers, bearer = "";
@@ -39,7 +40,7 @@
async function phases(path: string, status = 200): Promise<string[]> {
  const res = await fetch(`${servers.url}${path}`, { headers: auth() });
  await res.arrayBuffer();
  expect(res.status).toBe(status);
  return (res.headers.get("server-timing") ?? "").split(", ").map((p) => p.split(";")[0]!).filter((n) => n !== "app" && n !== "db");
  return requestTiming(res).split(", ").map((p) => p.split(";")[0]!).filter((n) => n !== "app" && n !== "db");
}
test("an org names session, org, render", async () => {
@@ -6,6 +6,7 @@
import { join } from "node:path";
import { createApp, type App } from "../src/app.ts";
import { serve, type Servers } from "../src/http/server.ts";
import { issue } from "../src/kernel/passport.ts";
import { requestTiming } from "./helpers/request-timing.ts";
let dataDir = "";
let app: App, servers: Servers;
@@ -23,7 +24,7 @@
afterAll(async () => {
});
const phases = (res: Response) =>
  (res.headers.get("server-timing") ?? "").split(", ").map((p) => p.split(";")[0]!).filter((n) => n && n !== "app");
  requestTiming(res).split(", ").map((p) => p.split(";")[0]!).filter((n) => n && n !== "app");
const ask = (token?: string) =>
  fetch(`${servers.url}/api/v1/passport/health`, {
@@ -23,6 +23,7 @@
import { serve, type Servers } from "../src/http/server.ts";
import { quietLogs } from "./helpers/globals.ts";
import { PULL_PAGE_PHASES } from "./helpers/pull-phases.ts";
import { PNG } from "./helpers/studio.ts";
import { requestTiming } from "./helpers/request-timing.ts";
quietLogs();
@@ -101,7 +102,7 @@
async function timed(): Promise<{ names: string[]; ms: (n: string) => number; bo
  const res = await fetch(`${servers.url}/alice/r/pulls/${number}`, { headers: { cookie } });
  expect(res.status).toBe(200);
  const body = await res.text();
  const parts = (res.headers.get("server-timing") ?? "").split(", ");
  const parts = requestTiming(res).split(", ");
  const all = parts.map((p) => p.split(";")[0]!);
  const ms = (n: string) => Number(parts[all.indexOf(n)]!.match(/dur=([\d.]+)/)![1]);
  return { names: all.slice(all.indexOf("app") + 1), ms, body };
@@ -14,6 +14,7 @@
import { createUser } from "../src/core/users.ts";
import { serve, type Servers } from "../src/http/server.ts";
import { quietLogs } from "./helpers/globals.ts";
import { PULL_PAGE_PHASES } from "./helpers/pull-phases.ts";
import { requestTiming } from "./helpers/request-timing.ts";
quietLogs();
@@ -105,7 +106,7 @@
test("a pull names its read phases and render after app, summing to no more than
  const res = await fetch(`${servers.url}/alice/r/pulls/${number}`, { headers: { cookie } });
  expect(res.status).toBe(200);
  await res.arrayBuffer();
  const parts = (res.headers.get("server-timing") ?? "").split(", ");
  const parts = requestTiming(res).split(", ");
  const names = parts.map((p) => p.split(";")[0]!);
  const after = names.slice(names.indexOf("app") + 1);
  expect(after).toEqual([...PULL_PAGE_PHASES]);
@@ -124,7 +125,7 @@
test("a pull's Files page names session, diff, checks, reviews and render, in th
  const html = await res.text();
  expect(html).toContain("m39.ts");
  expect(html).not.toContain("<b>1</b>");
  const parts = (res.headers.get("server-timing") ?? "").split(", ");
  const parts = requestTiming(res).split(", ");
  const names = parts.map((p) => p.split(";")[0]!);
  expect(names.slice(names.indexOf("app") + 1)).toEqual(["session", "diff", "diff-git", "diff-parse", "diff-highlight", "git", "checks", "reviews", "render"]);
});
@@ -7,6 +7,7 @@
import { createApp, type App } from "../src/app.ts";
import { createRepo } from "../src/actions/repos.ts";
import { serve, type Servers } from "../src/http/server.ts";
import { seedAdmin } from "./helpers/admin.ts";
import { requestTiming } from "./helpers/request-timing.ts";
let dataDir = "";
let app: App, servers: Servers, bearer = "";
@@ -34,7 +35,7 @@
afterAll(async () => {
});
function names(res: Response): string[] {
  return (res.headers.get("server-timing") ?? "").split(", ").map((p) => p.split(";")[0]!);
  return requestTiming(res).split(", ").map((p) => p.split(";")[0]!);
}
test("a repository's pulls list names session, repo, pulls, words, tells, labels, steps and render in order", async () => {
@@ -11,6 +11,7 @@
import { serve, type Servers } from "../src/http/server.ts";
import { proveAll } from "./helpers/verified.ts";
import { quietLogs } from "./helpers/globals.ts";
import { promote } from "./helpers/members.ts";
import { requestTiming } from "./helpers/request-timing.ts";
quietLogs();
@@ -79,7 +80,7 @@
for (const [path, who, names] of PAGES)
      const res = await fetch(`${servers.url}${path}`, { headers: { cookie } });
      await res.text();
      expect(res.status).toBe(200);
      return (res.headers.get("server-timing") ?? "").split(", ");
      return requestTiming(res).split(", ");
    };
    const dur = (part: string | undefined): number => {
      expect(part).toMatch(/^[a-z-]+;dur=\d+\.\d$/);
@@ -6,6 +6,7 @@
import { join } from "node:path";
import { createApp, type App } from "../src/app.ts";
import { serve, type Servers } from "../src/http/server.ts";
import { seedAdmin } from "./helpers/admin.ts";
import { requestTiming } from "./helpers/request-timing.ts";
let dataDir = "";
let app: App, servers: Servers, bearer = "";
@@ -19,7 +20,7 @@
const call = (path: string, init: RequestInit = {}) =>
const phases = async (path: string): Promise<{ status: number; names: string[] }> => {
  const res = await call(path);
  await res.arrayBuffer();
  const names = (res.headers.get("server-timing") ?? "").split(", ").filter(Boolean).map((p) => p.split(";")[0]!).filter((n) => n !== "db" && n !== "app");
  const names = requestTiming(res).split(", ").filter(Boolean).map((p) => p.split(";")[0]!).filter((n) => n !== "db" && n !== "app");
  return { status: res.status, names };
};
@@ -9,6 +9,7 @@
import { createSession } from "../src/core/sessions.ts";
import { createUser } from "../src/core/users.ts";
import { serve, type Servers } from "../src/http/server.ts";
import { quietLogs } from "./helpers/globals.ts";
import { requestTiming } from "./helpers/request-timing.ts";
quietLogs();
@@ -55,6 +56,6 @@
test("a repository home names session, appof, refs, tree, readme, following, wav
  const res = await fetch(`${servers.url}/alice/r`, { headers: { cookie } });
  expect(res.status).toBe(200);
  await res.arrayBuffer();
  const names = (res.headers.get("server-timing") ?? "").split(", ").map((p) => p.split(";")[0]!);
  const names = requestTiming(res).split(", ").map((p) => p.split(";")[0]!);
  expect(names).toEqual(["app", "session", "appof", "refs", "tree", "readme", "following", "wave", "behind", "render"]);
});
@@ -46,8 +46,8 @@
test("a response carries Server-Timing, and /alice/x and /bob/y share one route
  const a = await fetch(`${servers.url}/alice/x`);
  await fetch(`${servers.url}/bob/y`);
  const health = await fetch(`${servers.url}/healthz`);
  expect(a.headers.get("server-timing")).toMatch(/^app;dur=\d+\.\d$/);
  expect(health.headers.get("server-timing")).toMatch(/^db;dur=\d+\.\d, app;dur=\d+\.\d$/);
  expect(a.headers.get("server-timing")).toMatch(/^app;dur=\d+\.\d, lag;dur=\d+\.\d$/);
  expect(health.headers.get("server-timing")).toMatch(/^db;dur=\d+\.\d, app;dur=\d+\.\d, lag;dur=\d+\.\d$/);
  servers.stop();
  const rows = readTiming(app.db, "");
@@ -9,6 +9,7 @@
import { createUser } from "../src/core/users.ts";
import { serve, type Servers } from "../src/http/server.ts";
import { proveAll } from "./helpers/verified.ts";
import { quietLogs } from "./helpers/globals.ts";
import { requestTiming } from "./helpers/request-timing.ts";
quietLogs();
@@ -65,7 +66,7 @@
for (const [path, names] of PAGES)
      const res = await fetch(`${servers.url}${path}`, { headers: { cookie } });
      await res.text();
      expect(res.status).toBe(200);
      const parts = (res.headers.get("server-timing") ?? "").split(", ");
      const parts = requestTiming(res).split(", ");
      expect(parts.map((p) => p.split(";")[0]).filter((n) => n !== "app")).toEqual(names);
      for (const name of names) expect(parts.find((p) => p.startsWith(`${name};`))).toMatch(/^[a-z]+;dur=\d+\.\d$/);
    }
@@ -6,6 +6,7 @@
import { join } from "node:path";
import { createApp, type App } from "../src/app.ts";
import { serve, type Servers } from "../src/http/server.ts";
import { seedAdmin } from "./helpers/admin.ts";
import { requestTiming } from "./helpers/request-timing.ts";
let dataDir = "";
let app: App, servers: Servers, bearer = "";
@@ -30,7 +31,7 @@
afterAll(async () => {
});
const phases = (res: Response) =>
  (res.headers.get("server-timing") ?? "").split(", ").map((p) => p.split(";")[0]!).filter((n) => n && n !== "app");
  requestTiming(res).split(", ").map((p) => p.split(";")[0]!).filter((n) => n && n !== "app");
for (const what of ["system", "history", "flow", "sources"]) {
  test(`telemetry/${what} names session, read, render in order`, async () => {
		@@ -16,4 +16,6 @@ A new `/settings…` page route goes in `src/http/settings_routes.ts` (`settings
16	16
17	17	State shared between modules through process memory, not the database, is named here. `src/perf/views_report.ts`: `readVisits` holds each scope and window's visits for 15 seconds (dropped by `flushViews`), so a page and its probe share one read; `src/perf/views_store.ts`: the view buffer, flushed every 10 seconds. The traffic sources view's terminal door is `src/tui/screens/trafficview.ts` (palette entry for admins, per-app command for a repository's admins). `src/runs/held.ts`: each dispatcher pass (`src/crew/dispatch.ts`, `pump`) records which queued agent runs it held and why (valve, pace, limit), and vitals (`src/kernel/vitals.ts`) leaves those out of `queue:agent`. A record older than `HELD_FRESH_MS` is ignored, so a stopped dispatcher cannot hide its queue.
18	18
	19	`src/perf/loop_worst.ts`: `loopWorst`, the worst event-loop lag of the last 10 s in ten one-second slots, fed by one unref'd 50 ms timer that the first `serve` starts (`startLoopWorst`), and read by every response's `lag;dur` and by `/healthz` asked for JSON (`loopLagMs`). Tests listing a request's phases read `requestTiming` (`test/helpers/request-timing.ts`), which leaves `lag` out.
	20
19	21	`src/core/transfer.ts`: the old owner/name pairs a transfer left behind (`repo_redirect`), held per database after the first request reads them and dropped by `transferRepo`, so a request under a path nothing moved from costs no statement (#569).
		@@ -1,5 +1,5 @@
1	1	# Performance watcher (#7559)
2	2
3		`src/perf/` keeps a capped in-memory record of real requests per route pattern (total, each Server-Timing phase, signed in or out; no paths, ids or queries). `budgets.ts` holds the budgets in words with the number beside them. Once a minute `duty.ts` files one issue per route and phase in the forge's repo when p95 has been over budget for 15 min with 20+ real requests; the finding names the slowest phase, its share and the cache hit rate. `git.ts` keeps the same record for every git process the forge spawns (`git/env.ts`, `git/local.ts`), keyed `git <subcommand>` from a fixed list (never an argument, path or ref; anything else is `git other`), timed from before the spawn gate so a queue counts; a subcommand whose p95 passes its budget the same way (250 ms; 10 s for the pack-moving ones: clone, fetch, push, gc, repack, pack-objects and the like) files one issue naming it, its count, p50 and p95. `loop.ts` names the routes running across an event-loop stall in the `loop` log line; nothing is kept beyond that line.
	3	`src/perf/` keeps a capped in-memory record of real requests per route pattern (total, each Server-Timing phase, signed in or out; no paths, ids or queries). `budgets.ts` holds the budgets in words with the number beside them. Once a minute `duty.ts` files one issue per route and phase in the forge's repo when p95 has been over budget for 15 min with 20+ real requests; the finding names the slowest phase, its share and the cache hit rate. `git.ts` keeps the same record for every git process the forge spawns (`git/env.ts`, `git/local.ts`), keyed `git <subcommand>` from a fixed list (never an argument, path or ref; anything else is `git other`), timed from before the spawn gate so a queue counts; a subcommand whose p95 passes its budget the same way (250 ms; 10 s for the pack-moving ones: clone, fetch, push, gc, repack, pack-objects and the like) files one issue naming it, its count, p50 and p95. `loop.ts` names the routes running across an event-loop stall in the `loop` log line; nothing is kept beyond that line. `loop_worst.ts` keeps the worst event-loop lag of the last 10 s (ten one-second slots fed by the 50 ms sampler) and every response's Server-Timing names it as `lag;dur`; `/healthz` answers it as `loopLagMs` to `Accept: application/json`, so a slow time to first byte with a small `app;dur` reads as a stall outside the handler.
4	4
5	5	Not yet: a synthetic probe for routes with no traffic (a client-written label would let anyone hide requests; it needs an admin-only door first), live route stats in the terminal and MCP (findings reach both doors as issues), browser timings, 24 h/7 d history, the board page, release before/after.
		@@ -210,6 +210,16 @@ export function serverTiming(
210	210	].join(", ");
211	211	}
212	212
	213	/**
	214	* `header` with the worst event-loop lag of the last 10 s appended as
	215	* `lag;dur=<ms>` (#10288): a request that waited on a loop someone else
	216	* blocked shows it here, though its own `app` was fast.
	217	*/
	218	export function withLag(header: string, lagMs: number): string {
	219	if (!Number.isFinite(lagMs) \|\| lagMs < 0) return header;
	220	return `${header}, lag;dur=${lagMs.toFixed(1)}`;
	221	}
	222
213	223	/** One named stretch of a request, in milliseconds. */
214	224	export interface Phase {
215	225	readonly name: string;
		@@ -87,8 +87,13 @@ export function startDraining(log: Log, why: string, fields: Record<string, numb
87	87	* Liveness: `ping` runs one trivial query against the database. However
88	88	* long it takes, an answer is 200; only a throw is 503, logged when it
89	89	* starts and when it ends.
	90	*
	91	* Given `loopLagMs` (the caller asked for JSON), the 200 is
	92	* `{"ok":true,"loopLagMs":n}`: the worst event-loop lag of the last 10 s
	93	* (`perf/loop_worst.ts`, #10288). Otherwise it stays the plain `ok` a
	94	* probe and a stranger hear (#2917).
90	95	*/
91		export function liveResponse(ping: () => unknown, log: Log): Response {
	96	export function liveResponse(ping: () => unknown, log: Log, loopLagMs?: number): Response {
92	97	try {
93	98	ping();
94	99	} catch (error) {
		@@ -101,6 +106,8 @@ export function liveResponse(ping: () => unknown, log: Log): Response {
101	106	}
102	107	if (databaseDown) log.info("forge alive again: the database answers");
103	108	databaseDown = false;
	109	if (loopLagMs !== undefined && Number.isFinite(loopLagMs))
	110	return Response.json({ ok: true, loopLagMs: Math.round(loopLagMs * 10) / 10 }, { status: 200 });
104	111	return new Response("ok", { status: 200 });
105	112	}
106	113
		@@ -480,6 +480,7 @@ import {
480	480	noteStart,
481	481	takePhases,
482	482	serverTiming,
	483	withLag,
483	484	takeDbTime,
484	485	type RouteTiming,
485	486	} from "../core/route_timing.ts";
		@@ -493,6 +494,7 @@ import { appSourcesPage } from "../web/pages/sources.ts";
493	494	import { createViewWriter } from "../perf/views_store.ts";
494	495	import { createReadWriter, readOf } from "../perf/reads.ts";
495	496	import { parseServerTiming } from "../perf/record.ts";
	497	import { currentLoopLag, startLoopWorst } from "../perf/loop_worst.ts";
496	498	import { methodOf, noteUsage, roleOf, surfaceOf, takeUsage } from "./usage_tag.ts";
497	499	import { bearerChallenge, oauthRoutes } from "./oauth.ts";
498	500	import { flushAccess, recordAccess } from "./access_log.ts";
		@@ -2357,6 +2359,8 @@ export async function serve(app: App): Promise<Servers> {
2357	2359	const featureSchedule = startFeatureSchedule(app);
2358	2360	const pullSchedule = startPullSchedule(app);
2359	2361	const readWriter = createReadWriter(app.db, readLedger, app.log);
	2362	// The worst event-loop lag of the last 10 s, on every response (#10288).
	2363	startLoopWorst();
2360	2364	const counted = (
2361	2365	owner: App,
2362	2366	request: Request,
		@@ -2368,7 +2372,8 @@ export async function serve(app: App): Promise<Servers> {
2368	2372	finishedStrangerDeep(owner, request);
2369	2373	try {
2370	2374	const header = serverTiming(ms, takeDbTime(request), takePhases(request));
2371		response.headers.set("server-timing", header);
	2375	// `lag` is the loop's, not this request's: kept out of the record's phases.
	2376	response.headers.set("server-timing", withLag(header, currentLoopLag()));
2372	2377	const end = performance.now();
2373	2378	const family = familyOf(request.headers.get("user-agent") ?? "");
2374	2379	perfRecord.add(
		@@ -2730,7 +2735,13 @@ async function answerGet(
2730	2735	if (url.pathname === "/healthz") {
2731	2736	noteUsage(request, { pattern: "/healthz", role: "anon" });
2732	2737	const dbStart = performance.now();
2733		const live = liveResponse(() => app.db.query("select 1").get(), app.log);
	2738	// `Accept: application/json` adds the loop's worst lag of the last 10 s (#10288).
	2739	const wantsJson = (request.headers.get("accept") ?? "").includes("application/json");
	2740	const live = liveResponse(
	2741	() => app.db.query("select 1").get(),
	2742	app.log,
	2743	wantsJson ? currentLoopLag() : undefined,
	2744	);
2734	2745	noteDbTime(request, performance.now() - dbStart);
2735	2746	// The release proof learns which release answered, old pod or new; a
2736	2747	// stranger is told only that one did (#2917).
		@@ -0,0 +1,100 @@
	1	/**
	2	* The worst event-loop lag of the last ten seconds (#10288), written on every
	3	* response as `lag;dur=<ms>` and told by `/healthz` as `loopLagMs`. A request
	4	* whose `app;dur` is 4 ms but whose time to first byte is 300 ms waited on a
	5	* loop blocked by something else; this names how long that block was.
	6	*
	7	* Lag is the lateness `kernel/loop_lag.ts` measures: a timer asks to wake
	8	* every 50 ms, and how much later than asked it wakes is how long the loop
	9	* was busy. A block of B ms is read as B − (time already waited, 0–50 ms),
	10	* so at 50 ms the reading undercounts a block by at most one interval.
	11	*
	12	* The window is a ring of ten one-second slots, each the worst lag noted in
	13	* its second: `note` is O(1) (a division, a compare, two array writes) and
	14	* `worst` reads ten numbers, so a tick costs well under 0.1 ms. A stall
	15	* stays named for 9–10 s after the wake that saw it, then falls out.
	16	*/
	17
	18	import { LAG_EVERY_MS, startLoopLag } from "../kernel/loop_lag.ts";
	19
	20	/** The window `worst` covers, ms. */
	21	export const LAG_WINDOW_MS = 10_000;
	22	/** One slot of the ring, ms: the window's resolution. */
		sentinelcrew 2d ago The sub-0.1 ms tick cost is only asserted in prose here. Add a test that bounds it (see the review body).
	23	export const LAG_SLOT_MS = 1_000;
	24
	25	export interface LoopWorst {
	26	/** A wake `lateMs` late, seen at `at` (ms, the clock `worst` reads). */
	27	note(lateMs: number, at: number): void;
	28	/** The worst lateness noted in the window ending at `at`, ms; 0 when none. */
	29	worst(at: number): number;
	30	}
	31
	32	export function createLoopWorst(
	33	windowMs = LAG_WINDOW_MS,
	34	slotMs = LAG_SLOT_MS,
	35	): LoopWorst {
	36	const n = Math.max(1, Math.round(windowMs / slotMs));
	37	// slot[i] is which second (at / slotMs, floored) max[i] holds; -1 is empty.
	38	const slot = new Float64Array(n).fill(-1);
	39	const max = new Float64Array(n);
	40	return {
	41	note(lateMs, at) {
	42	if (!Number.isFinite(lateMs) \|\| lateMs < 0 \|\| !Number.isFinite(at)) return;
	43	const s = Math.floor(at / slotMs);
	44	const i = ((s % n) + n) % n;
	45	if (slot[i] !== s) {
	46	slot[i] = s;
	47	max[i] = lateMs;
	48	} else if (lateMs > max[i]!) max[i] = lateMs;
	49	},
	50	worst(at) {
	51	const now = Math.floor(at / slotMs);
	52	let w = 0;
	53	for (let i = 0; i < n; i++)
	54	if (slot[i]! > now - n && slot[i]! <= now && max[i]! > w) w = max[i]!;
	55	return w;
	56	},
	57	};
	58	}
	59
	60	/** The process's one window, fed by `startLoopWorst`'s timer and read by every response. */
	61	export const loopWorst = createLoopWorst();
	62
	63	let sampling: (() => void) \| null = null;
	64	/** The clock the window is read on; a test injects one to step ten seconds at once. */
	65	let windowClock: () => number = () => performance.now();
	66
	67	export interface LoopWorstOptions {
	68	/** The window's clock, ms; lateness is always measured on `performance.now`. */
	69	readonly clock?: () => number;
	70	/** How often the timer asks to wake, ms. */
	71	readonly everyMs?: number;
	72	}
	73
	74	/**
	75	* Start the one sampler feeding `loopWorst` (idempotent: a second server in
	76	* the same process shares it). Its timer is unref'd, so it never holds a
	77	* test or a shutdown open. Returns the stop, which also restores the clock.
	78	*/
	79	export function startLoopWorst(options: LoopWorstOptions = {}): () => void {
	80	if (sampling === null) {
	81	if (options.clock !== undefined) windowClock = options.clock;
	82	const lag = startLoopLag(options.everyMs ?? LAG_EVERY_MS, () => performance.now(), (late) =>
	83	loopWorst.note(late, windowClock()),
	84	);
	85	sampling = lag.stop;
	86	}
	87	return stopLoopWorst;
	88	}
	89
	90	/** Stop the sampler, if one runs, and put the window back on `performance.now`. */
	91	export function stopLoopWorst(): void {
	92	sampling?.();
	93	sampling = null;
	94	windowClock = () => performance.now();
	95	}
	96
	97	/** The worst lag of the window ending now, ms, for a header or `/healthz`. */
	98	export function currentLoopLag(): number {
	99	return loopWorst.worst(windowClock());
	100	}
		@@ -6,6 +6,7 @@ import { join } from "node:path";
6	6	import { createApp, type App } from "../src/app.ts";
7	7	import { serve, type Servers } from "../src/http/server.ts";
8	8	import { seedAdmin } from "./helpers/admin.ts";
	9	import { requestTiming } from "./helpers/request-timing.ts";
9	10
10	11	let dataDir = "";
11	12	let app: App, servers: Servers, bearer = "";
		@@ -31,7 +32,7 @@ afterAll(async () => {
31	32
32	33	const basic = `Basic ${btoa("alice:correct-horse-battery")}`;
33	34	const phases = (res: Response) =>
34		(res.headers.get("server-timing") ?? "").split(", ").map((p) => p.split(";")[0]!).filter((n) => n && n !== "app");
	35	requestTiming(res).split(", ").map((p) => p.split(";")[0]!).filter((n) => n && n !== "app");
35	36
36	37	for (const [path, read] of [
37	38	["/api/v1/tokens", "tokens"],
		@@ -9,6 +9,7 @@ import { createSession } from "../src/core/sessions.ts";
9	9	import { createUser } from "../src/core/users.ts";
10	10	import { serve, type Servers } from "../src/http/server.ts";
11	11	import { quietLogs } from "./helpers/globals.ts";
	12	import { requestTiming } from "./helpers/request-timing.ts";
12	13
13	14	quietLogs();
14	15
		@@ -49,7 +50,7 @@ afterAll(async () => {
49	50	async function phases(path: string): Promise<{ status: number; names: string[]; body: string }> {
50	51	const res = await fetch(`${servers.url}${path}`, { headers: { cookie } });
51	52	const body = await res.text();
52		const names = (res.headers.get("server-timing") ?? "").split(", ").map((p) => p.split(";")[0]!);
	53	const names = requestTiming(res).split(", ").map((p) => p.split(";")[0]!);
53	54	return { status: res.status, names: names.slice(names.indexOf("app") + 1), body };
54	55	}
55	56
		@@ -11,6 +11,7 @@ import { createSession } from "../src/core/sessions.ts";
11	11	import { createUser } from "../src/core/users.ts";
12	12	import { serve, type Servers } from "../src/http/server.ts";
13	13	import { quietLogs } from "./helpers/globals.ts";
	14	import { requestTiming } from "./helpers/request-timing.ts";
14	15
15	16	quietLogs();
16	17
		@@ -61,7 +62,7 @@ afterAll(async () => {
61	62	async function phases(path: string): Promise<{ status: number; names: string[]; body: string }> {
62	63	const res = await fetch(`${servers.url}${path}`, { headers: { cookie } });
63	64	const body = await res.text();
64		const names = (res.headers.get("server-timing") ?? "").split(", ").map((p) => p.split(";")[0]!);
	65	const names = requestTiming(res).split(", ").map((p) => p.split(";")[0]!);
65	66	return { status: res.status, names: names.slice(names.indexOf("app") + 1), body };
66	67	}
67	68
		@@ -8,6 +8,7 @@ import { createSession } from "../src/core/sessions.ts";
8	8	import { createUser } from "../src/core/users.ts";
9	9	import { serve, type Servers } from "../src/http/server.ts";
10	10	import { quietLogs } from "./helpers/globals.ts";
	11	import { requestTiming } from "./helpers/request-timing.ts";
11	12
12	13	quietLogs();
13	14
		@@ -46,7 +47,7 @@ afterAll(async () => {
46	47	async function phases(path: string): Promise<{ status: number; names: string[]; body: string }> {
47	48	const res = await fetch(`${servers.url}${path}`, { headers: { cookie } });
48	49	const body = await res.text();
49		const names = (res.headers.get("server-timing") ?? "").split(", ").map((p) => p.split(";")[0]!);
	50	const names = requestTiming(res).split(", ").map((p) => p.split(";")[0]!);
50	51	return { status: res.status, names: names.slice(names.indexOf("app") + 1), body };
51	52	}
52	53