Vito Sansevero
ed809f7fa4
Final review fixes for the per-worker test servers (#274): - A failed test gets the stderr its server wrote during that test attached as `server-stderr`, so an aiohttp traceback behind a 500 reaches the CI report. The launcher keeps the newest 256 KB with a stream position per test (stderrMark/stderrSince), and the fixture attaches it only when the test did not end as expected. - The port announcement counts only as a complete line; a chunk ending mid-number was read as a shorter port. - server.py --exit-on-stdin-eof shuts down gracefully (database closed, temp root removed) when stdin closes. The launcher holds that pipe, so a SIGKILLed worker leaves no server behind, on every OS. - settled() gives up after 600 frames with the observation stats instead of hanging to the test timeout. - The Classic text-sync test waits for the page's 50 ms timer to install serializeValue instead of sleeping 60 ms. With that timer run 100 ms late (a scratch copy), the old wait failed 20/20 and the poll passed 20/20; the spec passed 240/240 at 8 workers x10 and 240/240 at 1 CPU with 4 workers. - The workflow test checks each npm cache key names its job's pinned image tag. Every new unit test failed before its change (missing export, the old regex timing out on the split announcement, an unknown server flag, a hung settle, a mismatched cache key).
45 lines
2.0 KiB
JavaScript
45 lines
2.0 KiB
JavaScript
// A stand-in for tests/browser/server.py: `--port N` (0 = an OS-chosen port)
|
|
// serves the readiness page and announces the bound port on stdout as
|
|
// `PM_TEST_SERVER_PORT=<n>`, `--fail` writes to stderr and exits before
|
|
// listening, and GET /__exit makes the process die unexpectedly after writing a
|
|
// last stderr line. GET /__stderr?text=T writes T to stderr before answering.
|
|
// `--split-announce` writes the announcement in two chunks, the first ending
|
|
// mid-number. `--exit-on-stdin-eof` exits when its stdin closes, as server.py does.
|
|
import { createServer } from 'node:http';
|
|
|
|
const args = process.argv.slice(2);
|
|
const port = Number(args[args.indexOf('--port') + 1]);
|
|
if (args.includes('--fail')) {
|
|
process.stderr.write('fake server: refusing to start\nlast fake stderr line\n');
|
|
process.exit(4);
|
|
}
|
|
const server = createServer((request, response) => {
|
|
const url = new URL(request.url, 'http://fake');
|
|
if (url.pathname === '/__stderr') {
|
|
process.stderr.write(url.searchParams.get('text'));
|
|
response.end('written');
|
|
return;
|
|
}
|
|
if (request.url === '/__exit') {
|
|
process.stderr.write('fake server: crashed on purpose\n');
|
|
response.end('bye', () => process.exit(3));
|
|
return;
|
|
}
|
|
response.end(request.url === '/prompt_manager/test' ? 'ready' : `pid ${process.pid}`);
|
|
});
|
|
server.listen(port, '127.0.0.1', () => {
|
|
const line = `PM_TEST_SERVER_PORT=${server.address().port}\n`;
|
|
if (!args.includes('--split-announce')) {
|
|
process.stdout.write(`fake server: listening\n${line}`);
|
|
return;
|
|
}
|
|
// The first chunk is a complete-looking number, one digit short of the real port.
|
|
process.stdout.write(`fake server: listening\n${line.slice(0, -2)}`);
|
|
setTimeout(() => process.stdout.write(line.slice(-2)), 300);
|
|
});
|
|
if (args.includes('--exit-on-stdin-eof')) {
|
|
process.stdin.resume();
|
|
process.stdin.once('end', () => process.exit(0));
|
|
}
|
|
for (const signal of ['SIGTERM', 'SIGINT']) process.once(signal, () => server.close(() => process.exit(0)));
|