Function run

test/e2e/run.mjs:33–148

()

let failure = false;

async function run() {
    if (!['LOCAL', 'MEMORY', 'PLATFORM'].includes(process.env.STORAGE_IMPLEMENTATION)) {
        throw new Error(`Unknown storage provided: '${process.env.STORAGE_IMPLEMENTATION}'`);
    }

    console.log(`Running E2E tests with storage implementation '${process.env.STORAGE_IMPLEMENTATION}'`);

    const paths = await readdir(basePath, { withFileTypes: true });
    const dirs = paths.filter((dirent) => dirent.isDirectory());

    for (const dir of dirs) {
        if (process.argv.length === 3 && dir.name !== process.argv[2]) {
            continue;
        }

        const now = Date.now();
        console.log(`${colors.yellow(`[${dir.name}] `)}${colors.grey('Test starting...')}`);
        const worker = new Worker(fileURLToPath(import.meta.url), {
            workerData: dir.name,
            stdout: true,
            stderr: true,
        });
        let seenFirst = false;
        const prefix = colors.yellow(`[${dir.name}] `);
        // Surface only lines that start with a structured `[…]` marker (init,
        // assertion, build, run, kv, test skipped, etc.). Everything else
        // (crawler INFO logs, per-URL request handler logs, npm warnings, …)
        // is noise on a green run; buffer it and re-emit from the exit
        // handler iff the test failed.
        const deferredOnSuccess = [];

        // Line-buffered streaming so prefixed lines stay intact across chunk boundaries.
        const streamLines = (stream, sink) => {
            let buffer = '';
            stream.on('data', (chunk) => {
                buffer += chunk.toString();
                const lines = buffer.split('\n');
                buffer = lines.pop();
                for (const line of lines) {
                    if (line === '') continue;

                    if (!line.startsWith('[')) {
                        if (!seenFirst) {
                            console.log(
                                `${colors.red('[fatal]')} test ${colors.yellow(
                                    `[${dir.name}]`,
                                )} did not call "initialize(import.meta.url)"!`,
                            );
                            worker.terminate();
                            return;
                        }
                        deferredOnSuccess.push(line);
                        continue;
                    }

                    seenFirst = true;
                    sink(`${prefix}${line}`);
                }