Skipped because an earlier part failed.
'; -+ } -+ const error = part.error -+ ? `` -+ : ''; -+ if (part.html === '') { -+ return `${error}${part.status === 'error' ? 'Rendered nothing because it failed.' : 'Rendered an empty string.'}
`; -+ } -+ return [ -+ error, -+ ``, -+ `${escapeHtml(part.html)}No changes since the previous render.
${lines.join('')}');
-+ });
-+
-+ it('detects change between results and between a result and a thrown error', () => {
-+ expect(renderChanged(rendered('a'), rendered('a'))).toBe(false);
-+ expect(renderChanged(rendered('a'), rendered('b'))).toBe(true);
-+ const err = new RenderError('m', { templateId: 't', partId: 'a', trace: [trace('a', 'a')] });
-+ expect(renderChanged(err, rendered('a'))).toBe(true);
-+ expect(renderChanged(rendered('a'), err)).toBe(true);
-+ });
-+});
-+
-+describe('inspectCommand', () => {
-+ function run(outcome: Outcome) {
-+ const written: Record = {};
-+ const logs: string[] = [];
-+ const code = inspectCommand('mod.mjs', 'out.html', {
-+ render: async () => outcome,
-+ write: async (file, contents) => void (written[file] = contents),
-+ log: (line) => void logs.push(line),
-+ });
-+ return { code, written, logs };
-+ }
-+
-+ it('exits 0 for a clean render and writes the report', async () => {
-+ const r = run({ kind: 'result', result: rendered('x') });
-+ expect(await r.code).toBe(0);
-+ expect(r.written['out.html']).toContain('v-ok');
-+ expect(r.logs.join('\n')).toContain('t: ok');
-+ });
-+
-+ it('exits 1 when a part broke', async () => {
-+ const result: RenderResult = { ...rendered('x'), ok: false };
-+ expect(await run({ kind: 'result', result }).code).toBe(1);
-+ });
-+
-+ it('exits 1 for a throw and still writes a report', async () => {
-+ const r = run({
-+ kind: 'thrown',
-+ message: 'part failed',
-+ templateId: 't',
-+ partId: 'a',
-+ trace: [trace('a', '')],
-+ });
-+ expect(await r.code).toBe(1);
-+ expect(r.written['out.html']).toContain('Render threw in part');
-+ });
-+
-+ it('exits 2 for a crash, writes the crash page and prints the detail when there is one', async () => {
-+ const withDetail = run(crash('nope', 'stack'));
-+ expect(await withDetail.code).toBe(2);
-+ expect(withDetail.written['out.html']).toContain('CRASHED');
-+ expect(withDetail.logs).toContain('stack');
-+ const plain = run(crash('nope'));
-+ expect(await plain.code).toBe(2);
-+ expect(plain.logs).not.toContain('stack');
-+ });
-+});
-+
-+describe('startServer', () => {
-+ let server: DevServer | undefined;
-+ afterEach(async () => {
-+ await server?.close();
-+ server = undefined;
-+ });
-+
-+ let current: Outcome = { kind: 'result', result: rendered('one') };
-+ const start = async (extra: Partial[0]> = {}) => {
-+ const dir = await mkdtemp(join(tmpdir(), 'trd-srv-'));
-+ server = await startServer({
-+ file: join(dir, 'mod.mjs'),
-+ port: 0,
-+ render: async () => current,
-+ debounceMs: 10,
-+ ...extra,
-+ });
-+ return { dir, url: server.url };
-+ };
-+ const get = (url: string, init?: RequestInit) => fetch(url, init);
-+
-+ it('serves the inspector with a reload listener, no caching, and nosniff', async () => {
-+ current = { kind: 'result', result: rendered('one') };
-+ const { url } = await start();
-+ const res = await get(url);
-+ const body = await res.text();
-+ expect(res.status).toBe(200);
-+ expect(res.headers.get('cache-control')).toBe('no-store');
-+ expect(res.headers.get('x-content-type-options')).toBe('nosniff');
-+ expect(body).toContain("new EventSource('/__events')");
-+ expect(body.indexOf('EventSource')).toBeGreaterThan(body.indexOf('Generated by'));
-+ });
-+
-+ it('shows what changed once the output changes, and keeps it across reloads of the same render', async () => {
-+ current = { kind: 'result', result: rendered('one') };
-+ const { url } = await start();
-+ expect(await (await get(url)).text()).not.toContain('Changes since');
-+ current = { kind: 'result', result: rendered('two') };
-+ expect(await (await get(url)).text()).toContain('Changes since the previous render');
-+ expect(await (await get(url)).text()).toContain('Changes since the previous render');
-+ });
-+
-+ it('serves the document alone at /email, or a 404 when there is none', async () => {
-+ current = { kind: 'result', result: rendered('doc
') };
-+ const { url } = await start();
-+ expect(await (await get(`${url}email`)).text()).toBe('doc
');
-+ current = { kind: 'result', result: rendered('') };
-+ expect((await get(`${url}email`)).status).toBe(404);
-+ current = crash('c');
-+ expect((await get(`${url}email`)).status).toBe(404);
-+ const page = await get(url);
-+ expect(page.status).toBe(200);
-+ expect(await page.text()).toContain('CRASHED');
-+ });
-+
-+ it('refuses other paths, other methods and foreign Host headers', async () => {
-+ const { url } = await start();
-+ expect((await get(`${url}nope`)).status).toBe(404);
-+ expect((await get(url, { method: 'POST' })).status).toBe(405);
-+ const forged = await new Promise((resolve, reject) => {
-+ import('node:http').then(({ request }) => {
-+ const req = request(url, { headers: { host: 'evil.example' } }, (res) => {
-+ res.resume();
-+ resolve(res.statusCode ?? 0);
-+ });
-+ req.on('error', reject);
-+ req.end();
-+ }, reject);
-+ });
-+ expect(forged).toBe(403);
-+ });
-+
-+ it('answers 500 when rendering itself throws', async () => {
-+ const { url } = await start({
-+ render: async () => {
-+ throw new Error('boom');
-+ },
-+ });
-+ expect((await get(url)).status).toBe(500);
-+ });
-+
-+ it('pushes a reload when a watched file changes, and ignores node_modules', async () => {
-+ const { dir, url } = await start();
-+ const res = await get(`${url}__events`);
-+ const reader = res.body!.getReader();
-+ const next = async () => new TextDecoder().decode((await reader.read()).value);
-+ expect(await next()).toContain('retry: 500');
-+ await writeFile(join(dir, 'mod.mjs'), 'export {}');
-+ expect(await next()).toContain('data: reload');
-+ server!.reload();
-+ expect(await next()).toContain('data: reload');
-+ await reader.cancel();
-+ });
-+
-+ it('reports a port that is already taken', async () => {
-+ const { url } = await start();
-+ const port = Number(new URL(url).port);
-+ await expect(
-+ startServer({ file: join(tmpdir(), 'x.mjs'), port, render: async () => current }),
-+ ).rejects.toMatchObject({ code: 'EADDRINUSE' });
-+ });
-+});
-diff --git a/test/diff.test.ts b/test/diff.test.ts
-new file mode 100644
-index 0000000..d7c5612
---- /dev/null
-+++ b/test/diff.test.ts
-@@ -0,0 +1,221 @@
-+import { describe, expect, it } from 'vitest';
-+import { diffRenders, formatDiff } from '../src/index';
-+import type { PartStatus, PartTrace, RenderResult } from '../src/index';
-+import { diffLines, trimContext } from '../src/inspect/diff';
-+import type { DiffLine } from '../src/inspect/diff';
-+
-+function part(id: string, html: string, status: PartStatus = 'ok'): PartTrace {
-+ return { id, status, html, chars: html.length, ms: 0 };
-+}
-+
-+function result(parts: PartTrace[], html?: string, templateId = 'demo'): RenderResult {
-+ return {
-+ templateId,
-+ ok: parts.every((p) => p.status !== 'error'),
-+ html: html ?? parts.map((p) => p.html).join('\n'),
-+ parts,
-+ };
-+}
-+
-+function summarize(lines: readonly DiffLine[]): string[] {
-+ return lines.map(
-+ (line) => `${line.kind === 'add' ? '+' : line.kind === 'del' ? '-' : '='}${line.text}`,
-+ );
-+}
-+
-+describe('diffLines', () => {
-+ it('marks identical text as unchanged', () => {
-+ expect(summarize(diffLines('a\nb', 'a\nb'))).toEqual(['=a', '=b']);
-+ });
-+
-+ it('reports pure additions and pure deletions', () => {
-+ expect(summarize(diffLines('a', 'a\nb'))).toEqual(['=a', '+b']);
-+ expect(summarize(diffLines('a\nb', 'a'))).toEqual(['=a', '-b']);
-+ });
-+
-+ it('keeps the shared head and tail and diffs only the middle', () => {
-+ expect(summarize(diffLines('head\nold\ntail', 'head\nnew\ntail'))).toEqual([
-+ '=head',
-+ '-old',
-+ '+new',
-+ '=tail',
-+ ]);
-+ });
-+
-+ it('finds the common line inside the middle block', () => {
-+ expect(summarize(diffLines('a\nb\nc\nd', 'a\nx\nc\ny'))).toEqual([
-+ '=a',
-+ '-b',
-+ '+x',
-+ '=c',
-+ '-d',
-+ '+y',
-+ ]);
-+ });
-+
-+ it('takes an addition before a shared line when that keeps more in common', () => {
-+ expect(summarize(diffLines('q', 'p\nq'))).toEqual(['+p', '=q']);
-+ });
-+
-+ it('keeps deleting after the other side is used up', () => {
-+ expect(summarize(diffLines('q\nz', 'p\nq'))).toEqual(['+p', '=q', '-z']);
-+ });
-+
-+ it('keeps adding after the other side is used up', () => {
-+ expect(summarize(diffLines('x\ny', 'y\nz'))).toEqual(['-x', '=y', '+z']);
-+ });
-+
-+ it('replaces the whole middle block when the search would be too large', () => {
-+ const before = Array.from({ length: 600 }, (_, i) => `a${i}`).join('\n');
-+ const after = Array.from({ length: 600 }, (_, i) => `b${i}`).join('\n');
-+ const lines = diffLines(before, after);
-+ expect(lines).toHaveLength(1200);
-+ expect(lines.slice(0, 600).every((line) => line.kind === 'del')).toBe(true);
-+ expect(lines.slice(600).every((line) => line.kind === 'add')).toBe(true);
-+ });
-+
-+ it('treats an empty side as all additions or all deletions', () => {
-+ expect(summarize(diffLines('', 'a'))).toEqual(['-', '+a']);
-+ expect(summarize(diffLines('a', ''))).toEqual(['-a', '+']);
-+ });
-+});
-+
-+describe('diffRenders', () => {
-+ it('reports no change for identical renders', () => {
-+ const before = result([part('a', 'A
'), part('b', 'B
')]);
-+ const diff = diffRenders(before, result([part('a', 'A
'), part('b', 'B
')]));
-+ expect(diff.changed).toBe(false);
-+ expect(diff.parts.map((p) => p.change)).toEqual(['unchanged', 'unchanged']);
-+ expect(diff.parts.every((p) => p.lines.length === 0 && p.charsDelta === 0)).toBe(true);
-+ expect(diff.lines.every((line) => line.kind === 'same')).toBe(true);
-+ });
-+
-+ it('names the part whose HTML changed and by how many characters', () => {
-+ const diff = diffRenders(
-+ result([part('a', 'A
'), part('b', 'B
')]),
-+ result([part('a', 'A
'), part('b', 'Bee
')]),
-+ );
-+ const changed = diff.parts.filter((p) => p.change !== 'unchanged');
-+ expect(diff.changed).toBe(true);
-+ expect(changed.map((p) => p.id)).toEqual(['b']);
-+ expect(changed[0]?.change).toBe('changed');
-+ expect(changed[0]?.charsDelta).toBe(2);
-+ expect(summarize(changed[0]?.lines ?? [])).toEqual(['-B
', '+Bee
']);
-+ expect(changed[0]?.statusBefore).toBe('ok');
-+ expect(changed[0]?.statusAfter).toBe('ok');
-+ });
-+
-+ it('counts a status change as a change even when the HTML is the same', () => {
-+ const diff = diffRenders(
-+ result([part('a', '', 'error')], ''),
-+ result([part('a', '', 'empty')], ''),
-+ );
-+ expect(diff.changed).toBe(true);
-+ expect(diff.parts[0]).toMatchObject({
-+ change: 'changed',
-+ statusBefore: 'error',
-+ statusAfter: 'empty',
-+ charsDelta: 0,
-+ });
-+ });
-+
-+ it('reports added and removed parts, counting from zero', () => {
-+ const diff = diffRenders(
-+ result([part('keep', 'K'), part('gone', 'gone!')]),
-+ result([part('keep', 'K'), part('fresh', 'new')]),
-+ );
-+ const byId = Object.fromEntries(diff.parts.map((p) => [p.id, p]));
-+ expect(byId['gone']).toMatchObject({ change: 'removed', charsDelta: -5 });
-+ expect(byId['gone']?.statusAfter).toBeUndefined();
-+ expect(byId['gone']?.statusBefore).toBe('ok');
-+ expect(byId['fresh']).toMatchObject({ change: 'added', charsDelta: 3 });
-+ expect(byId['fresh']?.statusBefore).toBeUndefined();
-+ expect(byId['fresh']?.statusAfter).toBe('ok');
-+ expect(summarize(byId['fresh']?.lines ?? [])).toEqual(['-', '+new']);
-+ });
-+
-+ it('matches parts by id, so reordering alone is not a part change', () => {
-+ const diff = diffRenders(
-+ result([part('a', 'A'), part('b', 'B')], 'same'),
-+ result([part('b', 'B'), part('a', 'A')], 'same'),
-+ );
-+ expect(diff.changed).toBe(false);
-+ });
-+
-+ it('flags a changed document even when every part is the same', () => {
-+ const parts = [part('a', 'A')];
-+ const diff = diffRenders(result(parts, 'one '), result(parts, 'two '));
-+ expect(diff.changed).toBe(true);
-+ expect(diff.parts.every((p) => p.change === 'unchanged')).toBe(true);
-+ });
-+
-+ it('carries both template ids', () => {
-+ const diff = diffRenders(result([], '', 'before'), result([], '', 'after'));
-+ expect([diff.templateBefore, diff.templateAfter]).toEqual(['before', 'after']);
-+ });
-+});
-+
-+describe('trimContext', () => {
-+ const lines = (...kinds: string[]): DiffLine[] =>
-+ kinds.map((kind, i) => ({ kind: kind as DiffLine['kind'], text: `l${i}` }));
-+
-+ it('collapses an unchanged document to one marker', () => {
-+ expect(summarize(trimContext(lines('same', 'same', 'same')))).toEqual(['=…']);
-+ });
-+
-+ it('keeps context around a change and collapses each gap once', () => {
-+ const out = trimContext(
-+ lines('same', 'same', 'same', 'same', 'add', 'same', 'same', 'same', 'same', 'same'),
-+ 1,
-+ );
-+ expect(summarize(out)).toEqual(['=…', '=l3', '+l4', '=l5', '=…']);
-+ });
-+
-+ it('stops at the edges of the document', () => {
-+ expect(summarize(trimContext(lines('del', 'same', 'same', 'same', 'add'), 1))).toEqual([
-+ '-l0',
-+ '=l1',
-+ '=…',
-+ '=l3',
-+ '+l4',
-+ ]);
-+ });
-+
-+ it('uses two lines of context by default and none when asked', () => {
-+ const six = lines('same', 'same', 'same', 'add', 'same', 'same', 'same');
-+ expect(summarize(trimContext(six))).toEqual(['=…', '=l1', '=l2', '+l3', '=l4', '=l5', '=…']);
-+ expect(summarize(trimContext(six, 0))).toEqual(['=…', '+l3', '=…']);
-+ });
-+});
-+
-+describe('formatDiff', () => {
-+ it('says so when nothing changed', () => {
-+ const same = result([part('a', 'A')]);
-+ expect(formatDiff(diffRenders(same, same))).toBe('demo: no changes');
-+ });
-+
-+ it('lists the changed parts, then the changed lines', () => {
-+ const text = formatDiff(
-+ diffRenders(
-+ result([part('a', 'A'), part('b', 'old text')], 'top\nold text\nbottom'),
-+ result([part('a', 'A'), part('b', 'new')], 'top\nnew\nbottom'),
-+ ),
-+ );
-+ expect(text).toBe(
-+ ['demo: changed', ' b changed (-5 chars)', ' top', '- old text', '+ new', ' bottom'].join(
-+ '\n',
-+ ),
-+ );
-+ });
-+
-+ it('prefixes growth with a plus sign and skips unchanged parts', () => {
-+ const text = formatDiff(
-+ diffRenders(
-+ result([part('a', 'A'), part('b', '')]),
-+ result([part('a', 'A'), part('b', 'xy')]),
-+ ),
-+ );
-+ expect(text).toContain(' b changed (+2 chars)');
-+ expect(text).not.toContain(' a ');
-+ });
-+});
-diff --git a/test/fixtures/bad-throw.mjs b/test/fixtures/bad-throw.mjs
-new file mode 100644
-index 0000000..3db1408
---- /dev/null
-+++ b/test/fixtures/bad-throw.mjs
-@@ -0,0 +1 @@
-+throw 'a plain string';
-diff --git a/test/fixtures/broken.mjs b/test/fixtures/broken.mjs
-new file mode 100644
-index 0000000..cf477c5
---- /dev/null
-+++ b/test/fixtures/broken.mjs
-@@ -0,0 +1,11 @@
-+export const template = {
-+ id: 'broken',
-+ parts: [
-+ {
-+ id: 'bad',
-+ render: () => {
-+ throw new Error('boom');
-+ },
-+ },
-+ ],
-+};
-diff --git a/test/fixtures/default-export.mjs b/test/fixtures/default-export.mjs
-new file mode 100644
-index 0000000..717a367
---- /dev/null
-+++ b/test/fixtures/default-export.mjs
-@@ -0,0 +1 @@
-+export default { template: { id: 'dflt', parts: [] } };
-diff --git a/test/fixtures/no-template.mjs b/test/fixtures/no-template.mjs
-new file mode 100644
-index 0000000..77bda47
---- /dev/null
-+++ b/test/fixtures/no-template.mjs
-@@ -0,0 +1 @@
-+export const props = {};
-diff --git a/test/fixtures/ok.mjs b/test/fixtures/ok.mjs
-new file mode 100644
-index 0000000..a278485
---- /dev/null
-+++ b/test/fixtures/ok.mjs
-@@ -0,0 +1,2 @@
-+export const template = { id: 'ok', parts: [{ id: 'note', render: () => 'hi
' }] };
-+export const props = { title: 'T' };
-diff --git a/test/fixtures/syntax.mjs b/test/fixtures/syntax.mjs
-new file mode 100644
-index 0000000..4aa8236
---- /dev/null
-+++ b/test/fixtures/syntax.mjs
-@@ -0,0 +1 @@
-+export const template = {{{
-diff --git a/test/fixtures/throws.mjs b/test/fixtures/throws.mjs
-new file mode 100644
-index 0000000..db5b107
---- /dev/null
-+++ b/test/fixtures/throws.mjs
-@@ -0,0 +1,12 @@
-+export const template = {
-+ id: 'throws',
-+ parts: [
-+ {
-+ id: 'bad',
-+ render: () => {
-+ throw new Error('boom');
-+ },
-+ },
-+ ],
-+};
-+export const options = { onError: 'throw' };
-diff --git a/test/fixtures/worker-dies.mjs b/test/fixtures/worker-dies.mjs
-new file mode 100644
-index 0000000..a488b63
---- /dev/null
-+++ b/test/fixtures/worker-dies.mjs
-@@ -0,0 +1,2 @@
-+console.error('about to die');
-+process.exit(3);
-diff --git a/test/fixtures/worker-loops.mjs b/test/fixtures/worker-loops.mjs
-new file mode 100644
-index 0000000..32940f0
---- /dev/null
-+++ b/test/fixtures/worker-loops.mjs
-@@ -0,0 +1 @@
-+setInterval(() => {}, 1000);
-diff --git a/test/fixtures/worker-reports.mjs b/test/fixtures/worker-reports.mjs
-new file mode 100644
-index 0000000..741e1b8
---- /dev/null
-+++ b/test/fixtures/worker-reports.mjs
-@@ -0,0 +1 @@
-+process.send({ kind: 'crash', message: 'from worker ' + process.argv[2] });
-diff --git a/test/inspect.test.ts b/test/inspect.test.ts
-new file mode 100644
-index 0000000..22d75d3
---- /dev/null
-+++ b/test/inspect.test.ts
-@@ -0,0 +1,310 @@
-+import { describe, expect, it } from 'vitest';
-+import {
-+ defineEmailTemplate,
-+ defineTemplate,
-+ inspect,
-+ renderEmail,
-+ renderTemplate,
-+ RenderError,
-+ slot,
-+} from '../src/index';
-+import type { PartStatus, PartTrace, RenderResult } from '../src/index';
-+
-+function part(
-+ id: string,
-+ html: string,
-+ status: PartStatus = 'ok',
-+ extra: Partial = {},
-+): PartTrace {
-+ return { id, status, html, chars: html.length, ms: 0, ...extra };
-+}
-+
-+function result(parts: PartTrace[], overrides: Partial = {}): RenderResult {
-+ return {
-+ templateId: 'demo',
-+ ok: parts.every((p) => p.status !== 'error'),
-+ html: parts.map((p) => p.html).join('\n'),
-+ parts,
-+ ...overrides,
-+ };
-+}
-+
-+const letter = defineEmailTemplate({
-+ id: 'weekly',
-+ parts: [
-+ {
-+ id: 'promo',
-+ render: (ctx) => `Code ${(ctx.props as { code?: string }).code!.toUpperCase()}
`,
-+ },
-+ { id: 'note', render: (ctx) => slot(ctx, 'note') },
-+ ],
-+});
-+
-+describe('inspect: a healthy render', () => {
-+ const html = inspect(renderEmail(letter, { title: 'Hi', heading: 'Hi', code: 'x1' } as never));
-+
-+ it('is a complete HTML5 page', () => {
-+ expect(html.startsWith('\n')).toBe(true);
-+ expect(html).toContain('');
-+ expect(html).toContain('Inspect · weekly ');
-+ expect(html.trimEnd().endsWith('')).toBe(true);
-+ });
-+
-+ it('shows the verdict, the template id and a summary line', () => {
-+ expect(html).toContain('v-ok">OK');
-+ expect(html).toContain('weekly
');
-+ expect(html).toMatch(/5 parts · [\d,]+ chars · /);
-+ });
-+
-+ it('draws one timeline row and one part card per part', () => {
-+ for (const id of ['head', 'main', 'promo', 'note', 'footer']) {
-+ expect(html).toContain(`${id}`);
-+ }
-+ expect(html.match(/class="row"/g)).toHaveLength(5);
-+ expect(html.match(/ {
-+ expect(html).not.toContain('role="alert"');
-+ expect(html).not.toMatch(//);
-+ });
-+
-+ it('has no scripts, no network requests and never prints "undefined"', () => {
-+ expect(html).not.toMatch(/ {
-+ expect(html).toContain('id="vp-full" checked');
-+ expect(html).toContain('for="vp-tablet">Tablet 768');
-+ expect(html).toContain('for="vp-mobile">Mobile 375');
-+ expect(html).toContain(
-+ '`,
+ '',
+ '',
+ ].join('\n');
+}
+
+function partsSection(parts: readonly PartTrace[]): string {
+ if (parts.length === 0) return '';
+ return `Parts
${parts.map(partCard).join('\n')}${escapeHtml(part.id)} ${chip(part.status)}
`,
+ partBody(part),
+ '',
+ ].join('\n');
+}
+
+function partBody(part: PartTrace): string {
+ if (part.status === 'skipped') {
+ return 'Skipped because an earlier part failed.
';
+ }
+ const error = part.error
+ ? ``
+ : '';
+ if (part.html === '') {
+ return `${error}${part.status === 'error' ? 'Rendered nothing because it failed.' : 'Rendered an empty string.'}
`;
+ }
+ return [
+ error,
+ ``,
+ `${escapeHtml(part.html)}
`,
+ ].join('\n');
+}
+
+function diffSection(diff: RenderDiff): string {
+ if (!diff.changed) {
+ return 'Changes
No changes since the previous render.
${escapeHtml(part.id)} ${part.change} `;
+ });
+ const lines = trimContext(diff.lines).map(diffLine);
+ return `Changes since the previous render
${changes.join('')}
${lines.join('')}
');
+ });
+
+ it('shows the version', () => {
+ expect(parseArgs(['-v'])).toEqual({ kind: 'version' });
+ expect(parseArgs(['--version'])).toEqual({ kind: 'version' });
+ });
+
+ it('parses dev with defaults and with every option, in both flag styles', () => {
+ expect(parseArgs(['dev', 'a.mjs'])).toEqual({
+ kind: 'dev',
+ file: 'a.mjs',
+ port: 4177,
+ host: '127.0.0.1',
+ watch: [],
+ });
+ expect(
+ parseArgs(['dev', 'a.mjs', '--port', '0', '--host=::1', '--watch', 'src', '--watch=lib']),
+ ).toEqual({ kind: 'dev', file: 'a.mjs', port: 0, host: '::1', watch: ['src', 'lib'] });
+ });
+
+ it('parses inspect with and without --out', () => {
+ expect(parseArgs(['inspect', 'a.mjs'])).toEqual({
+ kind: 'inspect',
+ file: 'a.mjs',
+ out: 'inspect.html',
+ });
+ expect(parseArgs(['inspect', '--out', 'r.html', 'a.mjs'])).toEqual({
+ kind: 'inspect',
+ file: 'a.mjs',
+ out: 'r.html',
+ });
+ });
+
+ it.each([
+ [['nope'], /Unknown command "nope"/],
+ [['dev'], /dev needs a module path/],
+ [['inspect'], /inspect needs a module path/],
+ [['dev', 'a', 'b'], /Unexpected extra argument "b"/],
+ [['dev', 'a', '--out', 'x'], /Unknown option "--out" for dev/],
+ [['inspect', 'a', '--port', '1'], /Unknown option "--port" for inspect/],
+ [['dev', 'a', '--port'], /--port needs a value/],
+ [['dev', 'a', '--port='], /--port needs a value/],
+ [['dev', 'a', '--port', 'abc'], /Invalid port "abc"/],
+ [['dev', 'a', '--port', '70000'], /Invalid port "70000"/],
+ [['dev', 'a', '--port', '1.5'], /Invalid port "1.5"/],
+ [['dev', 'a', '--port', '-1'], /Invalid port "-1"/],
+ ])('rejects %j', (argv: string[], message: RegExp) => {
+ const command = parseArgs(argv);
+ expect(command.kind).toBe('error');
+ expect((command as { message: string }).message).toMatch(message);
+ });
+});
+
+describe('runModule', () => {
+ it('renders a module in collect mode and returns the result', async () => {
+ const outcome = await runModule(fx('ok.mjs'));
+ expect(outcome.kind).toBe('result');
+ expect(outcome.kind === 'result' && outcome.result.ok).toBe(true);
+ });
+
+ it('collects a broken part by default', async () => {
+ const outcome = await runModule(fx('broken.mjs'));
+ expect(outcome.kind === 'result' && outcome.result.ok).toBe(false);
+ expect(
+ outcome.kind === 'result' && outcome.result.parts.some((p) => p.status === 'error'),
+ ).toBe(true);
+ });
+
+ it('reports a throw when the module asks for throw mode', async () => {
+ const outcome = await runModule(fx('throws.mjs'));
+ expect(outcome).toMatchObject({ kind: 'thrown', templateId: 'throws', partId: 'bad' });
+ expect(outcome.kind === 'thrown' && outcome.trace.length).toBeGreaterThan(0);
+ });
+
+ it('accepts a default export with the same keys', async () => {
+ expect((await runModule(fx('default-export.mjs'))).kind).toBe('result');
+ });
+
+ it('turns a missing template, a syntax error and a non-Error throw into a crash', async () => {
+ expect(await runModule(fx('no-template.mjs'))).toMatchObject({
+ kind: 'crash',
+ message: expect.stringContaining('does not export a template'),
+ });
+ expect(await runModule(fx('syntax.mjs'))).toMatchObject({
+ kind: 'crash',
+ detail: expect.any(String),
+ });
+ expect(await runModule(fx('bad-throw.mjs'))).toEqual({
+ kind: 'crash',
+ message: 'a plain string',
+ detail: 'a plain string',
+ });
+ expect((await runModule(fx('missing-file.mjs'))).kind).toBe('crash');
+ });
+
+ it('caps crash detail', () => {
+ expect((crash('m', 'x'.repeat(9000)) as { detail: string }).detail).toHaveLength(4000);
+ expect(crash('m')).toEqual({ kind: 'crash', message: 'm' });
+ });
+
+ it('does not treat a lookalike error as a RenderError', async () => {
+ const fake = Object.assign(new Error('x'), { name: 'RenderError', templateId: 1 });
+ expect(fake).toBeInstanceOf(Error);
+ const dir = await mkdtemp(join(tmpdir(), 'trd-'));
+ const file = join(dir, 'fake.mjs');
+ await writeFile(
+ file,
+ "const e = new Error('lookalike'); e.name = 'RenderError'; e.templateId = 1; throw e;",
+ );
+ expect(await runModule(file)).toMatchObject({ kind: 'crash', message: 'lookalike' });
+ await rm(dir, { recursive: true });
+ });
+});
+
+describe('forkRender', () => {
+ it('returns what the worker reports, passing the module path', async () => {
+ const outcome = await forkRender('m.mjs', { workerPath: fx('worker-reports.mjs') });
+ expect(outcome).toEqual({ kind: 'crash', message: 'from worker m.mjs' });
+ });
+
+ it('turns a worker that dies into a crash with its stderr', async () => {
+ const outcome = await forkRender('m', { workerPath: fx('worker-dies.mjs') });
+ expect(outcome).toMatchObject({
+ kind: 'crash',
+ message: expect.stringContaining('exit code 3'),
+ detail: expect.stringContaining('about to die'),
+ });
+ });
+
+ it('kills a worker that never reports', async () => {
+ const outcome = await forkRender('m', { workerPath: fx('worker-loops.mjs'), timeoutMs: 150 });
+ expect(outcome).toMatchObject({
+ kind: 'crash',
+ message: expect.stringContaining('timed out after 150ms'),
+ });
+ });
+
+ it('turns a program that cannot start into a crash', async () => {
+ const outcome = await forkRender('m', {
+ workerPath: fx('worker-reports.mjs'),
+ execPath: '/nonexistent/node',
+ });
+ expect(outcome.kind).toBe('crash');
+ });
+
+ it('turns a missing worker file into a crash', async () => {
+ const outcome = await forkRender('m', { workerPath: fx('nope.mjs') });
+ expect(outcome.kind).toBe('crash');
+ });
+});
+
+const trace = (id: string, html: string): PartTrace => ({
+ id,
+ status: 'ok',
+ html,
+ chars: html.length,
+ ms: 0,
+});
+const rendered = (html: string): RenderResult => ({
+ templateId: 't',
+ ok: true,
+ html,
+ parts: [trace('a', html)],
+});
+
+describe('pages', () => {
+ it('maps each outcome to something the inspector can show', () => {
+ const result = rendered('x');
+ expect(toInspectable({ kind: 'result', result })).toBe(result);
+ const thrown = toInspectable({
+ kind: 'thrown',
+ message: 'm',
+ templateId: 't',
+ partId: 'a',
+ trace: [trace('a', '')],
+ });
+ expect(thrown).toBeInstanceOf(RenderError);
+ expect(toInspectable(crash('c'))).toBeUndefined();
+ });
+
+ it('renders the inspector, the comparison and the crash page', () => {
+ expect(outcomePage({ kind: 'result', result: rendered('one') })).toContain('t
');
+ expect(outcomePage({ kind: 'result', result: rendered('two') }, rendered('one'))).toContain(
+ 'Changes since',
+ );
+ const page = outcomePage(crash('', 'stack '));
+ expect(page).toContain('CRASHED');
+ expect(page).toContain('<bad>');
+ expect(page).toContain('stack <here>');
+ expect(crashPage({ kind: 'crash', message: 'no detail' })).not.toContain('');
+ });
+
+ it('detects change between results and between a result and a thrown error', () => {
+ expect(renderChanged(rendered('a'), rendered('a'))).toBe(false);
+ expect(renderChanged(rendered('a'), rendered('b'))).toBe(true);
+ const err = new RenderError('m', { templateId: 't', partId: 'a', trace: [trace('a', 'a')] });
+ expect(renderChanged(err, rendered('a'))).toBe(true);
+ expect(renderChanged(rendered('a'), err)).toBe(true);
+ });
+});
+
+describe('inspectCommand', () => {
+ function run(outcome: Outcome) {
+ const written: Record = {};
+ const logs: string[] = [];
+ const code = inspectCommand('mod.mjs', 'out.html', {
+ render: async () => outcome,
+ write: async (file, contents) => void (written[file] = contents),
+ log: (line) => void logs.push(line),
+ });
+ return { code, written, logs };
+ }
+
+ it('exits 0 for a clean render and writes the report', async () => {
+ const r = run({ kind: 'result', result: rendered('x') });
+ expect(await r.code).toBe(0);
+ expect(r.written['out.html']).toContain('v-ok');
+ expect(r.logs.join('\n')).toContain('t: ok');
+ });
+
+ it('exits 1 when a part broke', async () => {
+ const result: RenderResult = { ...rendered('x'), ok: false };
+ expect(await run({ kind: 'result', result }).code).toBe(1);
+ });
+
+ it('exits 1 for a throw and still writes a report', async () => {
+ const r = run({
+ kind: 'thrown',
+ message: 'part failed',
+ templateId: 't',
+ partId: 'a',
+ trace: [trace('a', '')],
+ });
+ expect(await r.code).toBe(1);
+ expect(r.written['out.html']).toContain('Render threw in part');
+ });
+
+ it('exits 2 for a crash, writes the crash page and prints the detail when there is one', async () => {
+ const withDetail = run(crash('nope', 'stack'));
+ expect(await withDetail.code).toBe(2);
+ expect(withDetail.written['out.html']).toContain('CRASHED');
+ expect(withDetail.logs).toContain('stack');
+ const plain = run(crash('nope'));
+ expect(await plain.code).toBe(2);
+ expect(plain.logs).not.toContain('stack');
+ });
+});
+
+describe('startServer', () => {
+ let server: DevServer | undefined;
+ afterEach(async () => {
+ await server?.close();
+ server = undefined;
+ });
+
+ let current: Outcome = { kind: 'result', result: rendered('one') };
+ const start = async (extra: Partial[0]> = {}) => {
+ const dir = await mkdtemp(join(tmpdir(), 'trd-srv-'));
+ server = await startServer({
+ file: join(dir, 'mod.mjs'),
+ port: 0,
+ render: async () => current,
+ debounceMs: 10,
+ ...extra,
+ });
+ return { dir, url: server.url };
+ };
+ const get = (url: string, init?: RequestInit) => fetch(url, init);
+
+ it('serves the inspector with a reload listener, no caching, and nosniff', async () => {
+ current = { kind: 'result', result: rendered('one') };
+ const { url } = await start();
+ const res = await get(url);
+ const body = await res.text();
+ expect(res.status).toBe(200);
+ expect(res.headers.get('cache-control')).toBe('no-store');
+ expect(res.headers.get('x-content-type-options')).toBe('nosniff');
+ expect(body).toContain("new EventSource('/__events')");
+ expect(body.indexOf('EventSource')).toBeGreaterThan(body.indexOf('Generated by'));
+ });
+
+ it('shows what changed once the output changes, and keeps it across reloads of the same render', async () => {
+ current = { kind: 'result', result: rendered('one') };
+ const { url } = await start();
+ expect(await (await get(url)).text()).not.toContain('Changes since');
+ current = { kind: 'result', result: rendered('two') };
+ expect(await (await get(url)).text()).toContain('Changes since the previous render');
+ expect(await (await get(url)).text()).toContain('Changes since the previous render');
+ });
+
+ it('serves the document alone at /email, or a 404 when there is none', async () => {
+ current = { kind: 'result', result: rendered('doc
') };
+ const { url } = await start();
+ expect(await (await get(`${url}email`)).text()).toBe('doc
');
+ current = { kind: 'result', result: rendered('') };
+ expect((await get(`${url}email`)).status).toBe(404);
+ current = crash('c');
+ expect((await get(`${url}email`)).status).toBe(404);
+ const page = await get(url);
+ expect(page.status).toBe(200);
+ expect(await page.text()).toContain('CRASHED');
+ });
+
+ it('refuses other paths, other methods and foreign Host headers', async () => {
+ const { url } = await start();
+ expect((await get(`${url}nope`)).status).toBe(404);
+ expect((await get(url, { method: 'POST' })).status).toBe(405);
+ const forged = await new Promise((resolve, reject) => {
+ import('node:http').then(({ request }) => {
+ const req = request(url, { headers: { host: 'evil.example' } }, (res) => {
+ res.resume();
+ resolve(res.statusCode ?? 0);
+ });
+ req.on('error', reject);
+ req.end();
+ }, reject);
+ });
+ expect(forged).toBe(403);
+ });
+
+ it('answers 500 when rendering itself throws', async () => {
+ const { url } = await start({
+ render: async () => {
+ throw new Error('boom');
+ },
+ });
+ expect((await get(url)).status).toBe(500);
+ });
+
+ it('pushes a reload when a watched file changes, and ignores node_modules', async () => {
+ const { dir, url } = await start();
+ const res = await get(`${url}__events`);
+ const reader = res.body!.getReader();
+ const next = async () => new TextDecoder().decode((await reader.read()).value);
+ expect(await next()).toContain('retry: 500');
+ await writeFile(join(dir, 'mod.mjs'), 'export {}');
+ expect(await next()).toContain('data: reload');
+ server!.reload();
+ expect(await next()).toContain('data: reload');
+ await reader.cancel();
+ });
+
+ it('uses default port and debounce when omitted, and handles a missing request url', async () => {
+ const dir = await mkdtemp(join(tmpdir(), 'trd-def-'));
+ const server = await startServer({
+ file: join(dir, 'mod.mjs'),
+ render: async () => ({ kind: 'result', result: rendered('x') }),
+ });
+ expect(server.port).toBeGreaterThan(0);
+ await server.close();
+ await rm(dir, { recursive: true, force: true });
+ });
+
+ it('withReload appends the script when the page has no body tag', async () => {
+ // Force a page without