Method start

packages/e2e-tests/src/pi-runner/rpc-client.ts:223–263

()

  }

  async start(): Promise<void> {
    if (this.process) throw new Error("Pi RPC client already started");
    writeConfigs(this.env, this.options);

    this.process = spawn(
      "bun",
      [
        PI_CLI,
        "--mode",
        "rpc",
        "--no-extensions",
        "--extension",
        this.env.pluginDir,
        "--no-skills",
        "--no-prompt-templates",
        "--no-themes",
        "--model",
        "anthropic/claude-haiku-4-5",
        "--api-key",
        "test-key-not-real",
      ],
      { cwd: this.env.workdir, env: childEnv(this.env), stdio: ["pipe", "pipe", "pipe"] },
    );

    this.process.stderr?.on("data", (chunk: Buffer) => {
      this.stderr += chunk.toString();
    });
    this.stopReadingStdout = attachStrictJsonlReader(this.process.stdout!, (line) => {
      this.protocol.dispatchLine(line);
    });
    this.process.once("exit", (code, signal) => {
      this.protocol.rejectPending(
        new Error(`Pi RPC process exited with code ${code ?? "null"} signal ${signal ?? "null"}\n${this.stderr}`),
      );
    });

    await Bun.sleep(100);
    if (this.process.exitCode !== null) {
      throw new Error(`Pi RPC process exited during startup with code ${this.process.exitCode}\n${this.stderr}`);
    }
  }

  onEvent(listener: (event: PiRpcEvent) => void): () => void {
    return this.protocol.onEvent(listener);