import { type ChildProcess, type SpawnOptions, spawn,} from "node:child_process";import BufferList from "bl"; export const spawnAsync = ( command: string, args?: string[] | undefined, onData?: (data: string) => void, // Callback opcional para manejar datos en tiempo real options?: SpawnOptions,): Promise<BufferList> & { child: ChildProcess } => { const child = spawn(command, args ?? [], options ?? {}); const stdout = child.stdout ? new BufferList() : new BufferList(); const stderr = child.stderr ? new BufferList() : new BufferList(); if (child.stdout) { child.stdout.on("data", (data) => { stdout.append(data); if (onData) { onData(data.toString()); } }); } if (child.stderr) { child.stderr.on("data", (data) => { stderr.append(data); if (onData) { onData(data.toString()); } }); } const promise = new Promise<BufferList>((resolve, reject) => { child.on("error", reject); child.on("close", (code) => { if (code === 0) { resolve(stdout); } else { const err = new Error(`child exited with code ${code}`) as Error & { code: number; stderr: BufferList; stdout: BufferList; }; err.code = code || -1; err.stderr = stderr; err.stdout = stdout; reject(err); } }); }) as Promise<BufferList> & { child: ChildProcess }; promise.child = child; return promise;};
import {
type ChildProcess,
type SpawnOptions,
spawn,
} from "node:child_process";
import BufferList from "bl";
export const spawnAsync = (
command: string,
args?: string[] | undefined,
onData?: (data: string) => void, // Callback opcional para manejar datos en tiempo real
options?: SpawnOptions,
): Promise<BufferList> & { child: ChildProcess } => {
const child = spawn(command, args ?? [], options ?? {});
const stdout = child.stdout ? new BufferList() : new BufferList();
const stderr = child.stderr ? new BufferList() : new BufferList();
if (child.stdout) {
child.stdout.on("data", (data) => {
stdout.append(data);
if (onData) {
onData(data.toString());
}
});
}
if (child.stderr) {
child.stderr.on("data", (data) => {
stderr.append(data);
if (onData) {
onData(data.toString());
}
});
}
const promise = new Promise<BufferList>((resolve, reject) => {
child.on("error", reject);
child.on("close", (code) => {
if (code === 0) {
resolve(stdout);
} else {
const err = new Error(`child exited with code ${code}`) as Error & {
code: number;
stderr: BufferList;
stdout: BufferList;
};
err.code = code || -1;
err.stderr = stderr;
err.stdout = stdout;
reject(err);
}
});
}) as Promise<BufferList> & { child: ChildProcess };
promise.child = child;
return promise;
};