Function parallelTask

scripts/parallel-task.js:11–115

(tasks, options = {})

 * @returns {Promise<void>} Rejects (process.exit) if any task fails
 */
export async function parallelTask(tasks, options = {}) {
	const { timeoutMs = 30_000 } = options
	const total = tasks.length

	const bgColors = [
		chalk.bgCyan,
		chalk.bgMagenta,
		chalk.bgBlue,
		chalk.bgYellow,
		chalk.bgGreenBright,
	]
	const fgOnBg = [chalk.black, chalk.white, chalk.white, chalk.black, chalk.black]

	let done = 0
	let failed = 0

	const spinner = ['◐', '◓', '◑', '◒']
	let tick = 0

	const printProgress = () => {
		const running = total - done - failed
		const s = spinner[tick++ % spinner.length]
		const status = failed
			? `${running} running, ${done} done, ${chalk.bgRed.white.bold(` ${failed} failed `)}`
			: `${running} running, ${done} done`
		process.stderr.write(`\r${chalk.bgCyan.black.bold(` ${s} ${done}/${total} `)} ${status}  `)
	}

	const timer = setInterval(printProgress, 1000)
	printProgress()

	/** @type {{ label: string, output: string, exitCode: number | null, timedOut: boolean }[]} */
	const results = await Promise.all(
		tasks.map(
			(task) =>
				new Promise((resolve) => {
					const chunks = /** @type {Buffer[]} */ ([])

					const child = spawn('sh', ['-c', task.command], {
						cwd: task.cwd,
						env: { ...process.env, FORCE_COLOR: '1', NO_COLOR: '' },
						stdio: ['ignore', 'pipe', 'pipe'],
					})

					child.stdout.on('data', (d) => chunks.push(d))
					child.stderr.on('data', (d) => chunks.push(d))

					const timeout = setTimeout(() => {
						child.kill('SIGTERM')
					}, timeoutMs)

					child.on('close', (code, signal) => {
						clearTimeout(timeout)
						const timedOut = signal === 'SIGTERM'
						const exitCode = timedOut ? 1 : code

						if (exitCode === 0) done++
						else failed++