73cf3c3 · e3add40 · e4107b4 · 08e6435 · 2dcf73a · 9adec1a
@@ -0,0 +1,4 @@
# Home
- `.moving` — the living home's two lists (Being built, Just shipped), drawn by `movingRegion` in `src/web/studio/living.ts`: a one-column grid on a phone, two equal columns from 700px. Each list always holds three rows, so a quiet list is as tall as a busy one and nothing below it moves.
- `.tell-box` — home's one-line box that tells the crew: a `bar` whose text input takes the free width (`flex: 1 1 14rem`) and wraps the app picker and Tell under it on a phone.
@@ -54,6 +54,7 @@
Machine routes are not pages and have no entry: `/audit.csv`,
- `/board/returns` — `pages/returns.ts` · what the window's dollars bought · `/settings/subscriptions` spend tables, `/settings/usage` · none seen.
- `/big` — `pages/board.ts` (`bigRedirect`) · a redirect kept for old addresses into the board's wall mode · it is `/board` · none (no page of its own).
- `/boards` — `pages/boards-view.ts` · saved queries as panels · `/board` · none seen.
- `/feed` — `studio/home.ts` · the composer and one timeline, what home was before it became the living pipeline (#8015) · `/` · none seen.
- `/boards/data` — `pages/boards.ts` · the boards' query/data surface · `/board` · none seen.
- `/asks` — `studio/asks_page.ts` · what the crew is waiting on me for · `/` "needs me" list · colours 2.
- `/asked` — `studio/asked_page.ts` · what I answered, as a record · `/asks` · none seen.
@@ -0,0 +1,17 @@
# The living home (#8015)
Signed in, `/` is five things and nothing else:
1. **The box** — one line that tells the crew (`POST /tell`, the same action the feed's composer posts to). A phone's share sheet fills it.
2. **The figures** (admins) — the KPI tiles and any alarm, one calm line each. Everyone else gets the live version line.
3. **Now** (site admins) — `check › review › land › live`, each the sum of the `/boards` stages it names (`nowOf` in `src/flow/moving.ts`), each a link. The counts take in every repository, private ones too, so no one else is shown them.
4. **Being built / Just shipped** — three rows each, every row a link to its issue or pull, read for the viewer (a repository they cannot read, and a sealed report, are never named). One live region, `#live-moving`, redrawn from `/live/moving` when a run or a merge moves; it always holds six rows, so nothing below it shifts.
5. **Your apps** — a chip per app and a plus; `#live-chips`, redrawn from `/live/chips`.
The terminal's home carries the same lines (`movingLines` in `src/tui/screens/moving.ts`): Now for a site admin, then being built and just shipped, read for the viewer; its tell is the box.
The feed — the composer, the timeline, what is on you, since you were here, pinned panels — is `/feed`, linked from home.
Left out on purpose: the waiting-on-you line, the clog, vitals and keeper lines (the boards and the Flow dialog still show them), and "slowest right now" (it needs a timing read the home does not have). The box posts to `/tell` today; it becomes the `/talk` entry (#7652) when that lands.
The two scans behind the lists are read once per write (`writeStamp`), so a warm home reads no tables for them.
@@ -3,7 +3,7 @@
    "api.anthropic.com"
  ],
  "app": {
    "looks": ["/", "/forges", "/family", "/front", "/explore", "/board", "/boards", "/asked", "/review", "/search", "/new", "/audit", "/releases", "/changelog", "/apps", "/migrate", "/map", "/system", "/contribute", "/resilience", "/settings"],
    "looks": ["/", "/forges", "/family", "/front", "/explore", "/board", "/boards", "/asked", "/feed", "/review", "/search", "/new", "/audit", "/releases", "/changelog", "/apps", "/migrate", "/map", "/system", "/contribute", "/resilience", "/settings"],
    "run": "bun run src/main.ts",
    "install": "",
    "health": "/healthz",
@@ -109,6 +109,7 @@
export const SYSTEM_NAMES: readonly string[] = [
  "recover",
  "www",
  "asked",
  "feed",
  "review",
  "claim",
  "first-admin",
@@ -0,0 +1,122 @@
/**
 * What is moving through the forge, for the home (#8015): the builds running
 * now, the changes that just shipped, and the pipeline in four words.
 * Plain data out. Every row is read for a viewer: a repository they cannot
 * read, and a sealed report, are never named.
 */
import type { Database } from "bun:sqlite";
import { canRead, getReposByIds, type Repo } from "../core/repos.ts";
import type { User } from "../core/users.ts";
import { writeStamp } from "../core/write_clock.ts";
import type { PipelineStage } from "./pipeline.ts";
/** One line of a list: who, what, where it goes, and when. */
export interface MovingRow {
  readonly who: string;
  readonly title: string;
  readonly href: string;
  readonly at: string;
  /** `owner/name`, for the row's title attribute. */
  readonly repo: string;
}
export const MOVING_ROWS = 3;
/** Rows read before the viewer's access filters them; bounded, so the read is. */
const SCAN = 40;
interface Raw {
  repo_id: string;
  number: number;
  title: string;
  sealed: number;
  who: string | null;
  at: string;
}
const RAW_MAX_AGE_MS = 30_000;
const kept = new WeakMap<Database, Map<string, { stamp: string; at: number; raw: Raw[] }>>();
/** A scan read once per write: the same rows serve every viewer until anything is written (or 30 s pass). */
function scanned(db: Database, key: string, read: () => Raw[], now = Date.now()): Raw[] {
  const stamp = writeStamp(db);
  if (stamp === undefined) return read();
  let byKey = kept.get(db);
  if (byKey === undefined) kept.set(db, (byKey = new Map()));
  const had = byKey.get(key);
  if (had !== undefined && had.stamp === stamp && now - had.at < RAW_MAX_AGE_MS) return had.raw;
  const raw = read();
  byKey.set(key, { stamp, at: now, raw });
  return raw;
}
function visible(db: Database, viewer: User, raw: readonly Raw[], path: string, limit: number): MovingRow[] {
  const repos = getReposByIds(db, raw.map((r) => r.repo_id));
  const readable = new Map<string, Repo | undefined>();
  const out: MovingRow[] = [];
  for (const r of raw) {
    if (r.sealed !== 0) continue;
    if (!readable.has(r.repo_id)) {
      const repo = repos.get(r.repo_id);
      readable.set(r.repo_id, repo !== undefined && canRead(db, repo, viewer) ? repo : undefined);
    }
    const repo = readable.get(r.repo_id);
    if (repo === undefined) continue;
    out.push({
      who: r.who ?? "",
      title: r.title,
      href: `/${repo.ownerName}/${repo.name}/${path}/${r.number}`,
      at: r.at,
      repo: `${repo.ownerName}/${repo.name}`,
    });
    if (out.length === limit) break;
  }
  return out;
}
/** Agent builds running now (reviews are not building), newest first, each on the issue it works. */
export function readBuilding(db: Database, viewer: User, limit = MOVING_ROWS): MovingRow[] {
  const raw = scanned(db, "building", () => db
    .query<Raw, [number]>(
      `SELECT r.repo_id, i.number, i.title, i.sealed, u.username AS who, COALESCE(r.started_at, r.created_at) AS at
         FROM run r JOIN issue i ON i.id = r.issue_id LEFT JOIN user u ON u.id = r.actor_id
        WHERE r.kind = 'agent' AND r.state = 'running' AND r.reason != 'review'
        ORDER BY at DESC LIMIT ?1`,
    )
    .all(SCAN));
  return visible(db, viewer, raw, "issues", limit);
}
/** Changes merged most recently, newest first, each linking to its pull. */
export function readShipped(db: Database, viewer: User, limit = MOVING_ROWS): MovingRow[] {
  const raw = scanned(db, "shipped", () => db
    .query<Raw, [number]>(
      `SELECT i.repo_id, i.number, i.title, i.sealed, u.username AS who, p.merged_at AS at
         FROM pull p JOIN issue i ON i.id = p.issue_id LEFT JOIN user u ON u.id = p.merged_by
        WHERE p.merged_at IS NOT NULL
        ORDER BY p.merged_at DESC LIMIT ?1`,
    )
    .all(SCAN));
  return visible(db, viewer, raw, "pulls", limit);
}
/** The pipeline in the four words the forge uses; each count is the sum of the `/boards` stages it names. */
export interface Now {
  readonly check: number;
  readonly review: number;
  readonly land: number;
  readonly live: number;
}
export function nowOf(stages: readonly PipelineStage[]): Now {
  const n = (key: PipelineStage["key"]): number => {
    const s = stages.find((x) => x.key === key);
    return s === undefined ? 0 : s.waiting + s.active;
  };
  return {
    check: n("check-queue") + n("checking"),
    review: n("review"),
    land: n("approved"),
    live: n("live"),
  };
}
@@ -288,6 +288,7 @@
import {
import { keeperAnswer } from "../web/studio/keeper_row.ts";
import { homeArchive, homeArchived, homeArchiveUndo } from "../web/studio/home_archive.ts";
import { liveFeedFragment } from "../web/studio/feed.ts";
import { liveChipsFragment, liveMovingFragment } from "../web/studio/living.ts";
import { HOME_REGIONS } from "../web/studio/home_last.ts";
import { serviceWorker } from "../web/sw.ts";
import { explorePage } from "../web/studio/explore.ts";
@@ -297,6 +298,7 @@
import {
} from "../web/studio/make_it_yours.ts";
import {
  frontUpdate,
  feedPage,
  liveAppsFragment,
  liveClientAppsFragment,
  liveHomeFragment,
@@ -853,6 +855,9 @@
export function buildRouter(): Router<Handler> {
  router.add("GET", "/live/on-you", liveOnYouFragment);
  router.add("GET", "/live/client-apps", liveClientAppsFragment);
  router.add("GET", "/live/feed", liveFeedFragment);
  router.add("GET", "/live/moving", liveMovingFragment);
  router.add("GET", "/live/chips", liveChipsFragment);
  router.add("GET", "/feed", feedPage);
  // The home's late regions, each drawn alone (#7660).
  for (const name of HOME_REGIONS) router.add("GET", `/live/home/${name}`, (ctx) => liveHomeFragment(ctx, name));
  // Whether a hostname is an app's verified domain — what Caddy's
@@ -28,6 +28,8 @@
import { agentsLine } from "../../web/studio/client_home.ts";
import { lastVisit } from "../../core/home_visit.ts";
import { sinceDigest } from "../../web/studio/since.ts";
import { askForSomething } from "./tell.ts";
import { movingLines } from "./moving.ts";
import { pipelineNow } from "../../web/studio/living.ts";
import { askForEveryday, everydayOf, EVERYDAY_WHY, keepAdmin } from "../../core/everyday.ts";
import { mayView } from "../../core/sealed.ts";
import { applyFleetIds, previewFleetIds, undoFleetOp } from "../../actions/fleet.ts";
@@ -199,6 +201,8 @@
export function dashboardScreen(f: Session, ctx: Ctx): Screen {
  let clientLines: string[] = [];
  /** "Since you were here" and its lines: read from the web home's last-visit row, never written here. */
  let sinceLines: string[] = [];
  /** The web home's living pipeline (#8015): Now for a site admin, then being built and just shipped. */
  let moving: string[] = [];
  /** The ids of those apps, so the key that asks for something stays on them. */
  let clientRepoIds = new Set<string>();
  /** The live address of each of those apps that is running, by repo id; `o` shows it. */
@@ -370,6 +374,7 @@
export function dashboardScreen(f: Session, ctx: Ctx): Screen {
    lane = forgeLane(f.app, f.user);
    flaky = forgeFlakes(f.app, f.user);
    decider = deciderLine(f.app, f.user);
    moving = f.user ? movingLines(f.db, f.user, f.user.isAdmin ? pipelineNow(f.db) : undefined) : [];
    const commit = running().commit;
    const cleared = lastClearedNote(f.db, now);
    figures =
@@ -1033,6 +1038,13 @@
export function dashboardScreen(f: Session, ctx: Ctx): Screen {
        );
        body = rest!;
      }
      if (moving.length > 0) {
        const [strip, rest] = split(body, "v", [len(moving.length), fill(1)]);
        moving.forEach((line, i) =>
          s.text(strip!.x, strip!.y + i, truncate(line, strip!.w), style(c.mutedFg, c.bg), strip!.x + strip!.w),
        );
        body = rest!;
      }
      // A short terminal drops the last figures before it drops the list.
      const shown = figures.slice(0, Math.max(0, body.h - FIGURES_ROOM));
      if (shown.length > 0) {
@@ -0,0 +1,23 @@
/**
 * The terminal home's living pipeline (#8015), the web home's in lines: the
 * pipeline in four words for a site admin, then what is being built and what
 * just shipped, each filtered to what the viewer reads by the same reads the
 * web uses. The tell box is the home's own tell, already there.
 */
import type { Database } from "bun:sqlite";
import type { User } from "../../core/users.ts";
import { readBuilding, readShipped, type MovingRow, type Now } from "../../flow/moving.ts";
import { plain } from "./boards.ts";
const listLine = (label: string, rows: readonly MovingRow[], empty: string): string =>
  `${label}  ${rows.length === 0 ? empty : rows.map((r) => `${plain(r.title)} (${plain(r.repo)})`).join(" · ")}`;
/** `now` is passed only for a site admin: the counts take in every repository, private ones too. */
export function movingLines(db: Database, viewer: User, now: Now | undefined): string[] {
  return [
    ...(now === undefined ? [] : [`Now  check ${now.check} › review ${now.review} › land ${now.land} › ${now.live} live`]),
    listLine("Being built", readBuilding(db, viewer), "nothing right now"),
    listLine("Just shipped", readShipped(db, viewer), "nothing yet"),
  ];
}
@@ -172,14 +172,16 @@
export async function composerSubmit(ctx: Ctx): Promise<Response> {
  const form = await readForm(ctx, "rw");
  if (form instanceof Response) return form;
  const target = field(form, "app");
  // The feed's composer asks to come back to the feed; any other box, to home.
  const home = backTo(form, "/");
  // "the forge" is no app: the words are kept as a thought, exactly as typed.
  if (target === FORGE_TARGET) {
    if (field(form, "text").trim() === "")
      return flashOrJson(ctx, "/", { tone: "danger", message: SAY_SOMETHING_WORDS });
      return flashOrJson(ctx, home, { tone: "danger", message: SAY_SOMETHING_WORDS });
    const kept = keepThought(ctx.app, ctx.auth.user, field(form, "text"), "composer");
    return flashOrJson(
      ctx,
      "/",
      home,
      kept.ok
        ? { message: "Received." }
        : {
@@ -187,13 +189,13 @@
export async function composerSubmit(ctx: Ctx): Promise<Response> {
            message:
              kept.error === "too_long" ? "That is too long to keep." : "That could not be kept.",
          },
      { href: "/" },
      { href: home },
    );
  }
  const [owner = "", name = "", ...extra] = target.split("/");
  const repo = extra.length === 0 ? getRepo(ctx.app.db, owner, name) : undefined;
  if (!repo || !canRead(ctx.app.db, repo, ctx.auth.user)) return notFoundPage(ctx);
  return tellFrom(ctx, repo, form, "/");
  return tellFrom(ctx, repo, form, home);
}
@@ -226,6 +226,7 @@
export function composer(ctx: Ctx, user: User): Html {
  })}`;
  const form = html`<form id="composer" class="card" method="post" action="/tell">
    <div class="card-body stack">
    <input type="hidden" name="back" value="/feed" />
    <textarea class="input" name="text" rows="2" maxlength="2000" required placeholder="Tell the crew what should change" aria-label="Tell the crew" data-draft="${user.id}">${sharedDraft(ctx.url.searchParams)}</textarea>
    <div class="bar">
      ${repos.length === 0
@@ -341,14 +342,14 @@
export function caughtUp(items: readonly FeedItem[], next: string | null, cursor
  // Ranked by score, not time: the last card is not always the oldest.
  const oldest = items.reduce<string | undefined>((min, item) => (min === undefined || item.at < min ? item.at : min), undefined);
  if (oldest === undefined) return null;
  const newest = cursor === undefined ? html`` : html`<a href="/">Newest</a>`;
  const newest = cursor === undefined ? html`` : html`<a href="/feed">Newest</a>`;
  return next === null
    ? html`<p class="bar muted small" data-caught-up="end"><span>That's everything</span><span class="spacer"></span>${newest}</p>`
    : html`<p class="bar muted small" data-caught-up="more">
        <span>You're caught up to ${time(oldest)}</span>
        <span class="spacer"></span>
        ${newest}
        <a href="/?cursor=${encodeURIComponent(next)}&day=${encodeURIComponent(items[items.length - 1]!.at)}">Older posts</a>
        <a href="/feed?cursor=${encodeURIComponent(next)}&day=${encodeURIComponent(items[items.length - 1]!.at)}">Older posts</a>
      </p>`;
}
@@ -403,6 +404,9 @@
export function liveFeedFragment(ctx: Ctx): Response {
  return response;
}
/** Offline: the worker keeps the last home and the page that shows it is stale (`sw.ts`). */
export const registerWorkerJs = `if ('serviceWorker' in navigator) navigator.serviceWorker.register('/sw.js', { scope: '/' }).catch(function () {});`;
/**
 * When a card is hidden, the day divider just above it goes with it, unless
 * a later card of that day is still showing — then the divider moves down to
@@ -599,7 +603,7 @@
${dayKeepJs}
      if (navigator.serviceWorker && navigator.serviceWorker.controller) navigator.serviceWorker.controller.postMessage('clear');
    }
  });
  if ('serviceWorker' in navigator) navigator.serviceWorker.register('/sw.js', { scope: '/' }).catch(function () {});
  ${registerWorkerJs}
  paint();
  flush();
})();
@@ -12,6 +12,13 @@
export const feedCss = /* css */ `
@media (max-width: 899px) {
  #live-apps { display: none; }
}
/* Home's living pipeline (#8015): two lists side by side on a desk. Each list always holds three rows, so nothing below moves. */
.moving { display: grid; grid-template-columns: 1fr; gap: 12px; }
@media (min-width: 700px) {
  .moving { grid-template-columns: 1fr 1fr; }
}
.moving .row { min-height: 44px; }
.tell-box > input[name="text"] { flex: 1 1 14rem; min-width: 0; }
@media (max-width: 600px) {
  .feed .bar .btn { padding: 8px 10px; }
  .feed .disclosure > summary { min-height: 44px; display: flex; align-items: center; }
@@ -51,10 +51,10 @@
import {
import { writableAppsOf } from "./asks.ts";
import { needsYouSection } from "./asks_page.ts";
import { flowCards } from "./flow_card.ts";
import { composer, feedJs, feedNote, feedRegion } from "./feed.ts";
import { composer, feedJs, feedNote, feedRegion, registerWorkerJs } from "./feed.ts";
import { appChips, movingRegion, tellBox } from "./living.ts";
import { alarmLines, cachedAlarms } from "./alarm_lines.ts";
import { keeperRow } from "./keeper_row.ts";
import { clogRow, kpiRow, vitalsRow, waitingLine } from "./kpi_row.ts";
import { kpiRow, waitingLine } from "./kpi_row.ts";
import { feedCandidateCache } from "../../feed/feed.ts";
import { notePhase, notePhaseRest, takeSessionTime, timePhase, timePhaseAsync } from "../../core/route_timing.ts";
import { idleReason } from "../../crew/idle_reason.ts";
@@ -228,7 +228,7 @@
export function liveOnYouFragment(ctx: Ctx): Response {
 * How each late region of home is drawn for `user` (#7660): the page serves
 * the last drawing from memory and `/live/home/<name>` draws it fresh.
 */
function homeDraws(ctx: Ctx, user: User): Record<HomeRegion, () => Html | Promise<Html>> {
export function homeDraws(ctx: Ctx, user: User): Record<HomeRegion, () => Html | Promise<Html>> {
  const { db } = ctx.app;
  const request = ctx.request;
  return {
@@ -237,8 +237,6 @@
function homeDraws(ctx: Ctx, user: User): Record<HomeRegion, () => Html | Promis
      const kpiTime: KpiTimer = (name, fn) => timePhase(request, name, fn);
      const kpiOpts = { idle: () => idleReason(ctx.app, new Date()), dataDir: ctx.app.config.dataDir, time: kpiTime, ...(ceilingUsd === null ? {} : { ceilingUsd }) };
      return html`${timePhase(request, "kpis", () => kpiRow(db, kpiOpts), () => kpiCache(db))}
        ${timePhase(request, "vitals", () => vitalsRow(db))} ${clogRow(db)}
        ${keeperRow(db, true)}
        ${alarmLines(cachedAlarms(db, new Date(), ceilingUsd))}`;
    },
    waiting: () => timePhase(request, "waiting", () => waitingLine(db, user), () => waitingCache(db)),
@@ -316,9 +314,46 @@
export async function studioHome(
  }
  // The client's first screen names its own phases (`clientApps`).
  notePhase(ctx.request, "session", takeSessionTime(ctx.request));
  const { repos: appRepos } = timePhase(ctx.request, "repos", () => writableAppsOf(ctx, user));
  // Render is what is left of the page once the named reads are taken out.
  const rendering = performance.now();
  const access = timePhase(ctx.request, "access", () => accessFingerprint(ctx.app.db, user));
  const ask = firstSteps ?? everydayCard(ctx, user);
  const figures = user.isAdmin && steps === undefined;
  const kpis = figures
    ? await homeRegion(ctx.app.db, ctx.request, user.id, "kpis", homeVariant(ctx.url), access, homeDraws(ctx, user).kpis)
    : liveLine(ctx);
  const body = html`<h1 class="sr-only">Home</h1>
    ${tellBox(ctx, user)}
    ${ask} ${address}
    <section class="stack" aria-label="The forge">${kpis}</section>
    ${timePhase(ctx.request, "moving", () => movingRegion(ctx.app.db, user))}
    ${appChips(ctx, user)}
    ${when(
      steps,
      () => html`<p class="small muted" id="lean-home"><a href="/">Just my apps</a></p>`,
    )}
    <p class="small muted"><a href="/feed">The feed</a></p>`;
  const res = page({
    ctx,
    title: "Home",
    body,
    scriptJs: `${liveClientJs}\n${liveRegionsJs}\n${refreshJs}\n${registerWorkerJs}${ask ? `\n${passkeyJs}` : ""}`,
  });
  notePhaseRest(ctx.request, "render", rendering, ["kpis", "moving", "access"]);
  return res;
}
/**
 * The feed (#8015), kept off home: the composer, then one timeline — what
 * home was before it became the living pipeline — with your apps and what
 * is on you beside it on a desk.
 */
export async function feedPage(ctx: Ctx): Promise<Response> {
  const user = ctx.auth.user;
  if (!user) return signInFirst(ctx);
  notePhase(ctx.request, "session", takeSessionTime(ctx.request));
  const { repos: appRepos } = timePhase(ctx.request, "repos", () => writableAppsOf(ctx, user));
  const rendering = performance.now();
  const visitedAt = Date.now();
  const before = timePhase(ctx.request, "visit", () =>
    isNavigation(ctx.request) ? noteVisit(ctx.app.db, user.id, visitedAt) : lastVisit(ctx.app.db, user.id),
@@ -328,18 +363,9 @@
export async function studioHome(
  const access = timePhase(ctx.request, "access", () => accessFingerprint(ctx.app.db, user));
  const regionOf = (name: HomeRegion): Promise<Html> =>
    homeRegion(ctx.app.db, ctx.request, user.id, name, homeVariant(ctx.url), access, draws[name]);
  const ask = firstSteps ?? everydayCard(ctx, user);
  const figures = user.isAdmin && steps === undefined;
  const body = html`<h1 class="sr-only">Home</h1>
    ${ask} ${address} ${figures ? await regionOf("kpis") : liveLine(ctx)}
  const body = html`<h1 class="sr-only">Feed</h1>
    ${await regionOf("waiting")}
    ${figures ? await regionOf("panels") : null}
    ${when(
      steps,
      () => html`<p class="small muted" id="lean-home">
        <a href="/">Just my apps</a>
      </p>`,
    )}
    ${user.isAdmin ? await regionOf("panels") : null}
    ${since}
    ${await regionOf("asked")}
    <div class="split" data-rail="wide">
@@ -350,12 +376,7 @@
export async function studioHome(
        ${await regionOf("feed")}
      </div>
      <aside class="stack">
        ${
          // The crew's missing key is the owner's to fix, not the first
          // thing above every post: beside the timeline on a desk, after it
          // on a phone.
          user.isAdmin || appRepos.length > 0 ? crewKeyNote(ctx) : null
        }
        ${user.isAdmin || appRepos.length > 0 ? crewKeyNote(ctx) : null}
        ${appsRegion(ctx, user)}
        ${terminalCard(ctx)} ${downloadsCard(ctx, user)}
        ${orgsCard(ctx, user)}
@@ -363,11 +384,11 @@
export async function studioHome(
    </div>`;
  const res = page({
    ctx,
    title: "Home",
    title: "Feed",
    body,
    scriptJs: `${liveClientJs}\n${liveRegionsJs}\n${feedJs}\n${refreshJs}${ask ? `\n${passkeyJs}` : ""}`,
    scriptJs: `${liveClientJs}\n${liveRegionsJs}\n${feedJs}\n${refreshJs}`,
  });
  notePhaseRest(ctx.request, "render", rendering, ["kpis", "vitals", "waiting", "panels", "feed", "visit", "since", "access"]);
  notePhaseRest(ctx.request, "render", rendering, ["waiting", "feed", "asked", "visit", "since", "access", "repos"]);
  return res;
}
@@ -27,7 +27,7 @@
export function homeTabs(current: HomeTab, unshipped = 0): Html {
  });
  return html`<div class="mb">
    ${tabs(
      [item("feed", "/", "Feed"), item("apps", "/apps", "Your apps"), item("asked", "/asked", "Asked", unshipped)],
      [item("feed", "/feed", "Feed"), item("apps", "/apps", "Your apps"), item("asked", "/asked", "Asked", unshipped)],
      "Home",
    )}
  </div>`;
@@ -11,9 +11,7 @@
import type { Database } from "bun:sqlite";
import { backupAge, backupFull, backupOverdue, buildersValue, checkTime, reactNote, speedWords, spendCeilingWords, spendFull, spendValue, usersValue, visitorsNote, visitorsValue, waitingWords } from "../../flow/kpi_words.ts";
import type { IdleReason } from "../../crew/idle_reason.ts";
import type { KpiTimer, Kpis } from "../../flow/kpis.ts";
import { clogLines, readClog } from "../../flow/clog_read.ts";
import { vitalsLine } from "../../flow/vitals.ts";
import { cachedKpis, cachedVitals, cachedWaiting } from "./home_cache.ts";
import { cachedKpis, cachedWaiting } from "./home_cache.ts";
import { escapeHtml, html, raw, type Html } from "../html.ts";
import { BOOTED } from "../../release/gate.ts";
import { running } from "../../kernel/version.ts";
@@ -192,17 +190,3 @@
export function waitingLine(db: Database, user: User, now: Date = new Date()): H
  // The fold is a form, which cannot sit in the paragraph: it follows it.
  return html`${words === null ? null : html`<p class="small muted break stack stack-tight"><span>${words}</span><a href="/review">Review them</a></p>`}${stale.length === 0 ? null : staleArchive(stale)}`;
}
/** Home's flow vitals for an admin (#5935): one muted line of counts; the open count links to the boards. */
export function vitalsRow(db: Database, now: Date = new Date()): Html {
  const v = cachedVitals(db, now);
  const rest = vitalsLine(v).split(" · ").slice(1).join(" · ");
  return html`<p class="small muted"><a href="/boards">${v.open} open pulls</a> · ${rest}</p>`;
}
/** Home's clog lines for an admin (#6757): the clog standing now and the last cleared note; nothing when there is neither. */
export function clogRow(db: Database, now: Date = new Date()): Html {
  const lines = clogLines(readClog(db, now), now.getTime());
  if (lines.length === 0) return html``;
  return html`${lines.map((l) => html`<p class="small muted break">${l}</p>`)}`;
}
@@ -0,0 +1,138 @@
/**
 * The home's living pipeline (#8015): the pipeline in four words, what is
 * being built, what just shipped, and the box that tells the crew. Each part
 * is plain rows with a link to the thing it names. Being built and just
 * shipped are one live region (`/live/moving`) that the shared stream
 * redraws when a run or a merge moves; it always holds the same number of
 * rows, so nothing below it shifts.
 */
import type { Database } from "bun:sqlite";
import { MOVING_ROWS, nowOf, readBuilding, readShipped, type MovingRow, type Now } from "../../flow/moving.ts";
import { readPipeline } from "../../flow/pipeline.ts";
import type { User } from "../../core/users.ts";
import type { Ctx } from "../../http/context.ts";
import { html, type Html } from "../html.ts";
import { fragment } from "../layout.ts";
import { btn, listCard, row, timeAgo } from "../ui.ts";
import { notePhase, takeSessionTime, timePhase } from "../../core/route_timing.ts";
import { writableAppsOf } from "./asks.ts";
import { FORGE_TARGET, sharedDraft } from "./feed.ts";
import { repoBase } from "../chrome.ts";
/** The events that move a build or a shipment. */
const MOVING_LIVE = "run.started,run.finished,pull.merged,pull.opened,pull.closed,app.serving";
const NOW_TTL_MS = 3_000;
// One entry per forge, not per viewer: the counts are forge-wide, so only a site admin is ever shown them.
const nows = new WeakMap<Database, { at: number; now: Now }>();
/** Admin only: the caller has checked. The pipeline counts, read at most every few seconds: the same stages `/boards` draws. */
export function pipelineNow(db: Database, at = Date.now()): Now {
  const kept = nows.get(db);
  if (kept !== undefined && at - kept.at < NOW_TTL_MS) return kept.now;
  const now = nowOf(readPipeline(db, new Date(at)));
  nows.set(db, { at, now });
  return now;
}
/** `check 10 › review 1 › land 3 › live`: each word links to the boards where the same stage is. */
export function nowLine(now: Now, boards = true): Html {
  // An agent admin has no boards to open: the word is then plain.
  const part = (word: string, n: number) =>
    boards ? html`<a href="/boards"><strong>${String(n)}</strong> ${word}</a>` : html`<span><strong>${String(n)}</strong> ${word}</span>`;
  return html`<section aria-label="Now">
    <h2 class="small muted">Now</h2>
    <p class="bar" id="now-line">
      ${part("check", now.check)} <span class="muted" aria-hidden="true">›</span>
      ${part("review", now.review)} <span class="muted" aria-hidden="true">›</span>
      ${part("land", now.land)} <span class="muted" aria-hidden="true">›</span>
      <a href="/releases"><strong>${String(now.live)}</strong> live</a>
    </p>
  </section>`;
}
function listOf(label: string, rows: readonly MovingRow[], empty: string): Html {
  const shown = rows.map((r) =>
    row({
      href: r.href,
      ...(r.who === "" ? {} : { lead: html`<span class="muted small">${r.who}</span>` }),
      title: html`<span class="truncate" title="${r.repo}">${r.title}</span>`,
      trail: html`<span class="muted small">${timeAgo(r.at)}</span>`,
    }),
  );
  // Always MOVING_ROWS rows: a quiet slot is as tall as a busy one.
  for (let i = shown.length; i < MOVING_ROWS; i++)
    shown.push(row({ title: html`<span class="muted small">${i === 0 ? empty : " "}</span>` }));
  return html`<section aria-label="${label}">
    <h2 class="small muted">${label}</h2>
    ${listCard(shown)}
  </section>`;
}
/**
 * The pipeline, then being built and just shipped side by side on a desk and
 * stacked on a phone; one live region. The pipeline counts every repository,
 * private ones too, so only a site admin, who reads them all, sees the line.
 */
export function movingRegion(db: Database, viewer: User): Html {
  const building = readBuilding(db, viewer);
  const shipped = readShipped(db, viewer);
  return html`<div id="live-moving" class="stack" data-live="${MOVING_LIVE}" data-live-src="/live/moving">
    ${viewer.isAdmin ? nowLine(pipelineNow(db), viewer.kind !== "agent") : null}
    <div class="moving">
      ${listOf("Being built", building, "Nothing is being built right now")}
      ${listOf("Just shipped", shipped, "Nothing has shipped yet")}
    </div>
  </div>`;
}
// GET /live/moving — the two lists alone, for the region that shows them.
export function liveMovingFragment(ctx: Ctx): Response {
  const user = ctx.auth.user;
  notePhase(ctx.request, "session", takeSessionTime(ctx.request));
  if (!user) {
    notePhase(ctx.request, "render", 0);
    return fragment(html``, { status: 404 });
  }
  const body = timePhase(ctx.request, "moving", () => movingRegion(ctx.app.db, user));
  notePhase(ctx.request, "render", 0);
  return fragment(body, { request: ctx.request });
}
/** The box that tells the crew: one line, the app it goes to, Tell. Posts to `/tell` as the composer does. */
export function tellBox(ctx: Ctx, user: User): Html {
  const { repos } = writableAppsOf(ctx, user);
  const slug = (r: { ownerName: string; name: string }) => `${r.ownerName}/${r.name}`;
  return html`<form id="tell-box" class="bar tell-box" method="post" action="/tell">
    <input class="input" name="text" maxlength="2000" required placeholder="Tell the crew…" aria-label="Tell the crew" data-draft="${user.id}" value="${sharedDraft(ctx.url.searchParams).replace(/\s+/g, " ")}" />
    ${repos.length === 0
      ? html`<input type="hidden" name="app" value="${FORGE_TARGET}" />`
      : html`<select name="app" class="input" aria-label="Send to">
          ${repos.map((r) => html`<option value="${slug(r)}">${slug(r)}</option>`)}
          <option value="${FORGE_TARGET}">the forge</option>
        </select>`}
    ${btn("Tell", { variant: "primary" })}
  </form>`;
}
/** Your apps as chips, each a link to the app, and a plus for a new one. */
export function appChips(ctx: Ctx, user: User): Html {
  const { repos } = writableAppsOf(ctx, user);
  return html`<section aria-label="Your apps" id="live-chips" data-live="app.serving,app.stopped,app.created,app.deleted" data-live-src="/live/chips">
    <h2 class="small muted">Your apps</h2>
    <div class="bar">
      ${repos.slice(0, 12).map((r) => btn(r.name, { href: repoBase(r), size: "sm" }))}
      ${btn("New app", { href: "/apps/new", size: "sm", icon: "plus" })}
      ${repos.length > 12 ? btn(`All ${repos.length}`, { href: "/apps", size: "sm" }) : null}
    </div>
  </section>`;
}
// GET /live/chips — the chips alone.
export function liveChipsFragment(ctx: Ctx): Response {
  const user = ctx.auth.user;
  notePhase(ctx.request, "session", takeSessionTime(ctx.request));
  notePhase(ctx.request, "render", 0);
  if (!user) return fragment(html``, { status: 404 });
  return fragment(appChips(ctx, user), { request: ctx.request });
}
@@ -72,7 +72,7 @@
test("homeTabs reads plain Asked at 0 or when not given, and the count otherwise
test("with no asks the Asked tab is plain on all three pages", async () => {
  forgetHome(app.db);
  for (const path of ["/?all=1", "/apps", "/asked"]) expect(await askedTab(path)).toBe("Asked");
  for (const path of ["/feed?all=1", "/apps", "/asked"]) expect(await askedTab(path)).toBe("Asked");
});
test("three unshipped asks read Asked 3 on `/`, `/apps` and `/asked`", async () => {
@@ -81,8 +81,8 @@
test("three unshipped asks read Asked 3 on `/`, `/apps` and `/asked`", async ()
    if (!ask.ok) throw new Error(ask.error);
  }
  forgetHome(app.db);
  for (const path of ["/?all=1", "/apps", "/asked"]) expect(await askedTab(path)).toBe("Asked 3");
  const res = await fetch(`${servers.url}/?all=1`, { headers: { cookie } });
  for (const path of ["/feed?all=1", "/apps", "/asked"]) expect(await askedTab(path)).toBe("Asked 3");
  const res = await fetch(`${servers.url}/feed?all=1`, { headers: { cookie } });
  await res.arrayBuffer();
  expect(res.headers.get("server-timing") ?? "").toContain("asked;");
});
@@ -279,7 +279,7 @@
describe("what you asked for", () => {
    expect(page.indexOf("Fix the gate")).toBeLessThan(page.indexOf("Plant tomatoes"));
    // Reached from the board and the feed's header, not only the asks page.
    expect(await (await fetch(`${servers.url}/board`, { headers: { cookie } })).text()).toContain('href="/asked"');
    expect(await (await fetch(`${servers.url}/`, { headers: { cookie } })).text()).toContain('href="/asked"');
    expect(await (await fetch(`${servers.url}/feed`, { headers: { cookie } })).text()).toContain('href="/asked"');
    const flagged = (
      await (
        await fetch(`${servers.url}/asked?show=flagged`, {
@@ -432,7 +432,7 @@
describe("the audit reads every app's policy from git", () => {
  test("the way in: the studio home links the audit, and an app's page says its policy in one line", async () => {
    const home = await (
      await fetch(`${servers.url}/`, {
      await fetch(`${servers.url}/feed`, {
        headers: { cookie: `${cookie}; forge_mode=studio` },
      })
    ).text();
@@ -26,7 +26,7 @@
const post = (path: string, fields: Record<string, string>, who = "alice", heade
    headers: { authorization: `Bearer ${tok[who]}`, ...headers },
  });
const home = async (who: string) =>
  (await fetch(servers.url + "/", { headers: { authorization: `Bearer ${tok[who]}` } })).text();
  (await fetch(servers.url + "/feed", { headers: { authorization: `Bearer ${tok[who]}` } })).text();
const titles = (h: string) => [...h.matchAll(/<h2>(Pin [ABC])<\/h2>/g)].map((m) => m[1]);
beforeAll(async () => {
@@ -176,7 +176,7 @@
describe("a client's first screen", () => {
    expect(apps).toContain('href="/marias/bakery"');
    expect(apps).toMatch(/data-agents="(working|waiting)"/);
    expect(apps).toContain("agents are waiting");
    expect(home).not.toContain('id="live-apps"');
    expect(home).not.toContain('id="live-chips"');
    for (const gone of ['href="/map"', 'href="/board"', 'href="/audit"', 'href="/settings"'])
      expect(home).not.toContain(gone);
    expect(home).toContain('href="/?all=1"');
@@ -359,7 +359,7 @@
describe("a client's first screen", () => {
  test("asked for, the whole home is still there", async () => {
    const home = await page(owner, "/?all=1");
    expect(home).toContain('id="live-apps"');
    expect(home).toContain('id="live-chips"');
    expect(home).not.toContain('id="client-apps"');
  });
@@ -47,7 +47,7 @@
beforeAll(async () => {
afterAll(() => servers.stop());
test("the composer names its user for the draft key, and the script stays small", async () => {
  const res = await fetch(`${servers.url}/`, { headers: { cookie: `forge_session=${cookie}; forge_mode=studio` } });
  const res = await fetch(`${servers.url}/feed`, { headers: { cookie: `forge_session=${cookie}; forge_mode=studio` } });
  const page = await res.text();
  expect(page).toContain(`data-draft="${alice.id}"`);
  expect(feedJs).toContain("forgeDraft(");
@@ -153,7 +153,7 @@
test.skipIf(noChromium)("in a real browser: type, reload, find it; send, reload,
    const load = async () => {
      const loaded = once("Page.loadEventFired");
      loaded.catch(() => {});
      await send("Page.navigate", { url: `${servers.url}/` });
      await send("Page.navigate", { url: `${servers.url}/feed` });
      await loaded;
      await waitFor(`!!document.getElementById("composer")`);
    };
@@ -176,7 +176,7 @@
test.skipIf(noChromium)("in a real browser: type, reload, find it; send, reload,
    await load();
    await type("Water the tomatoes at dawn");
    await waitFor(`localStorage.getItem(${JSON.stringify(`draft.${alice.id}/`)}) === "Water the tomatoes at dawn"`);
    await waitFor(`localStorage.getItem(${JSON.stringify(`draft.${alice.id}/feed`)}) === "Water the tomatoes at dawn"`);
    await load();
    expect(await run(`${box}.value`)).toBe("Water the tomatoes at dawn");
@@ -203,7 +203,7 @@
test.skipIf(noChromium)("in a real browser: type, reload, find it; send, reload,
    await type("Mulch first");
    await run(`(() => { const c = document.getElementById("composer"); const o = document.createElement("option"); o.value = "alice/nowhere"; c.elements.app.append(o); c.elements.app.value = "alice/nowhere"; c.requestSubmit(); })()`);
    await waitFor(`!localStorage.getItem("forge.outbox") || localStorage.getItem("forge.outbox") === "[]"`);
    await waitFor(`localStorage.getItem(${JSON.stringify(`draft.${alice.id}/`)}) === "Mulch first"`);
    await waitFor(`localStorage.getItem(${JSON.stringify(`draft.${alice.id}/feed`)}) === "Mulch first"`);
    expect(await run(`${box}.value`)).toBe("Mulch first");
    await load();
    expect(await run(`${box}.value`)).toBe("Mulch first");
@@ -215,3 +215,20 @@
test.skipIf(noChromium)("in a real browser: type, reload, find it; send, reload,
}, 90000);
test.skipIf(!noChromium)("no chromium on this machine: the composer draft browser test did not run", () => {});
test("a tell sent from the feed's composer comes back to the feed, the forge's too", async () => {
  // Its own session: the browser test before it signs its session out.
  const cookie = createSession(app.db, alice.id).token;
  const page = await (await fetch(`${servers.url}/feed`, { headers: { cookie: `forge_session=${cookie}; forge_mode=studio` } })).text();
  expect(page).toContain('name="back" value="/feed"');
  for (const app of ["forge", "alice/garden"]) {
    const res = await fetch(`${servers.url}/tell`, {
      method: "POST",
      redirect: "manual",
      headers: { cookie: `forge_session=${cookie}; forge_mode=studio`, origin: servers.url, "content-type": "application/x-www-form-urlencoded" },
      body: new URLSearchParams({ app, text: "Plant beans", back: "/feed" }),
    });
    expect(res.status).toBeLessThan(400);
    expect(new URL(res.headers.get("location") ?? "", servers.url).pathname).toBe("/feed");
  }
});
@@ -47,7 +47,7 @@
afterAll(async () => {
test("web, terminal and MCP give identical digest lines for one seeded forge", async () => {
  const cookie = `forge_session=${createSession(app.db, alice.id).token}; forge_mode=studio`;
  const page = await fetch(`${servers.url}/`, { headers: { cookie } }).then((r) => r.text());
  const page = await fetch(`${servers.url}/feed`, { headers: { cookie } }).then((r) => r.text());
  const d = sinceDigest(app.db, alice, lastVisit(app.db, alice.id), Date.now())!;
  expect(d).toBeDefined();
  const lines = d.lines;
@@ -26,7 +26,7 @@
describe("the timeline's caught-up line", () => {
    for (let i = 0; i < n; i++)
      app.bus.append({ kind: "run.finished", repoId: repo.id, actorId: alice.id, payload: { kind: "agent", state: "ok", summary: `work ${i}`, runId: `r${i}` } });
  };
  const home = (path = "/") => freshHome(servers.url, cookie, path);
  const home = (path = "/feed") => freshHome(servers.url, cookie, path);
  beforeAll(async () => {
    dataDir = await mkdtemp(join(tmpdir(), "forge-caught-up-"));
@@ -62,18 +62,18 @@
describe("the timeline's caught-up line", () => {
    const text = await home();
    expect(text).toContain("You're caught up to");
    expect(text).not.toContain("That's everything");
    const href = /href="(\/\?cursor=[^"]+)"[^>]*>Older posts/.exec(text);
    const href = /href="(\/feed\?cursor=[^"]+)"[^>]*>Older posts/.exec(text);
    expect(href).not.toBeNull();
    const older = await home(href![1]!.replaceAll("&amp;", "&"));
    expect(older).toContain("data-item=");
    expect(older).toContain("That's everything");
    expect(older).toContain('<a href="/">Newest</a>');
    expect(older).toContain('<a href="/feed">Newest</a>');
    expect(text).not.toContain(">Newest<");
  });
  test("a page after the first carries its own address, so a chip refetch stays on it", async () => {
    const href = /href="(\/\?cursor=[^"]+)"[^>]*>Older posts/.exec(await home())![1]!.replaceAll("&amp;", "&");
    const cursor = href.slice("/?cursor=".length).split("&day=")[0];
    const href = /href="(\/feed\?cursor=[^"]+)"[^>]*>Older posts/.exec(await home())![1]!.replaceAll("&amp;", "&");
    const cursor = href.slice("/feed?cursor=".length).split("&day=")[0];
    const older = await home(href);
    expect(older).toContain(`data-live-src="/live/feed?cursor=${cursor}&amp;day=`);
    expect(await home()).toContain('data-live-src="/live/feed"');
@@ -88,7 +88,7 @@
describe("the timeline's caught-up line", () => {
  });
  test("a cursor not issued here is the first page", async () => {
    const text = await home("/?cursor=garbage");
    const text = await home("/feed?cursor=garbage");
    expect(text).toContain("You're caught up to");
  });
});
@@ -171,7 +171,7 @@
describe("the chips of a forge", () => {
  test("the home draws the chips, pressed unless switched off", async () => {
    const session = createSession(app.db, bob.id);
    setChip(app.db, bob.id, { kind: "kind", value: "crew" }, true);
    const page = await (await fetch(`${servers.url}/`, { headers: { cookie: `forge_session=${session.token}` } })).text();
    const page = await (await fetch(`${servers.url}/feed`, { headers: { cookie: `forge_session=${session.token}` } })).text();
    expect(page).toContain('data-value="crew"');
    expect(page).toMatch(/data-chip="kind"\s+data-value="crew"\s+aria-pressed="false"/);
    expect(page).toMatch(/data-chip="kind"\s+data-value="reviews"\s+aria-pressed="true"/);
@@ -57,7 +57,7 @@
describe("day dividers on the home timeline", () => {
  });
  test("three days give three dividers in order, once each", async () => {
    const labels = dividerLabels(await get("/"));
    const labels = dividerLabels(await get("/feed"));
    expect(labels).toHaveLength(3);
    expect(labels.slice(0, 2)).toEqual(["Today", "Yesterday"]);
  });
@@ -67,13 +67,13 @@
describe("day dividers on the home timeline", () => {
      const e = app.bus.append({ kind: "run.finished", repoId: repoId, actorId: aliceId, payload: { kind: "agent", state: "ok", summary: `more ${i}`, runId: `m${i}` } });
      app.db.query("UPDATE event SET created_at = ?1 WHERE id = ?2").run(new Date(Date.now() - i * 1000).toISOString(), e.id);
    }
    const first = await get("/");
    const first = await get("/feed");
    expect(dividerLabels(first)[0]).toBe("Today");
    const href = /href="(\/\?cursor=[^"]+)"[^>]*>Older posts/.exec(first)![1]!.replaceAll("&amp;", "&");
    const href = /href="(\/feed\?cursor=[^"]+)"[^>]*>Older posts/.exec(first)![1]!.replaceAll("&amp;", "&");
    const older = await get(href);
    expect(older).toContain("data-item=");
    expect(dividerLabels(older)).not.toContain("Today");
    const live = await get(href.replace("/?", "/live/feed?"));
    const live = await get(href.replace("/feed?", "/live/feed?"));
    expect(dividerLabels(live)).toEqual(dividerLabels(older));
  });
@@ -78,7 +78,7 @@
describe("a failed run's feed post", () => {
  test("home reads the words and links to the line", async () => {
    expect(ranOn).toBe(1);
    const text = await (await fetch(`${servers.url}/`, { headers: { cookie: `${cookie}; forge_mode=studio` } })).text();
    const text = await (await fetch(`${servers.url}/feed`, { headers: { cookie: `${cookie}; forge_mode=studio` } })).text();
    expect(text).toContain("an agent run on #1 failed: error: Cannot find module");
    expect(text).toContain(`/alice/garden/runs/${runId}?all=1#L3`);
  });
@@ -97,7 +97,7 @@
describe("a failed run's feed post", () => {
  });
  test("a reader who is not crew gets the summary and the plain link, never the log line", async () => {
    const home = await (await fetch(`${servers.url}/`, { headers: { cookie: `${bobCookie}; forge_mode=studio` } })).text();
    const home = await (await fetch(`${servers.url}/feed`, { headers: { cookie: `${bobCookie}; forge_mode=studio` } })).text();
    expect(home).toContain("failed");
    expect(home).not.toContain("Cannot find module");
    expect(home).not.toContain("#L3");
@@ -78,7 +78,7 @@
describe("the feed on the home page", () => {
    });
  test("/ renders the ranked feed on first paint, escaped", async () => {
    const res = await get("/", aliceCookie);
    const res = await get("/feed", aliceCookie);
    expect(res.status).toBe(200);
    const text = await res.text();
    expect(text).toContain('id="live-feed"');
@@ -91,7 +91,7 @@
describe("the feed on the home page", () => {
  });
  test("a card links into the thing and steers or tells from where it is", async () => {
    const text = await (await get("/", aliceCookie)).text();
    const text = await (await get("/feed", aliceCookie)).text();
    expect(text).toContain('href="/alice/open/runs/r1"');
    expect(text).toContain('action="/alice/open/runs/r1/steer"');
    const item = readFeed(app.db, alice).items[0]!;
@@ -119,7 +119,7 @@
describe("the feed on the home page", () => {
  });
  test("a viewer sees only their own feed: no leak from a private app", async () => {
    const text = await (await get("/", bobCookie)).text();
    const text = await (await get("/feed", bobCookie)).text();
    expect(text).not.toContain("alice/secret");
    expect(text).not.toContain("hidden work");
    expect(text).toContain("alice/open");
@@ -151,7 +151,7 @@
describe("the feed on the home page", () => {
  });
  test("the page carries the feed script and a card is focusable for j/k", async () => {
    const text = await (await get("/", aliceCookie)).text();
    const text = await (await get("/feed", aliceCookie)).text();
    expect(text).toContain("data-nav");
    expect(text).toContain("/api/v1/feed/interactions");
  });
@@ -126,7 +126,7 @@
test("each verdict is said in the post, asked-for-changes first, on / and in the
    .filter((w) => w.startsWith("approved ") || w.startsWith("asked for changes"));
  expect(posts.sort()).toEqual([APPROVED, CHANGES].sort());
  const home = await fetch(`${servers.url}/`, { headers: { cookie } });
  const home = await fetch(`${servers.url}/feed`, { headers: { cookie } });
  const html = (await home.text()).replace(/\s+/g, " ");
  const at = (s: string): number => html.indexOf(s);
  expect(at(APPROVED)).toBeGreaterThan(-1);
@@ -210,7 +210,7 @@
const COVERED = ["pull", "run", "look", "release", "ask", "decision"];
const NOT_COVERED = ["milestone", "map", "cost", "tell", "reply", "choose"];
let home: string[] | undefined;
const homeHrefs = async (): Promise<string[]> => (home ??= hrefs(await (await get("/")).text()));
const homeHrefs = async (): Promise<string[]> => (home ??= hrefs(await (await get("/feed")).text()));
/**
 * Tap 1: the post's `link` is an href on the home page a person sees, and it
@@ -236,7 +236,7 @@
const one = (items: Item[], kind: string, says: RegExp): Item => {
};
test("the feed carries a post of every covered kind and no kind unaccounted for", async () => {
  expect((await get("/")).status).toBe(200);
  expect((await get("/feed")).status).toBe(200);
  const kinds = new Set((await feed()).map((i) => i.kind));
  for (const k of COVERED) expect(kinds.has(k), k).toBe(true);
  for (const k of kinds) expect([...COVERED, ...NOT_COVERED], `kind ${k} needs a two-taps test`).toContain(k);
@@ -83,7 +83,7 @@
describe("stalled steps on the home", () => {
      .run(r.id, hoursAgo(hours), state);
  };
  const home = async (): Promise<string> =>
    (await fetch(`${servers.url}/`, { headers: { cookie: `${cookie}; forge_mode=studio` } })).text();
    (await fetch(`${servers.url}/feed`, { headers: { cookie: `${cookie}; forge_mode=studio` } })).text();
  const stalled = (user = alice) => readStalled(app.db, user, new Date());
  beforeAll(async () => {
@@ -130,13 +130,11 @@
test("clogLines: the standing clog, then the last cleared note", () => {
  expect(clogLines({ standing: null, last: null }, T0.getTime())).toEqual([]);
});
test("the admin sees the clog on home and in the Flow dialog; a guest and an agent see neither", async () => {
test("the clog is in the Flow dialog for the admin, never on home (#8015), never to a guest or an agent", async () => {
  reset();
  app.db.run("INSERT INTO clog_state (id, since, started_at, first_reasons, quiet) VALUES (1, ?1, ?1, ?2, 0)", [Date.now(), JSON.stringify(["31 pulls conflict <b>"])]);
  const home = async (cookie: string): Promise<string> => (await fetch(`${servers.url}/`, { headers: { cookie } })).text();
  const mine = await home(adminCookie);
  expect(mine).toContain("31 pulls conflict &lt;b&gt;");
  expect(mine).not.toContain("<b>");
  expect(await home(adminCookie)).not.toContain("pulls conflict");
  expect(await home(guestCookie)).not.toContain("pulls conflict");
  expect(flowLines(app.db, new Date(), [], undefined, []).join("\n")).toContain("31 pulls conflict");
  expect(flowLines(app.db, new Date(), [], { queues: [] }, []).join("\n")).not.toContain("31 pulls conflict");
@@ -92,12 +92,13 @@
test("2026-11-01: ready issues wait and no builder runs: it names the cause and
  expect(swept).toBe(1);
});
test("the cause and last act show on home, the boards panel, and the MCP flow report", async () => {
test("the cause and last act show on the boards panel and the MCP flow report, not on home (#8015)", async () => {
  const home = await (await fetch(`${servers.url}/`, { headers: cookie() })).text();
  expect(home).toContain('id="keeper"');
  expect(home).toContain("Binding landings:");
  expect(home).not.toContain('id="keeper"');
  const boards = await (await fetch(`${servers.url}/boards`, { headers: cookie() })).text();
  expect(boards).toContain("unstuck assigned issues");
  expect(boards).toContain('id="keeper"');
  expect(boards).toContain("Binding landings:");
  const report = flowFor(app, { kind: "owner" });
  expect(report.keeper.cause).toContain("no builder is running");
  expect(report.keeper.last).toContain("unstuck assigned issues");
@@ -71,8 +71,8 @@
describe("flow vitals", () => {
        redirect: "manual",
      });
      const cookie = (signin.headers.get("set-cookie") ?? "").split(";")[0]!;
      const home = await (await fetch(`${servers.url}/`, { headers: { cookie } })).text();
      expect(home).toContain(">3 open pulls</a> · 1 opened, 1 landed in 1 h · 3 opened, 2 landed in 6 h · 1 conflicted · 0 red, 0 queued · $0.00 stranded");
      // Home no longer carries the line (#8015): it is the tick line and the flow tool.
      expect(await (await fetch(`${servers.url}/`, { headers: { cookie } })).text()).not.toContain("open pulls</a>");
    } finally {
      await servers.stop();
      app.close();
@@ -27,7 +27,7 @@
const parts = (res: Response): string[] => (res.headers.get("server-timing") ??
test("the signed-in home names its session, reads and render and a cold feed read", async () => {
  const get = async (): Promise<Response> => {
    const res = await fetch(`${f.base}/`, { headers: { cookie: f.ownerCookie } });
    const res = await fetch(`${f.base}/feed`, { headers: { cookie: f.ownerCookie } });
    await res.arrayBuffer();
    return res;
  };
@@ -39,7 +39,7 @@
test("the signed-in home names its session, reads and render and a cold feed rea
  const res = await get();
  const all = parts(res);
  const names = all.map((p) => p.split(";")[0]!);
  for (const n of ["session", "steps", "repos", "kpis", "panels", "feed", "render"])
  for (const n of ["session", "repos", "panels", "feed", "render"])
    expect(names.filter((x) => x === n).length).toBe(1);
  // A miss is a bare `feed;dur=…`: a hit would carry `desc="hit"`.
  expect(all.find((p) => p.startsWith("feed;"))).toMatch(/^feed;dur=\d+(\.\d+)?$/);
@@ -39,12 +39,12 @@
test("the second look at home as the owner costs a bounded number of statements,
  expectWork(await statements(f.app.db, async () => void (await look())), { max: 70 });
  // The page's own total is the sum of named phases: nothing over 20 ms hides in "app" alone.
  // Every phase home.ts and the feed time: one missing here fails as a plain expect, which the gate's budget retry never re-runs.
  const known = new Set(["app", "spawned", "steps", "session", "repos", "asked", "kpis", "vitals", "waiting", "panels", "feed", "settled", "visit", "since", "render"]);
  const known = new Set(["app", "spawned", "steps", "session", "repos", "asked", "kpis", "vitals", "waiting", "panels", "feed", "settled", "visit", "since", "moving", "render"]);
  for (const p of slow) expect(known.has(p.name)).toBe(true);
});
const waiting = async (): Promise<number> => {
  const text = await freshHome(f.base, f.ownerCookie);
  const text = await freshHome(f.base, f.ownerCookie, "/feed");
  return Number(/(\d+) waiting on you/.exec(text)?.[1] ?? 0);
};
@@ -52,7 +52,7 @@
test("the waiting line is a hit on the second look and a write puts it back", as
  const first = await waiting();
  expect(first).toBeGreaterThan(0);
  expect(await waiting()).toBe(first);
  const timing = (await fetch(`${f.base}/`, { headers: { cookie: f.ownerCookie } })).headers.get("server-timing") ?? "";
  const timing = (await fetch(`${f.base}/feed`, { headers: { cookie: f.ownerCookie } })).headers.get("server-timing") ?? "";
  expect(timing).toMatch(/waiting;dur=[\d.]+;desc="hit"/);
  // Every ask is put down in one write: the line is gone at once, not in 30 seconds.
  f.app.db.query("UPDATE issue SET assignee_id = NULL").run();
@@ -82,7 +82,7 @@
describe("home archive", () => {
  const body = (...ids: string[]) => ids.map((id) => `repo=${id}`).join("&");
  const home = async (cookie: string) => (await get("/live/apps", cookie)).text();
  const full = async (cookie: string) => (await get("/", cookie)).text();
  const full = async (cookie: string) => (await get("/feed", cookie)).text();
  test("an admin archives two, the answer lists them, Undo brings them back", async () => {
    const before = await full(rootCookie);
@@ -2,7 +2,7 @@
 * No button spins at rest on Home (#3067, the browser half of #3039).
 *
 * `test/button-rest.test.ts` reads the source for `icon: "loader"`; this loads
 * `/` as an admin in a real headless Chromium, with a stalled step's card on
 * `/feed` as an admin in a real headless Chromium, with a stalled step's card on
 * the page, and asks the computed style: no `button` or `.btn` is
 * `aria-busy`, and nothing inside one runs an animation. It goes red if
 * `flow_card.ts` goes back to the loader icon.
@@ -99,14 +99,14 @@
describe.skipIf(chromium === undefined)("Home's buttons rest", () => {
      test(`${label}, ${scheme}: with a stalled step on the page, no button is busy or animating`, async () => {
        const page = await findBusyButtons(
          chromium!,
          `${servers.url}/`,
          `${servers.url}/feed`,
          { width, height: 800 },
          cookies,
          scheme,
        );
        // The stalled step's button is on the page, so the check has teeth.
        const html = await (
          await fetch(`${servers.url}/`, {
          await fetch(`${servers.url}/feed`, {
            headers: { cookie: cookies.map((c) => `${c.name}=${c.value}`).join("; ") },
          })
        ).text();
@@ -14,7 +14,18 @@
import { kpiCache, panelCache } from "../src/web/studio/home_cache.ts";
import { snappyFixture, type SnappyFixture } from "../bench/snappy.ts";
let f: SnappyFixture;
const home = (cookie?: string): Promise<string> => freshHome(f.base, cookie);
/** Home and the feed page, which together hold what home was: the figures, then the panels and the timeline. */
const home = async (cookie?: string): Promise<string> => (await freshHome(f.base, cookie)) + (await freshHome(f.base, cookie, "/feed"));
/** Both pages' answers: the worst status and every phase either named. */
async function both(cookie: string): Promise<{ status: number; timing: string }> {
  const answers = [];
  for (const path of ["/", "/feed"]) {
    const res = await fetch(`${f.base}${path}`, { headers: { cookie } });
    await res.arrayBuffer();
    answers.push(res);
  }
  return { status: Math.max(...answers.map((r) => r.status)), timing: answers.map((r) => r.headers.get("server-timing") ?? "").join(", ") };
}
beforeAll(async () => {
  f = await snappyFixture();
@@ -42,7 +53,7 @@
test("a warm home reads neither the KPIs nor the panels again, even after a writ
  await home(f.ownerCookie);
  expect([kpi.misses, panel.misses]).toEqual([km, pm]);
  // The second look is a hit one layer in front of those caches (`home_last.ts`): both phases say so.
  const timing = (await fetch(`${f.base}/`, { headers: { cookie: f.ownerCookie } })).headers.get("server-timing") ?? "";
  const { timing } = await both(f.ownerCookie);
  expect(timing).toMatch(/kpis;dur=[\d.]+;desc="hit"/);
  expect(timing).toMatch(/panels;dur=[\d.]+;desc="hit"/);
@@ -84,10 +95,9 @@
interface Counted {
async function counted(): Promise<Counted> {
  const before = writeStamp(f.app.db);
  f.counter.reset();
  const res = await fetch(`${f.base}/`, { headers: { cookie: f.ownerCookie } });
  await res.arrayBuffer();
  const res = await both(f.ownerCookie);
  const ran = new Map(f.counter.top(10_000).map((s) => [s.sql, s.times]));
  return { status: res.status, hits: phases(res.headers.get("server-timing")), ran, before, after: writeStamp(f.app.db) };
  return { status: res.status, hits: phases(res.timing), ran, before, after: writeStamp(f.app.db) };
}
/**
@@ -84,7 +84,7 @@
test("the real home never contradicts its own figures; with one figure changed i
  const honest = await run([servers.url]);
  expect(honest.out).toMatch(/errors 0 ·/);
  expect(honest.out).not.toMatch(/^wrong /m);
  const home = await (await fetch(`${servers.url}/`, { headers: { cookie } })).text();
  const home = await (await fetch(`${servers.url}/feed`, { headers: { cookie } })).text();
  expect(home).toContain("3 waiting on you");
  // A stand-in in front of the forge: the real home with one figure wrong, every API read passed through.
  stub = Bun.serve({
@@ -125,13 +125,13 @@
describe("home is the feed", () => {
  });
  test("the composer is a §5 card, and no .composer class remains", async () => {
    const text = await (await get("/", aliceCookie)).text();
    const text = await (await get("/feed", aliceCookie)).text();
    expect(text).toMatch(/<form id="composer" class="card" method="post" action="\/tell">\s*<div class="card-body/);
    expect(text).not.toContain('class="composer');
  });
  test("the composer's action bar is §5's bar, not .composer-bar", async () => {
    const text = await (await get("/", aliceCookie)).text();
    const text = await (await get("/feed", aliceCookie)).text();
    const form = text.slice(text.indexOf('id="composer"'), text.indexOf("</form>", text.indexOf('id="composer"')));
    expect(form).not.toContain("composer-bar");
    expect(form).toContain('<div class="bar">');
@@ -142,7 +142,7 @@
describe("home is the feed", () => {
  });
  test("signed in, / is the composer above one timeline; your apps one step away", async () => {
    const text = await (await get("/", aliceCookie)).text();
    const text = await (await get("/feed", aliceCookie)).text();
    const composer = text.indexOf('id="composer"');
    const feed = text.indexOf('id="live-feed"');
    expect(composer).toBeGreaterThan(-1);
@@ -183,7 +183,7 @@
describe("home is the feed", () => {
    const asked = await (await get("/asked", aliceCookie)).text();
    expect(asked).toMatch(/class="tabs"[\s\S]*?href="\/asked"\s+aria-current="page"/);
    expect(asked).toContain('href="/"');
    expect(text).toMatch(/class="tabs"[\s\S]*?href="\/"\s+aria-current="page"/);
    expect(text).toMatch(/class="tabs"[\s\S]*?href="\/feed"\s+aria-current="page"/);
    for (const page of [apps, asked]) {
      expect(page).not.toContain("home-tabs");
      for (const w of ["Feed", "Your apps", "Asked"]) expect(page).toContain(w);
@@ -191,7 +191,7 @@
describe("home is the feed", () => {
  });
  test("a reader's timeline has the public repository's posts and nothing private or configured", async () => {
    const text = await (await get("/", bobCookie)).text();
    const text = await (await get("/feed", bobCookie)).text();
    expect(text).toContain("Water the tomatoes at dawn");
    expect(text).not.toContain("The combination is 4-8-15");
    expect(text).not.toContain("alice/vault");
@@ -222,7 +222,7 @@
describe("home is the feed", () => {
      text: 'Look at this </textarea><script>alert(1)</script>',
      url: "https://example.com/gauge",
    });
    const res = await get(`/?${q}`, aliceCookie);
    const res = await get(`/feed?${q}`, aliceCookie);
    const text = await res.text();
    const box = /<textarea[^>]*name="text"[^>]*>([\s\S]*?)<\/textarea>/.exec(text);
    expect(box?.[1]).toContain("Rain gauges\nLook at this &lt;/textarea&gt;&lt;script&gt;");
@@ -323,13 +323,13 @@
describe("home is the feed", () => {
      )
      .get(alice.id);
    expect(row).toEqual({ text, source: "composer" });
    const page = await freshHome(servers.url, `${aliceCookie}; forge_mode=studio`);
    const page = await freshHome(servers.url, `${aliceCookie}; forge_mode=studio`, "/feed");
    expect(page).toContain("&lt;script&gt;alert(1)&lt;/script&gt; &amp; more");
    expect(page).not.toContain("<script>alert(1)</script>");
    expect(page).toContain("Received");
    expect(page).toContain('<option value="forge">the forge</option>');
    // It is the author's alone, and another site's form is refused.
    const bobs = await freshHome(servers.url, `${bobCookie}; forge_mode=studio`);
    const bobs = await freshHome(servers.url, `${bobCookie}; forge_mode=studio`, "/feed");
    expect(bobs).not.toContain("alert(1)");
    const forged = await fetch(`${servers.url}/tell`, {
      method: "POST",
@@ -342,21 +342,21 @@
describe("home is the feed", () => {
  });
  test("a person with no apps can still send to the forge, and a day-old thought leaves the feed", async () => {
    const empty = await freshHome(servers.url, `${bobCookie}; forge_mode=studio`);
    const empty = await freshHome(servers.url, `${bobCookie}; forge_mode=studio`, "/feed");
    expect(empty).toContain('name="app" value="forge"');
    expect(empty).toContain("No apps yet");
    const old = new Date(Date.now() - 2 * 86_400_000).toISOString();
    app.db
      .query("INSERT INTO thought (id, author, text, source, received_at) VALUES ('old1', ?1, 'ancient musing', 'composer', ?2)")
      .run(bob.id, old);
    expect(await freshHome(servers.url, `${bobCookie}; forge_mode=studio`)).not.toContain("ancient musing");
    expect(await freshHome(servers.url, `${bobCookie}; forge_mode=studio`, "/feed")).not.toContain("ancient musing");
    await fetch(`${servers.url}/tell`, {
      method: "POST",
      headers: { cookie: bobCookie, origin: servers.url },
      body: new URLSearchParams({ app: "forge", text: "fresh musing" }),
      redirect: "manual",
    });
    const after = await freshHome(servers.url, `${bobCookie}; forge_mode=studio`);
    const after = await freshHome(servers.url, `${bobCookie}; forge_mode=studio`, "/feed");
    expect(after).toContain("fresh musing");
    expect(after).not.toContain("ancient musing");
  });
@@ -366,7 +366,7 @@
describe("home is the feed", () => {
    const serving = (payload: Record<string, unknown>) =>
      app.bus.append({ kind: "app.serving", repoId: garden.id, payload: { app: "garden", env: "production", commitOid: oid, ...payload } });
    serving({ version: "0.7.251", pulls: [{ title: "Water <b>early</b>", number: 1 }, { title: "Mulch", number: 2 }, { title: "Weed", number: 3 }] });
    const page = await freshHome(servers.url, `${aliceCookie}; forge_mode=studio`);
    const page = await freshHome(servers.url, `${aliceCookie}; forge_mode=studio`, "/feed");
    expect(page).toContain("0.7.251 is serving: Water &lt;b&gt;early&lt;/b&gt; and 2 more");
    expect(page).not.toContain("<b>early</b>");
    expect(page).toContain(`href="/alice/garden/commit/${oid}"`);
@@ -424,7 +424,7 @@
describe("home is the feed", () => {
      if (!made.ok) throw new Error("issue");
      expect(assignIssue(app, alice, garden, made.value, alice).ok).toBe(true);
    }
    const page = await (await get("/", aliceCookie)).text();
    const page = await (await get("/feed", aliceCookie)).text();
    // The timeline may still tell of a filed issue as a post; the asks are
    // what must be gone, so the page is read up to the timeline.
    const home = page.slice(0, page.indexOf('id="live-feed"'));
@@ -24,7 +24,7 @@
afterAll(async () => {
  await f.close();
});
const look = async (cookie: string, path = "/") => {
const look = async (cookie: string, path = "/feed") => {
  const res = await fetch(`${f.base}${path}`, { headers: { cookie } });
  const text = await res.text();
  const app = /app;dur=([\d.]+)/.exec(res.headers.get("server-timing") ?? "");
@@ -66,11 +66,14 @@
test("after a write, signed-in home is answered from memory within the budget an
    median = times[Math.floor(times.length / 2)]!;
  }
  expect(median).toBeLessThan(APP_BUDGET_MS);
  for (const name of ["kpis", "waiting", "panels", "asked", "feed"]) {
  for (const name of ["waiting", "panels", "asked", "feed"]) {
    expect(marked).toContain(`id="home-${name}"`);
  }
  expect(marked).toContain('data-refresh="/live/home/feed"');
  expect(marked).toContain('data-refresh="/live/home/kpis"');
  // The figures are on home itself, the feed's page holds the rest.
  await look(f.ownerCookie, "/");
  write(99);
  expect((await look(f.ownerCookie, "/")).text).toContain('data-refresh="/live/home/kpis"');
});
test("the first response stays under its byte limit", async () => {
@@ -96,6 +99,7 @@
test("each late region answers alone, to its own viewer, and to no one else", as
test("one viewer's remembered regions never reach another", async () => {
  await look(f.ownerCookie);
  await look(f.ownerCookie, "/");
  write(99);
  const peer = await look(f.peerCookie);
  const owners = await look(f.ownerCookie);
@@ -379,7 +379,7 @@
describe("home waiting line", () => {
      const cookie = (signin.headers.get("set-cookie") ?? "").split(";")[0]!;
      const review = await (await fetch(`${servers.url}/review`, { headers: { cookie } })).text();
      expect(review.split("<li").filter((r) => r.includes('class="row"')).length).toBe(stale.length);
      return await (await fetch(`${servers.url}/`, { headers: { cookie } })).text();
      return await (await fetch(`${servers.url}/feed`, { headers: { cookie } })).text();
    } finally {
      await servers.stop();
      app.close();
@@ -0,0 +1,218 @@
/**
 * Home is the living pipeline (#8015): the box, the figures, the pipeline in
 * four words, what is being built and what just shipped (each row a link),
 * your apps; the feed is its own page. Rows are read for the viewer.
 */
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 { createRepo } from "../src/actions/repos.ts";
import { createIssue } from "../src/core/issues.ts";
import { createSession } from "../src/core/sessions.ts";
import { createUser, type User } from "../src/core/users.ts";
import { serve, type Servers } from "../src/http/server.ts";
import { MOVING_ROWS, nowOf, readBuilding, readShipped } from "../src/flow/moving.ts";
import type { PipelineStage } from "../src/flow/pipeline.ts";
import { expectWork, requestStatements } from "./helpers/work.ts";
import { statements } from "./helpers/statements.ts";
import { promote } from "./helpers/members.ts";
import { createForgeApp } from "../src/tui/forge.ts";
import { dashboardScreen } from "../src/tui/screens/dashboard.ts";
import { headlessTerminal } from "../src/tui/term/terminal.ts";
import { settleApp } from "./helpers/tui.ts";
let dataDir: string;
let app: App;
let servers: Servers;
let alice: User;
let bob: User;
let aliceCookie: string;
let bobCookie: string;
let rootCookie: string;
let root: User;
let openRepoId: string;
let secretRepoId: string;
const get = (path: string, cookie?: string) => fetch(`${servers.url}${path}`, { headers: cookie ? { cookie } : {}, redirect: "manual" });
const home = async (cookie?: string) => (await get("/", cookie)).text();
/** The terminal's home, as the viewer's session draws it. */
async function terminalHome(user: User): Promise<string> {
  const { app: tui, session } = createForgeApp(
    app,
    { sshUsername: user.username, remoteAddress: "127.0.0.1", fingerprint: "SHA256:test", user },
    { terminal: headlessTerminal(200, 40), exitHooks: false },
  );
  tui.start();
  tui.ctx.push(dashboardScreen(session, tui.ctx));
  await settleApp(tui);
  const text = tui.screen.toText();
  tui.stop?.();
  return text;
}
function merged(repoId: string, title: string, minutesAgo: number) {
  const made = createIssue(app.db, { repoId, authorId: alice.id, title, kind: "pull" });
  if (!made.ok) throw new Error(made.error);
  app.db
    .query("INSERT INTO pull (issue_id, base_branch, head_branch, base_oid, head_oid, merged_at, merged_by) VALUES (?, 'main', ?, 'b', 'h', ?, ?)")
    .run(made.value.id, `h-${title}`, new Date(Date.now() - minutesAgo * 60_000).toISOString(), alice.id);
  return made.value;
}
function building(repoId: string, title: string) {
  const made = createIssue(app.db, { repoId, authorId: alice.id, title, kind: "issue" });
  if (!made.ok) throw new Error(made.error);
  app.db
    .query("INSERT INTO run (id, repo_id, kind, issue_id, commit_oid, state, actor_id, started_at) VALUES (?, ?, 'agent', ?, 'c', 'running', ?, ?)")
    .run(`zzzz-${crypto.randomUUID()}`, repoId, made.value.id, alice.id, new Date().toISOString());
  return made.value;
}
beforeAll(async () => {
  dataDir = await mkdtemp(join(tmpdir(), "forge-home-living-"));
  app = createApp({ dataDir, port: 0 });
  servers = await serve(app);
  const mk = async (username: string, first = false) => {
    const r = await createUser(app.db, { origin: "seed", trusted: true, username, allowReserved: true, email: `${username}@forge.local`, password: "a-good-passphrase", adminIfFirst: first });
    if (!r.ok) throw new Error(r.error);
    promote(app.db, r.value);
    return r.value;
  };
  root = await mk("root", true);
  rootCookie = `forge_session=${createSession(app.db, root.id).token}`;
  alice = await mk("alice");
  bob = await mk("bob");
  aliceCookie = `forge_session=${createSession(app.db, alice.id).token}`;
  bobCookie = `forge_session=${createSession(app.db, bob.id).token}`;
  const open = await createRepo(app, alice, { name: "open", visibility: "public" });
  const secret = await createRepo(app, alice, { name: "secret", visibility: "private" });
  if (!open.ok || !secret.ok) throw new Error("repos");
  openRepoId = open.value.id;
  secretRepoId = secret.value.id;
});
afterAll(async () => {
  servers.stop();
  app.close();
  await rm(dataDir, { recursive: true, force: true });
});
describe("home", () => {
  test("holds the box, both lists and your apps, and no feed", async () => {
    const page = await home(aliceCookie);
    expect(page).toContain('id="tell-box"');
    expect(page).toContain('action="/tell"');
    expect(page).toContain("Being built");
    expect(page).toContain("Just shipped");
    expect(page).toContain('id="live-chips"');
    expect(page).toContain('href="/apps/new"');
    expect(page).toContain('href="/feed"');
    for (const gone of ['id="live-feed"', 'id="composer"', "waiting on you", "id=\"keeper\""]) expect(page).not.toContain(gone);
  });
  test("a site admin sees the pipeline in four words, each linking to where it is", async () => {
    const page = await home(rootCookie);
    expect(page).toContain('id="now-line"');
    for (const word of ["check", "review", "land"]) expect(page).toContain(`</strong> ${word}</a>`);
    expect(page).toMatch(/href="\/releases"><strong>\d+<\/strong> live<\/a>/);
  });
  test("the forge-wide pipeline counts never reach a viewer who is not a site admin", async () => {
    building(secretRepoId, "Counted build");
    for (const cookie of [aliceCookie, bobCookie]) {
      expect(await home(cookie)).not.toContain('id="now-line"');
      expect(await (await get("/live/moving", cookie)).text()).not.toContain('id="now-line"');
    }
    expect(await (await get("/live/moving", rootCookie)).text()).toContain('id="now-line"');
  });
  test("the terminal home carries the same lines: Now for a site admin, being built and just shipped as the viewer reads them", async () => {
    building(openRepoId, "Terminal build");
    building(secretRepoId, "Terminal secret");
    const mine = await terminalHome(alice);
    expect(mine).toContain("Being built");
    expect(mine).toContain("Just shipped");
    expect(mine).toContain("Terminal build");
    expect(mine).not.toContain("Now  check");
    const theirs = await terminalHome(bob);
    expect(theirs).toContain("Being built");
    expect(theirs).not.toContain("Terminal secret");
    expect(await terminalHome(root)).toMatch(/Now {2}check \d+ › review \d+ › land \d+ › \d+ live/);
  });
  test("a stranger gets the door, not the box", async () => {
    const page = await home();
    expect(page).not.toContain('id="tell-box"');
    expect(page).not.toContain("Being built");
  });
  test("being built and just shipped are links to what they name, escaped, and always hold the same number of rows", async () => {
    const quiet = await (await get("/live/moving", aliceCookie)).text();
    const rows = (t: string) => t.split('class="row"').length - 1;
    const base = rows(quiet);
    expect(base).toBe(2 * MOVING_ROWS);
    const issue = building(openRepoId, "Teach <b>trails</b>");
    const pull = merged(openRepoId, "Instant home", 2);
    const page = await home(aliceCookie);
    expect(page).toContain(`href="/alice/open/issues/${issue.number}"`);
    expect(page).toContain(`href="/alice/open/pulls/${pull.number}"`);
    expect(page).toContain("Teach &lt;b&gt;trails&lt;/b&gt;");
    expect(page).not.toContain("<b>trails");
    const busy = await (await get("/live/moving", aliceCookie)).text();
    expect(rows(busy)).toBe(base);
  });
  test("a row in a repository the viewer cannot read is never named", async () => {
    building(secretRepoId, "Hidden build");
    merged(secretRepoId, "Hidden ship", 1);
    expect(await home(aliceCookie)).toContain("Hidden ship");
    for (const cookie of [bobCookie]) {
      const page = await home(cookie);
      expect(page).not.toContain("Hidden ship");
      expect(page).not.toContain("Hidden build");
      expect(page).not.toContain("alice/secret");
    }
    expect(readShipped(app.db, bob).map((r) => r.title)).not.toContain("Hidden ship");
    expect(readBuilding(app.db, bob).map((r) => r.title)).not.toContain("Hidden build");
  });
  test("the live fragment is for the signed in, and the region is wired to the stream", async () => {
    expect((await get("/live/moving")).status).toBe(404);
    expect((await get("/live/chips")).status).toBe(404);
    const chips = await get("/live/chips", aliceCookie);
    expect(chips.status).toBe(200);
    expect(await chips.text()).toContain('id="live-chips"');
    expect(await home(aliceCookie)).toMatch(/id="live-moving"[^>]*data-live="[^"]*pull\.merged[^"]*"[^>]*data-live-src="\/live\/moving"/);
  });
  test("a warm home costs a bounded number of statements, the two scans read once per write", async () => {
    await home(aliceCookie);
    const warm = await requestStatements(app.db, `${servers.url}/`, { headers: { cookie: aliceCookie } });
    expectWork(warm, { max: 40 });
    const scans = await statements(app.db, async () => void (await get("/live/moving", aliceCookie).then((r) => r.text())));
    const again = await statements(app.db, async () => void (await get("/live/moving", aliceCookie).then((r) => r.text())));
    expect(again).toBeLessThanOrEqual(scans);
  });
});
describe("the pipeline in four words", () => {
  const stage = (key: PipelineStage["key"], waiting: number, active: number) => ({ key, waiting, active }) as PipelineStage;
  test("each word is the sum of the boards' stages it names", () => {
    const now = nowOf([stage("check-queue", 4, 0), stage("checking", 0, 6), stage("review", 1, 0), stage("approved", 3, 0), stage("live", 0, 0), stage("ready", 9, 9)]);
    expect(now).toEqual({ check: 10, review: 1, land: 3, live: 0 });
  });
});
describe("the feed page", () => {
  test("holds the composer and the timeline; a stranger is sent to sign in", async () => {
    const page = await (await get("/feed", aliceCookie)).text();
    expect(page).toContain('id="composer"');
    expect(page).toContain('id="live-feed"');
    expect(page).not.toContain("Being built");
    const stranger = await get("/feed");
    expect(stranger.status).not.toBe(200);
  });
});
@@ -67,7 +67,7 @@
test("home heads the digest with the window, lists only landed pulls the viewer
  db.query("DELETE FROM pull WHERE issue_id = ?1").run(`since-${priv.id}-3`);
  db.query("INSERT INTO home_visit (user_id, at) VALUES (?1, ?2) ON CONFLICT(user_id) DO UPDATE SET at = excluded.at").run(f.owner.id, Date.now() - 3 * H);
  const res = await fetch(`${f.base}/?all=1`, { headers: { cookie: f.ownerCookie } });
  const res = await fetch(`${f.base}/feed?all=1`, { headers: { cookie: f.ownerCookie } });
  const text = await res.text();
  expect(text).toContain("Since you were here · 3 hours");
  expect(text).toContain("1 landed");
@@ -80,7 +80,7 @@
test("home heads the digest with the window, lists only landed pulls the viewer
test("a first-time user, with no home_visit row, gets the 24 hour heading", async () => {
  const db = f.app.db;
  db.query("DELETE FROM home_visit WHERE user_id = ?1").run(f.owner.id);
  const text = await (await fetch(`${f.base}/?all=1`, { headers: { cookie: f.ownerCookie } })).text();
  const text = await (await fetch(`${f.base}/feed?all=1`, { headers: { cookie: f.ownerCookie } })).text();
  expect(text).toContain("Since you were here · 1 day<");
  expect(text).toContain("1 landed");
  expect(lastVisit(db, f.owner.id)).toBeDefined();
@@ -118,12 +118,12 @@
test("a prefetch, a preview or a non-document fetch leaves home_visit unchanged;
    { "sec-fetch-dest": "iframe" },
  ]) {
    set();
    const text = await (await fetch(`${f.base}/?all=1`, { headers: { cookie: f.ownerCookie, ...headers } })).text();
    const text = await (await fetch(`${f.base}/feed?all=1`, { headers: { cookie: f.ownerCookie, ...headers } })).text();
    expect(text).toContain("Since you were here · 3 hours");
    expect(lastVisit(db, f.owner.id)).toBe(at);
  }
  set();
  await (await fetch(`${f.base}/?all=1`, { headers: { cookie: f.ownerCookie, "sec-fetch-dest": "document" } })).text();
  await (await fetch(`${f.base}/feed?all=1`, { headers: { cookie: f.ownerCookie, "sec-fetch-dest": "document" } })).text();
  expect(lastVisit(db, f.owner.id)).toBeGreaterThan(at);
});
@@ -13,11 +13,13 @@
afterAll(async () => {
  await f.close();
});
async function timing(cookie?: string): Promise<string[]> {
  const res = await fetch(`${f.base}/`, { headers: cookie ? { cookie } : {} });
async function timing(cookie?: string, path = "/"): Promise<string[]> {
  const res = await fetch(`${f.base}${path}`, { headers: cookie ? { cookie } : {} });
  await res.arrayBuffer();
  return (res.headers.get("server-timing") ?? "").split(", ");
}
/** Home's phases and the feed page's together: what home was before the feed moved off it. */
const timings = async (cookie?: string): Promise<string[]> => [...(await timing(cookie)), ...(await timing(cookie, "/feed"))];
const names = (parts: string[]): string[] => parts.map((p) => p.split(";")[0]!);
test("a cold look at the owner's home names each part of the kpis read", async () => {
@@ -27,8 +29,8 @@
test("a cold look at the owner's home names each part of the kpis read", async (
});
test("the owner's home names feed, kpis and panels; a warm look is a hit", async () => {
  await timing(f.ownerCookie);
  const warm = await timing(f.ownerCookie);
  await timings(f.ownerCookie);
  const warm = await timings(f.ownerCookie);
  expect(names(warm)).toEqual(expect.arrayContaining(["feed", "kpis", "panels"]));
  expect(names(warm)).not.toContain("shelf");
  expect(warm.find((p) => p.startsWith("kpis;"))).toMatch(/^kpis;dur=\d+\.\d;desc="hit"$/);
@@ -36,7 +38,7 @@
test("the owner's home names feed, kpis and panels; a warm look is a hit", async
});
test("a signed-in non-admin gets the feed and none of the admin-only phases", async () => {
  const got = names(await timing(f.peerCookie));
  const got = names(await timings(f.peerCookie));
  expect(got).toContain("feed");
  expect(got).not.toContain("kpis");
  for (const part of KPI_PARTS) expect(got).not.toContain(part);
@@ -58,7 +58,7 @@
test("composer, timeline, a tell, a crew member's run and pull, a share, the app
  if (!repo.ok) throw new Error("repo");
  expect(addToCrew(app, root, repo.value, "scribe").ok).toBe(true);
  const cookie = (u: User) => `forge_session=${createSession(app.db, u.id).token}; forge_mode=studio`;
  const home = (u: User) => freshHome(servers.url, cookie(u));
  const home = (u: User) => freshHome(servers.url, cookie(u), "/feed");
  // The composer comes first, then the timeline.
  const first = await home(alice);
@@ -156,7 +156,7 @@
describe("live browsing pages", () => {
    ).split(";")[0]!;
    const html = await (
      await fetch(`${base}/`, {
      await fetch(`${base}/feed`, {
        headers: { cookie: `${cookie}; forge_mode=studio` },
      })
    ).text();
@@ -127,7 +127,7 @@
describe("the viewer's stream", () => {
  });
  test("the studio pages carry live regions and the script that keeps them fresh", async () => {
    const res = await fetch(`${servers.url}/`, {
    const res = await fetch(`${servers.url}/feed`, {
      headers: { cookie: `${cookie}; forge_mode=studio` },
    });
    const page = await res.text();
@@ -156,7 +156,7 @@
describe("the service worker and the server", () => {
  });
  test("the home page registers the worker, has the note, and allows workers", async () => {
    const res = await fetch(`${servers.url}/`, { headers: { cookie } });
    const res = await fetch(`${servers.url}/feed`, { headers: { cookie } });
    const text = await res.text();
    expect(text).toContain("serviceWorker");
    expect(text).toContain('id="feed-note"');
@@ -165,7 +165,7 @@
describe("the service worker and the server", () => {
  });
  test("the live client resumes /events from the last seen id", async () => {
    const text = await (await fetch(`${servers.url}/`, { headers: { cookie } })).text();
    const text = await (await fetch(`${servers.url}/feed`, { headers: { cookie } })).text();
    expect(text).toContain("/events?since=");
    expect(text).toContain("'online'");
  });
@@ -56,7 +56,7 @@
test("the real home reads as text: heading and waiting count, no CSS, script or
      .query(`INSERT INTO pull (issue_id, base_branch, head_branch, base_oid, head_oid, head_repo_id) VALUES (?1, 'main', ?2, ?3, ?3, ?4)`)
      .run(issueId, `b/${i}`, "0".repeat(40), repo.value.id);
  }
  const raw = await get("/");
  const raw = await get("/feed");
  expect(raw).toContain("<script");
  expect(raw).toContain("<style");
  const text = pageText(raw);
@@ -92,7 +92,7 @@
const run = async (args: string[], env: Record<string, string> = {}) => {
};
test("scripts/home-read.ts prints the text and the stats line, sends FORGE_COOKIE and never prints it", async () => {
  const r = await run([`${servers.url}/`], { FORGE_COOKIE: cookie });
  const r = await run([`${servers.url}/feed`], { FORGE_COOKIE: cookie });
  expect(r.code).toBe(0);
  expect(r.out.trimEnd().split("\n").pop()).toMatch(/^chars \d+ · words \d+ · fetched in \d+ ms$/);
  expect(r.out).toContain("Feed Your apps Asked");
@@ -170,8 +170,8 @@
describe("the releases page", () => {
    const cookie = await login("alice", "a-good-passphrase");
    const body = await (await fetch(`${servers.url}/`, { headers: { cookie } })).text();
    expect(body).toContain('href="/releases"');
    expect(body).toContain("live:");
    expect(body).toContain("aaaaaaa");
    // An admin's tile, or the plain line anyone else gets: both name the live version.
    expect(body).toMatch(/live: <span class="sha">aaaaaaa|Live version: a{7}/);
  });
  test("a signed-out visitor is sent to sign in", async () => {
@@ -63,7 +63,7 @@
describe("one count on Home, /review and the MCP", () => {
      const cookie = (signin.headers.get("set-cookie") ?? "").split(";")[0]!;
      const get = async (path: string) => await (await fetch(`${servers.url}${path}`, { headers: { cookie } })).text();
      const home = await get("/");
      const home = await get("/feed");
      const said = Number(/(\d+) waiting on you/.exec(home)?.[1]);
      expect(home).toContain("2 stale, archive?");
      expect(home).toContain('action="/asks/bulk"');
@@ -71,7 +71,7 @@
describe("the terminal on the website", () => {
  });
  test("the dashboard has a Terminal card, with the host key", async () => {
    const page = await fetch(`${base}/`, { headers: { cookie } }).then((r) =>
    const page = await fetch(`${base}/feed`, { headers: { cookie } }).then((r) =>
      r.text(),
    );
    expect(page).toContain("<h2>Terminal</h2>");
@@ -91,7 +91,7 @@
describe("the terminal on the website", () => {
  });
  test("the dashboard's Terminal card has no terminal-line, keeps the keys link", async () => {
    const page = await fetch(`${base}/`, { headers: { cookie } }).then((r) =>
    const page = await fetch(`${base}/feed`, { headers: { cookie } }).then((r) =>
      r.text(),
    );
    expect(page).not.toContain("terminal-line");
@@ -92,7 +92,7 @@
describe("a tell from the four places", () => {
    expect(pill.status).toBe(200);
    // 3. the share sheet: land on the composer with a draft, then post it
    const landed = await fetch(`${servers.url}/?text=${encodeURIComponent("Tell from share")}`, {
    const landed = await fetch(`${servers.url}/feed?text=${encodeURIComponent("Tell from share")}`, {
      headers: { authorization: `Bearer ${token}` },
    });
    expect(landed.status).toBe(200);
@@ -1129,7 +1129,7 @@
describe("the studio, continued", () => {
    // Erin's front door: the empty state and New app, never alice's public
    // app — #69's case, finally reachable.
    const erinHome = await (await erinGet("/")).text();
    const erinHome = await (await erinGet("/feed")).text();
    expect(erinHome).toContain("No apps yet");
    expect(erinHome).toContain('href="/apps/new"');
    expect(erinHome).toContain('href="/erin"');
@@ -527,7 +527,7 @@
describe("the studio home keeps itself current", () => {
  let readme: Issue;
  const get = (extraCookie = "") =>
    fetch(`${base}/`, {
    fetch(`${base}/feed`, {
      headers: {
        cookie: `${cookie}${extraCookie}; forge_mode=studio`,
      },
@@ -174,7 +174,7 @@
describe("the studio", () => {
      description: "",
    });
    if (!later.ok) throw new Error(String(later.error));
    const html = await (await get("/")).text();
    const html = await (await get("/feed")).text();
    const block = html.match(
      /<script type="application\/json" id="palette-index">([\s\S]*?)<\/script>/,
    )?.[1];
@@ -276,7 +276,7 @@
describe("the studio", () => {
  });
  test("the home and an app's page lay main and rail with .split's wide rail; no dash class is left (#4748)", async () => {
    for (const path of ["/", "/alice/notes"]) {
    for (const path of ["/feed", "/alice/notes"]) {
      const page = await (await get(path)).text();
      expect(page).not.toMatch(/class="[^"]*\bdash(?:-main|-rail)?\b/);
      expect(page).toContain('<div class="split" data-rail="wide">');
@@ -230,7 +230,7 @@
describe("surfaces adversarial: web", () => {
      },
    );
    expect(assignedToAlice.status).toBe(303);
    const dash = await bodyOf(alice, "/");
    const dash = await bodyOf(alice, "/feed");
    expect(dash).not.toContain(payload);
    expect(dash).toContain(escaped);
@@ -291,7 +291,7 @@
describe("apps, runs and the crew on the web", () => {
  test("the dashboard and /apps list the app with its state and URL", async () => {
    // The home's rail names your apps and offers New app (#625).
    const dash = await bodyOf(alice, "/");
    const dash = await bodyOf(alice, "/feed");
    expect(dash).toContain("<h2>Your apps</h2>");
    expect(dash).toContain("alice/hello");
    expect(dash).toContain('href="/apps/new"');
@@ -607,7 +607,7 @@
describe("browsing an origin repository on the web", () => {
    const pages = {
      repo: await bodyOf(alice, "/alice/widgets"),
      picker: await bodyOf(alice, `/settings/origins/${originId}/repos`),
      home: await bodyOf(alice, "/"),
      home: await bodyOf(alice, "/feed"),
      search: await bodyOf(alice, "/search?q=widgets"),
    };
    const strip = stripOf(pages.repo);
@@ -599,7 +599,7 @@
describe("origins on the web", () => {
    expect(picker).toContain("mirrored as");
    expect(picker).toContain("this machine");
    const dash = await (await asUser(`${alice}; forge_mode=dev`, "/")).text();
    const dash = await (await asUser(`${alice}; forge_mode=dev`, "/feed")).text();
    expect(dash).toContain("On your machine");
    expect(dash).toContain("forge sync");
    expect(dash).toContain('href="/alice/widgets"');
@@ -138,7 +138,7 @@
describe("one hostile string, every surface", () => {
  });
  const pages: [string, () => string][] = [
    ["the home feed", () => "/"],
    ["the home feed", () => "/feed"],
    ["the issue", () => `/alice/game/issues/${issueNo}`],
    ["the pull", () => `/alice/game/pulls/${pullNo}`],
    ["the issue list", () => "/alice/game/issues"],
		@@ -0,0 +1,4 @@
	1	# Home
	2
	3	- `.moving` — the living home's two lists (Being built, Just shipped), drawn by `movingRegion` in `src/web/studio/living.ts`: a one-column grid on a phone, two equal columns from 700px. Each list always holds three rows, so a quiet list is as tall as a busy one and nothing below it moves.
	4	- `.tell-box` — home's one-line box that tells the crew: a `bar` whose text input takes the free width (`flex: 1 1 14rem`) and wraps the app picker and Tell under it on a phone.
		@@ -54,6 +54,7 @@ Machine routes are not pages and have no entry: `/audit.csv`,
54	54	- `/board/returns` — `pages/returns.ts` · what the window's dollars bought · `/settings/subscriptions` spend tables, `/settings/usage` · none seen.
55	55	- `/big` — `pages/board.ts` (`bigRedirect`) · a redirect kept for old addresses into the board's wall mode · it is `/board` · none (no page of its own).
56	56	- `/boards` — `pages/boards-view.ts` · saved queries as panels · `/board` · none seen.
	57	- `/feed` — `studio/home.ts` · the composer and one timeline, what home was before it became the living pipeline (#8015) · `/` · none seen.
57	58	- `/boards/data` — `pages/boards.ts` · the boards' query/data surface · `/board` · none seen.
58	59	- `/asks` — `studio/asks_page.ts` · what the crew is waiting on me for · `/` "needs me" list · colours 2.
59	60	- `/asked` — `studio/asked_page.ts` · what I answered, as a record · `/asks` · none seen.
		@@ -0,0 +1,17 @@
	1	# The living home (#8015)
	2
	3	Signed in, `/` is five things and nothing else:
	4
	5	1. The box — one line that tells the crew (`POST /tell`, the same action the feed's composer posts to). A phone's share sheet fills it.
	6	2. The figures (admins) — the KPI tiles and any alarm, one calm line each. Everyone else gets the live version line.
	7	3. Now (site admins) — `check › review › land › live`, each the sum of the `/boards` stages it names (`nowOf` in `src/flow/moving.ts`), each a link. The counts take in every repository, private ones too, so no one else is shown them.
	8	4. Being built / Just shipped — three rows each, every row a link to its issue or pull, read for the viewer (a repository they cannot read, and a sealed report, are never named). One live region, `#live-moving`, redrawn from `/live/moving` when a run or a merge moves; it always holds six rows, so nothing below it shifts.
	9	5. Your apps — a chip per app and a plus; `#live-chips`, redrawn from `/live/chips`.
	10
	11	The terminal's home carries the same lines (`movingLines` in `src/tui/screens/moving.ts`): Now for a site admin, then being built and just shipped, read for the viewer; its tell is the box.
	12
	13	The feed — the composer, the timeline, what is on you, since you were here, pinned panels — is `/feed`, linked from home.
	14
	15	Left out on purpose: the waiting-on-you line, the clog, vitals and keeper lines (the boards and the Flow dialog still show them), and "slowest right now" (it needs a timing read the home does not have). The box posts to `/tell` today; it becomes the `/talk` entry (#7652) when that lands.
	16
	17	The two scans behind the lists are read once per write (`writeStamp`), so a warm home reads no tables for them.
		@@ -3,7 +3,7 @@
3	3	"api.anthropic.com"
4	4	],
5	5	"app": {
6		"looks": ["/", "/forges", "/family", "/front", "/explore", "/board", "/boards", "/asked", "/review", "/search", "/new", "/audit", "/releases", "/changelog", "/apps", "/migrate", "/map", "/system", "/contribute", "/resilience", "/settings"],
	6	"looks": ["/", "/forges", "/family", "/front", "/explore", "/board", "/boards", "/asked", "/feed", "/review", "/search", "/new", "/audit", "/releases", "/changelog", "/apps", "/migrate", "/map", "/system", "/contribute", "/resilience", "/settings"],
7	7	"run": "bun run src/main.ts",
8	8	"install": "",
9	9	"health": "/healthz",
		@@ -109,6 +109,7 @@ export const SYSTEM_NAMES: readonly string[] = [
109	109	"recover",
110	110	"www",
111	111	"asked",
	112	"feed",
112	113	"review",
113	114	"claim",
114	115	"first-admin",
		@@ -0,0 +1,122 @@
	1	/**
	2	* What is moving through the forge, for the home (#8015): the builds running
	3	* now, the changes that just shipped, and the pipeline in four words.
	4	* Plain data out. Every row is read for a viewer: a repository they cannot
	5	* read, and a sealed report, are never named.
	6	*/
	7
	8	import type { Database } from "bun:sqlite";
	9	import { canRead, getReposByIds, type Repo } from "../core/repos.ts";
	10	import type { User } from "../core/users.ts";
	11	import { writeStamp } from "../core/write_clock.ts";
	12	import type { PipelineStage } from "./pipeline.ts";
	13
	14	/** One line of a list: who, what, where it goes, and when. */
	15	export interface MovingRow {
	16	readonly who: string;
	17	readonly title: string;
	18	readonly href: string;
	19	readonly at: string;
	20	/** `owner/name`, for the row's title attribute. */
	21	readonly repo: string;
	22	}
	23
	24	export const MOVING_ROWS = 3;
	25	/** Rows read before the viewer's access filters them; bounded, so the read is. */
	26	const SCAN = 40;
	27
	28	interface Raw {
	29	repo_id: string;
	30	number: number;
	31	title: string;
	32	sealed: number;
	33	who: string \| null;
	34	at: string;
	35	}
	36
	37	const RAW_MAX_AGE_MS = 30_000;
	38	const kept = new WeakMap<Database, Map<string, { stamp: string; at: number; raw: Raw[] }>>();
	39
	40	/** A scan read once per write: the same rows serve every viewer until anything is written (or 30 s pass). */
	41	function scanned(db: Database, key: string, read: () => Raw[], now = Date.now()): Raw[] {
	42	const stamp = writeStamp(db);
	43	if (stamp === undefined) return read();
	44	let byKey = kept.get(db);
	45	if (byKey === undefined) kept.set(db, (byKey = new Map()));
	46	const had = byKey.get(key);
	47	if (had !== undefined && had.stamp === stamp && now - had.at < RAW_MAX_AGE_MS) return had.raw;
	48	const raw = read();
	49	byKey.set(key, { stamp, at: now, raw });
	50	return raw;
	51	}
	52
	53	function visible(db: Database, viewer: User, raw: readonly Raw[], path: string, limit: number): MovingRow[] {
	54	const repos = getReposByIds(db, raw.map((r) => r.repo_id));
	55	const readable = new Map<string, Repo \| undefined>();
	56	const out: MovingRow[] = [];
	57	for (const r of raw) {
	58	if (r.sealed !== 0) continue;
	59	if (!readable.has(r.repo_id)) {
	60	const repo = repos.get(r.repo_id);
	61	readable.set(r.repo_id, repo !== undefined && canRead(db, repo, viewer) ? repo : undefined);
	62	}
	63	const repo = readable.get(r.repo_id);
	64	if (repo === undefined) continue;
	65	out.push({
	66	who: r.who ?? "",
	67	title: r.title,
	68	href: `/${repo.ownerName}/${repo.name}/${path}/${r.number}`,
	69	at: r.at,
	70	repo: `${repo.ownerName}/${repo.name}`,
	71	});
	72	if (out.length === limit) break;
	73	}
	74	return out;
	75	}
	76
	77	/** Agent builds running now (reviews are not building), newest first, each on the issue it works. */
	78	export function readBuilding(db: Database, viewer: User, limit = MOVING_ROWS): MovingRow[] {
	79	const raw = scanned(db, "building", () => db
	80	.query<Raw, [number]>(
	81	`SELECT r.repo_id, i.number, i.title, i.sealed, u.username AS who, COALESCE(r.started_at, r.created_at) AS at
	82	FROM run r JOIN issue i ON i.id = r.issue_id LEFT JOIN user u ON u.id = r.actor_id
	83	WHERE r.kind = 'agent' AND r.state = 'running' AND r.reason != 'review'
	84	ORDER BY at DESC LIMIT ?1`,
	85	)
	86	.all(SCAN));
	87	return visible(db, viewer, raw, "issues", limit);
	88	}
	89
	90	/** Changes merged most recently, newest first, each linking to its pull. */
	91	export function readShipped(db: Database, viewer: User, limit = MOVING_ROWS): MovingRow[] {
	92	const raw = scanned(db, "shipped", () => db
	93	.query<Raw, [number]>(
	94	`SELECT i.repo_id, i.number, i.title, i.sealed, u.username AS who, p.merged_at AS at
	95	FROM pull p JOIN issue i ON i.id = p.issue_id LEFT JOIN user u ON u.id = p.merged_by
	96	WHERE p.merged_at IS NOT NULL
	97	ORDER BY p.merged_at DESC LIMIT ?1`,
	98	)
	99	.all(SCAN));
	100	return visible(db, viewer, raw, "pulls", limit);
	101	}
	102
	103	/** The pipeline in the four words the forge uses; each count is the sum of the `/boards` stages it names. */
	104	export interface Now {
	105	readonly check: number;
	106	readonly review: number;
	107	readonly land: number;
	108	readonly live: number;
	109	}
	110
	111	export function nowOf(stages: readonly PipelineStage[]): Now {
	112	const n = (key: PipelineStage["key"]): number => {
	113	const s = stages.find((x) => x.key === key);
	114	return s === undefined ? 0 : s.waiting + s.active;
	115	};
	116	return {
	117	check: n("check-queue") + n("checking"),
	118	review: n("review"),
	119	land: n("approved"),
	120	live: n("live"),
	121	};
	122	}
		@@ -288,6 +288,7 @@ import {
288	288	import { keeperAnswer } from "../web/studio/keeper_row.ts";
289	289	import { homeArchive, homeArchived, homeArchiveUndo } from "../web/studio/home_archive.ts";
290	290	import { liveFeedFragment } from "../web/studio/feed.ts";
	291	import { liveChipsFragment, liveMovingFragment } from "../web/studio/living.ts";
291	292	import { HOME_REGIONS } from "../web/studio/home_last.ts";
292	293	import { serviceWorker } from "../web/sw.ts";
293	294	import { explorePage } from "../web/studio/explore.ts";
		@@ -297,6 +298,7 @@ import {
297	298	} from "../web/studio/make_it_yours.ts";
298	299	import {
299	300	frontUpdate,
	301	feedPage,
300	302	liveAppsFragment,
301	303	liveClientAppsFragment,
302	304	liveHomeFragment,
		@@ -853,6 +855,9 @@ export function buildRouter(): Router<Handler> {
853	855	router.add("GET", "/live/on-you", liveOnYouFragment);
854	856	router.add("GET", "/live/client-apps", liveClientAppsFragment);
855	857	router.add("GET", "/live/feed", liveFeedFragment);
	858	router.add("GET", "/live/moving", liveMovingFragment);
	859	router.add("GET", "/live/chips", liveChipsFragment);
	860	router.add("GET", "/feed", feedPage);
856	861	// The home's late regions, each drawn alone (#7660).
857	862	for (const name of HOME_REGIONS) router.add("GET", `/live/home/${name}`, (ctx) => liveHomeFragment(ctx, name));
858	863	// Whether a hostname is an app's verified domain — what Caddy's
		@@ -28,6 +28,8 @@ import { agentsLine } from "../../web/studio/client_home.ts";
28	28	import { lastVisit } from "../../core/home_visit.ts";
29	29	import { sinceDigest } from "../../web/studio/since.ts";
30	30	import { askForSomething } from "./tell.ts";
	31	import { movingLines } from "./moving.ts";
	32	import { pipelineNow } from "../../web/studio/living.ts";
31	33	import { askForEveryday, everydayOf, EVERYDAY_WHY, keepAdmin } from "../../core/everyday.ts";
32	34	import { mayView } from "../../core/sealed.ts";
33	35	import { applyFleetIds, previewFleetIds, undoFleetOp } from "../../actions/fleet.ts";
		@@ -199,6 +201,8 @@ export function dashboardScreen(f: Session, ctx: Ctx): Screen {
199	201	let clientLines: string[] = [];
200	202	/** "Since you were here" and its lines: read from the web home's last-visit row, never written here. */
201	203	let sinceLines: string[] = [];
	204	/** The web home's living pipeline (#8015): Now for a site admin, then being built and just shipped. */
	205	let moving: string[] = [];
202	206	/** The ids of those apps, so the key that asks for something stays on them. */
203	207	let clientRepoIds = new Set<string>();
204	208	/** The live address of each of those apps that is running, by repo id; `o` shows it. */
		@@ -370,6 +374,7 @@ export function dashboardScreen(f: Session, ctx: Ctx): Screen {
370	374	lane = forgeLane(f.app, f.user);
371	375	flaky = forgeFlakes(f.app, f.user);
372	376	decider = deciderLine(f.app, f.user);
	377	moving = f.user ? movingLines(f.db, f.user, f.user.isAdmin ? pipelineNow(f.db) : undefined) : [];
373	378	const commit = running().commit;
374	379	const cleared = lastClearedNote(f.db, now);
375	380	figures =
		@@ -1033,6 +1038,13 @@ export function dashboardScreen(f: Session, ctx: Ctx): Screen {
1033	1038	);
1034	1039	body = rest!;
1035	1040	}
	1041	if (moving.length > 0) {
	1042	const [strip, rest] = split(body, "v", [len(moving.length), fill(1)]);
	1043	moving.forEach((line, i) =>
	1044	s.text(strip!.x, strip!.y + i, truncate(line, strip!.w), style(c.mutedFg, c.bg), strip!.x + strip!.w),
	1045	);
	1046	body = rest!;
	1047	}
1036	1048	// A short terminal drops the last figures before it drops the list.
1037	1049	const shown = figures.slice(0, Math.max(0, body.h - FIGURES_ROOM));
1038	1050	if (shown.length > 0) {
		@@ -0,0 +1,23 @@
	1	/**
	2	* The terminal home's living pipeline (#8015), the web home's in lines: the
	3	* pipeline in four words for a site admin, then what is being built and what
	4	* just shipped, each filtered to what the viewer reads by the same reads the
	5	* web uses. The tell box is the home's own tell, already there.
	6	*/
	7
	8	import type { Database } from "bun:sqlite";
	9	import type { User } from "../../core/users.ts";
	10	import { readBuilding, readShipped, type MovingRow, type Now } from "../../flow/moving.ts";
	11	import { plain } from "./boards.ts";
	12
	13	const listLine = (label: string, rows: readonly MovingRow[], empty: string): string =>
	14	`${label} ${rows.length === 0 ? empty : rows.map((r) => `${plain(r.title)} (${plain(r.repo)})`).join(" · ")}`;
	15
	16	/** `now` is passed only for a site admin: the counts take in every repository, private ones too. */
	17	export function movingLines(db: Database, viewer: User, now: Now \| undefined): string[] {
	18	return [
	19	...(now === undefined ? [] : [`Now check ${now.check} › review ${now.review} › land ${now.land} › ${now.live} live`]),
	20	listLine("Being built", readBuilding(db, viewer), "nothing right now"),
	21	listLine("Just shipped", readShipped(db, viewer), "nothing yet"),
	22	];
	23	}
		@@ -172,14 +172,16 @@ export async function composerSubmit(ctx: Ctx): Promise<Response> {
172	172	const form = await readForm(ctx, "rw");
173	173	if (form instanceof Response) return form;
174	174	const target = field(form, "app");
	175	// The feed's composer asks to come back to the feed; any other box, to home.
	176	const home = backTo(form, "/");
175	177	// "the forge" is no app: the words are kept as a thought, exactly as typed.
176	178	if (target === FORGE_TARGET) {
177	179	if (field(form, "text").trim() === "")
178		return flashOrJson(ctx, "/", { tone: "danger", message: SAY_SOMETHING_WORDS });
	180	return flashOrJson(ctx, home, { tone: "danger", message: SAY_SOMETHING_WORDS });
179	181	const kept = keepThought(ctx.app, ctx.auth.user, field(form, "text"), "composer");
180	182	return flashOrJson(
181	183	ctx,
182		"/",
	184	home,
183	185	kept.ok
184	186	? { message: "Received." }
185	187	: {
		@@ -187,13 +189,13 @@ export async function composerSubmit(ctx: Ctx): Promise<Response> {
187	189	message:
188	190	kept.error === "too_long" ? "That is too long to keep." : "That could not be kept.",
189	191	},
190		{ href: "/" },
	192	{ href: home },
191	193	);
192	194	}
193	195	const [owner = "", name = "", ...extra] = target.split("/");
194	196	const repo = extra.length === 0 ? getRepo(ctx.app.db, owner, name) : undefined;
195	197	if (!repo \|\| !canRead(ctx.app.db, repo, ctx.auth.user)) return notFoundPage(ctx);
196		return tellFrom(ctx, repo, form, "/");
	198	return tellFrom(ctx, repo, form, home);
197	199	}
198	200
199	201