Method initializeInput

src/cli/remoteIO.ts:297–324

(
    initialPrompt: AsyncIterable<string> | undefined,
    refreshHeaders: () => Record<string, string>,
  )

  }

  private async initializeInput(
    initialPrompt: AsyncIterable<string> | undefined,
    refreshHeaders: () => Record<string, string>,
  ): Promise<void> {
    if (this.shouldReplayHistoricalSessionEvents) {
      await this.hydrateHistoricalSessionEvents(refreshHeaders)
    }

    if (initialPrompt) {
      // Convert the initial prompt to the input stream format.
      // Chunks from stdin may already contain trailing newlines, so strip
      // them before appending our own to avoid double-newline issues that
      // cause structuredIO to parse empty lines. String() handles both
      // string chunks and Buffer objects from process.stdin.
      const stream = this.inputStream
      void (async () => {
        for await (const chunk of initialPrompt) {
          stream.write(String(chunk).replace(/\n$/, '') + '\n')
        }
      })()
    } else if (!this.shouldReplayHistoricalSessionEvents) {
      await this.hydrateHistoricalSessionEvents(refreshHeaders)
    }

    // Start connection only after all callbacks are wired (setOnData above,
    // setOnEvent inside new CCRClient() when CCR v2 is enabled).
    void this.transport.connect()
  }

  private async hydrateHistoricalSessionEvents(
    refreshHeaders: () => Record<string, string>,