Function runGitAsync

packages/shared/workspace-status.ts:74–124

(cwd: string, args: string[])

}

function runGitAsync(cwd: string, args: string[]): Promise<GitResult> {
	return new Promise((resolveResult) => {
		const child = spawn("git", ["--no-optional-locks", "-C", cwd, ...args], {
			stdio: ["ignore", "pipe", "pipe"],
		});
		let stdout = "";
		let stderr = "";
		let stdoutBytes = 0;
		let stderrBytes = 0;
		let settled = false;
		let timeout: ReturnType<typeof setTimeout> | null = null;

		const finish = (result: GitResult) => {
			if (settled) return;
			settled = true;
			if (timeout) clearTimeout(timeout);
			resolveResult(result);
		};

		const timeoutMs = getGitTimeoutMs();
		timeout = setTimeout(() => {
			child.kill("SIGKILL");
			finish({ ok: false, error: `git timed out after ${timeoutMs}ms` });
		}, timeoutMs);

		child.stdout.setEncoding("utf8");
		child.stderr.setEncoding("utf8");
		child.stdout.on("data", (chunk: string) => {
			stdoutBytes += Buffer.byteLength(chunk);
			if (stdoutBytes > GIT_MAX_BUFFER) {
				child.kill();
				finish({ ok: false, error: `git stdout exceeded ${GIT_MAX_BUFFER} bytes` });
				return;
			}
			stdout += chunk;
		});
		child.stderr.on("data", (chunk: string) => {
			stderrBytes += Buffer.byteLength(chunk);
			if (stderrBytes <= GIT_MAX_BUFFER) stderr += chunk;
		});
		child.on("error", (error) => finish({ ok: false, error: error.message }));
		child.on("close", (status) => {
			if (status === 0) {
				finish({ ok: true, stdout });
				return;
			}
			const message = stderr.trim() || `git exited with status ${status ?? "unknown"}`;
			finish({ ok: false, error: message });
		});
	});
}

function resolveGitPath(cwd: string, value: string): string {
	return isAbsolute(value) ? value : resolve(cwd, value);