1import { beforeAll, describe, expect, test } from "bun:test";2import { mkdir, mkdtemp, writeFile } from "node:fs/promises";3import { tmpdir } from "node:os";4import { join } from "node:path";5import type { Hono } from "hono";6import { openBucket } from "../src/bucket/reader.ts";7import { syncAll } from "../src/bucket/sync.ts";8import { fileAt, objectBytes, type Save } from "../src/mirror/queries.ts";9import { openMirror } from "../src/mirror/store.ts";10import { timelineSvg } from "../src/pages/timeline.ts";11import { createApp } from "../src/server/app.ts";12import { openKeprDb } from "../src/server/db.ts";13import { type Fixture, makeKohBucket } from "./fixture.ts";1415let fx: Fixture;16let app: Hono;17let mirrorDir: string;18let tailSaves: string[];19const get = (path: string) => app.request(path);20const body = async (path: string) => (await get(path)).text();2122const historyIds = (page: string) => {23 const list = /data-list="history">(.*?)<\/div>/s.exec(page)?.[1] ?? "";24 return [...list.matchAll(/class="history-id">([0-9a-f]+)</g)].map((m) => m[1]);25};2627beforeAll(async () => {28 fx = await makeKohBucket();29 const secretRepo = await makeKohBucket("hidden");30 const large = await makeKohBucket("large");31 32 await writeFile(33 join(large.repoDir, "big.txt"),34 `${"a".repeat(1024 * 1024 - 1)}é${"b".repeat(1000)}\n`,35 );36 await writeFile(join(large.repoDir, "big.bin"), new Uint8Array(1024 * 1024 + 500).fill(0xff));37 Bun.spawnSync(["koh3", "save", "add large files"], {38 cwd: large.repoDir,39 env: { PATH: process.env.PATH, HOME: join(large.repoDir, "../../home"), NO_COLOR: "1" },40 });41 42 const tail = await makeKohBucket("tail");43 const tailEnv = { PATH: process.env.PATH, HOME: join(tail.repoDir, "../../home"), NO_COLOR: "1" };44 for (const [text, message] of [45 ["a\nb", "add tail"],46 ["a\nb\n", "end tail with a newline"],47 ["a\nb", "drop the newline"],48 ] as const) {49 await writeFile(join(tail.repoDir, "tail.txt"), text);50 Bun.spawnSync(["koh3", "save", message], { cwd: tail.repoDir, env: tailEnv });51 }52 tailSaves = JSON.parse(53 Bun.spawnSync(["koh3", "view", "--json"], {54 cwd: tail.repoDir,55 env: tailEnv,56 }).stdout.toString(),57 ).saves.map((save: { id: string }) => save.id);58 const dataDir = await mkdtemp(join(tmpdir(), "kepr-pages-"));59 await mkdir(join(dataDir, "assets"));60 await writeFile(join(dataDir, "assets", "plain.txt"), "asset\n");61 const kepr = openKeprDb(dataDir);62 mirrorDir = join(dataDir, "mirror");63 for (const bucketDir of [fx.bucketDir, secretRepo.bucketDir, large.bucketDir, tail.bucketDir]) {64 const bucket = openBucket({ kind: "folder", path: bucketDir });65 await syncAll({ bucket, kepr, mirrorDir });66 }67 kepr.run("UPDATE repos SET public = 1, homepage = 'https://demo.example' WHERE name = 'demo'");68 kepr.run("UPDATE repos SET public = 1 WHERE name IN ('large', 'tail')");69 app = createApp(70 {71 domain: "kepr.example",72 dataDir,73 adminPasswordHash: "$argon2id$x",74 bucket: { kind: "folder", path: fx.bucketDir },75 },76 kepr,77 );78});7980const [head, , second, first] = [0, 1, 2, 3].map((i) => () => fx.saveIds[i] as string);8182describe("the visibility gate", () => {83 test("a private repo and an unknown one are the same 404, everywhere", async () => {84 for (const suffix of ["", "/files/src/main.ts", "/raw/src/main.ts"]) {85 const hidden = await get(`/hidden${suffix}`);86 const missing = await get(`/nowhere${suffix}`);87 expect(hidden.status).toBe(404);88 expect(missing.status).toBe(404);89 expect((await hidden.text()).replaceAll("/hidden", "/nowhere")).toBe(await missing.text());90 }91 });92});9394describe("the repo page", () => {95 test("renders header, timeline, history and README at HEAD with a short cache", async () => {96 const response = await get("/demo");97 expect(response.status).toBe(200);98 expect(response.headers.get("cache-control")).toBe("public, max-age=60");99 const page = await response.text();100 expect(page).toContain('<h1 class="repo-name">demo</h1>');101 102 expect(/<div class="repo-desc"><p>(.*?)<\/p>/.exec(page)?.[1]).toBe(103 "A small repo for <strong>Kepr's</strong> tests.",104 );105 expect(page).toContain(106 '<meta property="og:description" content="A small repo for Kepr's tests.">',107 );108 expect(page).toContain('href="https://demo.example"');109 expect(page).toContain('<span class="lang-badge">TypeScript</span>');110 expect(page).toContain("3 saves");111 expect(page).not.toContain('class="install-line"');112 expect(page.match(/class="dot d\d"/g)?.length).toBe(3);113 expect(page).not.toContain("density = activity");114 expect(historyIds(page)).toEqual([head(), second(), first()]);115 expect(page).toContain('data-copy="koh steal kepr.example/demo"');116 expect(page).toContain('href="/demo/releases" data-panel="releases">builds</a>');117 });118119 test("a page past the last, or too large to bind, is page 1", async () => {120 for (const query of ["?page=2", `?page=${"9".repeat(400)}`, "?page=1e999", "?page=x"]) {121 const response = await get(`/demo${query}`);122 expect([query, response.status]).toEqual([query, 200]);123 expect(historyIds(await response.text()).length).toBe(3);124 }125 });126127 test("checkpoints never appear", async () => {128 expect(await body("/demo")).not.toContain(fx.saveIds[1] as string);129 });130131 test("the README points relative links and images at raw files and drops unsafe links", async () => {132 const page = await body("/demo");133 expect(page).toContain('<a href="/demo/raw/docs/guide.md">the guide</a>');134 expect(page).toContain('<img src="/demo/raw/docs/logo.png" alt="logo">');135 expect(page).toContain('<a href="https://example.com">the site</a>');136 expect(page).not.toContain('href="javascript:');137 expect(page).toContain("<script>alert");138 expect(page).not.toContain("<script>alert");139 });140});141142describe("the timeline", () => {143 144 const saves = [300, 100, 500, 200].map(145 (created_at, i): Save => ({146 id: `00000000000${i}`,147 parent: "",148 message: "m",149 created_at: created_at * 86400,150 machine: "m",151 agent: "",152 session: "",153 is_checkpoint: false,154 }),155 );156157 test("span from the earliest to the latest save, whatever the line's order", () => {158 const dots = [...timelineSvg("demo", saves).value.matchAll(/cx="([\d.]+)%"/g)].map((m) => m[1]);159 expect(dots).toEqual(["50.000", "1.000", "99.000", "25.500"]);160 });161162 test("a dot's tooltip keeps a long message's first 120 characters", () => {163 const long = { ...(saves[0] as Save), message: `${"x".repeat(150)}\nsecond line` };164 const svg = timelineSvg("demo", [long]).value;165 expect(svg).toContain(`\n${"x".repeat(119)}…\n`);166 expect(svg).not.toContain("x".repeat(120));167 });168});169170describe("the file viewer", () => {171 test("shows a file at HEAD and at an old save, with line anchors", async () => {172 const now = await get("/demo/files/src/main.ts");173 expect(now.headers.get("cache-control")).toBe("public, max-age=60");174 const nowPage = await now.text();175 expect(nowPage).toContain("hello");176 expect(nowPage).toContain(177 '<span class="line" id="L2"><a class="ln" href="#L2">2</a><span class="lc">',178 );179 expect(nowPage).toContain('class="tk-');180181 const then = await get(`/demo/files/src/main.ts?at=${second().slice(0, 6)}`);182 expect(then.headers.get("cache-control")).toBe("private, max-age=31536000");183 const thenPage = await then.text();184 expect(thenPage).toContain("'hi'");185 expect(thenPage).not.toContain("hello");186 expect(thenPage).toContain(`/demo/raw/src/main.ts?at=${second()}`);187 });188189 test("a file absent at that save, a bad save or an unsafe path is a 404", async () => {190 expect((await get(`/demo/files/src/main.ts?at=${first()}`)).status).toBe(404);191 expect((await get("/demo/files/src/main.ts?at=zzzzzz")).status).toBe(404);192 expect((await get("/demo/files/src/main.ts?at=abc")).status).toBe(404);193 expect((await get("/demo/files/src%2F..%2FREADME.md")).status).toBe(404);194 expect((await get("/demo/files/nothing.txt")).status).toBe(404);195 });196197 test("Markdown renders, with a source toggle", async () => {198 const rendered = await body("/demo/files/docs/guide.md");199 expect(rendered).toContain("<h1>Guide</h1>");200 const source = await body("/demo/files/docs/guide.md?view=source");201 expect(source).toContain('id="L1"');202 expect(source).not.toContain("<h1>Guide</h1>");203 });204205 test("an image displays inline from its raw file", async () => {206 expect(await body("/demo/files/docs/logo.png")).toContain('<img src="/demo/raw/docs/logo.png"');207 });208});209210describe("files over 1 MB", () => {211 test("text shows its first 1 MB with a raw link, even with a character cut at the mark", async () => {212 const page = await body("/large/files/big.txt");213 expect(page).toContain("showing the first 1 MB");214 expect(page).toContain('href="/large/raw/big.txt"');215 expect(page).not.toContain("bbb");216 const raw = await get("/large/raw/big.txt");217 expect(raw.headers.get("content-type")).toBe("text/plain; charset=utf-8");218 });219220 test("invalid UTF-8 without a NUL is binary, not text", async () => {221 const page = await body("/large/files/big.bin");222 expect(page).toContain("binary file");223 expect(page).not.toContain('class="code"');224 const raw = await get("/large/raw/big.bin");225 expect(raw.headers.get("content-type")).toBe("application/octet-stream");226 });227});228229describe("the Atlas", () => {230 231 const panelOf = (path: string, at?: string) =>232 body(`/demo/atlas/panel?${new URLSearchParams(at ? { path, at } : { path })}`);233 const rowOf = (page: string, name: string) =>234 new RegExp(`data-name="${name}"[^>]*>(.*?)</a>`, "s").exec(page)?.[1] ?? "";235236 test("sits between the timeline and History", async () => {237 const page = await body("/demo");238 const atlas = page.indexOf('id="atlas"');239 expect(page.indexOf('class="timeline"')).toBeLessThan(atlas);240 expect(atlas).toBeLessThan(page.indexOf('id="history"'));241 });242243 test("is a folder tree, folders first, then files, alphabetical", async () => {244 const names = [...(await body("/demo")).matchAll(/class="atlas-name">([^<]*)</g)].map(245 (m) => m[1],246 );247 expect(names).toEqual([248 "docs/",249 "guide.md",250 "logo.png",251 "src/",252 "lib/",253 "deep/",254 "util.ts",255 "main.ts",256 "vendor/",257 "big.c",258 "README.md",259 "secret.txt",260 ]);261 });262263 test("rows carry the first sentence of the file's own comment, rendered, and link to the file", async () => {264 const page = await body("/demo");265 expect(rowOf(page, "util.ts")).toContain(266 '<span class="atlas-desc">The <em>one</em> helper.</span>',267 );268 expect(rowOf(page, "main.ts")).toContain("Entry point.");269 expect(rowOf(page, "guide.md")).toContain('<span class="atlas-desc">Read me.</span>');270 expect(rowOf(page, "secret.txt")).toContain('<span class="atlas-desc"></span>');271 expect(page).toContain(272 '<a class="atlas-row atlas-file" href="/demo/files/src/main.ts" data-name="main.ts" data-path="src/main.ts">',273 );274 const util = await panelOf("src/lib/deep/util.ts");275 expect(util).toContain("<p>The <em>one</em> helper. Deep down.</p>");276 expect(util).toContain("<dt>exports</dt><dd>one</dd>");277 expect(await panelOf("src/main.ts")).not.toContain("atlas-map");278 });279280 test("the panel counts only real saves, crediting a checkpoint's change to the next save", async () => {281 const page = await body("/demo");282 const main = await panelOf("src/main.ts");283 expect(main).toContain("<dt>lines</dt><dd>2</dd>");284 expect(main).toContain("<dt>saves</dt><dd>2</dd>");285 expect(main).toContain(`<dt>first save</dt><dd><a href="/demo/saves/${second()}">`);286 expect(main).toContain(`<dt>last save</dt><dd><a href="/demo/saves/${head()}">`);287 const guide = await panelOf("docs/guide.md");288 expect(guide).toContain("<dt>saves</dt><dd>2</dd>");289 expect(guide).toContain(`<dt>last save</dt><dd><a href="/demo/saves/${head()}">`);290 expect(await panelOf("docs/logo.png")).toContain("<dt>lines</dt><dd>binary</dd>");291 expect(page).not.toContain(fx.saveIds[1] as string);292 });293294 test("a folder's panel sums its files and counts the saves that touched anything under it", async () => {295 const docs = await panelOf("docs/");296 expect(docs).toContain('<p class="atlas-info-path mono">docs</p>');297 expect(docs).toContain("<dt>lines</dt><dd>3</dd>");298 expect(docs).toContain("<dt>files</dt><dd>2</dd>");299 expect(docs).toContain("<dt>saves</dt><dd>2</dd>");300 expect(docs).toContain(`<dt>first save</dt><dd><a href="/demo/saves/${first()}">`);301 expect(docs).toContain(`<dt>last save</dt><dd><a href="/demo/saves/${head()}">`);302 const src = await panelOf("src/");303 expect(src).toContain("<dt>saves</dt><dd>3</dd>");304 });305306 test("can be viewed at an older save, and an unknown save is a 404", async () => {307 const page = await body(`/demo?at=${second().slice(0, 8)}`);308 expect(page).toContain(`title="explore through time">${second()}</summary>`);309 const picker = await body(`/demo/atlas/saves?at=${second()}`);310 expect(picker).toContain(311 `<a class="atlas-picker-row active" href="/demo?at=${second()}#atlas"`,312 );313 expect(picker).toContain(`<a class="atlas-picker-row" href="/demo?at=${head()}#atlas"`);314 expect(page).toContain('<a class="atlas-head-link mono" href="/demo#atlas">back to HEAD</a>');315 expect(page).toContain(`href="/demo/files/src/main.ts?at=${second()}"`);316 const main = await panelOf("src/main.ts", second().slice(0, 8));317 expect(main).toContain("<dt>saves</dt><dd>1</dd>");318 expect(main).not.toContain(head());319 const oldest = await body(`/demo?at=${first()}`);320 expect(oldest).not.toContain('data-name="main.ts"');321 expect((await get("/demo?at=abcdef")).status).toBe(404);322 expect((await get("/demo?at=../x")).status).toBe(404);323 });324325 test("the page carries no panels; each is fetched alone, and anything unknown is a 404", async () => {326 const page = await body("/demo");327 expect(page).not.toContain("<template>");328 expect(page).not.toContain('class="atlas-picker-row" href="/demo?at=');329 expect(page).toContain('data-src="/demo/atlas/saves"');330 expect((await get("/demo/atlas/saves?at=abcdef")).status).toBe(404);331 expect((await get("/nobody/atlas/saves")).status).toBe(404);332 const panel = await get("/demo/atlas/panel?path=src/main.ts");333 expect(panel.status).toBe(200);334 expect(panel.headers.get("content-type")).toContain("text/html");335 for (const query of [336 "path=nope.ts",337 "path=src/main.ts&at=abcdef",338 "path=../secret.txt",339 "path=",340 "",341 "path=nope/",342 ]) {343 expect(`${query} ${(await get(`/demo/atlas/panel?${query}`)).status}`).toBe(`${query} 404`);344 }345 expect((await get("/nobody/atlas/panel?path=README.md")).status).toBe(404);346 });347});348349describe("the save page", () => {350 test("shows the save's facts and diffs against the previous real save, skipping the checkpoint", async () => {351 const response = await get(`/demo/saves/${head()}`);352 expect(response.status).toBe(200);353 expect(response.headers.get("cache-control")).toBe("public, max-age=60");354 const page = await response.text();355 expect(page).toContain('<h1 class="save-message-head">say hello</h1>');356 expect(page).toContain(357 `<dt>parent</dt><dd><a href="/demo/saves/${second()}">${second()}</a></dd>`,358 );359 expect(page).not.toContain(fx.saveIds[1] as string);360 expect(page).not.toContain("save-flag");361 362 const rows = [363 ...page.matchAll(364 /class="change-row change-(\w+)" href="#diff-\d"><span class="change-path">([^<]+)</g,365 ),366 ];367 expect(rows.map((m) => [m[1], m[2]])).toEqual([368 ["modified", "docs/guide.md"],369 ["modified", "src/main.ts"],370 ]);371 expect(page).toContain('<span class="diff-add">+1</span> <span class="diff-del">−1</span>');372 expect(page).toContain('<span class="dh">@@ -1,2 +1,2 @@</span>');373 expect(page).toContain(374 '<span class="dl dl-del"><span class="ln">2</span><span class="ln"></span><span class="ds">-</span>',375 );376 expect(page).toContain('class="tk-');377 expect(page).toContain(`href="/demo/archive/${head()}.tar.gz"`);378 expect(page).toContain(`href="/demo?at=${head()}#atlas"`);379 });380381 test("the first save diffs against nothing, notes binaries, and shows its flag and agent", async () => {382 const page = await body(`/demo/saves/${first()}`);383 expect(page).toContain('<span class="save-flag-label mono">flagged</span> holds a secret');384 expect(page).toContain("<dt>parent</dt><dd>none, the first save</dd>");385 expect(page).toContain(386 'change-added" href="#diff-2"><span class="change-path">docs/logo.png</span><span class="change-stat mono"><span class="diff-note">binary</span>',387 );388 expect(page).toContain("binary file, not shown");389 expect(page).toContain('<span class="dh">@@ -0,0 +1 @@</span>');390 const second_ = await body(`/demo/saves/${second()}`);391 expect(second_).toContain("<dt>agent</dt><dd>test-agent</dd><dt>session</dt><dd>fixture</dd>");392 expect(second_).not.toContain("save-flag");393 });394395 test("a change to the final newline alone is a changed last line, marked as in GNU diff", async () => {396 const marker = '<span class="dh">\\ No newline at end of file</span>';397 const row = (kind: string, a: string, b: string, sign: string) =>398 `<span class="dl dl-${kind}"><span class="ln">${a}</span><span class="ln">${b}</span><span class="ds">${sign}</span><span class="lc">b</span></span>`;399 const gained = await body(`/tail/saves/${tailSaves[1]}`);400 expect(gained).toContain('<span class="diff-add">+1</span> <span class="diff-del">−1</span>');401 expect(gained).toContain(`${row("del", "2", "", "-")}${marker}${row("add", "", "2", "+")}<`);402 const lost = await body(`/tail/saves/${tailSaves[0]}`);403 expect(lost).toContain(`${row("del", "2", "", "-")}${row("add", "", "2", "+")}${marker}`);404 });405406 test("a prefix redirects, and a checkpoint, an unknown or a private save is a 404", async () => {407 const short = await get(`/demo/saves/${head().slice(0, 6)}`);408 expect(short.status).toBe(302);409 expect(short.headers.get("location")).toBe(`/demo/saves/${head()}`);410 expect((await get(`/demo/saves/${fx.saveIds[1]}`)).status).toBe(404);411 expect((await get("/demo/saves/abcdef")).status).toBe(404);412 expect((await get("/demo/saves/abc")).status).toBe(404);413 expect((await get(`/hidden/saves/${head()}`)).status).toBe(404);414 });415});416417describe("raw files", () => {418 test("are the exact object bytes, text as text/plain", async () => {419 const mirror = openMirror(mirrorDir, "demo");420 for (const [path, type] of [421 ["src/main.ts", "text/plain; charset=utf-8"],422 ["docs/logo.png", "image/png"],423 ["README.md", "text/plain; charset=utf-8"],424 ] as const) {425 const response = await get(`/demo/raw/${path}`);426 const file = fileAt(mirror, head(), path);427 expect(response.headers.get("content-type")).toBe(type);428 expect(new Uint8Array(await response.arrayBuffer())).toEqual(429 objectBytes(mirror, file?.hash as string) as Uint8Array<ArrayBuffer>,430 );431 }432 expect(await (await get(`/demo/raw/src/main.ts?at=${second()}`)).text()).toContain("'hi'");433 });434});435436test("static assets and raw files carry route-based sandboxing", async () => {437 const css = await get("/static/css/kepr.css");438 expect(css.status).toBe(200);439 expect(css.headers.get("content-type")).toContain("text/css");440 const raw = await get("/demo/raw/README.md");441 expect(raw.headers.get("content-security-policy")).toContain("sandbox");442 const asset = await get("/static/assets/plain.txt");443 expect(asset.headers.get("content-security-policy")).toContain("sandbox");444 const favicon = await get("/favicon.svg");445 expect(favicon.headers.get("content-type")).toBe("image/svg+xml");446 expect(favicon.headers.get("content-security-policy")).not.toContain("sandbox");447 expect((await get("/static/../package.json")).status).toBe(404);448 const csp = (await get("/demo")).headers.get("content-security-policy") ?? "";449 expect(csp).toContain("style-src 'self' https://fonts.bunny.net");450 expect(csp).toContain("font-src https://fonts.bunny.net");451 expect(csp).not.toContain("unsafe-inline");452});453454describe("housekeeping routes", () => {455 test("robots.txt points at the sitemap, which lists public repos only", async () => {456 expect(await body("/robots.txt")).toBe(457 "User-agent: *\nAllow: /\n\nSitemap: https://kepr.example/sitemap.xml\n",458 );459 const sitemap = await get("/sitemap.xml");460 expect(sitemap.headers.get("Content-Type")).toBe("application/xml; charset=UTF-8");461 const xml = await sitemap.text();462 expect(xml).toStartWith('<?xml version="1.0" encoding="UTF-8"?>\n<urlset');463 for (const repo of ["demo", "large", "tail"]) {464 expect(xml).toContain(`<loc>https://kepr.example/${repo}</loc>`);465 }466 expect(xml).not.toContain("hidden");467 });468469 test("favicon.svg is Kepr 2's mark, and every page links it", async () => {470 const res = await get("/favicon.svg");471 expect(res.headers.get("Content-Type")).toBe("image/svg+xml");472 expect(await res.text()).toContain('<polygon points="16,3 27,23 5,23"');473 expect(await body("/demo")).toContain(474 '<link rel="icon" href="/favicon.svg" type="image/svg+xml">',475 );476 });477});