{"version":3,"sources":["../src/worker.ts","../../node_modules/.pnpm/tsup@8.4.0_@microsoft+api-extractor@7.58.12_@types+node@22.19.1__postcss@8.5.23_tsx@4.23.1_typescript@5.9.3/node_modules/tsup/assets/cjs_shims.js"],"sourcesContent":["// SPDX-FileCopyrightText: 2024 LiveKit, Inc.\n//\n// SPDX-License-Identifier: Apache-2.0\nimport type { JobAssignment, JobTermination, TrackSource } from '@livekit/protocol';\nimport {\n type AvailabilityRequest,\n JobType,\n ParticipantPermission,\n ServerMessage,\n WorkerMessage,\n WorkerStatus,\n} from '@livekit/protocol';\nimport { type Throws, ThrowsPromise } from '@livekit/throws-transformer/throws';\nimport type { ParticipantInfo } from 'livekit-server-sdk';\nimport { AccessToken, RoomServiceClient } from 'livekit-server-sdk';\nimport { EventEmitter } from 'node:events';\nimport { availableParallelism } from 'node:os';\nimport { extname } from 'node:path';\nimport { WebSocket } from 'ws';\nimport { APIStatusError } from './_exceptions.js';\nimport { ATTRIBUTE_AGENT_NAME } from './constants.js';\nimport { getCpuMonitor } from './cpu.js';\nimport { HTTPServer } from './http_server.js';\nimport { _getLocalInferenceModule } from './inference/_warmup.js';\nimport { EOT_INFERENCE_METHOD } from './inference/eot/runner.js';\nimport { InferenceRunner } from './inference_runner.js';\nimport { InferenceProcExecutor } from './ipc/inference_proc_executor.js';\nimport { ProcPool } from './ipc/proc_pool.js';\nimport type { JobAcceptArguments, JobProcess, RunningJobInfo } from './job.js';\nimport { JobRequest } from './job.js';\nimport { DEFAULT_SESSION_END_TIMEOUT, validateSessionEndTimeout } from './job_lifecycle.js';\nimport { log } from './log.js';\nimport {\n type EventLoopMonitor,\n startMonitoring,\n stopMonitoring,\n} from './telemetry/loop_monitor.js';\nimport { Future, rejectOnAbort } from './utils.js';\nimport { version } from './version.js';\n\nconst MAX_RECONNECT_ATTEMPTS = 10;\nconst ASSIGNMENT_TIMEOUT = 7.5 * 1000;\nconst UPDATE_LOAD_INTERVAL = 2.5 * 1000;\nconst DRAIN_TIMEOUT = 60 * 60 * 1000;\nconst PROJECT_TYPE = 'nodejs';\n// Mirrors CurrentWorkerProtocol in livekit/protocol. LiveKit Cloud reads this off\n// the /worker endpoint to decide whether the SDK supports agent deployments; a\n// worker that omits it is treated as legacy and registered without its deployment.\nconst WORKER_PROTOCOL_VERSION = 1;\n\nlet localEotRunnerRegistered = false;\n/**\n * Register the local audio-EOT inference runner so it runs in the shared\n * inference process. Idempotent and guarded by native-binding availability;\n * a no-op (with a one-time warning) when `@livekit/local-inference` can't be\n * loaded so the worker still starts on unsupported platforms.\n */\nfunction maybeRegisterLocalEotRunner(): void {\n if (localEotRunnerRegistered) return;\n localEotRunnerRegistered = true;\n if (InferenceRunner.registeredRunners[EOT_INFERENCE_METHOD]) return;\n if (_getLocalInferenceModule() === undefined) {\n log().warn(\n '@livekit/local-inference native binding unavailable; local audio EOT disabled ' +\n '(predictions will degrade to a positive default). cloud EOT and other turn ' +\n 'detection modes are unaffected.',\n );\n return;\n }\n const ext = extname(import.meta.url); // '.js' (built) or '.ts' (tsx/ts-node)\n InferenceRunner.registerRunner(\n EOT_INFERENCE_METHOD,\n new URL(`./inference/eot/runner${ext}`, import.meta.url).toString(),\n );\n}\n\nclass Default {\n static loadThreshold(production: boolean): number {\n if (production) {\n return 0.7;\n } else {\n return Infinity;\n }\n }\n\n static numIdleProcesses(production: boolean): number {\n if (production) {\n return Math.min(availableParallelism(), 4);\n } else {\n return 0;\n }\n }\n\n static port(production: boolean): number {\n if (production) {\n return 8081;\n } else {\n return 0;\n }\n }\n}\n\n/** Necessary credentials not provided and not found in an appropriate environment variable. */\nexport class MissingCredentialsError extends Error {\n constructor(msg?: string) {\n super(msg);\n Object.setPrototypeOf(this, new.target.prototype);\n }\n}\n\n/** Worker did not run as expected. */\nexport class WorkerError extends Error {\n constructor(msg?: string) {\n super(msg);\n Object.setPrototypeOf(this, new.target.prototype);\n }\n}\n\n/** @internal */\nexport const defaultInitializeProcessFunc = (_: JobProcess) => _;\nconst defaultRequestFunc = async (ctx: JobRequest) => {\n await ctx.accept();\n};\n\nconst cpuMonitor = getCpuMonitor();\n\n// eslint-disable-next-line @typescript-eslint/no-unused-vars\nconst defaultCpuLoad = async (_worker: AgentServer): Promise => {\n return cpuMonitor.cpuPercent(UPDATE_LOAD_INTERVAL);\n};\n\n/** Participant permissions to pass to every agent spun up by this worker. */\nexport class WorkerPermissions {\n canPublish: boolean;\n canSubscribe: boolean;\n canPublishData: boolean;\n canUpdateMetadata: boolean;\n canPublishSources: TrackSource[];\n hidden: boolean;\n\n constructor(\n canPublish = true,\n canSubscribe = true,\n canPublishData = true,\n canUpdateMetadata = true,\n canPublishSources: TrackSource[] = [],\n hidden = false,\n ) {\n this.canPublish = canPublish;\n this.canSubscribe = canSubscribe;\n this.canPublishData = canPublishData;\n this.canUpdateMetadata = canUpdateMetadata;\n this.canPublishSources = canPublishSources;\n this.hidden = hidden;\n }\n}\n\n/**\n * Data class describing worker behaviour.\n *\n * @remarks\n * The Agents framework provides sane worker defaults, and works out-of-the-box with no tweaking\n * necessary. The only mandatory parameter is `agent`, which points to the entry function.\n *\n * This class is mostly useful in conjunction with {@link cli.runApp}.\n */\nexport class ServerOptions {\n agent: string;\n requestFunc: (job: JobRequest) => Promise;\n loadFunc: (worker: AgentServer) => Promise;\n loadThreshold: number;\n numIdleProcesses: number;\n drainTimeout: number;\n shutdownProcessTimeout: number;\n /**\n * Maximum time to wait for `onSessionEnd`. Defaults to five minutes.\n */\n sessionEndTimeout: number;\n initializeProcessTimeout: number;\n permissions: WorkerPermissions;\n agentName: string;\n agentNameIsEnv: boolean;\n serverType: JobType;\n maxRetry: number;\n wsURL: string;\n apiKey?: string;\n apiSecret?: string;\n workerToken?: string;\n host: string;\n port: number;\n logLevel: string;\n production: boolean;\n simulation: boolean;\n jobMemoryWarnMB: number;\n jobMemoryLimitMB: number;\n\n /** @param options - Worker options */\n constructor({\n agent,\n requestFunc = defaultRequestFunc,\n loadFunc = defaultCpuLoad,\n loadThreshold = undefined,\n numIdleProcesses = undefined,\n drainTimeout = DRAIN_TIMEOUT,\n shutdownProcessTimeout = 60 * 1000,\n sessionEndTimeout = DEFAULT_SESSION_END_TIMEOUT,\n initializeProcessTimeout = 10 * 1000,\n permissions = new WorkerPermissions(),\n agentName = '',\n agentNameIsEnv = undefined,\n serverType = JobType.JT_ROOM,\n maxRetry = MAX_RECONNECT_ATTEMPTS,\n wsURL = 'ws://localhost:7880',\n apiKey = undefined,\n apiSecret = undefined,\n workerToken = undefined,\n host = '0.0.0.0',\n port = undefined,\n logLevel = 'info',\n production = false,\n simulation = false,\n jobMemoryWarnMB = 1000,\n jobMemoryLimitMB = 0,\n }: {\n /**\n * Path to a file that has {@link Agent} as a default export, dynamically imported later for\n * entrypoint and prewarm functions\n */\n agent: string;\n requestFunc?: (job: JobRequest) => Promise;\n /** Called to determine the current load of the worker. Should return a value between 0 and 1. */\n loadFunc?: (worker: AgentServer) => Promise;\n /** When the load exceeds this threshold, the worker will be marked as unavailable. */\n loadThreshold?: number;\n numIdleProcesses?: number;\n /** Number of milliseconds to wait for current jobs to finish upon shutdown. */\n drainTimeout?: number;\n shutdownProcessTimeout?: number;\n /**\n * Maximum number of milliseconds to wait for `onSessionEnd`.\n */\n sessionEndTimeout?: number;\n initializeProcessTimeout?: number;\n permissions?: WorkerPermissions;\n /**\n * Set agentName to enable explicit dispatch. When explicit dispatch is enabled, jobs will not\n * be dispatched to rooms automatically. Instead, you can either specify the agent(s) to be\n * dispatched in the end-user's token, or use the AgentDispatch.createDispatch API.\n *\n * By default it uses `LIVEKIT_AGENT_NAME` from environment.\n */\n agentName?: string;\n /**\n * Internal flag indicating that `agentName` was resolved from `LIVEKIT_AGENT_NAME`. Forwarded\n * through ServerOptions re-construction (e.g. cli.ts spread) so the env-source signal isn't\n * lost.\n */\n agentNameIsEnv?: boolean;\n serverType?: JobType;\n maxRetry?: number;\n wsURL?: string;\n apiKey?: string;\n apiSecret?: string;\n workerToken?: string;\n host?: string;\n port?: number;\n logLevel?: string;\n production?: boolean;\n simulation?: boolean;\n jobMemoryWarnMB?: number;\n jobMemoryLimitMB?: number;\n }) {\n this.agent = agent;\n if (!this.agent) {\n throw new Error('No Agent file was passed to the worker');\n }\n this.requestFunc = requestFunc;\n this.loadFunc = loadFunc;\n this.loadThreshold = simulation ? Infinity : loadThreshold || Default.loadThreshold(production);\n this.numIdleProcesses = numIdleProcesses || Default.numIdleProcesses(production);\n this.drainTimeout = drainTimeout;\n this.shutdownProcessTimeout = shutdownProcessTimeout;\n this.sessionEndTimeout = validateSessionEndTimeout(sessionEndTimeout);\n this.initializeProcessTimeout = initializeProcessTimeout;\n this.permissions = permissions;\n // agentNameIsEnv may be passed explicitly when ServerOptions is re-constructed (e.g.\n // cli.ts spreads an existing ServerOptions instance), so prefer it when defined.\n if (process.env.LIVEKIT_AGENT_NAME_OVERRIDE) {\n // Highest priority: `lk simulate` sets this to force the worker to register\n // under the agent name it dispatches to, overriding any configured agentName.\n this.agentName = process.env.LIVEKIT_AGENT_NAME_OVERRIDE;\n this.agentNameIsEnv = agentNameIsEnv ?? true;\n } else if (agentName) {\n this.agentName = agentName;\n this.agentNameIsEnv = agentNameIsEnv ?? false;\n } else if (process.env.LIVEKIT_AGENT_NAME) {\n this.agentName = process.env.LIVEKIT_AGENT_NAME;\n this.agentNameIsEnv = agentNameIsEnv ?? true;\n } else {\n this.agentName = '';\n this.agentNameIsEnv = agentNameIsEnv ?? false;\n }\n this.serverType = serverType;\n this.maxRetry = maxRetry;\n this.wsURL = wsURL;\n this.apiKey = apiKey;\n this.apiSecret = apiSecret;\n this.workerToken = workerToken;\n this.host = host;\n this.port = port || Default.port(production);\n this.logLevel = logLevel;\n this.production = production;\n this.simulation = simulation;\n this.jobMemoryWarnMB = jobMemoryWarnMB;\n this.jobMemoryLimitMB = jobMemoryLimitMB;\n }\n}\n\nclass PendingAssignment {\n promise = new ThrowsPromise((resolve) => {\n this.resolve = resolve; // this is how JavaScript lets you resolve promises externally\n });\n resolve(arg: JobAssignment) {\n arg; // useless call to counteract TypeScript E6133\n }\n}\n\n/**\n * Central orchestrator for all processes and job requests.\n *\n * @remarks\n * For most usecases, Worker should not be initialized or handled directly; you should instead call\n * for its creation through {@link cli.runApp}. This could, however, be useful in situations where\n * you don't have access to a command line, such as a headless program, or one that uses Agents\n * behind a wrapper.\n */\nexport class AgentServer {\n #opts: ServerOptions;\n #procPool: ProcPool;\n\n #deployment = process.env.LIVEKIT_AGENT_DEPLOYMENT || '';\n #id = 'unregistered';\n #closed = true;\n #draining = false;\n #connecting = false;\n #tasks: Promise[] = [];\n #pending: { [id: string]: PendingAssignment } = {};\n #close = new Future();\n\n event = new EventEmitter();\n #session: WebSocket | undefined = undefined;\n #httpServer?: HTTPServer;\n #logger = log().child({ version });\n #inferenceExecutor?: InferenceProcExecutor;\n #loopMonitor?: EventLoopMonitor;\n\n /* @throws {@link MissingCredentialsError} if URL, API key or API secret are missing */\n constructor(opts: ServerOptions) {\n opts.wsURL = opts.wsURL || process.env.LIVEKIT_URL || '';\n opts.apiKey = opts.apiKey || process.env.LIVEKIT_API_KEY || '';\n opts.apiSecret = opts.apiSecret || process.env.LIVEKIT_API_SECRET || '';\n\n if (opts.wsURL === '')\n throw new MissingCredentialsError(\n 'URL is required: Set LIVEKIT_URL, run with --url, or pass wsURL in ServerOptions',\n );\n if (opts.apiKey === '')\n throw new MissingCredentialsError(\n 'API Key is required: Set LIVEKIT_API_KEY, run with --api-key, or pass apiKey in ServerOptions',\n );\n if (opts.apiSecret === '')\n throw new MissingCredentialsError(\n 'API Secret is required: Set LIVEKIT_API_SECRET, run with --api-secret, or pass apiSecret in ServerOptions',\n );\n\n if (opts.workerToken) {\n // Re-export into the environment so forked subprocesses inherit it (fork()\n // copies process.env by default). The inference-header code in the child reads\n // process.env.LIVEKIT_WORKER_TOKEN — see inference/utils.ts buildMetadataHeaders().\n // Mirrors Python worker.py, which sets os.environ before spawning job procs.\n process.env.LIVEKIT_WORKER_TOKEN = opts.workerToken;\n\n if (opts.loadFunc !== defaultCpuLoad) {\n this.#logger.warn(\n 'custom loadFunc is not supported when deploying to Cloud, using defaults',\n );\n opts.loadFunc = defaultCpuLoad;\n }\n const loadThreshold = Default.loadThreshold(opts.production);\n if (opts.loadThreshold !== loadThreshold) {\n this.#logger.warn(\n 'custom loadThreshold is not supported when deploying to Cloud, using defaults',\n );\n opts.loadThreshold = loadThreshold;\n }\n }\n\n // Register the local audio-EOT runner so it runs in the shared inference\n // process (loaded once per host, ~138 MB) instead of in every job worker.\n // Guarded by binding availability: on a platform where\n // `@livekit/local-inference` can't load, skip registration so the worker\n // still starts (local EOT then degrades to a positive-default prediction).\n maybeRegisterLocalEotRunner();\n\n this.#inferenceExecutor = InferenceProcExecutor.createIfNeeded();\n\n this.#procPool = new ProcPool({\n agent: opts.agent,\n numIdleProcesses: opts.numIdleProcesses,\n initializeTimeout: opts.initializeProcessTimeout,\n closeTimeout: opts.shutdownProcessTimeout,\n sessionEndTimeout: opts.sessionEndTimeout,\n inferenceExecutor: this.#inferenceExecutor,\n memoryWarnMB: opts.jobMemoryWarnMB,\n memoryLimitMB: opts.jobMemoryLimitMB,\n });\n\n this.#opts = opts;\n\n // Simulations run ephemeral workers side by side; a health endpoint on a fixed port would make\n // concurrent runs collide.\n if (!opts.simulation) {\n const healthCheck = () => {\n // Check if inference executor exists and is not alive\n if (this.#inferenceExecutor && !this.#inferenceExecutor.isAlive) {\n return { healthy: false, message: 'inference process not running' };\n }\n\n // Only healthy when fully connected with an active WebSocket\n if (\n this.#closed ||\n this.#connecting ||\n !this.#session ||\n this.#session.readyState !== WebSocket.OPEN\n ) {\n return { healthy: false, message: 'not connected to livekit' };\n }\n\n return { healthy: true, message: 'OK' };\n };\n\n const getWorkerInfo = () => ({\n agent_name: opts.agentName,\n agent_name_is_env: opts.agentNameIsEnv,\n deployment: this.#deployment,\n worker_type: JobType[opts.serverType],\n active_jobs: this.activeJobs.length,\n sdk_version: version,\n project_type: PROJECT_TYPE,\n protocol_version: WORKER_PROTOCOL_VERSION,\n });\n\n this.#httpServer = new HTTPServer(opts.host, opts.port, healthCheck, getWorkerInfo);\n }\n }\n\n /** @throws {@link WorkerError} if worker failed to connect or already running */\n async run() {\n if (!this.#closed) {\n throw new WorkerError('worker is already running');\n }\n\n if (this.#inferenceExecutor) {\n await this.#inferenceExecutor.start();\n await this.#inferenceExecutor.initialize();\n }\n\n this.#logger.info('starting worker');\n this.#closed = false;\n this.#loopMonitor = startMonitoring({ name: 'worker', emitSpans: false });\n this.#procPool.start();\n\n const workerWS = async () => {\n let retries = 0;\n this.#connecting = true;\n\n while (!this.#closed) {\n const url = new URL(this.#opts.wsURL);\n url.protocol = url.protocol.replace('http', 'ws');\n const token = new AccessToken(this.#opts.apiKey, this.#opts.apiSecret);\n token.addGrant({ agent: true });\n const jwt = await token.toJwt();\n const wsUrl = new URL(url + 'agent');\n if (this.#opts.workerToken) {\n wsUrl.searchParams.append('worker_token', this.#opts.workerToken);\n }\n this.#session = new WebSocket(wsUrl, {\n headers: { authorization: 'Bearer ' + jwt },\n });\n\n try {\n await new ThrowsPromise((resolve, reject) => {\n this.#session!.on('open', resolve);\n this.#session!.on('error', (error) => reject(error));\n this.#session!.on('close', (code) => reject(new Error(`WebSocket returned ${code}`)));\n });\n\n retries = 0;\n this.#logger.debug('connected to LiveKit server');\n await this.#runWS(this.#session);\n } catch (e: unknown) {\n if (this.#closed) return;\n if (retries >= this.#opts.maxRetry) {\n throw new WorkerError(\n `failed to connect to LiveKit server (${this.#opts.wsURL}) after ${retries} attempts: ${e}`,\n );\n }\n\n retries++;\n const delay = Math.min(retries * 2, 10);\n\n this.#logger.warn(\n { error: e, retry_count: retries, max_retry: this.#opts.maxRetry },\n `failed to connect to LiveKit server (${this.#opts.wsURL}), retrying in ${delay} seconds: (${retries}/${this.#opts.maxRetry})`,\n );\n\n await new ThrowsPromise((resolve) => setTimeout(resolve, delay * 1000));\n }\n }\n };\n\n const tasks = [workerWS()];\n if (this.#httpServer) {\n tasks.push(this.#httpServer.run());\n }\n try {\n await ThrowsPromise.all(tasks);\n this.#close.resolve();\n } catch (e) {\n if (!this.#close.done) {\n this.#close.reject(e instanceof Error ? e : new Error(String(e)));\n }\n throw e;\n }\n }\n\n get id(): string {\n return this.#id;\n }\n\n get activeJobs(): RunningJobInfo[] {\n return this.#procPool.processes\n .filter((proc) => proc.runningJob)\n .map((proc) => proc.runningJob!);\n }\n\n /** @throws {@link WorkerError} if worker did not drain in time */\n async drain(timeout?: number): Promise> {\n if (this.#draining) {\n return;\n }\n\n this.#logger.debug('draining worker');\n this.#draining = true;\n\n this.event.emit(\n 'worker_msg',\n new WorkerMessage({\n message: {\n case: 'updateWorker',\n value: {\n status: WorkerStatus.WS_FULL,\n },\n },\n }),\n );\n\n const joinJobs = async (): Promise> => {\n return ThrowsPromise.all(\n this.#procPool.processes.map((proc): Promise> => {\n if (!proc.runningJob) {\n proc.close();\n }\n return proc.join();\n }),\n );\n };\n\n const promises = [joinJobs()];\n\n const timeoutMs = timeout ?? this.#opts.drainTimeout;\n\n if (timeoutMs) {\n promises.push(\n rejectOnAbort(AbortSignal.timeout(timeoutMs)).catch(() => {\n throw new WorkerError('timed out draining');\n }),\n );\n }\n await ThrowsPromise.race(promises);\n }\n\n async simulateJob(roomName: string, participantIdentity?: string) {\n const client = new RoomServiceClient(this.#opts.wsURL, this.#opts.apiKey, this.#opts.apiSecret);\n const room = await client.createRoom({ name: roomName });\n let participant: ParticipantInfo | undefined = undefined;\n if (participantIdentity) {\n try {\n // TODO(AJS-269): resolve compatibility issue with node-sdk to remove the forced type casting\n participant = (await client.getParticipant(\n roomName,\n participantIdentity,\n )) as unknown as ParticipantInfo;\n } catch (e) {\n this.#logger.fatal(\n `participant with identity ${participantIdentity} not found in room ${roomName}`,\n );\n throw e;\n }\n }\n\n this.event.emit(\n 'worker_msg',\n new WorkerMessage({\n message: {\n case: 'simulateJob',\n value: {\n type: JobType.JT_PUBLISHER,\n room,\n participant,\n },\n },\n }),\n );\n }\n\n async #runWS(ws: WebSocket) {\n let closingWS = false;\n\n const send = (msg: WorkerMessage) => {\n if (closingWS) {\n this.event.off('worker_msg', send);\n return;\n }\n ws.send(msg.toBinary());\n };\n this.event.on('worker_msg', send);\n\n const close = new ThrowsPromise((resolve, reject) => {\n ws.addEventListener('close', (event) => {\n closingWS = true;\n if (!this.#closed) {\n reject(\n new APIStatusError({\n message: 'worker connection closed unexpectedly',\n options: {\n statusCode: event.code || -1,\n body: {\n code: event.code,\n reason: event.reason,\n wasClean: event.wasClean,\n },\n },\n }),\n );\n return;\n }\n resolve();\n });\n });\n\n ws.addEventListener('error', (event) => {\n this.#logger.error('worker error:', event.message);\n });\n\n ws.addEventListener('message', (event) => {\n let data: Uint8Array;\n if (event.data instanceof Uint8Array) {\n data = event.data;\n } else if (event.data instanceof ArrayBuffer) {\n data = new Uint8Array(event.data);\n } else if (Array.isArray(event.data)) {\n data = Buffer.concat(event.data);\n } else {\n let wsData = String(event.data);\n if (wsData.length > 128) {\n wsData = `${wsData.slice(0, 128)}...(+${wsData.length - 128} more)`;\n }\n const type = typeof event.data;\n this.#logger.warn(\n { type, 'lk.pii.ws_data': wsData },\n 'received unexpected worker message type',\n );\n return;\n }\n\n const msg = new ServerMessage();\n msg.fromBinary(data);\n\n // register is the only valid first message, and it is only valid as the\n // first message\n if (this.#connecting && msg.message.case !== 'register') {\n throw new WorkerError('expected register response as first message');\n }\n\n switch (msg.message.case) {\n case 'register': {\n this.#id = msg.message.value.workerId;\n this.#logger\n .child({\n id: this.id,\n agentName: this.#opts.agentName,\n agentNameIsEnv: this.#opts.agentNameIsEnv,\n deployment: this.#deployment,\n server_info: msg.message.value.serverInfo,\n })\n .info('registered worker');\n this.event.emit(\n 'worker_registered',\n msg.message.value.workerId,\n msg.message.value.serverInfo,\n );\n this.#connecting = false;\n break;\n }\n case 'availability': {\n if (!msg.message.value.job) return;\n const task = this.#availability(msg.message.value);\n this.#tasks.push(task);\n task.finally(() => {\n const taskIndex = this.#tasks.indexOf(task);\n if (taskIndex !== -1) {\n this.#tasks.splice(taskIndex, 1);\n } else {\n throw new Error(`task ${task} not found in tasks`);\n }\n });\n break;\n }\n case 'assignment': {\n if (!msg.message.value.job) return;\n const job = msg.message.value.job;\n if (job.id in this.#pending) {\n const task = this.#pending[job.id];\n delete this.#pending[job.id];\n task?.resolve(msg.message.value);\n } else {\n this.#logger.child({ job }).warn('received assignment for unknown job ' + job.id);\n }\n break;\n }\n case 'termination': {\n const task = this.#termination(msg.message.value);\n this.#tasks.push(task);\n task.finally(() => {\n const taskIndex = this.#tasks.indexOf(task);\n if (taskIndex !== -1) {\n this.#tasks.splice(taskIndex, 1);\n } else {\n throw new Error(`task ${task} not found in tasks`);\n }\n });\n break;\n }\n }\n });\n\n this.event.emit(\n 'worker_msg',\n new WorkerMessage({\n message: {\n case: 'register',\n value: {\n type: this.#opts.serverType,\n agentName: this.#opts.agentName,\n deployment: this.#deployment,\n allowedPermissions: new ParticipantPermission({\n canPublish: this.#opts.permissions.canPublish,\n canSubscribe: this.#opts.permissions.canSubscribe,\n canPublishData: this.#opts.permissions.canPublishData,\n canUpdateMetadata: this.#opts.permissions.canUpdateMetadata,\n hidden: this.#opts.permissions.hidden,\n agent: true,\n }),\n version,\n },\n },\n }),\n );\n\n let currentStatus = WorkerStatus.WS_AVAILABLE;\n const loadMonitor = setInterval(() => {\n if (closingWS) clearInterval(loadMonitor);\n\n if (this.#draining) {\n if (currentStatus !== WorkerStatus.WS_FULL) {\n currentStatus = WorkerStatus.WS_FULL;\n this.event.emit(\n 'worker_msg',\n new WorkerMessage({\n message: {\n case: 'updateWorker',\n value: {\n load: 1,\n status: WorkerStatus.WS_FULL,\n },\n },\n }),\n );\n }\n return;\n }\n\n const oldStatus = currentStatus;\n this.#opts\n .loadFunc(this)\n .then((currentLoad: number) => {\n const isFull = currentLoad >= this.#opts.loadThreshold;\n const currentlyAvailable = !isFull;\n currentStatus = currentlyAvailable ? WorkerStatus.WS_AVAILABLE : WorkerStatus.WS_FULL;\n\n if (oldStatus != currentStatus) {\n const extra = { load: currentLoad, loadThreshold: this.#opts.loadThreshold };\n if (isFull) {\n this.#logger.child(extra).info('worker is at full capacity, marking as unavailable');\n } else {\n this.#logger.child(extra).info('worker is below capacity, marking as available');\n }\n }\n\n this.event.emit(\n 'worker_msg',\n new WorkerMessage({\n message: {\n case: 'updateWorker',\n value: {\n load: currentLoad,\n status: currentStatus,\n },\n },\n }),\n );\n })\n .catch((e) => {\n this.#logger.warn({ error: e }, 'failed to measure CPU load');\n });\n }, UPDATE_LOAD_INTERVAL);\n\n try {\n await close;\n } finally {\n ws.removeAllListeners();\n }\n }\n\n async #availability(msg: AvailabilityRequest) {\n let answered = false;\n\n const onReject = async () => {\n answered = true;\n this.event.emit(\n 'worker_msg',\n new WorkerMessage({\n message: {\n case: 'availability',\n value: {\n jobId: msg.job!.id,\n available: false,\n },\n },\n }),\n );\n };\n\n const onAccept = async (args: JobAcceptArguments) => {\n answered = true;\n\n this.event.emit(\n 'worker_msg',\n new WorkerMessage({\n message: {\n case: 'availability',\n value: {\n jobId: msg.job!.id,\n available: true,\n participantIdentity: args.identity,\n participantName: args.name,\n participantMetadata: args.metadata,\n // Stamp the agent name on the participant (matches the Python SDK).\n // Consumers like `lk agent simulate` find the agent participant by\n // this attribute; without it they never detect the agent joining.\n participantAttributes: {\n ...args.attributes,\n [ATTRIBUTE_AGENT_NAME]: this.#opts.agentName,\n },\n },\n },\n }),\n );\n\n this.#pending[req.id] = new PendingAssignment();\n\n const timer = setTimeout(() => {\n this.#logger.child({ req }).warn(`assignment for job ${req.id} timed out`);\n return;\n }, ASSIGNMENT_TIMEOUT);\n const asgn = await this.#pending[req.id]?.promise.then(async (asgn) => {\n clearTimeout(timer);\n return asgn;\n });\n\n if (asgn) {\n try {\n await this.#procPool.launchJob({\n acceptArguments: args,\n job: msg.job!,\n url: asgn.url || this.#opts.wsURL,\n token: asgn.token,\n workerId: this.id,\n apiKey: this.#opts.apiKey,\n apiSecret: this.#opts.apiSecret,\n });\n } catch (e) {\n this.#logger.child({ requestId: req.id }).error(e, 'error launching job');\n }\n } else {\n this.#logger.child({ requestId: req.id }).warn('pending assignment not found');\n }\n };\n\n const req = new JobRequest(msg.job!, onReject, onAccept);\n this.#logger\n .child({\n jobId: msg.job?.id,\n room_id: msg.job?.room?.sid,\n resuming: msg.resuming,\n agentName: this.#opts.agentName,\n })\n .info('received job request');\n\n if (this.#draining) {\n this.#logger\n .child({\n jobId: msg.job?.id,\n room_id: msg.job?.room?.sid,\n resuming: msg.resuming,\n agentName: this.#opts.agentName,\n })\n .info('Worker is draining and no longer available, rejecting job');\n await req.reject();\n return;\n }\n\n const jobRequestTask = async () => {\n try {\n await this.#opts.requestFunc(req);\n } catch (e) {\n this.#logger\n .child({ job: msg.job, resuming: msg.resuming, agentName: this.#opts.agentName })\n .info('jobRequestFunc failed');\n await onReject();\n }\n\n if (!answered) {\n this.#logger\n .child({ job: msg.job, resuming: msg.resuming, agentName: this.#opts.agentName })\n .info('no answer was given inside the jobRequestFunc, automatically rejecting the job');\n }\n };\n\n const task = jobRequestTask();\n this.#tasks.push(task);\n task.finally(() => {\n const taskIndex = this.#tasks.indexOf(task);\n if (taskIndex !== -1) {\n this.#tasks.splice(taskIndex, 1);\n } else {\n throw new Error(`task ${task} not found in tasks`);\n }\n });\n }\n\n async #termination(msg: JobTermination) {\n const proc = this.#procPool.getByJobId(msg.jobId);\n if (proc === null) {\n // safe to ignore\n return;\n }\n await proc.close().catch((e) => this.#logger.error(e, 'Error terminating job'));\n }\n\n async close() {\n if (this.#closed) {\n await this.#close.await.catch(() => undefined);\n return;\n }\n\n this.#logger.debug('shutting down worker');\n\n this.#closed = true;\n if (this.#loopMonitor) stopMonitoring(this.#loopMonitor);\n this.#loopMonitor = undefined;\n\n await this.#inferenceExecutor?.close();\n await this.#procPool.close();\n await this.#httpServer?.close();\n await ThrowsPromise.allSettled(this.#tasks);\n\n this.#session?.close();\n await this.#close.await.catch(() => undefined);\n }\n}\n\n/**\n * @deprecated Use {@link AgentServer} instead. This alias is provided for backward compatibility.\n */\nexport const Worker = AgentServer;\n\n/**\n * @deprecated Use {@link ServerOptions} instead. This alias is provided for backward compatibility.\n */\nexport const WorkerOptions = ServerOptions;\n","// Shim globals in cjs bundle\n// There's a weird bug that esbuild will always inject importMetaUrl\n// if we export it as `const importMetaUrl = ... __filename ...`\n// But using a function will not cause this issue\n\nconst getImportMetaUrl = () =>\n typeof document === 'undefined'\n ? new URL(`file:${__filename}`).href\n : (document.currentScript && document.currentScript.src) ||\n new URL('main.js', document.baseURI).href\n\nexport const importMetaUrl = /* @__PURE__ */ getImportMetaUrl()\n"],"mappings":";;;;;;;;;;;;;;;;;;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA;ACKA,IAAM,mBAAmB,MACvB,OAAO,aAAa,cAChB,IAAI,IAAI,QAAQ,UAAU,EAAE,EAAE,OAC7B,SAAS,iBAAiB,SAAS,cAAc,OAClD,IAAI,IAAI,WAAW,SAAS,OAAO,EAAE;AAEpC,IAAM,gBAAgC,iCAAiB;ADP9D,sBAOO;AACP,oBAA2C;AAE3C,gCAA+C;AAC/C,yBAA6B;AAC7B,qBAAqC;AACrC,uBAAwB;AACxB,gBAA0B;AAC1B,wBAA+B;AAC/B,uBAAqC;AACrC,iBAA8B;AAC9B,yBAA2B;AAC3B,oBAAyC;AACzC,oBAAqC;AACrC,8BAAgC;AAChC,qCAAsC;AACtC,uBAAyB;AAEzB,iBAA2B;AAC3B,2BAAuE;AACvE,iBAAoB;AACpB,0BAIO;AACP,mBAAsC;AACtC,qBAAwB;AAExB,MAAM,yBAAyB;AAC/B,MAAM,qBAAqB,MAAM;AACjC,MAAM,uBAAuB,MAAM;AACnC,MAAM,gBAAgB,KAAK,KAAK;AAChC,MAAM,eAAe;AAIrB,MAAM,0BAA0B;AAEhC,IAAI,2BAA2B;AAO/B,SAAS,8BAAoC;AAC3C,MAAI,yBAA0B;AAC9B,6BAA2B;AAC3B,MAAI,wCAAgB,kBAAkB,kCAAoB,EAAG;AAC7D,UAAI,wCAAyB,MAAM,QAAW;AAC5C,wBAAI,EAAE;AAAA,MACJ;AAAA,IAGF;AACA;AAAA,EACF;AACA,QAAM,UAAM,0BAAQ,aAAe;AACnC,0CAAgB;AAAA,IACd;AAAA,IACA,IAAI,IAAI,yBAAyB,GAAG,IAAI,aAAe,EAAE,SAAS;AAAA,EACpE;AACF;AAEA,MAAM,QAAQ;AAAA,EACZ,OAAO,cAAc,YAA6B;AAChD,QAAI,YAAY;AACd,aAAO;AAAA,IACT,OAAO;AACL,aAAO;AAAA,IACT;AAAA,EACF;AAAA,EAEA,OAAO,iBAAiB,YAA6B;AACnD,QAAI,YAAY;AACd,aAAO,KAAK,QAAI,qCAAqB,GAAG,CAAC;AAAA,IAC3C,OAAO;AACL,aAAO;AAAA,IACT;AAAA,EACF;AAAA,EAEA,OAAO,KAAK,YAA6B;AACvC,QAAI,YAAY;AACd,aAAO;AAAA,IACT,OAAO;AACL,aAAO;AAAA,IACT;AAAA,EACF;AACF;AAGO,MAAM,gCAAgC,MAAM;AAAA,EACjD,YAAY,KAAc;AACxB,UAAM,GAAG;AACT,WAAO,eAAe,MAAM,WAAW,SAAS;AAAA,EAClD;AACF;AAGO,MAAM,oBAAoB,MAAM;AAAA,EACrC,YAAY,KAAc;AACxB,UAAM,GAAG;AACT,WAAO,eAAe,MAAM,WAAW,SAAS;AAAA,EAClD;AACF;AAGO,MAAM,+BAA+B,CAAC,MAAkB;AAC/D,MAAM,qBAAqB,OAAO,QAAoB;AACpD,QAAM,IAAI,OAAO;AACnB;AAEA,MAAM,iBAAa,0BAAc;AAGjC,MAAM,iBAAiB,OAAO,YAA0C;AACtE,SAAO,WAAW,WAAW,oBAAoB;AACnD;AAGO,MAAM,kBAAkB;AAAA,EAC7B;AAAA,EACA;AAAA,EACA;AAAA,EACA;AAAA,EACA;AAAA,EACA;AAAA,EAEA,YACE,aAAa,MACb,eAAe,MACf,iBAAiB,MACjB,oBAAoB,MACpB,oBAAmC,CAAC,GACpC,SAAS,OACT;AACA,SAAK,aAAa;AAClB,SAAK,eAAe;AACpB,SAAK,iBAAiB;AACtB,SAAK,oBAAoB;AACzB,SAAK,oBAAoB;AACzB,SAAK,SAAS;AAAA,EAChB;AACF;AAWO,MAAM,cAAc;AAAA,EACzB;AAAA,EACA;AAAA,EACA;AAAA,EACA;AAAA,EACA;AAAA,EACA;AAAA,EACA;AAAA;AAAA;AAAA;AAAA,EAIA;AAAA,EACA;AAAA,EACA;AAAA,EACA;AAAA,EACA;AAAA,EACA;AAAA,EACA;AAAA,EACA;AAAA,EACA;AAAA,EACA;AAAA,EACA;AAAA,EACA;AAAA,EACA;AAAA,EACA;AAAA,EACA;AAAA,EACA;AAAA,EACA;AAAA,EACA;AAAA;AAAA,EAGA,YAAY;AAAA,IACV;AAAA,IACA,cAAc;AAAA,IACd,WAAW;AAAA,IACX,gBAAgB;AAAA,IAChB,mBAAmB;AAAA,IACnB,eAAe;AAAA,IACf,yBAAyB,KAAK;AAAA,IAC9B,oBAAoB;AAAA,IACpB,2BAA2B,KAAK;AAAA,IAChC,cAAc,IAAI,kBAAkB;AAAA,IACpC,YAAY;AAAA,IACZ,iBAAiB;AAAA,IACjB,aAAa,wBAAQ;AAAA,IACrB,WAAW;AAAA,IACX,QAAQ;AAAA,IACR,SAAS;AAAA,IACT,YAAY;AAAA,IACZ,cAAc;AAAA,IACd,OAAO;AAAA,IACP,OAAO;AAAA,IACP,WAAW;AAAA,IACX,aAAa;AAAA,IACb,aAAa;AAAA,IACb,kBAAkB;AAAA,IAClB,mBAAmB;AAAA,EACrB,GAgDG;AACD,SAAK,QAAQ;AACb,QAAI,CAAC,KAAK,OAAO;AACf,YAAM,IAAI,MAAM,wCAAwC;AAAA,IAC1D;AACA,SAAK,cAAc;AACnB,SAAK,WAAW;AAChB,SAAK,gBAAgB,aAAa,WAAW,iBAAiB,QAAQ,cAAc,UAAU;AAC9F,SAAK,mBAAmB,oBAAoB,QAAQ,iBAAiB,UAAU;AAC/E,SAAK,eAAe;AACpB,SAAK,yBAAyB;AAC9B,SAAK,wBAAoB,gDAA0B,iBAAiB;AACpE,SAAK,2BAA2B;AAChC,SAAK,cAAc;AAGnB,QAAI,QAAQ,IAAI,6BAA6B;AAG3C,WAAK,YAAY,QAAQ,IAAI;AAC7B,WAAK,iBAAiB,kBAAkB;AAAA,IAC1C,WAAW,WAAW;AACpB,WAAK,YAAY;AACjB,WAAK,iBAAiB,kBAAkB;AAAA,IAC1C,WAAW,QAAQ,IAAI,oBAAoB;AACzC,WAAK,YAAY,QAAQ,IAAI;AAC7B,WAAK,iBAAiB,kBAAkB;AAAA,IAC1C,OAAO;AACL,WAAK,YAAY;AACjB,WAAK,iBAAiB,kBAAkB;AAAA,IAC1C;AACA,SAAK,aAAa;AAClB,SAAK,WAAW;AAChB,SAAK,QAAQ;AACb,SAAK,SAAS;AACd,SAAK,YAAY;AACjB,SAAK,cAAc;AACnB,SAAK,OAAO;AACZ,SAAK,OAAO,QAAQ,QAAQ,KAAK,UAAU;AAC3C,SAAK,WAAW;AAChB,SAAK,aAAa;AAClB,SAAK,aAAa;AAClB,SAAK,kBAAkB;AACvB,SAAK,mBAAmB;AAAA,EAC1B;AACF;AAEA,MAAM,kBAAkB;AAAA,EACtB,UAAU,IAAI,4BAAoC,CAAC,YAAY;AAC7D,SAAK,UAAU;AAAA,EACjB,CAAC;AAAA,EACD,QAAQ,KAAoB;AAC1B;AAAA,EACF;AACF;AAWO,MAAM,YAAY;AAAA,EACvB;AAAA,EACA;AAAA,EAEA,cAAc,QAAQ,IAAI,4BAA4B;AAAA,EACtD,MAAM;AAAA,EACN,UAAU;AAAA,EACV,YAAY;AAAA,EACZ,cAAc;AAAA,EACd,SAA0B,CAAC;AAAA,EAC3B,WAAgD,CAAC;AAAA,EACjD,SAAS,IAAI,oBAAO;AAAA,EAEpB,QAAQ,IAAI,gCAAa;AAAA,EACzB,WAAkC;AAAA,EAClC;AAAA,EACA,cAAU,gBAAI,EAAE,MAAM,EAAE,gCAAQ,CAAC;AAAA,EACjC;AAAA,EACA;AAAA;AAAA,EAGA,YAAY,MAAqB;AAC/B,SAAK,QAAQ,KAAK,SAAS,QAAQ,IAAI,eAAe;AACtD,SAAK,SAAS,KAAK,UAAU,QAAQ,IAAI,mBAAmB;AAC5D,SAAK,YAAY,KAAK,aAAa,QAAQ,IAAI,sBAAsB;AAErE,QAAI,KAAK,UAAU;AACjB,YAAM,IAAI;AAAA,QACR;AAAA,MACF;AACF,QAAI,KAAK,WAAW;AAClB,YAAM,IAAI;AAAA,QACR;AAAA,MACF;AACF,QAAI,KAAK,cAAc;AACrB,YAAM,IAAI;AAAA,QACR;AAAA,MACF;AAEF,QAAI,KAAK,aAAa;AAKpB,cAAQ,IAAI,uBAAuB,KAAK;AAExC,UAAI,KAAK,aAAa,gBAAgB;AACpC,aAAK,QAAQ;AAAA,UACX;AAAA,QACF;AACA,aAAK,WAAW;AAAA,MAClB;AACA,YAAM,gBAAgB,QAAQ,cAAc,KAAK,UAAU;AAC3D,UAAI,KAAK,kBAAkB,eAAe;AACxC,aAAK,QAAQ;AAAA,UACX;AAAA,QACF;AACA,aAAK,gBAAgB;AAAA,MACvB;AAAA,IACF;AAOA,gCAA4B;AAE5B,SAAK,qBAAqB,qDAAsB,eAAe;AAE/D,SAAK,YAAY,IAAI,0BAAS;AAAA,MAC5B,OAAO,KAAK;AAAA,MACZ,kBAAkB,KAAK;AAAA,MACvB,mBAAmB,KAAK;AAAA,MACxB,cAAc,KAAK;AAAA,MACnB,mBAAmB,KAAK;AAAA,MACxB,mBAAmB,KAAK;AAAA,MACxB,cAAc,KAAK;AAAA,MACnB,eAAe,KAAK;AAAA,IACtB,CAAC;AAED,SAAK,QAAQ;AAIb,QAAI,CAAC,KAAK,YAAY;AACpB,YAAM,cAAc,MAAM;AAExB,YAAI,KAAK,sBAAsB,CAAC,KAAK,mBAAmB,SAAS;AAC/D,iBAAO,EAAE,SAAS,OAAO,SAAS,gCAAgC;AAAA,QACpE;AAGA,YACE,KAAK,WACL,KAAK,eACL,CAAC,KAAK,YACN,KAAK,SAAS,eAAe,oBAAU,MACvC;AACA,iBAAO,EAAE,SAAS,OAAO,SAAS,2BAA2B;AAAA,QAC/D;AAEA,eAAO,EAAE,SAAS,MAAM,SAAS,KAAK;AAAA,MACxC;AAEA,YAAM,gBAAgB,OAAO;AAAA,QAC3B,YAAY,KAAK;AAAA,QACjB,mBAAmB,KAAK;AAAA,QACxB,YAAY,KAAK;AAAA,QACjB,aAAa,wBAAQ,KAAK,UAAU;AAAA,QACpC,aAAa,KAAK,WAAW;AAAA,QAC7B,aAAa;AAAA,QACb,cAAc;AAAA,QACd,kBAAkB;AAAA,MACpB;AAEA,WAAK,cAAc,IAAI,8BAAW,KAAK,MAAM,KAAK,MAAM,aAAa,aAAa;AAAA,IACpF;AAAA,EACF;AAAA;AAAA,EAGA,MAAM,MAAM;AACV,QAAI,CAAC,KAAK,SAAS;AACjB,YAAM,IAAI,YAAY,2BAA2B;AAAA,IACnD;AAEA,QAAI,KAAK,oBAAoB;AAC3B,YAAM,KAAK,mBAAmB,MAAM;AACpC,YAAM,KAAK,mBAAmB,WAAW;AAAA,IAC3C;AAEA,SAAK,QAAQ,KAAK,iBAAiB;AACnC,SAAK,UAAU;AACf,SAAK,mBAAe,qCAAgB,EAAE,MAAM,UAAU,WAAW,MAAM,CAAC;AACxE,SAAK,UAAU,MAAM;AAErB,UAAM,WAAW,YAAY;AAC3B,UAAI,UAAU;AACd,WAAK,cAAc;AAEnB,aAAO,CAAC,KAAK,SAAS;AACpB,cAAM,MAAM,IAAI,IAAI,KAAK,MAAM,KAAK;AACpC,YAAI,WAAW,IAAI,SAAS,QAAQ,QAAQ,IAAI;AAChD,cAAM,QAAQ,IAAI,sCAAY,KAAK,MAAM,QAAQ,KAAK,MAAM,SAAS;AACrE,cAAM,SAAS,EAAE,OAAO,KAAK,CAAC;AAC9B,cAAM,MAAM,MAAM,MAAM,MAAM;AAC9B,cAAM,QAAQ,IAAI,IAAI,MAAM,OAAO;AACnC,YAAI,KAAK,MAAM,aAAa;AAC1B,gBAAM,aAAa,OAAO,gBAAgB,KAAK,MAAM,WAAW;AAAA,QAClE;AACA,aAAK,WAAW,IAAI,oBAAU,OAAO;AAAA,UACnC,SAAS,EAAE,eAAe,YAAY,IAAI;AAAA,QAC5C,CAAC;AAED,YAAI;AACF,gBAAM,IAAI,4BAA8B,CAAC,SAAS,WAAW;AAC3D,iBAAK,SAAU,GAAG,QAAQ,OAAO;AACjC,iBAAK,SAAU,GAAG,SAAS,CAAC,UAAU,OAAO,KAAK,CAAC;AACnD,iBAAK,SAAU,GAAG,SAAS,CAAC,SAAS,OAAO,IAAI,MAAM,sBAAsB,IAAI,EAAE,CAAC,CAAC;AAAA,UACtF,CAAC;AAED,oBAAU;AACV,eAAK,QAAQ,MAAM,6BAA6B;AAChD,gBAAM,KAAK,OAAO,KAAK,QAAQ;AAAA,QACjC,SAAS,GAAY;AACnB,cAAI,KAAK,QAAS;AAClB,cAAI,WAAW,KAAK,MAAM,UAAU;AAClC,kBAAM,IAAI;AAAA,cACR,wCAAwC,KAAK,MAAM,KAAK,WAAW,OAAO,cAAc,CAAC;AAAA,YAC3F;AAAA,UACF;AAEA;AACA,gBAAM,QAAQ,KAAK,IAAI,UAAU,GAAG,EAAE;AAEtC,eAAK,QAAQ;AAAA,YACX,EAAE,OAAO,GAAG,aAAa,SAAS,WAAW,KAAK,MAAM,SAAS;AAAA,YACjE,wCAAwC,KAAK,MAAM,KAAK,kBAAkB,KAAK,cAAc,OAAO,IAAI,KAAK,MAAM,QAAQ;AAAA,UAC7H;AAEA,gBAAM,IAAI,4BAA2B,CAAC,YAAY,WAAW,SAAS,QAAQ,GAAI,CAAC;AAAA,QACrF;AAAA,MACF;AAAA,IACF;AAEA,UAAM,QAAQ,CAAC,SAAS,CAAC;AACzB,QAAI,KAAK,aAAa;AACpB,YAAM,KAAK,KAAK,YAAY,IAAI,CAAC;AAAA,IACnC;AACA,QAAI;AACF,YAAM,4BAAc,IAAI,KAAK;AAC7B,WAAK,OAAO,QAAQ;AAAA,IACtB,SAAS,GAAG;AACV,UAAI,CAAC,KAAK,OAAO,MAAM;AACrB,aAAK,OAAO,OAAO,aAAa,QAAQ,IAAI,IAAI,MAAM,OAAO,CAAC,CAAC,CAAC;AAAA,MAClE;AACA,YAAM;AAAA,IACR;AAAA,EACF;AAAA,EAEA,IAAI,KAAa;AACf,WAAO,KAAK;AAAA,EACd;AAAA,EAEA,IAAI,aAA+B;AACjC,WAAO,KAAK,UAAU,UACnB,OAAO,CAAC,SAAS,KAAK,UAAU,EAChC,IAAI,CAAC,SAAS,KAAK,UAAW;AAAA,EACnC;AAAA;AAAA,EAGA,MAAM,MAAM,SAA8D;AACxE,QAAI,KAAK,WAAW;AAClB;AAAA,IACF;AAEA,SAAK,QAAQ,MAAM,iBAAiB;AACpC,SAAK,YAAY;AAEjB,SAAK,MAAM;AAAA,MACT;AAAA,MACA,IAAI,8BAAc;AAAA,QAChB,SAAS;AAAA,UACP,MAAM;AAAA,UACN,OAAO;AAAA,YACL,QAAQ,6BAAa;AAAA,UACvB;AAAA,QACF;AAAA,MACF,CAAC;AAAA,IACH;AAEA,UAAM,WAAW,YAA4C;AAC3D,aAAO,4BAAc;AAAA,QACnB,KAAK,UAAU,UAAU,IAAI,CAAC,SAAuC;AACnE,cAAI,CAAC,KAAK,YAAY;AACpB,iBAAK,MAAM;AAAA,UACb;AACA,iBAAO,KAAK,KAAK;AAAA,QACnB,CAAC;AAAA,MACH;AAAA,IACF;AAEA,UAAM,WAAW,CAAC,SAAS,CAAC;AAE5B,UAAM,YAAY,WAAW,KAAK,MAAM;AAExC,QAAI,WAAW;AACb,eAAS;AAAA,YACP,4BAAc,YAAY,QAAQ,SAAS,CAAC,EAAE,MAAM,MAAM;AACxD,gBAAM,IAAI,YAAY,oBAAoB;AAAA,QAC5C,CAAC;AAAA,MACH;AAAA,IACF;AACA,UAAM,4BAAc,KAAK,QAAQ;AAAA,EACnC;AAAA,EAEA,MAAM,YAAY,UAAkB,qBAA8B;AAChE,UAAM,SAAS,IAAI,4CAAkB,KAAK,MAAM,OAAO,KAAK,MAAM,QAAQ,KAAK,MAAM,SAAS;AAC9F,UAAM,OAAO,MAAM,OAAO,WAAW,EAAE,MAAM,SAAS,CAAC;AACvD,QAAI,cAA2C;AAC/C,QAAI,qBAAqB;AACvB,UAAI;AAEF,sBAAe,MAAM,OAAO;AAAA,UAC1B;AAAA,UACA;AAAA,QACF;AAAA,MACF,SAAS,GAAG;AACV,aAAK,QAAQ;AAAA,UACX,6BAA6B,mBAAmB,sBAAsB,QAAQ;AAAA,QAChF;AACA,cAAM;AAAA,MACR;AAAA,IACF;AAEA,SAAK,MAAM;AAAA,MACT;AAAA,MACA,IAAI,8BAAc;AAAA,QAChB,SAAS;AAAA,UACP,MAAM;AAAA,UACN,OAAO;AAAA,YACL,MAAM,wBAAQ;AAAA,YACd;AAAA,YACA;AAAA,UACF;AAAA,QACF;AAAA,MACF,CAAC;AAAA,IACH;AAAA,EACF;AAAA,EAEA,MAAM,OAAO,IAAe;AAC1B,QAAI,YAAY;AAEhB,UAAM,OAAO,CAAC,QAAuB;AACnC,UAAI,WAAW;AACb,aAAK,MAAM,IAAI,cAAc,IAAI;AACjC;AAAA,MACF;AACA,SAAG,KAAK,IAAI,SAAS,CAAC;AAAA,IACxB;AACA,SAAK,MAAM,GAAG,cAAc,IAAI;AAEhC,UAAM,QAAQ,IAAI,4BAAoC,CAAC,SAAS,WAAW;AACzE,SAAG,iBAAiB,SAAS,CAAC,UAAU;AACtC,oBAAY;AACZ,YAAI,CAAC,KAAK,SAAS;AACjB;AAAA,YACE,IAAI,iCAAe;AAAA,cACjB,SAAS;AAAA,cACT,SAAS;AAAA,gBACP,YAAY,MAAM,QAAQ;AAAA,gBAC1B,MAAM;AAAA,kBACJ,MAAM,MAAM;AAAA,kBACZ,QAAQ,MAAM;AAAA,kBACd,UAAU,MAAM;AAAA,gBAClB;AAAA,cACF;AAAA,YACF,CAAC;AAAA,UACH;AACA;AAAA,QACF;AACA,gBAAQ;AAAA,MACV,CAAC;AAAA,IACH,CAAC;AAED,OAAG,iBAAiB,SAAS,CAAC,UAAU;AACtC,WAAK,QAAQ,MAAM,iBAAiB,MAAM,OAAO;AAAA,IACnD,CAAC;AAED,OAAG,iBAAiB,WAAW,CAAC,UAAU;AACxC,UAAI;AACJ,UAAI,MAAM,gBAAgB,YAAY;AACpC,eAAO,MAAM;AAAA,MACf,WAAW,MAAM,gBAAgB,aAAa;AAC5C,eAAO,IAAI,WAAW,MAAM,IAAI;AAAA,MAClC,WAAW,MAAM,QAAQ,MAAM,IAAI,GAAG;AACpC,eAAO,OAAO,OAAO,MAAM,IAAI;AAAA,MACjC,OAAO;AACL,YAAI,SAAS,OAAO,MAAM,IAAI;AAC9B,YAAI,OAAO,SAAS,KAAK;AACvB,mBAAS,GAAG,OAAO,MAAM,GAAG,GAAG,CAAC,QAAQ,OAAO,SAAS,GAAG;AAAA,QAC7D;AACA,cAAM,OAAO,OAAO,MAAM;AAC1B,aAAK,QAAQ;AAAA,UACX,EAAE,MAAM,kBAAkB,OAAO;AAAA,UACjC;AAAA,QACF;AACA;AAAA,MACF;AAEA,YAAM,MAAM,IAAI,8BAAc;AAC9B,UAAI,WAAW,IAAI;AAInB,UAAI,KAAK,eAAe,IAAI,QAAQ,SAAS,YAAY;AACvD,cAAM,IAAI,YAAY,6CAA6C;AAAA,MACrE;AAEA,cAAQ,IAAI,QAAQ,MAAM;AAAA,QACxB,KAAK,YAAY;AACf,eAAK,MAAM,IAAI,QAAQ,MAAM;AAC7B,eAAK,QACF,MAAM;AAAA,YACL,IAAI,KAAK;AAAA,YACT,WAAW,KAAK,MAAM;AAAA,YACtB,gBAAgB,KAAK,MAAM;AAAA,YAC3B,YAAY,KAAK;AAAA,YACjB,aAAa,IAAI,QAAQ,MAAM;AAAA,UACjC,CAAC,EACA,KAAK,mBAAmB;AAC3B,eAAK,MAAM;AAAA,YACT;AAAA,YACA,IAAI,QAAQ,MAAM;AAAA,YAClB,IAAI,QAAQ,MAAM;AAAA,UACpB;AACA,eAAK,cAAc;AACnB;AAAA,QACF;AAAA,QACA,KAAK,gBAAgB;AACnB,cAAI,CAAC,IAAI,QAAQ,MAAM,IAAK;AAC5B,gBAAM,OAAO,KAAK,cAAc,IAAI,QAAQ,KAAK;AACjD,eAAK,OAAO,KAAK,IAAI;AACrB,eAAK,QAAQ,MAAM;AACjB,kBAAM,YAAY,KAAK,OAAO,QAAQ,IAAI;AAC1C,gBAAI,cAAc,IAAI;AACpB,mBAAK,OAAO,OAAO,WAAW,CAAC;AAAA,YACjC,OAAO;AACL,oBAAM,IAAI,MAAM,QAAQ,IAAI,qBAAqB;AAAA,YACnD;AAAA,UACF,CAAC;AACD;AAAA,QACF;AAAA,QACA,KAAK,cAAc;AACjB,cAAI,CAAC,IAAI,QAAQ,MAAM,IAAK;AAC5B,gBAAM,MAAM,IAAI,QAAQ,MAAM;AAC9B,cAAI,IAAI,MAAM,KAAK,UAAU;AAC3B,kBAAM,OAAO,KAAK,SAAS,IAAI,EAAE;AACjC,mBAAO,KAAK,SAAS,IAAI,EAAE;AAC3B,yCAAM,QAAQ,IAAI,QAAQ;AAAA,UAC5B,OAAO;AACL,iBAAK,QAAQ,MAAM,EAAE,IAAI,CAAC,EAAE,KAAK,yCAAyC,IAAI,EAAE;AAAA,UAClF;AACA;AAAA,QACF;AAAA,QACA,KAAK,eAAe;AAClB,gBAAM,OAAO,KAAK,aAAa,IAAI,QAAQ,KAAK;AAChD,eAAK,OAAO,KAAK,IAAI;AACrB,eAAK,QAAQ,MAAM;AACjB,kBAAM,YAAY,KAAK,OAAO,QAAQ,IAAI;AAC1C,gBAAI,cAAc,IAAI;AACpB,mBAAK,OAAO,OAAO,WAAW,CAAC;AAAA,YACjC,OAAO;AACL,oBAAM,IAAI,MAAM,QAAQ,IAAI,qBAAqB;AAAA,YACnD;AAAA,UACF,CAAC;AACD;AAAA,QACF;AAAA,MACF;AAAA,IACF,CAAC;AAED,SAAK,MAAM;AAAA,MACT;AAAA,MACA,IAAI,8BAAc;AAAA,QAChB,SAAS;AAAA,UACP,MAAM;AAAA,UACN,OAAO;AAAA,YACL,MAAM,KAAK,MAAM;AAAA,YACjB,WAAW,KAAK,MAAM;AAAA,YACtB,YAAY,KAAK;AAAA,YACjB,oBAAoB,IAAI,sCAAsB;AAAA,cAC5C,YAAY,KAAK,MAAM,YAAY;AAAA,cACnC,cAAc,KAAK,MAAM,YAAY;AAAA,cACrC,gBAAgB,KAAK,MAAM,YAAY;AAAA,cACvC,mBAAmB,KAAK,MAAM,YAAY;AAAA,cAC1C,QAAQ,KAAK,MAAM,YAAY;AAAA,cAC/B,OAAO;AAAA,YACT,CAAC;AAAA,YACD;AAAA,UACF;AAAA,QACF;AAAA,MACF,CAAC;AAAA,IACH;AAEA,QAAI,gBAAgB,6BAAa;AACjC,UAAM,cAAc,YAAY,MAAM;AACpC,UAAI,UAAW,eAAc,WAAW;AAExC,UAAI,KAAK,WAAW;AAClB,YAAI,kBAAkB,6BAAa,SAAS;AAC1C,0BAAgB,6BAAa;AAC7B,eAAK,MAAM;AAAA,YACT;AAAA,YACA,IAAI,8BAAc;AAAA,cAChB,SAAS;AAAA,gBACP,MAAM;AAAA,gBACN,OAAO;AAAA,kBACL,MAAM;AAAA,kBACN,QAAQ,6BAAa;AAAA,gBACvB;AAAA,cACF;AAAA,YACF,CAAC;AAAA,UACH;AAAA,QACF;AACA;AAAA,MACF;AAEA,YAAM,YAAY;AAClB,WAAK,MACF,SAAS,IAAI,EACb,KAAK,CAAC,gBAAwB;AAC7B,cAAM,SAAS,eAAe,KAAK,MAAM;AACzC,cAAM,qBAAqB,CAAC;AAC5B,wBAAgB,qBAAqB,6BAAa,eAAe,6BAAa;AAE9E,YAAI,aAAa,eAAe;AAC9B,gBAAM,QAAQ,EAAE,MAAM,aAAa,eAAe,KAAK,MAAM,cAAc;AAC3E,cAAI,QAAQ;AACV,iBAAK,QAAQ,MAAM,KAAK,EAAE,KAAK,oDAAoD;AAAA,UACrF,OAAO;AACL,iBAAK,QAAQ,MAAM,KAAK,EAAE,KAAK,gDAAgD;AAAA,UACjF;AAAA,QACF;AAEA,aAAK,MAAM;AAAA,UACT;AAAA,UACA,IAAI,8BAAc;AAAA,YAChB,SAAS;AAAA,cACP,MAAM;AAAA,cACN,OAAO;AAAA,gBACL,MAAM;AAAA,gBACN,QAAQ;AAAA,cACV;AAAA,YACF;AAAA,UACF,CAAC;AAAA,QACH;AAAA,MACF,CAAC,EACA,MAAM,CAAC,MAAM;AACZ,aAAK,QAAQ,KAAK,EAAE,OAAO,EAAE,GAAG,4BAA4B;AAAA,MAC9D,CAAC;AAAA,IACL,GAAG,oBAAoB;AAEvB,QAAI;AACF,YAAM;AAAA,IACR,UAAE;AACA,SAAG,mBAAmB;AAAA,IACxB;AAAA,EACF;AAAA,EAEA,MAAM,cAAc,KAA0B;AA70BhD;AA80BI,QAAI,WAAW;AAEf,UAAM,WAAW,YAAY;AAC3B,iBAAW;AACX,WAAK,MAAM;AAAA,QACT;AAAA,QACA,IAAI,8BAAc;AAAA,UAChB,SAAS;AAAA,YACP,MAAM;AAAA,YACN,OAAO;AAAA,cACL,OAAO,IAAI,IAAK;AAAA,cAChB,WAAW;AAAA,YACb;AAAA,UACF;AAAA,QACF,CAAC;AAAA,MACH;AAAA,IACF;AAEA,UAAM,WAAW,OAAO,SAA6B;AAh2BzD,UAAAA;AAi2BM,iBAAW;AAEX,WAAK,MAAM;AAAA,QACT;AAAA,QACA,IAAI,8BAAc;AAAA,UAChB,SAAS;AAAA,YACP,MAAM;AAAA,YACN,OAAO;AAAA,cACL,OAAO,IAAI,IAAK;AAAA,cAChB,WAAW;AAAA,cACX,qBAAqB,KAAK;AAAA,cAC1B,iBAAiB,KAAK;AAAA,cACtB,qBAAqB,KAAK;AAAA;AAAA;AAAA;AAAA,cAI1B,uBAAuB;AAAA,gBACrB,GAAG,KAAK;AAAA,gBACR,CAAC,qCAAoB,GAAG,KAAK,MAAM;AAAA,cACrC;AAAA,YACF;AAAA,UACF;AAAA,QACF,CAAC;AAAA,MACH;AAEA,WAAK,SAAS,IAAI,EAAE,IAAI,IAAI,kBAAkB;AAE9C,YAAM,QAAQ,WAAW,MAAM;AAC7B,aAAK,QAAQ,MAAM,EAAE,IAAI,CAAC,EAAE,KAAK,sBAAsB,IAAI,EAAE,YAAY;AACzE;AAAA,MACF,GAAG,kBAAkB;AACrB,YAAM,OAAO,QAAMA,MAAA,KAAK,SAAS,IAAI,EAAE,MAApB,gBAAAA,IAAuB,QAAQ,KAAK,OAAOC,UAAS;AACrE,qBAAa,KAAK;AAClB,eAAOA;AAAA,MACT;AAEA,UAAI,MAAM;AACR,YAAI;AACF,gBAAM,KAAK,UAAU,UAAU;AAAA,YAC7B,iBAAiB;AAAA,YACjB,KAAK,IAAI;AAAA,YACT,KAAK,KAAK,OAAO,KAAK,MAAM;AAAA,YAC5B,OAAO,KAAK;AAAA,YACZ,UAAU,KAAK;AAAA,YACf,QAAQ,KAAK,MAAM;AAAA,YACnB,WAAW,KAAK,MAAM;AAAA,UACxB,CAAC;AAAA,QACH,SAAS,GAAG;AACV,eAAK,QAAQ,MAAM,EAAE,WAAW,IAAI,GAAG,CAAC,EAAE,MAAM,GAAG,qBAAqB;AAAA,QAC1E;AAAA,MACF,OAAO;AACL,aAAK,QAAQ,MAAM,EAAE,WAAW,IAAI,GAAG,CAAC,EAAE,KAAK,8BAA8B;AAAA,MAC/E;AAAA,IACF;AAEA,UAAM,MAAM,IAAI,sBAAW,IAAI,KAAM,UAAU,QAAQ;AACvD,SAAK,QACF,MAAM;AAAA,MACL,QAAO,SAAI,QAAJ,mBAAS;AAAA,MAChB,UAAS,eAAI,QAAJ,mBAAS,SAAT,mBAAe;AAAA,MACxB,UAAU,IAAI;AAAA,MACd,WAAW,KAAK,MAAM;AAAA,IACxB,CAAC,EACA,KAAK,sBAAsB;AAE9B,QAAI,KAAK,WAAW;AAClB,WAAK,QACF,MAAM;AAAA,QACL,QAAO,SAAI,QAAJ,mBAAS;AAAA,QAChB,UAAS,eAAI,QAAJ,mBAAS,SAAT,mBAAe;AAAA,QACxB,UAAU,IAAI;AAAA,QACd,WAAW,KAAK,MAAM;AAAA,MACxB,CAAC,EACA,KAAK,2DAA2D;AACnE,YAAM,IAAI,OAAO;AACjB;AAAA,IACF;AAEA,UAAM,iBAAiB,YAAY;AACjC,UAAI;AACF,cAAM,KAAK,MAAM,YAAY,GAAG;AAAA,MAClC,SAAS,GAAG;AACV,aAAK,QACF,MAAM,EAAE,KAAK,IAAI,KAAK,UAAU,IAAI,UAAU,WAAW,KAAK,MAAM,UAAU,CAAC,EAC/E,KAAK,uBAAuB;AAC/B,cAAM,SAAS;AAAA,MACjB;AAEA,UAAI,CAAC,UAAU;AACb,aAAK,QACF,MAAM,EAAE,KAAK,IAAI,KAAK,UAAU,IAAI,UAAU,WAAW,KAAK,MAAM,UAAU,CAAC,EAC/E,KAAK,gFAAgF;AAAA,MAC1F;AAAA,IACF;AAEA,UAAM,OAAO,eAAe;AAC5B,SAAK,OAAO,KAAK,IAAI;AACrB,SAAK,QAAQ,MAAM;AACjB,YAAM,YAAY,KAAK,OAAO,QAAQ,IAAI;AAC1C,UAAI,cAAc,IAAI;AACpB,aAAK,OAAO,OAAO,WAAW,CAAC;AAAA,MACjC,OAAO;AACL,cAAM,IAAI,MAAM,QAAQ,IAAI,qBAAqB;AAAA,MACnD;AAAA,IACF,CAAC;AAAA,EACH;AAAA,EAEA,MAAM,aAAa,KAAqB;AACtC,UAAM,OAAO,KAAK,UAAU,WAAW,IAAI,KAAK;AAChD,QAAI,SAAS,MAAM;AAEjB;AAAA,IACF;AACA,UAAM,KAAK,MAAM,EAAE,MAAM,CAAC,MAAM,KAAK,QAAQ,MAAM,GAAG,uBAAuB,CAAC;AAAA,EAChF;AAAA,EAEA,MAAM,QAAQ;AAr9BhB;AAs9BI,QAAI,KAAK,SAAS;AAChB,YAAM,KAAK,OAAO,MAAM,MAAM,MAAM,MAAS;AAC7C;AAAA,IACF;AAEA,SAAK,QAAQ,MAAM,sBAAsB;AAEzC,SAAK,UAAU;AACf,QAAI,KAAK,aAAc,yCAAe,KAAK,YAAY;AACvD,SAAK,eAAe;AAEpB,YAAM,UAAK,uBAAL,mBAAyB;AAC/B,UAAM,KAAK,UAAU,MAAM;AAC3B,YAAM,UAAK,gBAAL,mBAAkB;AACxB,UAAM,4BAAc,WAAW,KAAK,MAAM;AAE1C,eAAK,aAAL,mBAAe;AACf,UAAM,KAAK,OAAO,MAAM,MAAM,MAAM,MAAS;AAAA,EAC/C;AACF;AAKO,MAAM,SAAS;AAKf,MAAM,gBAAgB;","names":["_a","asgn"]}