Spaces:
Running
Running
File size: 7,511 Bytes
aa89cb5 | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 | import {spawn} from 'node:child_process';
import {readFileSync, writeFileSync} from 'node:fs';
import {createHash} from 'node:crypto';
import {join} from 'node:path';
import assert from 'node:assert/strict';
import puppeteer from 'puppeteer-core';
const generated = JSON.parse(readFileSync('generated-order-hashes.json', 'utf8'));
function checkLibrary() {
for (const [file, expected] of Object.entries(generated))
assert.equal(createHash('sha256').update(readFileSync(join('orders-lib', file))).digest('hex'), expected, `generated file changed: ${file}`);
}
checkLibrary();
const server = spawn(process.execPath, ['node_modules/vite/bin/vite.js', 'preview', '--host', '127.0.0.1', '--port', '4175', '--strictPort'],
{stdio: ['ignore', 'pipe', 'pipe']});
let serverOutput = '';
server.stdout.on('data', value => { serverOutput += value; }); server.stderr.on('data', value => { serverOutput += value; });
let browser;
const receipts = [];
try {
let ready = false;
for (let attempt = 0; attempt < 100; attempt++) {
try { ready = (await fetch('http://127.0.0.1:4175/orders.html')).ok; } catch { /* starting */ }
if (ready) break;
await new Promise(resolve => setTimeout(resolve, 100));
}
assert.ok(ready, serverOutput);
browser = await puppeteer.launch({executablePath: process.env.CHROME_BIN || (process.platform === 'darwin'
? '/Applications/Google Chrome.app/Contents/MacOS/Google Chrome'
: '/usr/bin/google-chrome'),
args: ['--no-sandbox', '--disable-dev-shm-usage'], headless: true});
const page = await browser.newPage(), errors = [];
page.on('pageerror', error => errors.push(error.message));
page.on('console', event => { if (event.type() === 'error') errors.push(event.text()); });
page.on('response', response => { if (response.status() >= 400) errors.push(`${response.status()} ${response.url()}`); });
page.on('requestfailed', request => errors.push(`${request.failure()?.errorText} ${request.url()}`));
async function waitReady(storage) {
try {
await page.waitForFunction(value => {
const text = document.querySelector('#status')?.textContent || '';
return text.startsWith(value) && text.includes('ready');
}, {timeout: 20_000}, storage);
} catch (error) {
throw new Error(`${error.message}; status=${await page.$eval('#status', element => element.textContent)}; browserErrors=${errors.join('\n')}`);
}
}
async function inspect(label, diagnostics) {
const response = JSON.parse(await page.$eval('#result', element => element.textContent));
assert.equal(response.metadata.totalCount, 3); assert.equal(response.metadata.aggregations.totalOrders, 3);
assert.equal(response.metadata.pageOffset, 1); assert.equal(response.metadata.pageSize, 1);
assert.deepEqual(response.metadata.searchWarnings, []);
assert.equal(response.data.length, 1); const order = response.data[0];
assert.equal(order.orderNumber, 'KEEP-002'); assert.equal(order.orderDate.slice(0, 10), '2026-10-02');
assert.equal(order.version, 1); assert.equal(order.status.name, 'Paid'); assert.equal(order.status.color, '#22C55E');
assert.deepEqual(order.items.map(item => [item.productName, item.quantity]), [['Box 1', 1], ['Box 2', 2], ['Box 3', 3]]);
assert.equal(order.itemCount, 5);
assert.deepEqual(response.facets.statusCounts.map(row => [String(row.id), row.orderCount, row.orderTotalAmount]),
[['1001', 1, 100], ['1002', 2, 500], ['1003', 0, null]]);
const evidence = JSON.parse(await page.$eval('#sql', element => element.textContent));
assert.equal(evidence.length, 8);
const comments = evidence.map(entry => entry.traceChain.filter(node => node.kind === 'comment').map(node => node.detail));
const expected = [
['load order list', "countAs('totalOrders')"], ['load order list'],
['load order list', 'selectStatusWith(...)', 'load status'],
['load order list', 'selectOrderItemListWith(...)', 'load item previews'],
['load order list', "countOrderItemsAs('itemCount')"],
['load order list', "facetByStatusAs('statusCounts')", 'aggregate status'],
['load order list', "facetByStatusAs('statusCounts')", 'load status facets'],
['load order list', "facetByStatusAs('statusCounts')", 'aggregate status'],
];
assert.deepEqual(comments.map(JSON.stringify).sort(), expected.map(JSON.stringify).sort());
for (const entry of evidence) {
assert.equal(entry.purpose, 'render order list page');
assert.ok(entry.tracePath.some(node => node.kind === 'provider'));
assert.equal(entry.traceChain.filter(node => node.kind === 'purpose').length, 1);
}
const text = await page.$eval('#status', element => element.textContent);
assert.ok(text.includes(`${diagnostics} diagnostics`), text);
assert.equal(await page.$eval('#trace', element => element.textContent), evidence.map(entry => `${entry.purpose}: ${entry.traceChain
.filter(node => node.kind === 'comment').map(node => node.detail).join(' → ')}`).join('\n'));
assert.deepEqual(await page.$$eval('.evidence-table th', cells => cells.map(cell => cell.textContent)),
['Time', 'Identity', 'Trace chain', 'SQL']);
const renderedEvidence = await page.$$eval('#evidence-rows tr', rows => rows.map(row =>
[...row.querySelectorAll('td')].map(cell => cell.textContent)));
assert.deepEqual(renderedEvidence, evidence.map(entry => [
`${entry.elapsedMicros} µs`, entry.tracePath.find(node => node.kind === 'request')?.name ?? '—',
`${entry.traceChain.find(node => node.kind === 'purpose').detail}: ${entry.traceChain
.filter(node => node.kind === 'comment').map(node => node.detail).join(' → ')}`, entry.debugSQL,
]));
receipts.push({label, response, evidence, diagnostics, renderedEvidence});
return response;
}
await page.goto('http://127.0.0.1:4175/orders.html', {waitUntil: 'networkidle0'});
await waitReady('MEMORY'); const baseline = await inspect('memory-first', 8);
await page.reload({waitUntil: 'networkidle0'}); await waitReady('MEMORY');
assert.deepEqual(await inspect('memory-refresh', 8), baseline);
await page.click('#logging');
await page.waitForFunction(() => document.querySelector('#status')?.textContent?.includes('0 diagnostics'));
assert.deepEqual(await inspect('memory-logging-off', 0), baseline);
await page.click('#reset');
await page.waitForFunction(() => !document.querySelector('#reset')?.hasAttribute('disabled'));
assert.deepEqual(await inspect('memory-reset', 0), baseline);
await page.click('#persist'); await waitReady('OPFS');
assert.deepEqual(await inspect('opfs-first', 0), baseline);
await page.reload({waitUntil: 'networkidle0'}); await waitReady('OPFS');
assert.deepEqual(await inspect('opfs-refresh', 8), baseline);
await page.click('#reset');
await page.waitForFunction(() => !document.querySelector('#reset')?.hasAttribute('disabled'));
assert.deepEqual(await inspect('opfs-reset', 8), baseline);
assert.deepEqual(errors, []); checkLibrary();
if (process.env.TEAQL_BROWSER_ORDER_EVIDENCE) writeFileSync(process.env.TEAQL_BROWSER_ORDER_EVIDENCE,
JSON.stringify({receipts, generatedLibraryUnchanged: true, browserErrors: errors}, null, 2) + '\n', {flag: 'wx'});
console.log('PASS browser generated order TraceChain: memory/OPFS, refresh/reset, logging on/off, exact facets/counts/previews, actual SQL=8, unchanged generated library');
} finally { await browser?.close(); server.kill('SIGTERM'); }
|