45 lines
1.5 KiB
TypeScript
45 lines
1.5 KiB
TypeScript
|
// This is an extremely simplified version of [`execa`](https://github.com/sindresorhus/execa)
|
||
|
|
// intended to keep our dependency size down
|
||
|
|
import type { StdioOptions } from 'node:child_process';
|
||
|
|
import type { Readable } from 'node:stream';
|
||
|
|
|
||
|
|
import { text as textFromStream } from 'node:stream/consumers';
|
||
|
|
import { spawn } from 'node:child_process';
|
||
|
|
import { setTimeout as sleep } from 'node:timers/promises';
|
||
|
|
|
||
|
|
export interface ExecaOptions {
|
||
|
|
cwd?: string | URL;
|
||
|
|
stdio?: StdioOptions;
|
||
|
|
timeout?: number;
|
||
|
|
}
|
||
|
|
export interface Output {
|
||
|
|
stdout: string;
|
||
|
|
stderr: string;
|
||
|
|
exitCode: number;
|
||
|
|
}
|
||
|
|
const text = (stream: NodeJS.ReadableStream | Readable | null) => stream ? textFromStream(stream).then(t => t.trimEnd()) : '';
|
||
|
|
|
||
|
|
export async function shell(command: string, flags: string[], opts: ExecaOptions = {}): Promise<Output> {
|
||
|
|
const controller = opts.timeout ? new AbortController() : undefined;
|
||
|
|
const child = spawn(command, flags, {
|
||
|
|
cwd: opts.cwd,
|
||
|
|
shell: true,
|
||
|
|
stdio: opts.stdio,
|
||
|
|
signal: controller?.signal
|
||
|
|
})
|
||
|
|
const stdout = await text(child.stdout);
|
||
|
|
const stderr = await text(child.stderr);
|
||
|
|
if (opts.timeout) {
|
||
|
|
sleep(opts.timeout).then(() => {
|
||
|
|
controller!.abort();
|
||
|
|
throw { stdout, stderr, exitCode: 1 }
|
||
|
|
})
|
||
|
|
}
|
||
|
|
await new Promise((resolve) => child.on('exit', resolve))
|
||
|
|
const { exitCode } = child;
|
||
|
|
if (exitCode !== 0) {
|
||
|
|
throw { stdout, stderr, exitCode };
|
||
|
|
}
|
||
|
|
return { stdout, stderr, exitCode }
|
||
|
|
}
|