dokploy/apps/dokploy/server/utils/process/spawnAsync.ts

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(`${stderr.toString()}`) 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;
};