Class Transport

node/src/transport.ts:106–349

}

export class Transport {
  #child?: ChildProcessWithoutNullStreams;
  #stdin?: Writable;
  #pending = new Map<number, Pending>();
  #nextId = 1;
  #closed = false;
  #starting?: Promise<void>;

  constructor(
    private readonly cfg: ClientConfig,
    private readonly binPath: string,
  ) {}

  /**
   * @internal Test seam: drive the demux off a provided stdin/stdout pair
   * instead of spawning a binary. Used by the transport unit tests, mirroring
   * the Python test that injects a fake process.
   */
  attachStreamsForTest(stdin: Writable, stdout: Readable): void {
    this.#stdin = stdin;
    this.#starting = Promise.resolve();
    this.#child = { stdin } as unknown as ChildProcessWithoutNullStreams;
    this.#startReader(stdout);
  }

  // -- lifecycle ---------------------------------------------------------

  private async ensureStarted(): Promise<void> {
    if (this.#child) return;
    if (this.#starting) return this.#starting;
    this.#starting = this.#spawn();
    try {
      await this.#starting;
    } finally {
      this.#starting = undefined;
    }
  }

  async #spawn(): Promise<void> {
    const child = spawn(this.binPath, ["--stdio"], {
      stdio: ["pipe", "pipe", "pipe"],
      env: {
        ...process.env,
        CMDOP_TOKEN: this.cfg.token,
        CMDOP_BASE_URL: this.cfg.baseUrl,
        // Django platform plane (skills) — separate credential + base URL.
        CMDOP_API_BASE_URL: this.cfg.apiBaseUrl,
        ...(this.cfg.apiKey ? { CMDOP_API_KEY: this.cfg.apiKey } : {}),
      },
      windowsHide: true,
    });
    this.#child = child;
    this.#stdin = child.stdin;

    // stderr is NOT part of the protocol — drain it so it never blocks/corrupts
    // the pipe (the core logs to a file when CMDOP_DEBUG=1).
    child.stderr.on("data", () => {});