cli.mjs

#!/usr/bin/env node
// @ts-check

import fsStreamable from 'node:fs'
import fs from 'node:fs/promises'
import path from 'node:path'
import config from './config.json' assert { type: 'json' }
import { spawn } from 'node:child_process'
import { Transform } from 'readable-stream'
import { fileURLToPath } from 'url'
import kill from '@nichoth/tree-kill'
import esbuild from 'esbuild'
const __filename = fileURLToPath(import.meta.url)
const __dirname = path.dirname(__filename)

const target = path.resolve(path.join(config.target, 'bundle.js'))
const writeStream = fsStreamable.createWriteStream(target)

let child

const transformer = new Transform({
    transform (_chunk, _, cb) {
        const chunk = _chunk.toString()
        if (chunk.includes('# ok')) {
            kill(child.pid)

            setTimeout(() => {
                process.exit(0)
            }, 100)
        }

        if (chunk.includes('# fail ')) {
            kill(child.pid)
            setTimeout(() => {
                process.exit(1)
            }, 100)
        }

        if (chunk.includes('Exiting Window#0 (code=1)')) {
            setTimeout(() => {
                process.exit(1)
            }, 100)
        }

        this.push(chunk)
        cb()
    }
})

const i = process.argv.findIndex(arg => arg.includes('--html'))
const html = process.argv[i]
if (html) {
    // need a custom html file, so write the html to target
    // parse the file name
    let filename
    if (html.includes('=')) {
        filename = html.split('=')[1]
    } else {
        filename = process.argv[i + 1]
    }

    await cp(
        path.join(process.cwd(), filename),
        path.join(path.join(config.target, 'index.html'))
    )
}

//
// build listener for uncaught errors, then add it to the user's test code
//
esbuild.build({
    entryPoints: [path.join(__dirname, 'index.mjs')],
    bundle: true,
    keepNames: true,
    external: ['socket:*'],
    format: 'esm',
    logLevel: 'silent',
    // found this via [source code](https://github.com/evanw/esbuild/blob/a7eb7891ec1aeb7f7967ae38d72ab96518913e62/lib/shared/types.ts#L212)
    write: false
}).then(res => {
    // https://github.com/evanw/esbuild/issues/496#issue-733010073
    const code = new TextDecoder('utf-8').decode(res.outputFiles[0].contents)

    writeStream.write(code, (err) => {
        // done writing `index.mjs`, now write `stdin` to `bundle.js`
        if (err) throw err

        process.stdin
            .pipe(writeStream)
            .on('close', () => {
                // have written the file, now run the tests
                child = spawn('npx', ['ssc', 'run', '--headless'], {
                    cwd: __dirname
                })

                child.stdout
                    .pipe(transformer)
                    .pipe(process.stdout)

                child.stderr.pipe(process.stderr)
            })
    })
})

function cp (a, b) {
    return fs.cp(
        path.resolve(a),
        path.resolve(b),
        { recursive: true, force: true }
    )
}