Function runCommand

scripts/verify-recording-pipeline.mjs:107–220

(name, command, args, options = {})

}

async function runCommand(name, command, args, options = {}) {
	const cwd = options.cwd || root;
	const env = { ...process.env, ...(options.env || {}) };
	const timeoutMs =
		options.timeoutMs ??
		Number(process.env.CAP_VERIFY_COMMAND_TIMEOUT_MS || "180000");
	const stdoutPath = outputPath(name, "stdout");
	const stderrPath = outputPath(name, "stderr");
	const statusPath = outputPath(name, "status.json");
	const stdout = fs.createWriteStream(stdoutPath);
	const stderr = fs.createWriteStream(stderrPath);
	const startedAt = Date.now();

	const result = await new Promise((resolve, reject) => {
		const child = spawn(command, args, {
			cwd,
			env,
			stdio: ["ignore", "pipe", "pipe"],
		});

		let stdoutText = "";
		let stderrText = "";
		let timedOut = false;
		let killTimer = null;
		const timeoutTimer =
			timeoutMs > 0
				? setTimeout(() => {
						timedOut = true;
						child.kill("SIGTERM");
						killTimer = setTimeout(() => child.kill("SIGKILL"), 5000);
					}, timeoutMs)
				: null;

		child.stdout.on("data", (chunk) => {
			const text = chunk.toString();
			stdoutText += text;
			stdout.write(chunk);
		});

		child.stderr.on("data", (chunk) => {
			const text = chunk.toString();
			stderrText += text;
			stderr.write(chunk);
		});

		child.on("error", (error) => {
			if (timeoutTimer) {
				clearTimeout(timeoutTimer);
			}
			if (killTimer) {
				clearTimeout(killTimer);
			}
			reject(error);
		});
		child.on("close", (code, signal) => {
			if (timeoutTimer) {
				clearTimeout(timeoutTimer);
			}