Method constructor

packages/ai-client/src/chat-client.ts:170–436

(options: ChatClientOptions<TTools, TContext>)

  }

  constructor(options: ChatClientOptions<TTools, TContext>) {
    this.uniqueId = options.id || this.generateUniqueId('chat')
    this.threadId = options.threadId || this.generateUniqueId('thread')
    if (options.persistence) {
      this.persistor = new ChatPersistor(
        options.persistence,
        this.uniqueId,
        (messages) => this.processor.setMessages(messages),
      )
    }
    // Both `body` (deprecated) and `forwardedProps` populate the AG-UI
    // `RunAgentInput.forwardedProps` wire field. They are stored
    // separately so `updateOptions` can replace one without touching the
    // other; the merge happens at send time, with `forwardedProps`
    // winning on key collision.
    this.bodyOption = options.body || {}
    this.forwardedPropsOption = options.forwardedProps || {}
    this.context = options.context
    this.connection = normalizeConnectionAdapter(resolveTransport(options))

    // Build client tools map
    this.clientToolsRef = { current: new Map() }
    if (options.tools) {
      for (const tool of options.tools) {
        this.clientToolsRef.current.set(tool.name, tool)
      }
    }

    this.devtoolsBridge = (
      options.devtoolsBridgeFactory ?? createNoOpChatDevtoolsBridge
    )(this.buildDevtoolsBridgeOptions(options.devtools))
    this.events = this.devtoolsBridge.events

    this.callbacksRef = {
      current: {
        onResponse: options.onResponse || (() => {}),
        onChunk: options.onChunk || (() => {}),
        onFinish: options.onFinish || (() => {}),
        onError: options.onError || (() => {}),
        onMessagesChange: options.onMessagesChange || (() => {}),
        onLoadingChange: options.onLoadingChange || (() => {}),
        onErrorChange: options.onErrorChange || (() => {}),
        onStatusChange: options.onStatusChange || (() => {}),
        onSubscriptionChange: options.onSubscriptionChange || (() => {}),
        onConnectionStatusChange:
          options.onConnectionStatusChange || (() => {}),
        onSessionGeneratingChange:
          options.onSessionGeneratingChange || (() => {}),
        onCustomEvent: options.onCustomEvent || (() => {}),
      },
    }

    // Create StreamProcessor with event handlers.
    // Use conditional spreads so we don't pass `undefined` into
    // `StreamProcessorOptions` fields under `exactOptionalPropertyTypes`.
    const persistedMessages = this.persistor?.readInitial()
    const initialMessages = Array.isArray(persistedMessages)
      ? persistedMessages