Method chatStream

packages/ai-codex/src/adapters/text.ts:201–354

(
    options: TextOptions<CodexTextProviderOptions>,
  )

  }

  async *chatStream(
    options: TextOptions<CodexTextProviderOptions>,
  ): AsyncIterable<StreamChunk> {
    const { logger } = options
    let bridge: HostToolBridge | undefined
    const tempFiles: Array<string> = []
    let cleanupSandbox: SandboxHandle | undefined
    const runId = options.runId ?? this.generateId()
    const threadId = options.threadId ?? this.generateId()
    // Surfaces custom events from bridged tools (e.g. code mode console logs)
    // on this run's live output stream.
    const channel = createBridgeEventChannel({
      model: this.model,
      threadId,
      runId,
    })
    try {
      const sandbox = this.sandboxFrom(options)
      cleanupSandbox = sandbox
      const cwd = this.workdir(options)

      // Project declarative workspace inputs (MCP/skills) into codex's native
      // format. Re-runs each call so rotated secrets re-apply; idempotent ops
      // are marker-gated inside the projector.
      const projection = options.capabilities
        ? getWorkspaceProjection(options.capabilities, { optional: true })
        : undefined
      if (projection) await projectCodexWorkspace(sandbox, projection)

      if (options.tools && options.tools.length > 0) {
        const provisioner =
          (options.capabilities
            ? getToolBridgeProvisioner(options.capabilities, { optional: true })
            : undefined) ?? nodeHttpBridgeProvisioner
        bridge = await provisioner.provision(options.tools, {
          provider: sandbox.provider,
          context: options.context,
          emitCustomEvent: channel.emitCustomEvent,
          ...(options.abortController?.signal
            ? { signal: options.abortController.signal }
            : {}),
        })
      }

      const { prompt, resume } = buildPrompt(
        options.messages,
        options.modelOptions?.sessionId,
      )
      const systemPrompts = normalizeSystemPrompts(options.systemPrompts)
        .map((p) => p.content)
        .filter((c) => c.trim() !== '')
      const fullPrompt =
        systemPrompts.length > 0
          ? `${systemPrompts.join('\n\n')}\n\n${prompt}`
          : prompt

      const policy = options.capabilities
        ? getSandboxPolicy(options.capabilities, { optional: true })