{"version":3,"sources":["../../src/llm/async_toolset.ts"],"sourcesContent":["// SPDX-FileCopyrightText: 2026 LiveKit, Inc.\n//\n// SPDX-License-Identifier: Apache-2.0\nimport type { AgentActivity } from '../voice/agent_activity.js';\nimport type { AgentSession } from '../voice/agent_session.js';\nimport { ToolExecutor, type ToolHandlingOptions } from '../voice/tool_executor.js';\nimport { Toolset, type ToolsetCreateOptions } from './tool_context.js';\n\nexport interface AsyncToolsetCreateOptions extends ToolsetCreateOptions {\n  toolHandling?: ToolHandlingOptions;\n}\n\nexport class AsyncToolset extends Toolset {\n  readonly _executor = new ToolExecutor({ owningActivity: null });\n  private readonly asyncToolOptionsOverride?: ToolHandlingOptions['asyncOptions'];\n\n  private constructor({ id, tools, toolHandling }: AsyncToolsetCreateOptions) {\n    super({ id, tools });\n    this.asyncToolOptionsOverride = toolHandling?.asyncOptions;\n  }\n\n  static override create(options: AsyncToolsetCreateOptions): AsyncToolset {\n    return new AsyncToolset(options);\n  }\n\n  _attachActivity({\n    activity,\n    session,\n  }: {\n    activity: AgentActivity | null;\n    session: AgentSession;\n  }): void {\n    this._executor.setOwningActivity(\n      activity as unknown as Parameters<ToolExecutor['setOwningActivity']>[0],\n    );\n    if (this.asyncToolOptionsOverride) {\n      this._executor.setToolOptions(this.asyncToolOptionsOverride);\n      return;\n    }\n    const activityOptions = activity?.agent?._asyncToolOptions;\n    if (activityOptions) {\n      this._executor.setToolOptions(activityOptions);\n      return;\n    }\n    const sessionOptions = session._asyncToolOptions;\n    if (sessionOptions) {\n      this._executor.setToolOptions(sessionOptions);\n    }\n  }\n\n  override async aclose(): Promise<void> {\n    await super.aclose();\n    await this._executor.drain();\n    await this._executor.aclose();\n  }\n}\n"],"mappings":";;;;;;;;;;;;;;;;;;AAAA;AAAA;AAAA;AAAA;AAAA;AAKA,2BAAuD;AACvD,0BAAmD;AAM5C,MAAM,qBAAqB,4BAAQ;AAAA,EAC/B,YAAY,IAAI,kCAAa,EAAE,gBAAgB,KAAK,CAAC;AAAA,EAC7C;AAAA,EAET,YAAY,EAAE,IAAI,OAAO,aAAa,GAA8B;AAC1E,UAAM,EAAE,IAAI,MAAM,CAAC;AACnB,SAAK,2BAA2B,6CAAc;AAAA,EAChD;AAAA,EAEA,OAAgB,OAAO,SAAkD;AACvE,WAAO,IAAI,aAAa,OAAO;AAAA,EACjC;AAAA,EAEA,gBAAgB;AAAA,IACd;AAAA,IACA;AAAA,EACF,GAGS;AA/BX;AAgCI,SAAK,UAAU;AAAA,MACb;AAAA,IACF;AACA,QAAI,KAAK,0BAA0B;AACjC,WAAK,UAAU,eAAe,KAAK,wBAAwB;AAC3D;AAAA,IACF;AACA,UAAM,mBAAkB,0CAAU,UAAV,mBAAiB;AACzC,QAAI,iBAAiB;AACnB,WAAK,UAAU,eAAe,eAAe;AAC7C;AAAA,IACF;AACA,UAAM,iBAAiB,QAAQ;AAC/B,QAAI,gBAAgB;AAClB,WAAK,UAAU,eAAe,cAAc;AAAA,IAC9C;AAAA,EACF;AAAA,EAEA,MAAe,SAAwB;AACrC,UAAM,MAAM,OAAO;AACnB,UAAM,KAAK,UAAU,MAAM;AAC3B,UAAM,KAAK,UAAU,OAAO;AAAA,EAC9B;AACF;","names":[]}