54cd37f · 320c7bd · c513fbe · 24f8a4a · 5708239
@@ -40,6 +40,8 @@
when). The terminal's palette has the same as "Crew hand-overs", a read-only
list of the same rows (repo#number, title, reasons; it does not open the
issue — use the link on the page). Both are a forge admin's only.
Home opens with "Since you were here · 2 days": the pulls that landed in public repositories since you last loaded `/` (1 hour to 7 days back, a day on a first visit); the terminal's home shows the same lines. See `docs/features/since-you-were-here.md`.
A hand-over card on `/asks` (an agent's pull the reviewer stopped on after three rounds) has "Give back to the crew": one press assigns the pull, and the open issue it closes if a person holds it, to the agent that opened it, writes "Given back to the crew by @who", and the card leaves; the next tick starts its run. It is for a writer of the repository, and a pull a person opened, or by an agent gone from the crew, gets no button. In the terminal, `b` on a handed-over row of the On you pane does the same (`src/actions/give_back.ts`).
A pull the merge queue holds as red alone (red on its own merge at its current head; cleared by a new head or a moved main) says so under its checks line: "red alone at <time>, waiting for a new head or a new main", on the pull page, its live checks line and the studio change step, and in the checks row of the pull's terminal screen (`redMark` in `src/checks/queue.ts`). Nothing is drawn when it is not held.
@@ -0,0 +1,15 @@
# Since you were here
Home shows a digest headed `Since you were here · 2 days`: the pulls that landed in public repositories since you last loaded `/`.
- The forge records your last load in `home_visit` (sqlite), at most once a minute per user.
- The window starts at that time, at least 1 hour and at most 7 days. A first visit looks back 24 hours.
- Nothing landed in the window: no section. Private repositories are never read.
## The terminal
The terminal's home (`ssh`, the dashboard) shows the same lines under the same heading, read from the same `home_visit` row. The terminal only reads it: opening home on the web is what moves "since you were here".
## A read that writes
`GET /` writes the viewer's `home_visit` row, but only for a real navigation: a request marked `Sec-Purpose`/`Purpose` prefetch, prerender or preview, or whose `Sec-Fetch-Dest` is not `document`, reads the row and leaves it alone. That is a deliberate exception to "a GET changes nothing": it is one upsert per user per minute at most, it holds no content, and the response does not depend on the write (the digest uses the visit *before* this one).
@@ -0,0 +1,35 @@
/**
 * When a person last loaded `/`, in epoch milliseconds. `noteVisit` answers
 * the visit before this one and writes the new time at most once a minute,
 * so a reload storm is one cheap indexed read.
 */
import type { Database } from "bun:sqlite";
export const VISIT_WRITE_GAP_MS = 60 * 1000;
export function lastVisit(db: Database, userId: string): number | undefined {
  return db.query<{ at: number }, [string]>("SELECT at FROM home_visit WHERE user_id = ?1").get(userId)?.at;
}
/** The time of the visit before this one, if any; records this one unless it is within a minute of it. */
export function noteVisit(db: Database, userId: string, now: number): number | undefined {
  const before = lastVisit(db, userId);
  if (before === undefined || now - before >= VISIT_WRITE_GAP_MS)
    db.query(
      "INSERT INTO home_visit (user_id, at) VALUES (?1, ?2) ON CONFLICT(user_id) DO UPDATE SET at = excluded.at",
    ).run(userId, now);
  return before;
}
/**
 * Whether a request is a person opening the page: not a prefetch or preview
 * (`Sec-Purpose` / `Purpose`), and, when the browser says what it is fetching,
 * a document. A client that sends neither header (curl, the terminal) counts.
 */
export function isNavigation(req: Request): boolean {
  const purpose = `${req.headers.get("sec-purpose") ?? ""} ${req.headers.get("purpose") ?? ""}`.toLowerCase();
  if (purpose.includes("prefetch") || purpose.includes("prerender") || purpose.includes("preview")) return false;
  const dest = req.headers.get("sec-fetch-dest");
  return dest === null || dest === "document";
}
@@ -0,0 +1,8 @@
// When a person last loaded home (#5804): the "Since you were here" digest
// starts there. One row per user, written at most once a minute.
export default `
  CREATE TABLE home_visit (
    user_id TEXT PRIMARY KEY REFERENCES user(id) ON DELETE CASCADE,
    at      INTEGER NOT NULL
  ) WITHOUT ROWID;
`;
@@ -5,6 +5,22 @@
export const DIGEST_WINDOW_MS = 24 * 3600 * 1000;
export const DIGEST_LINES = 3;
export const DIGEST_MIN_MS = 3600 * 1000;
export const DIGEST_MAX_MS = 7 * 24 * 3600 * 1000;
/** The window since the last visit: a day for a first visit, else at least an hour and at most a week. */
export function windowOf(lastVisit: number | undefined, now: number): number {
  if (lastVisit === undefined || !Number.isFinite(lastVisit)) return DIGEST_WINDOW_MS;
  return Math.min(DIGEST_MAX_MS, Math.max(DIGEST_MIN_MS, now - lastVisit));
}
/** The heading that names the window, e.g. `Since you were here · 2 days`. */
export function headingOf(windowMs: number): string {
  const hours = Math.round(windowMs / 3600000);
  if (hours < 24) return `Since you were here · ${hours} ${hours === 1 ? "hour" : "hours"}`;
  const days = Math.round(hours / 24);
  return `Since you were here · ${days} ${days === 1 ? "day" : "days"}`;
}
export type DigestKind = "landed" | "released" | "failed" | "decided";
const KINDS: readonly DigestKind[] = ["landed", "released", "failed", "decided"];
@@ -32,8 +48,8 @@
interface Group {
  counts: Record<DigestKind, number>;
}
export function digest(events: readonly DigestEvent[], now: number): DigestLine[] {
  const since = now - DIGEST_WINDOW_MS;
export function digest(events: readonly DigestEvent[], now: number, windowMs: number = DIGEST_WINDOW_MS): DigestLine[] {
  const since = now - windowMs;
  const groups = new Map<string, Group>();
  for (const e of events) {
    if (!(e.at >= since && e.at <= now)) continue;
@@ -23,6 +23,8 @@
import { coveredByVerdict, forgeVerdict, verdictLine } from "../../kernel/guard_
import { clientAppRows, clientDoings, clientFinished, doingLine, finishedLine } from "../../core/client-apps.ts";
import { nextStepsFor } from "../../core/next-steps.ts";
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 { mayView } from "../../core/sealed.ts";
import { applyFleetIds, previewFleetIds, undoFleetOp } from "../../actions/fleet.ts";
@@ -183,6 +185,8 @@
export function dashboardScreen(f: Session, ctx: Ctx): Screen {
  let waits: string[] = [];
  /** A client's apps, one sentence each on whether its agents work or wait (#1812). */
  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 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. */
@@ -235,6 +239,12 @@
export function dashboardScreen(f: Session, ctx: Ctx): Screen {
    ctx.invalidate();
  };
  const loadSinceLines = (): void => {
    const d = f.user ? sinceDigest(f.app.db, lastVisit(f.app.db, f.user.id), Date.now()) : undefined;
    sinceLines = d === undefined ? [] : [d.heading, ...d.lines.map((l) => `  ${l.says}`)];
    ctx.invalidate();
  };
  const loadPanelLines = async (): Promise<void> => {
    const listed = await listPinned(f.app, f.user);
    const titles = listed.ok ? listed.value.map((p) => `${plain(p.panel.title)} (${plain(p.board.title)})`) : [];
@@ -881,6 +891,7 @@
export function dashboardScreen(f: Session, ctx: Ctx): Screen {
      // functions of the outbox, so one subscription refreshes all of them.
      live(f, signal, {}, reload);
      reload();
      loadSinceLines();
      return Promise.all([loadClientLines(), loadPanelLines()]).then(() => undefined);
    },
    render(area, s) {
@@ -910,6 +921,14 @@
export function dashboardScreen(f: Session, ctx: Ctx): Screen {
        );
        body = rest!;
      }
      if (sinceLines.length > 0) {
        const lines = sinceLines.slice(0, 4);
        const [strip, rest] = split(body, "v", [len(lines.length), fill(1)]);
        lines.forEach((line, i) =>
          s.text(strip!.x, strip!.y + i, truncate(line, strip!.w), style(i === 0 ? c.mutedFg : c.fg, 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) {
@@ -58,6 +58,8 @@
import { feedCandidateCache } from "../../feed/feed.ts";
import { notePhase, notePhaseRest, takeSessionTime, timePhase, timePhaseAsync } from "../../core/route_timing.ts";
import { kpiCache, panelCache, waitingCache } from "./home_cache.ts";
import { pinnedPanels } from "./pinned.ts";
import { isNavigation, lastVisit, noteVisit } from "../../core/home_visit.ts";
import { sinceYouWere } from "./since.ts";
import { homeTabs } from "./home_tabs.ts";
import { crewKeyNote } from "./crew.ts";
import { everydayCard } from "../pages/everyday.ts";
@@ -266,6 +268,11 @@
export async function studioHome(
  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 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),
      
        junipercrew
        18d ago
        
      
      GET / mutates here. Bounded and documented, but it is the one write on a GET; a same-origin POST would be cleaner.
    
  );
  const since = timePhase(ctx.request, "since", () => sinceYouWere(ctx.app.db, before, visitedAt));
  const ask = firstSteps ?? everydayCard(ctx, user);
  const figures = user.isAdmin && steps === undefined;
  const ceilingUsd = forgeCeiling(ctx.app.config);
@@ -286,6 +293,7 @@
export async function studioHome(
        <a href="/">Just my apps</a>
      </p>`,
    )}
    ${since}
    ${homeTabs("feed")}
    <div class="split" data-rail="wide">
      <div class="stack">
@@ -316,7 +324,7 @@
export async function studioHome(
    body,
    scriptJs: `${liveClientJs}\n${liveRegionsJs}\n${feedJs}${ask ? `\n${passkeyJs}` : ""}`,
  });
  notePhaseRest(ctx.request, "render", rendering, ["kpis", "vitals", "waiting", "panels", "feed"]);
  notePhaseRest(ctx.request, "render", rendering, ["kpis", "vitals", "waiting", "panels", "feed", "visit", "since"]);
  return res;
}
@@ -0,0 +1,55 @@
/**
 * "Since you were here · 2 days": the pulls that landed in public repositories
 * since the viewer last loaded home (`core/home_visit.ts`), as the digest's
 * lines. Nothing landed, no section. Private repositories are never read here.
 */
import type { Database } from "bun:sqlite";
import { digest, headingOf, windowOf, type DigestEvent, type DigestLine } from "../../feed/digest.ts";
import { html, type Html } from "../html.ts";
import { listCard, row } from "../ui.ts";
interface Row {
  owner: string;
  name: string;
  number: number;
  merged_at: string;
}
export function landedSince(db: Database, since: number, now: number): DigestEvent[] {
  const rows = db
    .query<Row, [string, string]>(
      `SELECT u.username AS owner, r.name AS name, i.number AS number, p.merged_at AS merged_at
         FROM pull p JOIN issue i ON i.id = p.issue_id JOIN repo r ON r.id = i.repo_id JOIN user u ON u.id = r.owner_id
        WHERE p.merged_at >= ?1 AND p.merged_at <= ?2 AND r.visibility = 'public'
        ORDER BY p.merged_at DESC LIMIT 200`,
    )
    .all(new Date(since).toISOString(), new Date(now).toISOString());
  return rows.map((r) => ({
    repo: `${r.owner}/${r.name}`,
    kind: "landed",
    at: Date.parse(r.merged_at),
    href: `/${r.owner}/${r.name}/pulls/${r.number}`,
    weight: 1,
  }));
}
/** The heading and lines of the digest since `lastVisit`; no lines, no digest. */
export function sinceDigest(
  db: Database,
  lastVisit: number | undefined,
  now: number,
): { heading: string; lines: DigestLine[] } | undefined {
  const window = windowOf(lastVisit, now);
  const lines = digest(landedSince(db, now - window, now), now, window);
  return lines.length === 0 ? undefined : { heading: headingOf(window), lines };
}
export function sinceYouWere(db: Database, lastVisit: number | undefined, now: number): Html {
  const d = sinceDigest(db, lastVisit, now);
  if (d === undefined) return html``;
  return listCard(
    d.lines.map((l) => row({ title: html`${l.says}`, href: l.href, nav: true })),
    { id: "since-you-were-here", head: html`<h2>${d.heading}</h2>` },
      
        junipercrew
        18d ago
        
      
      The row title is the digest line text only. A short meta with the repo name would help a screen-reader user tell lines apart.
    
  );
}
@@ -39,7 +39,7 @@
test("the second look at home as the owner is within its budget, and every phase
  console.log(`home warm ${warm.ms.toFixed(0)} ms:`, warm.phases.map((p) => `${p.name} ${p.ms}`).join(", "));
  expectBudget(warm.ms, { ms: 300, against: await baselineMs(f.base) });
  // The page's own total is the sum of named phases: nothing over 20 ms hides in "app" alone.
  const known = new Set(["app", "spawned", "steps", "session", "repos", "kpis", "waiting", "panels", "feed", "render"]);
  const known = new Set(["app", "spawned", "steps", "session", "repos", "kpis", "waiting", "panels", "feed", "visit", "since", "render"]);
  for (const p of slow) expect(known.has(p.name)).toBe(true);
  const total = warm.phases.find((p) => p.name === "app")!.ms;
  const named = warm.phases.filter((p) => p.name !== "app").reduce((s, p) => s + p.ms, 0);
@@ -0,0 +1,141 @@
/**
 * #5804: "Since you were here" starts at the viewer's last load of home, at
 * least an hour and at most a week back, a day on a first visit; recording
 * the visit writes at most once a minute and shows as a `visit` phase on `/`.
 */
import { afterAll, beforeAll, expect, test } from "bun:test";
import { lastVisit, noteVisit } from "../src/core/home_visit.ts";
import { DIGEST_WINDOW_MS, headingOf, windowOf } from "../src/feed/digest.ts";
import { landedSince } from "../src/web/studio/since.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";
import { snappyFixture, type SnappyFixture } from "../bench/snappy.ts";
const H = 3600 * 1000;
const now = Date.parse("2026-10-27T12:00:00Z");
test("the window: a first visit is a day, 3 hours is 3 hours, 10 days is capped at 7, under an hour is an hour", () => {
  expect(windowOf(undefined, now)).toBe(DIGEST_WINDOW_MS);
  expect(windowOf(now - 3 * H, now)).toBe(3 * H);
  expect(windowOf(now - 10 * 24 * H, now)).toBe(7 * 24 * H);
  expect(windowOf(now - 5 * 60 * 1000, now)).toBe(H);
  expect(windowOf(now + H, now)).toBe(H);
});
test("the heading names the window", () => {
  expect(headingOf(3 * H)).toBe("Since you were here · 3 hours");
  expect(headingOf(H)).toBe("Since you were here · 1 hour");
  expect(headingOf(48 * H)).toBe("Since you were here · 2 days");
  expect(headingOf(7 * 24 * H)).toBe("Since you were here · 7 days");
});
let f: SnappyFixture;
beforeAll(async () => {
  f = await snappyFixture();
}, 120_000);
afterAll(async () => {
  await f.close();
});
test("a visit is written at most once a minute and answers the one before", () => {
  const id = f.peer.id;
  expect(noteVisit(f.app.db, id, now)).toBeUndefined();
  expect(lastVisit(f.app.db, id)).toBe(now);
  expect(noteVisit(f.app.db, id, now + 30_000)).toBe(now);
  expect(lastVisit(f.app.db, id)).toBe(now);
  expect(noteVisit(f.app.db, id, now + 61_000)).toBe(now);
  expect(lastVisit(f.app.db, id)).toBe(now + 61_000);
});
test("home heads the digest with the window, lists only public landed pulls, and records the visit", async () => {
  const db = f.app.db;
  const pub = f.repos.find((r) => r.visibility === "public")!;
  const priv = f.repos.find((r) => r.visibility === "private")!;
  const land = (repoId: string, number: number, ago: number): void => {
    const id = `since-${repoId}-${number}`;
    db.query("INSERT INTO issue (id, repo_id, number, kind, title, author_id) VALUES (?1, ?2, ?3, 'pull', 't', ?4)").run(id, repoId, 9000 + number, f.owner.id);
    db.query("INSERT INTO pull (issue_id, base_branch, head_branch, base_oid, head_oid, merged_at) VALUES (?1, 'main', 'h', 'a', 'b', ?2)").run(id, new Date(Date.now() - ago).toISOString());
  };
  land(pub.id, 1, 2 * H);
  land(pub.id, 2, 5 * 24 * H);
  land(priv.id, 3, H);
  expect(landedSince(db, Date.now() - 3 * H, Date.now())).toHaveLength(1);
  expect(landedSince(db, Date.now() - 10 * 24 * H, Date.now())).toHaveLength(2);
  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 text = await res.text();
  expect(text).toContain("Since you were here · 3 hours");
  expect(text).toContain("1 landed");
  expect(text).not.toContain(`/${f.owner.username}/${priv.name}/pulls/9003`);
  const visit = /visit;dur=([\d.]+)/.exec(res.headers.get("server-timing") ?? "");
  expect(visit).not.toBeNull();
  expect(Date.now() - lastVisit(db, f.owner.id)!).toBeLessThan(5000);
});
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();
  expect(text).toContain("Since you were here · 1 day<");
  expect(text).toContain("1 landed");
  expect(lastVisit(db, f.owner.id)).toBeDefined();
});
test("the terminal home shows the same digest from the same row and writes nothing", async () => {
  const db = f.app.db;
  const at = Date.now() - 3 * H;
  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, at);
  const terminal = headlessTerminal(120, 30);
  const { app: tui, session } = createForgeApp(
    f.app,
    { sshUsername: f.owner.username, remoteAddress: "127.0.0.1", fingerprint: "SHA256:test", user: f.owner },
    { terminal, exitHooks: false },
  );
  tui.start();
  tui.ctx.push(dashboardScreen(session, tui.ctx));
  await settleApp(tui);
  const text = tui.screen.toText();
  tui.stop?.();
  expect(text).toContain("Since you were here · 3 hours");
  expect(text).toContain("1 landed");
  expect(lastVisit(db, f.owner.id)).toBe(at);
});
test("a prefetch, a preview or a non-document fetch leaves home_visit unchanged; a navigation moves it", async () => {
  const db = f.app.db;
  const at = Date.now() - 3 * H;
  const set = () => 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, at);
  for (const headers of [
    { "sec-purpose": "prefetch" },
    { purpose: "prefetch" },
    { "sec-purpose": "prefetch;prerender" },
    { "sec-fetch-dest": "empty" },
    { "sec-fetch-dest": "iframe" },
  ]) {
    set();
    const text = await (await fetch(`${f.base}/?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();
  expect(lastVisit(db, f.owner.id)).toBeGreaterThan(at);
});
test("the digest query reads pull through the existing pull_merged index, and the home-visit migration adds no second one", () => {
  const plan = f.app.db
    .query<{ detail: string }, [string, string]>(
      `EXPLAIN QUERY PLAN SELECT p.merged_at FROM pull p WHERE p.merged_at >= ?1 AND p.merged_at <= ?2 ORDER BY p.merged_at DESC LIMIT 200`,
    )
    .all("2026-10-26T00:00:00.000Z", "2026-10-27T00:00:00.000Z")
    .map((r) => r.detail)
    .join("\n");
  expect(plan).toContain("pull_merged");
  const onMerged = f.app.db
    .query<{ name: string }, []>(`SELECT name FROM sqlite_master WHERE type = 'index' AND tbl_name = 'pull' AND sql LIKE '%merged_at%'`)
    .all();
  expect(onMerged.map((r) => r.name)).toEqual(["pull_merged"]);
});
		@@ -40,6 +40,8 @@ when). The terminal's palette has the same as "Crew hand-overs", a read-only
40	40	list of the same rows (repo#number, title, reasons; it does not open the
41	41	issue — use the link on the page). Both are a forge admin's only.
42	42
	43	Home opens with "Since you were here · 2 days": the pulls that landed in public repositories since you last loaded `/` (1 hour to 7 days back, a day on a first visit); the terminal's home shows the same lines. See `docs/features/since-you-were-here.md`.
	44
43	45	A hand-over card on `/asks` (an agent's pull the reviewer stopped on after three rounds) has "Give back to the crew": one press assigns the pull, and the open issue it closes if a person holds it, to the agent that opened it, writes "Given back to the crew by @who", and the card leaves; the next tick starts its run. It is for a writer of the repository, and a pull a person opened, or by an agent gone from the crew, gets no button. In the terminal, `b` on a handed-over row of the On you pane does the same (`src/actions/give_back.ts`).
44	46
45	47	A pull the merge queue holds as red alone (red on its own merge at its current head; cleared by a new head or a moved main) says so under its checks line: "red alone at <time>, waiting for a new head or a new main", on the pull page, its live checks line and the studio change step, and in the checks row of the pull's terminal screen (`redMark` in `src/checks/queue.ts`). Nothing is drawn when it is not held.
		@@ -0,0 +1,15 @@
	1	# Since you were here
	2
	3	Home shows a digest headed `Since you were here · 2 days`: the pulls that landed in public repositories since you last loaded `/`.
	4
	5	- The forge records your last load in `home_visit` (sqlite), at most once a minute per user.
	6	- The window starts at that time, at least 1 hour and at most 7 days. A first visit looks back 24 hours.
	7	- Nothing landed in the window: no section. Private repositories are never read.
	8
	9	## The terminal
	10
	11	The terminal's home (`ssh`, the dashboard) shows the same lines under the same heading, read from the same `home_visit` row. The terminal only reads it: opening home on the web is what moves "since you were here".
	12
	13	## A read that writes
	14
	15	`GET /` writes the viewer's `home_visit` row, but only for a real navigation: a request marked `Sec-Purpose`/`Purpose` prefetch, prerender or preview, or whose `Sec-Fetch-Dest` is not `document`, reads the row and leaves it alone. That is a deliberate exception to "a GET changes nothing": it is one upsert per user per minute at most, it holds no content, and the response does not depend on the write (the digest uses the visit before this one).
		@@ -0,0 +1,35 @@
	1	/**
	2	* When a person last loaded `/`, in epoch milliseconds. `noteVisit` answers
	3	* the visit before this one and writes the new time at most once a minute,
	4	* so a reload storm is one cheap indexed read.
	5	*/
	6
	7	import type { Database } from "bun:sqlite";
	8
	9	export const VISIT_WRITE_GAP_MS = 60 * 1000;
	10
	11	export function lastVisit(db: Database, userId: string): number \| undefined {
	12	return db.query<{ at: number }, [string]>("SELECT at FROM home_visit WHERE user_id = ?1").get(userId)?.at;
	13	}
	14
	15	/** The time of the visit before this one, if any; records this one unless it is within a minute of it. */
	16	export function noteVisit(db: Database, userId: string, now: number): number \| undefined {
	17	const before = lastVisit(db, userId);
	18	if (before === undefined \|\| now - before >= VISIT_WRITE_GAP_MS)
	19	db.query(
	20	"INSERT INTO home_visit (user_id, at) VALUES (?1, ?2) ON CONFLICT(user_id) DO UPDATE SET at = excluded.at",
	21	).run(userId, now);
	22	return before;
	23	}
	24
	25	/**
	26	* Whether a request is a person opening the page: not a prefetch or preview
	27	* (`Sec-Purpose` / `Purpose`), and, when the browser says what it is fetching,
	28	* a document. A client that sends neither header (curl, the terminal) counts.
	29	*/
	30	export function isNavigation(req: Request): boolean {
	31	const purpose = `${req.headers.get("sec-purpose") ?? ""} ${req.headers.get("purpose") ?? ""}`.toLowerCase();
	32	if (purpose.includes("prefetch") \|\| purpose.includes("prerender") \|\| purpose.includes("preview")) return false;
	33	const dest = req.headers.get("sec-fetch-dest");
	34	return dest === null \|\| dest === "document";
	35	}
		@@ -0,0 +1,8 @@
	1	// When a person last loaded home (#5804): the "Since you were here" digest
	2	// starts there. One row per user, written at most once a minute.
	3	export default `
	4	CREATE TABLE home_visit (
	5	user_id TEXT PRIMARY KEY REFERENCES user(id) ON DELETE CASCADE,
	6	at INTEGER NOT NULL
	7	) WITHOUT ROWID;
	8	`;
		@@ -5,6 +5,22 @@
5	5
6	6	export const DIGEST_WINDOW_MS = 24 * 3600 * 1000;
7	7	export const DIGEST_LINES = 3;
	8	export const DIGEST_MIN_MS = 3600 * 1000;
	9	export const DIGEST_MAX_MS = 7 * 24 * 3600 * 1000;
	10
	11	/** The window since the last visit: a day for a first visit, else at least an hour and at most a week. */
	12	export function windowOf(lastVisit: number \| undefined, now: number): number {
	13	if (lastVisit === undefined \|\| !Number.isFinite(lastVisit)) return DIGEST_WINDOW_MS;
	14	return Math.min(DIGEST_MAX_MS, Math.max(DIGEST_MIN_MS, now - lastVisit));
	15	}
	16
	17	/** The heading that names the window, e.g. `Since you were here · 2 days`. */
	18	export function headingOf(windowMs: number): string {
	19	const hours = Math.round(windowMs / 3600000);
	20	if (hours < 24) return `Since you were here · ${hours} ${hours === 1 ? "hour" : "hours"}`;
	21	const days = Math.round(hours / 24);
	22	return `Since you were here · ${days} ${days === 1 ? "day" : "days"}`;
	23	}
8	24
9	25	export type DigestKind = "landed" \| "released" \| "failed" \| "decided";
10	26	const KINDS: readonly DigestKind[] = ["landed", "released", "failed", "decided"];
		@@ -32,8 +48,8 @@ interface Group {
32	48	counts: Record<DigestKind, number>;
33	49	}
34	50
35		export function digest(events: readonly DigestEvent[], now: number): DigestLine[] {
36		const since = now - DIGEST_WINDOW_MS;
	51	export function digest(events: readonly DigestEvent[], now: number, windowMs: number = DIGEST_WINDOW_MS): DigestLine[] {
	52	const since = now - windowMs;
37	53	const groups = new Map<string, Group>();
38	54	for (const e of events) {
39	55	if (!(e.at >= since && e.at <= now)) continue;
		@@ -23,6 +23,8 @@ import { coveredByVerdict, forgeVerdict, verdictLine } from "../../kernel/guard_
23	23	import { clientAppRows, clientDoings, clientFinished, doingLine, finishedLine } from "../../core/client-apps.ts";
24	24	import { nextStepsFor } from "../../core/next-steps.ts";
25	25	import { agentsLine } from "../../web/studio/client_home.ts";
	26	import { lastVisit } from "../../core/home_visit.ts";
	27	import { sinceDigest } from "../../web/studio/since.ts";
26	28	import { askForSomething } from "./tell.ts";
27	29	import { mayView } from "../../core/sealed.ts";
28	30	import { applyFleetIds, previewFleetIds, undoFleetOp } from "../../actions/fleet.ts";
		@@ -183,6 +185,8 @@ export function dashboardScreen(f: Session, ctx: Ctx): Screen {
183	185	let waits: string[] = [];
184	186	/** A client's apps, one sentence each on whether its agents work or wait (#1812). */
185	187	let clientLines: string[] = [];
	188	/** "Since you were here" and its lines: read from the web home's last-visit row, never written here. */
	189	let sinceLines: string[] = [];
186	190	/** The ids of those apps, so the key that asks for something stays on them. */
187	191	let clientRepoIds = new Set<string>();
188	192	/** The live address of each of those apps that is running, by repo id; `o` shows it. */
		@@ -235,6 +239,12 @@ export function dashboardScreen(f: Session, ctx: Ctx): Screen {
235	239	ctx.invalidate();
236	240	};
237	241
	242	const loadSinceLines = (): void => {
	243	const d = f.user ? sinceDigest(f.app.db, lastVisit(f.app.db, f.user.id), Date.now()) : undefined;
	244	sinceLines = d === undefined ? [] : [d.heading, ...d.lines.map((l) => ` ${l.says}`)];
	245	ctx.invalidate();
	246	};
	247
238	248	const loadPanelLines = async (): Promise<void> => {
239	249	const listed = await listPinned(f.app, f.user);
240	250	const titles = listed.ok ? listed.value.map((p) => `${plain(p.panel.title)} (${plain(p.board.title)})`) : [];
		@@ -881,6 +891,7 @@ export function dashboardScreen(f: Session, ctx: Ctx): Screen {
881	891	// functions of the outbox, so one subscription refreshes all of them.
882	892	live(f, signal, {}, reload);
883	893	reload();
	894	loadSinceLines();
884	895	return Promise.all([loadClientLines(), loadPanelLines()]).then(() => undefined);
885	896	},
886	897	render(area, s) {
		@@ -910,6 +921,14 @@ export function dashboardScreen(f: Session, ctx: Ctx): Screen {
910	921	);
911	922	body = rest!;
912	923	}
	924	if (sinceLines.length > 0) {
	925	const lines = sinceLines.slice(0, 4);
	926	const [strip, rest] = split(body, "v", [len(lines.length), fill(1)]);
	927	lines.forEach((line, i) =>
	928	s.text(strip!.x, strip!.y + i, truncate(line, strip!.w), style(i === 0 ? c.mutedFg : c.fg, c.bg), strip!.x + strip!.w),
	929	);
	930	body = rest!;
	931	}
913	932	// A short terminal drops the last figures before it drops the list.
914	933	const shown = figures.slice(0, Math.max(0, body.h - FIGURES_ROOM));
915	934	if (shown.length > 0) {
		@@ -58,6 +58,8 @@ import { feedCandidateCache } from "../../feed/feed.ts";
58	58	import { notePhase, notePhaseRest, takeSessionTime, timePhase, timePhaseAsync } from "../../core/route_timing.ts";
59	59	import { kpiCache, panelCache, waitingCache } from "./home_cache.ts";
60	60	import { pinnedPanels } from "./pinned.ts";
	61	import { isNavigation, lastVisit, noteVisit } from "../../core/home_visit.ts";
	62	import { sinceYouWere } from "./since.ts";
61	63	import { homeTabs } from "./home_tabs.ts";
62	64	import { crewKeyNote } from "./crew.ts";
63	65	import { everydayCard } from "../pages/everyday.ts";
		@@ -266,6 +268,11 @@ export async function studioHome(
266	268	const { repos: appRepos } = timePhase(ctx.request, "repos", () => writableAppsOf(ctx, user));
267	269	// Render is what is left of the page once the named reads are taken out.
268	270	const rendering = performance.now();
	271	const visitedAt = Date.now();
	272	const before = timePhase(ctx.request, "visit", () =>
	273	isNavigation(ctx.request) ? noteVisit(ctx.app.db, user.id, visitedAt) : lastVisit(ctx.app.db, user.id),
		junipercrew 18d ago GET / mutates here. Bounded and documented, but it is the one write on a GET; a same-origin POST would be cleaner.
	274	);
	275	const since = timePhase(ctx.request, "since", () => sinceYouWere(ctx.app.db, before, visitedAt));
269	276	const ask = firstSteps ?? everydayCard(ctx, user);
270	277	const figures = user.isAdmin && steps === undefined;
271	278	const ceilingUsd = forgeCeiling(ctx.app.config);
		@@ -286,6 +293,7 @@ export async function studioHome(
286	293	<a href="/">Just my apps</a>
287	294	</p>`,
288	295	)}
	296	${since}
289	297	${homeTabs("feed")}
290	298	<div class="split" data-rail="wide">
291	299	<div class="stack">
		@@ -316,7 +324,7 @@ export async function studioHome(
316	324	body,
317	325	scriptJs: `${liveClientJs}\n${liveRegionsJs}\n${feedJs}${ask ? `\n${passkeyJs}` : ""}`,
318	326	});
319		notePhaseRest(ctx.request, "render", rendering, ["kpis", "vitals", "waiting", "panels", "feed"]);
	327	notePhaseRest(ctx.request, "render", rendering, ["kpis", "vitals", "waiting", "panels", "feed", "visit", "since"]);
320	328	return res;
321	329	}
322	330
		@@ -0,0 +1,55 @@
	1	/**
	2	* "Since you were here · 2 days": the pulls that landed in public repositories
	3	* since the viewer last loaded home (`core/home_visit.ts`), as the digest's
	4	* lines. Nothing landed, no section. Private repositories are never read here.
	5	*/
	6
	7	import type { Database } from "bun:sqlite";
	8	import { digest, headingOf, windowOf, type DigestEvent, type DigestLine } from "../../feed/digest.ts";
	9	import { html, type Html } from "../html.ts";
	10	import { listCard, row } from "../ui.ts";
	11
	12	interface Row {
	13	owner: string;
	14	name: string;
	15	number: number;
	16	merged_at: string;
	17	}
	18
	19	export function landedSince(db: Database, since: number, now: number): DigestEvent[] {
	20	const rows = db
	21	.query<Row, [string, string]>(
	22	`SELECT u.username AS owner, r.name AS name, i.number AS number, p.merged_at AS merged_at
	23	FROM pull p JOIN issue i ON i.id = p.issue_id JOIN repo r ON r.id = i.repo_id JOIN user u ON u.id = r.owner_id
	24	WHERE p.merged_at >= ?1 AND p.merged_at <= ?2 AND r.visibility = 'public'
	25	ORDER BY p.merged_at DESC LIMIT 200`,
	26	)
	27	.all(new Date(since).toISOString(), new Date(now).toISOString());
	28	return rows.map((r) => ({
	29	repo: `${r.owner}/${r.name}`,
	30	kind: "landed",
	31	at: Date.parse(r.merged_at),
	32	href: `/${r.owner}/${r.name}/pulls/${r.number}`,
	33	weight: 1,
	34	}));
	35	}
	36
	37	/** The heading and lines of the digest since `lastVisit`; no lines, no digest. */
	38	export function sinceDigest(
	39	db: Database,
	40	lastVisit: number \| undefined,
	41	now: number,
	42	): { heading: string; lines: DigestLine[] } \| undefined {
	43	const window = windowOf(lastVisit, now);
	44	const lines = digest(landedSince(db, now - window, now), now, window);
	45	return lines.length === 0 ? undefined : { heading: headingOf(window), lines };
	46	}
	47
	48	export function sinceYouWere(db: Database, lastVisit: number \| undefined, now: number): Html {
	49	const d = sinceDigest(db, lastVisit, now);
	50	if (d === undefined) return html``;
	51	return listCard(
	52	d.lines.map((l) => row({ title: html`${l.says}`, href: l.href, nav: true })),
	53	{ id: "since-you-were-here", head: html`<h2>${d.heading}</h2>` },
		junipercrew 18d ago The row title is the digest line text only. A short meta with the repo name would help a screen-reader user tell lines apart.
	54	);
	55	}
		@@ -39,7 +39,7 @@ test("the second look at home as the owner is within its budget, and every phase
39	39	console.log(`home warm ${warm.ms.toFixed(0)} ms:`, warm.phases.map((p) => `${p.name} ${p.ms}`).join(", "));
40	40	expectBudget(warm.ms, { ms: 300, against: await baselineMs(f.base) });
41	41	// The page's own total is the sum of named phases: nothing over 20 ms hides in "app" alone.
42		const known = new Set(["app", "spawned", "steps", "session", "repos", "kpis", "waiting", "panels", "feed", "render"]);
	42	const known = new Set(["app", "spawned", "steps", "session", "repos", "kpis", "waiting", "panels", "feed", "visit", "since", "render"]);
43	43	for (const p of slow) expect(known.has(p.name)).toBe(true);
44	44	const total = warm.phases.find((p) => p.name === "app")!.ms;
45	45	const named = warm.phases.filter((p) => p.name !== "app").reduce((s, p) => s + p.ms, 0);
		@@ -0,0 +1,141 @@
	1	/**
	2	* #5804: "Since you were here" starts at the viewer's last load of home, at
	3	* least an hour and at most a week back, a day on a first visit; recording
	4	* the visit writes at most once a minute and shows as a `visit` phase on `/`.
	5	*/
	6	import { afterAll, beforeAll, expect, test } from "bun:test";
	7	import { lastVisit, noteVisit } from "../src/core/home_visit.ts";
	8	import { DIGEST_WINDOW_MS, headingOf, windowOf } from "../src/feed/digest.ts";
	9	import { landedSince } from "../src/web/studio/since.ts";
	10	import { createForgeApp } from "../src/tui/forge.ts";
	11	import { dashboardScreen } from "../src/tui/screens/dashboard.ts";
	12	import { headlessTerminal } from "../src/tui/term/terminal.ts";
	13	import { settleApp } from "./helpers/tui.ts";
	14	import { snappyFixture, type SnappyFixture } from "../bench/snappy.ts";
	15
	16	const H = 3600 * 1000;
	17	const now = Date.parse("2026-10-27T12:00:00Z");
	18
	19	test("the window: a first visit is a day, 3 hours is 3 hours, 10 days is capped at 7, under an hour is an hour", () => {
	20	expect(windowOf(undefined, now)).toBe(DIGEST_WINDOW_MS);
	21	expect(windowOf(now - 3 * H, now)).toBe(3 * H);
	22	expect(windowOf(now - 10 * 24 * H, now)).toBe(7 * 24 * H);
	23	expect(windowOf(now - 5 * 60 * 1000, now)).toBe(H);
	24	expect(windowOf(now + H, now)).toBe(H);
	25	});
	26
	27	test("the heading names the window", () => {
	28	expect(headingOf(3 * H)).toBe("Since you were here · 3 hours");
	29	expect(headingOf(H)).toBe("Since you were here · 1 hour");
	30	expect(headingOf(48 * H)).toBe("Since you were here · 2 days");
	31	expect(headingOf(7 * 24 * H)).toBe("Since you were here · 7 days");
	32	});
	33
	34	let f: SnappyFixture;
	35	beforeAll(async () => {
	36	f = await snappyFixture();
	37	}, 120_000);
	38	afterAll(async () => {
	39	await f.close();
	40	});
	41
	42	test("a visit is written at most once a minute and answers the one before", () => {
	43	const id = f.peer.id;
	44	expect(noteVisit(f.app.db, id, now)).toBeUndefined();
	45	expect(lastVisit(f.app.db, id)).toBe(now);
	46	expect(noteVisit(f.app.db, id, now + 30_000)).toBe(now);
	47	expect(lastVisit(f.app.db, id)).toBe(now);
	48	expect(noteVisit(f.app.db, id, now + 61_000)).toBe(now);
	49	expect(lastVisit(f.app.db, id)).toBe(now + 61_000);
	50	});
	51
	52	test("home heads the digest with the window, lists only public landed pulls, and records the visit", async () => {
	53	const db = f.app.db;
	54	const pub = f.repos.find((r) => r.visibility === "public")!;
	55	const priv = f.repos.find((r) => r.visibility === "private")!;
	56	const land = (repoId: string, number: number, ago: number): void => {
	57	const id = `since-${repoId}-${number}`;
	58	db.query("INSERT INTO issue (id, repo_id, number, kind, title, author_id) VALUES (?1, ?2, ?3, 'pull', 't', ?4)").run(id, repoId, 9000 + number, f.owner.id);
	59	db.query("INSERT INTO pull (issue_id, base_branch, head_branch, base_oid, head_oid, merged_at) VALUES (?1, 'main', 'h', 'a', 'b', ?2)").run(id, new Date(Date.now() - ago).toISOString());
	60	};
	61	land(pub.id, 1, 2 * H);
	62	land(pub.id, 2, 5 * 24 * H);
	63	land(priv.id, 3, H);
	64	expect(landedSince(db, Date.now() - 3 * H, Date.now())).toHaveLength(1);
	65	expect(landedSince(db, Date.now() - 10 * 24 * H, Date.now())).toHaveLength(2);
	66
	67	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);
	68	const res = await fetch(`${f.base}/?all=1`, { headers: { cookie: f.ownerCookie } });
	69	const text = await res.text();
	70	expect(text).toContain("Since you were here · 3 hours");
	71	expect(text).toContain("1 landed");
	72	expect(text).not.toContain(`/${f.owner.username}/${priv.name}/pulls/9003`);
	73	const visit = /visit;dur=([\d.]+)/.exec(res.headers.get("server-timing") ?? "");
	74	expect(visit).not.toBeNull();
	75	expect(Date.now() - lastVisit(db, f.owner.id)!).toBeLessThan(5000);
	76	});
	77
	78	test("a first-time user, with no home_visit row, gets the 24 hour heading", async () => {
	79	const db = f.app.db;
	80	db.query("DELETE FROM home_visit WHERE user_id = ?1").run(f.owner.id);
	81	const text = await (await fetch(`${f.base}/?all=1`, { headers: { cookie: f.ownerCookie } })).text();
	82	expect(text).toContain("Since you were here · 1 day<");
	83	expect(text).toContain("1 landed");
	84	expect(lastVisit(db, f.owner.id)).toBeDefined();
	85	});
	86
	87	test("the terminal home shows the same digest from the same row and writes nothing", async () => {
	88	const db = f.app.db;
	89	const at = Date.now() - 3 * H;
	90	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, at);
	91	const terminal = headlessTerminal(120, 30);
	92	const { app: tui, session } = createForgeApp(
	93	f.app,
	94	{ sshUsername: f.owner.username, remoteAddress: "127.0.0.1", fingerprint: "SHA256:test", user: f.owner },
	95	{ terminal, exitHooks: false },
	96	);
	97	tui.start();
	98	tui.ctx.push(dashboardScreen(session, tui.ctx));
	99	await settleApp(tui);
	100	const text = tui.screen.toText();
	101	tui.stop?.();
	102	expect(text).toContain("Since you were here · 3 hours");
	103	expect(text).toContain("1 landed");
	104	expect(lastVisit(db, f.owner.id)).toBe(at);
	105	});
	106
	107	test("a prefetch, a preview or a non-document fetch leaves home_visit unchanged; a navigation moves it", async () => {
	108	const db = f.app.db;
	109	const at = Date.now() - 3 * H;
	110	const set = () => 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, at);
	111	for (const headers of [
	112	{ "sec-purpose": "prefetch" },
	113	{ purpose: "prefetch" },
	114	{ "sec-purpose": "prefetch;prerender" },
	115	{ "sec-fetch-dest": "empty" },
	116	{ "sec-fetch-dest": "iframe" },
	117	]) {
	118	set();
	119	const text = await (await fetch(`${f.base}/?all=1`, { headers: { cookie: f.ownerCookie, ...headers } })).text();
	120	expect(text).toContain("Since you were here · 3 hours");
	121	expect(lastVisit(db, f.owner.id)).toBe(at);
	122	}
	123	set();
	124	await (await fetch(`${f.base}/?all=1`, { headers: { cookie: f.ownerCookie, "sec-fetch-dest": "document" } })).text();
	125	expect(lastVisit(db, f.owner.id)).toBeGreaterThan(at);
	126	});
	127
	128	test("the digest query reads pull through the existing pull_merged index, and the home-visit migration adds no second one", () => {
	129	const plan = f.app.db
	130	.query<{ detail: string }, [string, string]>(
	131	`EXPLAIN QUERY PLAN SELECT p.merged_at FROM pull p WHERE p.merged_at >= ?1 AND p.merged_at <= ?2 ORDER BY p.merged_at DESC LIMIT 200`,
	132	)
	133	.all("2026-10-26T00:00:00.000Z", "2026-10-27T00:00:00.000Z")
	134	.map((r) => r.detail)
	135	.join("\n");
	136	expect(plan).toContain("pull_merged");
	137	const onMerged = f.app.db
	138	.query<{ name: string }, []>(`SELECT name FROM sqlite_master WHERE type = 'index' AND tbl_name = 'pull' AND sql LIKE '%merged_at%'`)
	139	.all();
	140	expect(onMerged.map((r) => r.name)).toEqual(["pull_merged"]);
	141	});