src/shared/utils/exec.ts - main - outbreak/kilocode

src/shared/utils/exec.ts
171 строка4 KB
John Fawcett
Fix windows spawning cmd.exe windows
15 дек 2025, 20:30
15 дек 2025, 20:30625561f
// kilocode_change - new file
import { spawn } from "child_process"
import { Readable } from "stream"

import { chunksToLinesAsync, combine } from "./iterable"

import type { ChildProcess } from "child_process"

export interface ExecOptions {
	/**
	 * command to execute
	 */
	cmd: string

	/**
	 * where to execute the command
	 */
	cwd?: string

	/**
	 * what is being executed that should be logged for
	 * the user when it fails.eg. "running user command"
	 */
	context?: string

	/**
	 * the user that should run the command
	 */
	uid?: number

	/**
	 * environment variables
	 */
	env?: Record<string, string | undefined>
}

/**
 * Returns a childProcess, piping stdin to the process
 */
export async function execWithStdin({ cmd, cwd, uid, env }: ExecOptions): Promise<ChildProcess> {
	const proc = spawn(cmd, {
		cwd,
		uid,
		shell: true,
		windowsHide: true,
		stdio: ["pipe", 1, 2],
		env,
	})
	return proc
}

/**
 * Executes a shell command, piping all stdio to the current process
 */
export async function exec({ cmd, cwd, context, uid, env }: ExecOptions): Promise<void> {
	const proc = spawn(cmd, {
		cwd,
		uid,
		shell: true,
		windowsHide: true,
		stdio: ["inherit", "inherit", "inherit"],
		env,
	})

	await onChildProcessExit(proc, context)
}

/**
 * Just like exec, except it is a generator which yields stdout lines
 */
export async function* execGetLines({
	cmd,
	cwd,
	context,
	uid,
	env,
}: ExecOptions): AsyncGenerator<string, void, unknown> {
	const proc = spawn(cmd, {
		cwd,
		uid,
		shell: true,
		windowsHide: true,
		stdio: ["ignore", "pipe", "inherit"],
		env,
	})

	const exit = onChildProcessExit(proc, context)

	try {
		for await (const line of chunksToLinesAsync(proc.stdout)) {
			yield line
		}
	} finally {
		// CRITICAL: Kill the process if the loop breaks, returns, or throws.
		if (!proc.killed) {
			proc.kill()
		}
	}

	await exit
}

/**
 * Just like exec, except it is a generator which yields stdout lines
 */
export async function* execGetLinesStdoutStderr({
	cmd,
	cwd,
	context,
	uid,
	env,
}: ExecOptions): AsyncGenerator<WithIOType, void, unknown> {
	const proc = spawn(cmd, {
		cwd,
		uid,
		shell: true,
		windowsHide: true,
		stdio: ["ignore", "pipe", "pipe"],
		env,
	})

	// Transform stdout/stderr into a stream of lines, then wrap the lines in
	// objects that say where the lines came from (either stdout | stderr)
	const stdout = withIOType("stdout", chunksToLinesAsync(proc.stdout))
	const stderr = withIOType("stderr", chunksToLinesAsync(proc.stderr))
	const exit = onChildProcessExit(proc, context)

	try {
		// Yield each line object from the combined iterable from stdout/stderr
		for await (const line of combine(stdout, stderr)) {
			yield line
		}
	} finally {
		// CRITICAL: Kill the process if the loop breaks, returns, or throws.
		if (!proc.killed) {
			proc.kill()
		}
	}

	await exit
}

export type WithIOType = {
	type: "stdout" | "stderr"
	line: string
}

function withIOType(type: WithIOType["type"], source: AsyncIterable<string>): AsyncIterable<WithIOType> {
	return Readable.from(source).map((line): WithIOType => ({ type, line }))
}

export function onChildProcessExit(childProcess: ChildProcess, context?: string): Promise<void> {
	return new Promise((resolve, reject) => {
		childProcess.once("exit", (code: number, _signal: string) => {
			if (code === 0) {
				resolve(undefined)
			} else {
				if (context) {
					reject(new ExecError(`Error while ${context}. Exited with error code: ${code}`))
				} else {
					reject(new Error(`Exit with error code: ${code}`))
				}
			}
		})
		childProcess.once("error", (err: Error) => {
			reject(err)
		})
	})
}

export class ExecError extends Error {}