Function execHookCommand

src/core/hooks.ts:392–463

Spawn a hook command, pipe `input` to its stdin, and collect its output.

(
	command: string,
	input: string,
	timeoutMs: number,
	cwd: string,
	env: NodeJS.ProcessEnv,
	signal?: AbortSignal,
)

/** Spawn a hook command, pipe `input` to its stdin, and collect its output. */
function execHookCommand(
	command: string,
	input: string,
	timeoutMs: number,
	cwd: string,
	env: NodeJS.ProcessEnv,
	signal?: AbortSignal,
): Promise<RawHookOutput> {
	return new Promise((resolve) => {
		let settled = false
		let timedOut = false
		let stdout = ""
		let stderr = ""

		const child = spawn(getShell(), getShellRunArgs(command), {
			cwd,
			env,
			stdio: ["pipe", "pipe", "pipe"],
			windowsVerbatimArguments: process.platform === "win32",
		})

		const onAbort = () => child.kill("SIGTERM")
		let killTimer: ReturnType<typeof setTimeout> | undefined
		const timer = setTimeout(() => {
			timedOut = true
			child.kill("SIGTERM")
			// Escalate to SIGKILL if SIGTERM is ignored; unref'd so this never
			// keeps the process alive on its own.
			killTimer = setTimeout(() => child.kill("SIGKILL"), 2000)
			killTimer.unref?.()
		}, timeoutMs)
		timer.unref?.()

		const finish = (code: number) => {
			if (settled) return
			settled = true
			clearTimeout(timer)
			if (killTimer) clearTimeout(killTimer)
			signal?.removeEventListener("abort", onAbort)
			resolve({ stdout, stderr, code, timedOut })
		}

		child.stdout.setEncoding("utf8")
		child.stderr.setEncoding("utf8")
		child.stdout.on("data", (d: string) => {
			if (stdout.length < MAX_HOOK_OUTPUT_CHARS) stdout += d
		})
		child.stderr.on("data", (d: string) => {
			if (stderr.length < MAX_HOOK_OUTPUT_CHARS) stderr += d
		})

		child.on("error", (error) => {
			stderr += (stderr ? "\n" : "") + (error as Error).message
			finish(1)
		})
		child.on("close", (code) => finish(code ?? (timedOut ? 124 : 0)))

		if (signal) {