Method spawn

packages/ai/providers/pi-sdk-node.ts:53–99

(piPath: string, cwd: string)

	private _alive = false;

	async spawn(piPath: string, cwd: string): Promise<void> {
		const commandPath = resolveWindowsCommandShim(piPath);
		const command =
			buildWindowsCommandScriptSpawnCommand(commandPath, ["--mode", "rpc"]) ?? [
				commandPath,
				"--mode",
				"rpc",
			];
		let proc: ChildProcess;
		try {
			const [file, ...args] = command;
			proc = spawn(file, args, {
				cwd,
				stdio: ["pipe", "pipe", "pipe"],
			});
		} catch (err) {
			const error = err instanceof Error ? err : new Error(String(err));
			this.handleProcessEnd(error);
			throw error;
		}

		this.proc = proc;
		proc.once("exit", () => {
			this.handleProcessEnd(new Error("Pi process exited unexpectedly"));
		});

		await new Promise<void>((resolve, reject) => {
			const cleanup = () => {
				proc.off("spawn", onSpawn);
				proc.off("error", onError);
			};
			const onSpawn = () => {
				cleanup();
				this._alive = true;
				this.readStream();
				resolve();
			};
			const onError = (err: Error) => {
				cleanup();
				this.handleProcessEnd(err);
				reject(err);
			};

			proc.once("spawn", onSpawn);
			proc.once("error", onError);
		});
	}

	private handleProcessEnd(error: Error): void {
		if (!this.proc && this.pendingRequests.size === 0) return;