{"version":3,"sources":["../../src/voice/generation_tools.test.ts"],"sourcesContent":["// SPDX-FileCopyrightText: 2025 LiveKit, Inc.\n//\n// SPDX-License-Identifier: Apache-2.0\nimport { ReadableStream as NodeReadableStream } from 'stream/web';\nimport { afterEach, describe, expect, it, vi } from 'vitest';\nimport { z } from 'zod';\nimport { FunctionCall, ToolContext, ToolError, tool } from '../llm/index.js';\nimport { initializeLogger } from '../log.js';\nimport type { Task } from '../utils.js';\nimport { cancelAndWait, delay } from '../utils.js';\nimport { AgentTask } from './agent.js';\nimport type { AgentSession } from './agent_session.js';\nimport {\n type _TextOut,\n _waitForToolExecutionResult,\n performTextForwarding,\n performToolExecutions,\n} from './generation.js';\nimport type { SpeechHandle } from './speech_handle.js';\nimport { ToolExecutor } from './tool_executor.js';\n\nfunction createStringStream(chunks: string[], delayMs: number = 0): NodeReadableStream {\n return new NodeReadableStream({\n async start(controller) {\n for (const c of chunks) {\n if (delayMs > 0) {\n await delay(delayMs);\n }\n controller.enqueue(c);\n }\n controller.close();\n },\n });\n}\n\nfunction createFunctionCallStream(fc: FunctionCall): NodeReadableStream {\n return new NodeReadableStream({\n start(controller) {\n controller.enqueue(fc);\n controller.close();\n },\n });\n}\n\nfunction createFunctionCallStreamFromArray(fcs: FunctionCall[]): NodeReadableStream {\n return new NodeReadableStream({\n start(controller) {\n for (const fc of fcs) {\n controller.enqueue(fc);\n }\n controller.close();\n },\n });\n}\n\ndescribe('Generation + Tool Execution', () => {\n initializeLogger({ pretty: false, level: 'silent' });\n\n afterEach(() => {\n vi.useRealTimers();\n });\n\n it('should not abort tool when preamble forwarders are cleaned up', async () => {\n vi.useFakeTimers();\n const replyAbortController = new AbortController();\n const forwarderController = new AbortController();\n\n const chunks = Array.from({ length: 50 }, () => `Hi.`);\n const fullPreambleText = chunks.join('');\n const preamble = createStringStream(chunks, 20);\n const [textForwardTask, textOut]: [Task, _TextOut] = performTextForwarding(\n preamble,\n forwarderController,\n null,\n );\n\n // Tool that takes > 5 seconds\n let toolAborted = false;\n const getWeather = tool({\n name: 'getWeather',\n description: 'weather',\n parameters: z.object({ location: z.string() }),\n execute: async ({ location }, { abortSignal }) => {\n abortSignal.addEventListener('abort', () => {\n toolAborted = true;\n });\n // 6s delay\n await delay(6000);\n return `Sunny in ${location}`;\n },\n });\n\n const fc = FunctionCall.create({\n callId: 'call_1',\n name: 'getWeather',\n args: JSON.stringify({ location: 'San Francisco' }),\n });\n const toolCallStream = createFunctionCallStream(fc);\n\n const [execTask, toolOutput] = performToolExecutions({\n session: {} as any,\n speechHandle: { id: 'speech_test', _itemAdded: () => {} } as any,\n toolCtx: new ToolContext([getWeather]) as any,\n toolCallStream,\n controller: replyAbortController,\n onToolExecutionStarted: () => {},\n onToolExecutionCompleted: () => {},\n });\n\n // Ensure tool has started, then cancel forwarders mid-stream (without aborting parent AbortController)\n await toolOutput.firstToolStartedFuture.await;\n await vi.advanceTimersByTimeAsync(100);\n const cancelForwarder = cancelAndWait([textForwardTask], 5000);\n await vi.advanceTimersByTimeAsync(20);\n await cancelForwarder;\n\n await vi.advanceTimersByTimeAsync(6000);\n await execTask.result;\n\n expect(toolOutput.output.length).toBe(1);\n const out = toolOutput.output[0]!;\n expect(out.toolCallOutput?.isError).toBe(false);\n expect(out.toolCallOutput?.output).toContain('Sunny in San Francisco');\n // Forwarder should have been cancelled before finishing all preamble chunks\n expect(textOut.text).not.toBe(fullPreambleText);\n // Tool's abort signal must not have fired\n expect(toolAborted).toBe(false);\n }, 30_000);\n\n it('should return basic tool execution output', async () => {\n const replyAbortController = new AbortController();\n\n const echo = tool({\n name: 'echo',\n description: 'echo',\n parameters: z.object({ msg: z.string() }),\n execute: async ({ msg }) => `echo: ${msg}`,\n });\n\n const fc = FunctionCall.create({\n callId: 'call_2',\n name: 'echo',\n args: JSON.stringify({ msg: 'hello' }),\n });\n const toolCallStream = createFunctionCallStream(fc);\n\n const [execTask, toolOutput] = performToolExecutions({\n session: {} as any,\n speechHandle: { id: 'speech_test2', _itemAdded: () => {} } as any,\n toolCtx: new ToolContext([echo]) as any,\n toolCallStream,\n controller: replyAbortController,\n });\n\n await execTask.result;\n expect(toolOutput.output.length).toBe(1);\n const out = toolOutput.output[0];\n expect(out?.toolCallOutput?.isError).toBe(false);\n expect(out?.toolCallOutput?.output).toContain('echo: hello');\n });\n\n it('should repair and canonicalize leaked template tokens in tool args', async () => {\n const replyAbortController = new AbortController();\n\n const removeOrderItem = tool({\n name: 'removeOrderItem',\n description: 'remove order item',\n parameters: z.object({ orderId: z.array(z.string()) }),\n execute: async ({ orderId }) => orderId.join(','),\n });\n\n const rawArgs = '{\"orderId\": [\"<|\\\\\"|\\\\\"O_WAAB70<|\\\\\"|\\\\\"]}';\n const fc = FunctionCall.create({\n callId: 'call_repair_args',\n name: 'removeOrderItem',\n args: rawArgs,\n });\n const toolCallStream = createFunctionCallStream(fc);\n\n const [execTask, toolOutput] = performToolExecutions({\n session: {} as AgentSession,\n speechHandle: { id: 'speech_repair', _itemAdded: () => {} } as unknown as SpeechHandle,\n toolCtx: new ToolContext([removeOrderItem]) as unknown as ToolContext,\n toolCallStream,\n controller: replyAbortController,\n });\n\n await execTask.result;\n expect(toolOutput.output.length).toBe(1);\n const out = toolOutput.output[0];\n expect(out?.toolCallOutput?.isError).toBe(false);\n expect(out?.toolCallOutput?.output).toBe('\"O_WAAB70\"');\n expect(fc.args).not.toBe(rawArgs);\n expect(JSON.parse(fc.args)).toEqual({ orderId: ['O_WAAB70'] });\n });\n\n it('should abort tool when reply is aborted mid-execution', async () => {\n const replyAbortController = new AbortController();\n\n let aborted = false;\n // Resolves once the tool body has begun and registered its abort listener. We cannot key off\n // `firstToolStartedFuture` here: that future now resolves right after argument parsing (before\n // execution), matching Python, so awaiting it does not guarantee the abort listener is wired.\n let signalToolStarted!: () => void;\n const toolStarted = new Promise((resolve) => {\n signalToolStarted = resolve;\n });\n const longOp = tool({\n name: 'longOp',\n description: 'longOp',\n parameters: z.object({ ms: z.number() }),\n execute: async ({ ms }, { abortSignal }) => {\n abortSignal.addEventListener('abort', () => {\n aborted = true;\n });\n signalToolStarted();\n await delay(ms);\n return 'done';\n },\n });\n\n const fc = FunctionCall.create({\n callId: 'call_abort_1',\n name: 'longOp',\n args: JSON.stringify({ ms: 5000 }),\n });\n const toolCallStream = createFunctionCallStream(fc);\n\n const [execTask, toolOutput] = performToolExecutions({\n session: {} as any,\n speechHandle: { id: 'speech_abort', _itemAdded: () => {} } as any,\n toolCtx: new ToolContext([longOp]) as any,\n toolCallStream,\n controller: replyAbortController,\n });\n\n await toolStarted;\n replyAbortController.abort();\n await execTask.result;\n\n expect(aborted).toBe(true);\n expect(toolOutput.output).toHaveLength(0);\n }, 20_000);\n\n it('keeps a settled tool result when abort is observed in the same tick', async () => {\n const replyAbortController = new AbortController();\n const settled = Promise.resolve('completed');\n replyAbortController.abort();\n\n await expect(\n _waitForToolExecutionResult(settled, replyAbortController.signal),\n ).resolves.toEqual({\n result: 'completed',\n isAborted: false,\n });\n });\n\n it('keeps completed output while omitting interrupted regular tools and handoffs', async () => {\n const replyAbortController = new AbortController();\n const neverFinish = new Promise(() => {});\n let signalSlowStarted!: () => void;\n const slowStarted = new Promise((resolve) => {\n signalSlowStarted = resolve;\n });\n let signalHandoffStarted!: () => void;\n const handoffStarted = new Promise((resolve) => {\n signalHandoffStarted = resolve;\n });\n let signalCompleted!: () => void;\n const completed = new Promise((resolve) => {\n signalCompleted = resolve;\n });\n\n const immediate = tool({\n name: 'immediate',\n description: 'Completes before interruption.',\n parameters: z.object({}),\n execute: async () => 'completed',\n });\n const slow = tool({\n name: 'slow',\n description: 'Remains in flight during interruption.',\n parameters: z.object({}),\n execute: async () => {\n signalSlowStarted();\n await neverFinish;\n return 'unreachable';\n },\n });\n const handoff = tool({\n name: 'handoff',\n description: 'Returns a handoff only if allowed to finish.',\n parameters: z.object({}),\n execute: async () => {\n signalHandoffStarted();\n await neverFinish;\n return new AgentTask({ instructions: 'Handle the transferred request.' });\n },\n });\n const calls = [\n FunctionCall.create({ callId: 'call_completed', name: immediate.name, args: '{}' }),\n FunctionCall.create({ callId: 'call_slow', name: slow.name, args: '{}' }),\n FunctionCall.create({ callId: 'call_handoff', name: handoff.name, args: '{}' }),\n ];\n const completedCallIds: string[] = [];\n\n const [execTask, toolOutput] = performToolExecutions({\n session: {} as any,\n speechHandle: { id: 'speech_mixed_abort', _itemAdded: () => {} } as any,\n toolCtx: new ToolContext([immediate, slow, handoff]) as any,\n toolCallStream: createFunctionCallStreamFromArray(calls),\n controller: replyAbortController,\n onToolExecutionCompleted: (output) => {\n completedCallIds.push(output.toolCall.callId);\n if (output.toolCall.callId === 'call_completed') signalCompleted();\n },\n });\n\n await Promise.all([completed, slowStarted, handoffStarted]);\n replyAbortController.abort();\n await execTask.result;\n\n expect(toolOutput.output.map((output) => output.toolCall.callId)).toEqual(['call_completed']);\n expect(completedCallIds).toEqual(['call_completed']);\n });\n\n it('resolves firstToolStartedFuture even when the only tool call is duplicate-rejected', async () => {\n const sharedExecutor = new ToolExecutor({ owningActivity: null });\n const session = { _activity: { _toolExecutor: sharedExecutor } } as unknown as AgentSession;\n const speechHandle = { id: 'speech_dup', _itemAdded: () => {} } as unknown as SpeechHandle;\n\n let releaseFirst!: () => void;\n const firstBlocked = new Promise((resolve) => {\n releaseFirst = resolve;\n });\n let signalFirstStarted!: () => void;\n const firstStarted = new Promise((resolve) => {\n signalFirstStarted = resolve;\n });\n const slow = tool({\n name: 'slow',\n description: 'slow',\n onDuplicate: 'reject',\n parameters: z.object({}),\n execute: async () => {\n signalFirstStarted();\n await firstBlocked;\n return 'done';\n },\n });\n const toolCtx = new ToolContext([slow]) as unknown as ToolContext;\n\n // First call: starts and stays running so it occupies the executor's duplicate slot.\n const fc1 = FunctionCall.create({ callId: 'dup_c1', name: 'slow', args: '{}' });\n const [task1] = performToolExecutions({\n session,\n speechHandle,\n toolCtx,\n toolCallStream: createFunctionCallStream(fc1),\n controller: new AbortController(),\n });\n await firstStarted;\n\n // Second call: a duplicate of the still-running first call -> rejected by the executor.\n const fc2 = FunctionCall.create({ callId: 'dup_c2', name: 'slow', args: '{}' });\n const [task2, out2] = performToolExecutions({\n session,\n speechHandle,\n toolCtx,\n toolCallStream: createFunctionCallStream(fc2),\n controller: new AbortController(),\n });\n\n // Would hang forever before the fix.\n await out2.firstToolStartedFuture.await;\n await task2.result;\n\n // The duplicate produced a (rejection) output, and no real execution happened for it.\n expect(out2.output.length).toBe(1);\n\n releaseFirst();\n await task1.result;\n }, 20_000);\n\n it('normalizes and commits an unknown tool call before its error output', async () => {\n const events: string[] = [];\n const fc = FunctionCall.create({\n callId: 'call_unknown',\n name: 'missing',\n args: 'definitely not json',\n });\n const [execTask, toolOutput] = performToolExecutions({\n session: {} as AgentSession,\n speechHandle: { id: 'speech_unknown', _itemAdded: () => {} } as unknown as SpeechHandle,\n toolCtx: ToolContext.empty(),\n toolCallStream: createFunctionCallStream(fc),\n controller: new AbortController(),\n onToolExecutionStarted: (call) => events.push(`call:${call.callId}`),\n onToolExecutionCompleted: (output) => events.push(`output:${output.toolCall.callId}`),\n });\n\n await execTask.result;\n\n expect(events).toEqual(['call:call_unknown', 'output:call_unknown']);\n expect(fc.args).toBe('{}');\n expect(toolOutput.firstToolStartedFuture.done).toBe(true);\n expect(toolOutput.output[0]?.toolCallOutput).toMatchObject({\n callId: 'call_unknown',\n isError: true,\n });\n });\n\n it('should surface zod validation errors to the LLM with field-level detail', async () => {\n const replyAbortController = new AbortController();\n\n const echo = tool({\n name: 'echo',\n description: 'echo',\n parameters: z.object({ msg: z.string() }),\n execute: async ({ msg }) => `echo: ${msg}`,\n });\n\n // invalid: msg should be a string\n const fc = FunctionCall.create({\n callId: 'call_invalid_args',\n name: 'echo',\n args: JSON.stringify({ msg: 123 }),\n });\n const toolCallStream = createFunctionCallStream(fc);\n const onToolExecutionStarted = vi.fn();\n\n const [execTask, toolOutput] = performToolExecutions({\n session: {} as any,\n speechHandle: { id: 'speech_invalid', _itemAdded: () => {} } as any,\n toolCtx: new ToolContext([echo]) as any,\n toolCallStream,\n controller: replyAbortController,\n onToolExecutionStarted,\n });\n\n await execTask.result;\n expect(onToolExecutionStarted).toHaveBeenCalledWith(fc);\n expect(JSON.parse(fc.args)).toEqual({ msg: 123 });\n expect(toolOutput.output.length).toBe(1);\n const out = toolOutput.output[0];\n expect(out?.toolCallOutput?.isError).toBe(true);\n // LLM must see enough detail (tool name + offending field) to self-correct,\n // not the masked generic message reserved for tool-runtime exceptions.\n const output = out?.toolCallOutput?.output ?? '';\n expect(output).toContain('Invalid arguments');\n expect(output).toContain('echo');\n expect(output).toContain('msg');\n expect(output).not.toContain('An internal error occurred');\n });\n\n it('should surface JSON parse errors to the LLM', async () => {\n const replyAbortController = new AbortController();\n\n const echo = tool({\n name: 'echo',\n description: 'echo',\n parameters: z.object({ msg: z.string() }),\n execute: async ({ msg }) => `echo: ${msg}`,\n });\n\n // unrepairable JSON: random text the repair pass can't recover\n const fc = FunctionCall.create({\n callId: 'call_invalid_json',\n name: 'echo',\n args: 'definitely not json',\n });\n const toolCallStream = createFunctionCallStream(fc);\n\n const [execTask, toolOutput] = performToolExecutions({\n session: {} as any,\n speechHandle: { id: 'speech_bad_json', _itemAdded: () => {} } as any,\n toolCtx: new ToolContext([echo]) as any,\n toolCallStream,\n controller: replyAbortController,\n });\n\n await execTask.result;\n expect(fc.args).toBe('{}');\n expect(toolOutput.output.length).toBe(1);\n const out = toolOutput.output[0];\n expect(out?.toolCallOutput?.isError).toBe(true);\n const output = out?.toolCallOutput?.output ?? '';\n expect(output).toContain('Invalid arguments');\n expect(output).toContain('echo');\n expect(output).not.toContain('An internal error occurred');\n });\n\n it('should mask generic tool exceptions so internal details do not reach the LLM', async () => {\n const replyAbortController = new AbortController();\n\n // The tool throws a regular Error whose message contains internals (db URL,\n // credentials) we must NOT forward to the LLM (and from there to end users).\n const sensitive = tool({\n name: 'sensitive',\n description: 'sensitive',\n parameters: z.object({}),\n execute: async () => {\n throw new Error('database connection failed: postgres://admin:hunter2@db.internal:5432');\n },\n });\n\n const fc = FunctionCall.create({\n callId: 'call_generic_error',\n name: 'sensitive',\n args: JSON.stringify({}),\n });\n const toolCallStream = createFunctionCallStream(fc);\n\n const [execTask, toolOutput] = performToolExecutions({\n session: {} as any,\n speechHandle: { id: 'speech_generic_err', _itemAdded: () => {} } as any,\n toolCtx: new ToolContext([sensitive]) as any,\n toolCallStream,\n controller: replyAbortController,\n });\n\n await execTask.result;\n expect(toolOutput.output.length).toBe(1);\n const out = toolOutput.output[0];\n expect(out?.toolCallOutput?.isError).toBe(true);\n const output = out?.toolCallOutput?.output ?? '';\n expect(output).toBe('An internal error occurred');\n expect(output).not.toContain('database');\n expect(output).not.toContain('hunter2');\n expect(output).not.toContain('postgres');\n // Raw exception is still preserved server-side for observability.\n expect(out?.rawException?.message).toContain('hunter2');\n });\n\n it('should forward ToolError messages to the LLM verbatim (escape hatch)', async () => {\n const replyAbortController = new AbortController();\n\n // Tools that intend to give the LLM a corrective hint opt in by throwing\n // ToolError — its message is forwarded as-is.\n const checked = tool({\n name: 'checked',\n description: 'checked',\n parameters: z.object({ qty: z.number() }),\n execute: async ({ qty }) => {\n if (qty <= 0) {\n throw new ToolError('qty must be positive — try again with a value greater than 0');\n }\n return qty;\n },\n });\n\n const fc = FunctionCall.create({\n callId: 'call_tool_error',\n name: 'checked',\n args: JSON.stringify({ qty: -1 }),\n });\n const toolCallStream = createFunctionCallStream(fc);\n\n const [execTask, toolOutput] = performToolExecutions({\n session: {} as any,\n speechHandle: { id: 'speech_tool_error', _itemAdded: () => {} } as any,\n toolCtx: new ToolContext([checked]) as any,\n toolCallStream,\n controller: replyAbortController,\n });\n\n await execTask.result;\n expect(toolOutput.output.length).toBe(1);\n const out = toolOutput.output[0];\n expect(out?.toolCallOutput?.isError).toBe(true);\n expect(out?.toolCallOutput?.output).toBe(\n 'qty must be positive — try again with a value greater than 0',\n );\n });\n\n it('should handle multiple tool calls within a single stream', async () => {\n const replyAbortController = new AbortController();\n\n const sum = tool({\n name: 'sum',\n description: 'sum',\n parameters: z.object({ a: z.number(), b: z.number() }),\n execute: async ({ a, b }) => a + b,\n });\n const upper = tool({\n name: 'upper',\n description: 'upper',\n parameters: z.object({ s: z.string() }),\n execute: async ({ s }) => s.toUpperCase(),\n });\n\n const fc1 = FunctionCall.create({\n callId: 'call_multi_1',\n name: 'sum',\n args: JSON.stringify({ a: 2, b: 3 }),\n });\n const fc2 = FunctionCall.create({\n callId: 'call_multi_2',\n name: 'upper',\n args: JSON.stringify({ s: 'hey' }),\n });\n const toolCallStream = createFunctionCallStreamFromArray([fc1, fc2]);\n\n const [execTask, toolOutput] = performToolExecutions({\n session: {} as any,\n speechHandle: { id: 'speech_multi', _itemAdded: () => {} } as any,\n toolCtx: new ToolContext([sum, upper]) as any,\n toolCallStream,\n controller: replyAbortController,\n });\n\n await execTask.result;\n expect(toolOutput.output.length).toBe(2);\n\n // sort by callId to assert deterministically\n const sorted = [...toolOutput.output].sort((a, b) =>\n a.toolCall.callId.localeCompare(b.toolCall.callId),\n );\n\n expect(sorted[0]?.toolCall.name).toBe('sum');\n expect(sorted[0]?.toolCallOutput?.isError).toBe(false);\n expect(sorted[0]?.toolCallOutput?.output).toBe('5');\n expect(sorted[1]?.toolCall.name).toBe('upper');\n expect(sorted[1]?.toolCallOutput?.isError).toBe(false);\n expect(sorted[1]?.toolCallOutput?.output).toBe('\"HEY\"');\n });\n});\n"],"mappings":";AAGA,iBAAqD;AACrD,oBAAoD;AACpD,iBAAkB;AAClB,iBAA2D;AAC3D,iBAAiC;AAEjC,mBAAqC;AACrC,mBAA0B;AAE1B,wBAKO;AAEP,2BAA6B;AAE7B,SAAS,mBAAmB,QAAkB,UAAkB,GAA+B;AAC7F,SAAO,IAAI,WAAAA,eAA2B;AAAA,IACpC,MAAM,MAAM,YAAY;AACtB,iBAAW,KAAK,QAAQ;AACtB,YAAI,UAAU,GAAG;AACf,oBAAM,oBAAM,OAAO;AAAA,QACrB;AACA,mBAAW,QAAQ,CAAC;AAAA,MACtB;AACA,iBAAW,MAAM;AAAA,IACnB;AAAA,EACF,CAAC;AACH;AAEA,SAAS,yBAAyB,IAAoD;AACpF,SAAO,IAAI,WAAAA,eAAiC;AAAA,IAC1C,MAAM,YAAY;AAChB,iBAAW,QAAQ,EAAE;AACrB,iBAAW,MAAM;AAAA,IACnB;AAAA,EACF,CAAC;AACH;AAEA,SAAS,kCAAkC,KAAuD;AAChG,SAAO,IAAI,WAAAA,eAAiC;AAAA,IAC1C,MAAM,YAAY;AAChB,iBAAW,MAAM,KAAK;AACpB,mBAAW,QAAQ,EAAE;AAAA,MACvB;AACA,iBAAW,MAAM;AAAA,IACnB;AAAA,EACF,CAAC;AACH;AAAA,IAEA,wBAAS,+BAA+B,MAAM;AAC5C,mCAAiB,EAAE,QAAQ,OAAO,OAAO,SAAS,CAAC;AAEnD,+BAAU,MAAM;AACd,qBAAG,cAAc;AAAA,EACnB,CAAC;AAED,wBAAG,iEAAiE,YAAY;AA9DlF;AA+DI,qBAAG,cAAc;AACjB,UAAM,uBAAuB,IAAI,gBAAgB;AACjD,UAAM,sBAAsB,IAAI,gBAAgB;AAEhD,UAAM,SAAS,MAAM,KAAK,EAAE,QAAQ,GAAG,GAAG,MAAM,KAAK;AACrD,UAAM,mBAAmB,OAAO,KAAK,EAAE;AACvC,UAAM,WAAW,mBAAmB,QAAQ,EAAE;AAC9C,UAAM,CAAC,iBAAiB,OAAO,QAA4B;AAAA,MACzD;AAAA,MACA;AAAA,MACA;AAAA,IACF;AAGA,QAAI,cAAc;AAClB,UAAM,iBAAa,iBAAK;AAAA,MACtB,MAAM;AAAA,MACN,aAAa;AAAA,MACb,YAAY,aAAE,OAAO,EAAE,UAAU,aAAE,OAAO,EAAE,CAAC;AAAA,MAC7C,SAAS,OAAO,EAAE,SAAS,GAAG,EAAE,YAAY,MAAM;AAChD,oBAAY,iBAAiB,SAAS,MAAM;AAC1C,wBAAc;AAAA,QAChB,CAAC;AAED,kBAAM,oBAAM,GAAI;AAChB,eAAO,YAAY,QAAQ;AAAA,MAC7B;AAAA,IACF,CAAC;AAED,UAAM,KAAK,wBAAa,OAAO;AAAA,MAC7B,QAAQ;AAAA,MACR,MAAM;AAAA,MACN,MAAM,KAAK,UAAU,EAAE,UAAU,gBAAgB,CAAC;AAAA,IACpD,CAAC;AACD,UAAM,iBAAiB,yBAAyB,EAAE;AAElD,UAAM,CAAC,UAAU,UAAU,QAAI,yCAAsB;AAAA,MACnD,SAAS,CAAC;AAAA,MACV,cAAc,EAAE,IAAI,eAAe,YAAY,MAAM;AAAA,MAAC,EAAE;AAAA,MACxD,SAAS,IAAI,uBAAY,CAAC,UAAU,CAAC;AAAA,MACrC;AAAA,MACA,YAAY;AAAA,MACZ,wBAAwB,MAAM;AAAA,MAAC;AAAA,MAC/B,0BAA0B,MAAM;AAAA,MAAC;AAAA,IACnC,CAAC;AAGD,UAAM,WAAW,uBAAuB;AACxC,UAAM,iBAAG,yBAAyB,GAAG;AACrC,UAAM,sBAAkB,4BAAc,CAAC,eAAe,GAAG,GAAI;AAC7D,UAAM,iBAAG,yBAAyB,EAAE;AACpC,UAAM;AAEN,UAAM,iBAAG,yBAAyB,GAAI;AACtC,UAAM,SAAS;AAEf,8BAAO,WAAW,OAAO,MAAM,EAAE,KAAK,CAAC;AACvC,UAAM,MAAM,WAAW,OAAO,CAAC;AAC/B,+BAAO,SAAI,mBAAJ,mBAAoB,OAAO,EAAE,KAAK,KAAK;AAC9C,+BAAO,SAAI,mBAAJ,mBAAoB,MAAM,EAAE,UAAU,wBAAwB;AAErE,8BAAO,QAAQ,IAAI,EAAE,IAAI,KAAK,gBAAgB;AAE9C,8BAAO,WAAW,EAAE,KAAK,KAAK;AAAA,EAChC,GAAG,GAAM;AAET,wBAAG,6CAA6C,YAAY;AAjI9D;AAkII,UAAM,uBAAuB,IAAI,gBAAgB;AAEjD,UAAM,WAAO,iBAAK;AAAA,MAChB,MAAM;AAAA,MACN,aAAa;AAAA,MACb,YAAY,aAAE,OAAO,EAAE,KAAK,aAAE,OAAO,EAAE,CAAC;AAAA,MACxC,SAAS,OAAO,EAAE,IAAI,MAAM,SAAS,GAAG;AAAA,IAC1C,CAAC;AAED,UAAM,KAAK,wBAAa,OAAO;AAAA,MAC7B,QAAQ;AAAA,MACR,MAAM;AAAA,MACN,MAAM,KAAK,UAAU,EAAE,KAAK,QAAQ,CAAC;AAAA,IACvC,CAAC;AACD,UAAM,iBAAiB,yBAAyB,EAAE;AAElD,UAAM,CAAC,UAAU,UAAU,QAAI,yCAAsB;AAAA,MACnD,SAAS,CAAC;AAAA,MACV,cAAc,EAAE,IAAI,gBAAgB,YAAY,MAAM;AAAA,MAAC,EAAE;AAAA,MACzD,SAAS,IAAI,uBAAY,CAAC,IAAI,CAAC;AAAA,MAC/B;AAAA,MACA,YAAY;AAAA,IACd,CAAC;AAED,UAAM,SAAS;AACf,8BAAO,WAAW,OAAO,MAAM,EAAE,KAAK,CAAC;AACvC,UAAM,MAAM,WAAW,OAAO,CAAC;AAC/B,+BAAO,gCAAK,mBAAL,mBAAqB,OAAO,EAAE,KAAK,KAAK;AAC/C,+BAAO,gCAAK,mBAAL,mBAAqB,MAAM,EAAE,UAAU,aAAa;AAAA,EAC7D,CAAC;AAED,wBAAG,sEAAsE,YAAY;AAjKvF;AAkKI,UAAM,uBAAuB,IAAI,gBAAgB;AAEjD,UAAM,sBAAkB,iBAAK;AAAA,MAC3B,MAAM;AAAA,MACN,aAAa;AAAA,MACb,YAAY,aAAE,OAAO,EAAE,SAAS,aAAE,MAAM,aAAE,OAAO,CAAC,EAAE,CAAC;AAAA,MACrD,SAAS,OAAO,EAAE,QAAQ,MAAM,QAAQ,KAAK,GAAG;AAAA,IAClD,CAAC;AAED,UAAM,UAAU;AAChB,UAAM,KAAK,wBAAa,OAAO;AAAA,MAC7B,QAAQ;AAAA,MACR,MAAM;AAAA,MACN,MAAM;AAAA,IACR,CAAC;AACD,UAAM,iBAAiB,yBAAyB,EAAE;AAElD,UAAM,CAAC,UAAU,UAAU,QAAI,yCAAsB;AAAA,MACnD,SAAS,CAAC;AAAA,MACV,cAAc,EAAE,IAAI,iBAAiB,YAAY,MAAM;AAAA,MAAC,EAAE;AAAA,MAC1D,SAAS,IAAI,uBAAY,CAAC,eAAe,CAAC;AAAA,MAC1C;AAAA,MACA,YAAY;AAAA,IACd,CAAC;AAED,UAAM,SAAS;AACf,8BAAO,WAAW,OAAO,MAAM,EAAE,KAAK,CAAC;AACvC,UAAM,MAAM,WAAW,OAAO,CAAC;AAC/B,+BAAO,gCAAK,mBAAL,mBAAqB,OAAO,EAAE,KAAK,KAAK;AAC/C,+BAAO,gCAAK,mBAAL,mBAAqB,MAAM,EAAE,KAAK,YAAY;AACrD,8BAAO,GAAG,IAAI,EAAE,IAAI,KAAK,OAAO;AAChC,8BAAO,KAAK,MAAM,GAAG,IAAI,CAAC,EAAE,QAAQ,EAAE,SAAS,CAAC,UAAU,EAAE,CAAC;AAAA,EAC/D,CAAC;AAED,wBAAG,yDAAyD,YAAY;AACtE,UAAM,uBAAuB,IAAI,gBAAgB;AAEjD,QAAI,UAAU;AAId,QAAI;AACJ,UAAM,cAAc,IAAI,QAAc,CAAC,YAAY;AACjD,0BAAoB;AAAA,IACtB,CAAC;AACD,UAAM,aAAS,iBAAK;AAAA,MAClB,MAAM;AAAA,MACN,aAAa;AAAA,MACb,YAAY,aAAE,OAAO,EAAE,IAAI,aAAE,OAAO,EAAE,CAAC;AAAA,MACvC,SAAS,OAAO,EAAE,GAAG,GAAG,EAAE,YAAY,MAAM;AAC1C,oBAAY,iBAAiB,SAAS,MAAM;AAC1C,oBAAU;AAAA,QACZ,CAAC;AACD,0BAAkB;AAClB,kBAAM,oBAAM,EAAE;AACd,eAAO;AAAA,MACT;AAAA,IACF,CAAC;AAED,UAAM,KAAK,wBAAa,OAAO;AAAA,MAC7B,QAAQ;AAAA,MACR,MAAM;AAAA,MACN,MAAM,KAAK,UAAU,EAAE,IAAI,IAAK,CAAC;AAAA,IACnC,CAAC;AACD,UAAM,iBAAiB,yBAAyB,EAAE;AAElD,UAAM,CAAC,UAAU,UAAU,QAAI,yCAAsB;AAAA,MACnD,SAAS,CAAC;AAAA,MACV,cAAc,EAAE,IAAI,gBAAgB,YAAY,MAAM;AAAA,MAAC,EAAE;AAAA,MACzD,SAAS,IAAI,uBAAY,CAAC,MAAM,CAAC;AAAA,MACjC;AAAA,MACA,YAAY;AAAA,IACd,CAAC;AAED,UAAM;AACN,yBAAqB,MAAM;AAC3B,UAAM,SAAS;AAEf,8BAAO,OAAO,EAAE,KAAK,IAAI;AACzB,8BAAO,WAAW,MAAM,EAAE,aAAa,CAAC;AAAA,EAC1C,GAAG,GAAM;AAET,wBAAG,uEAAuE,YAAY;AACpF,UAAM,uBAAuB,IAAI,gBAAgB;AACjD,UAAM,UAAU,QAAQ,QAAQ,WAAW;AAC3C,yBAAqB,MAAM;AAE3B,cAAM;AAAA,UACJ,+CAA4B,SAAS,qBAAqB,MAAM;AAAA,IAClE,EAAE,SAAS,QAAQ;AAAA,MACjB,QAAQ;AAAA,MACR,WAAW;AAAA,IACb,CAAC;AAAA,EACH,CAAC;AAED,wBAAG,gFAAgF,YAAY;AAC7F,UAAM,uBAAuB,IAAI,gBAAgB;AACjD,UAAM,cAAc,IAAI,QAAc,MAAM;AAAA,IAAC,CAAC;AAC9C,QAAI;AACJ,UAAM,cAAc,IAAI,QAAc,CAAC,YAAY;AACjD,0BAAoB;AAAA,IACtB,CAAC;AACD,QAAI;AACJ,UAAM,iBAAiB,IAAI,QAAc,CAAC,YAAY;AACpD,6BAAuB;AAAA,IACzB,CAAC;AACD,QAAI;AACJ,UAAM,YAAY,IAAI,QAAc,CAAC,YAAY;AAC/C,wBAAkB;AAAA,IACpB,CAAC;AAED,UAAM,gBAAY,iBAAK;AAAA,MACrB,MAAM;AAAA,MACN,aAAa;AAAA,MACb,YAAY,aAAE,OAAO,CAAC,CAAC;AAAA,MACvB,SAAS,YAAY;AAAA,IACvB,CAAC;AACD,UAAM,WAAO,iBAAK;AAAA,MAChB,MAAM;AAAA,MACN,aAAa;AAAA,MACb,YAAY,aAAE,OAAO,CAAC,CAAC;AAAA,MACvB,SAAS,YAAY;AACnB,0BAAkB;AAClB,cAAM;AACN,eAAO;AAAA,MACT;AAAA,IACF,CAAC;AACD,UAAM,cAAU,iBAAK;AAAA,MACnB,MAAM;AAAA,MACN,aAAa;AAAA,MACb,YAAY,aAAE,OAAO,CAAC,CAAC;AAAA,MACvB,SAAS,YAAY;AACnB,6BAAqB;AACrB,cAAM;AACN,eAAO,IAAI,uBAAU,EAAE,cAAc,kCAAkC,CAAC;AAAA,MAC1E;AAAA,IACF,CAAC;AACD,UAAM,QAAQ;AAAA,MACZ,wBAAa,OAAO,EAAE,QAAQ,kBAAkB,MAAM,UAAU,MAAM,MAAM,KAAK,CAAC;AAAA,MAClF,wBAAa,OAAO,EAAE,QAAQ,aAAa,MAAM,KAAK,MAAM,MAAM,KAAK,CAAC;AAAA,MACxE,wBAAa,OAAO,EAAE,QAAQ,gBAAgB,MAAM,QAAQ,MAAM,MAAM,KAAK,CAAC;AAAA,IAChF;AACA,UAAM,mBAA6B,CAAC;AAEpC,UAAM,CAAC,UAAU,UAAU,QAAI,yCAAsB;AAAA,MACnD,SAAS,CAAC;AAAA,MACV,cAAc,EAAE,IAAI,sBAAsB,YAAY,MAAM;AAAA,MAAC,EAAE;AAAA,MAC/D,SAAS,IAAI,uBAAY,CAAC,WAAW,MAAM,OAAO,CAAC;AAAA,MACnD,gBAAgB,kCAAkC,KAAK;AAAA,MACvD,YAAY;AAAA,MACZ,0BAA0B,CAAC,WAAW;AACpC,yBAAiB,KAAK,OAAO,SAAS,MAAM;AAC5C,YAAI,OAAO,SAAS,WAAW,iBAAkB,iBAAgB;AAAA,MACnE;AAAA,IACF,CAAC;AAED,UAAM,QAAQ,IAAI,CAAC,WAAW,aAAa,cAAc,CAAC;AAC1D,yBAAqB,MAAM;AAC3B,UAAM,SAAS;AAEf,8BAAO,WAAW,OAAO,IAAI,CAAC,WAAW,OAAO,SAAS,MAAM,CAAC,EAAE,QAAQ,CAAC,gBAAgB,CAAC;AAC5F,8BAAO,gBAAgB,EAAE,QAAQ,CAAC,gBAAgB,CAAC;AAAA,EACrD,CAAC;AAED,wBAAG,sFAAsF,YAAY;AACnG,UAAM,iBAAiB,IAAI,kCAAa,EAAE,gBAAgB,KAAK,CAAC;AAChE,UAAM,UAAU,EAAE,WAAW,EAAE,eAAe,eAAe,EAAE;AAC/D,UAAM,eAAe,EAAE,IAAI,cAAc,YAAY,MAAM;AAAA,IAAC,EAAE;AAE9D,QAAI;AACJ,UAAM,eAAe,IAAI,QAAc,CAAC,YAAY;AAClD,qBAAe;AAAA,IACjB,CAAC;AACD,QAAI;AACJ,UAAM,eAAe,IAAI,QAAc,CAAC,YAAY;AAClD,2BAAqB;AAAA,IACvB,CAAC;AACD,UAAM,WAAO,iBAAK;AAAA,MAChB,MAAM;AAAA,MACN,aAAa;AAAA,MACb,aAAa;AAAA,MACb,YAAY,aAAE,OAAO,CAAC,CAAC;AAAA,MACvB,SAAS,YAAY;AACnB,2BAAmB;AACnB,cAAM;AACN,eAAO;AAAA,MACT;AAAA,IACF,CAAC;AACD,UAAM,UAAU,IAAI,uBAAY,CAAC,IAAI,CAAC;AAGtC,UAAM,MAAM,wBAAa,OAAO,EAAE,QAAQ,UAAU,MAAM,QAAQ,MAAM,KAAK,CAAC;AAC9E,UAAM,CAAC,KAAK,QAAI,yCAAsB;AAAA,MACpC;AAAA,MACA;AAAA,MACA;AAAA,MACA,gBAAgB,yBAAyB,GAAG;AAAA,MAC5C,YAAY,IAAI,gBAAgB;AAAA,IAClC,CAAC;AACD,UAAM;AAGN,UAAM,MAAM,wBAAa,OAAO,EAAE,QAAQ,UAAU,MAAM,QAAQ,MAAM,KAAK,CAAC;AAC9E,UAAM,CAAC,OAAO,IAAI,QAAI,yCAAsB;AAAA,MAC1C;AAAA,MACA;AAAA,MACA;AAAA,MACA,gBAAgB,yBAAyB,GAAG;AAAA,MAC5C,YAAY,IAAI,gBAAgB;AAAA,IAClC,CAAC;AAGD,UAAM,KAAK,uBAAuB;AAClC,UAAM,MAAM;AAGZ,8BAAO,KAAK,OAAO,MAAM,EAAE,KAAK,CAAC;AAEjC,iBAAa;AACb,UAAM,MAAM;AAAA,EACd,GAAG,GAAM;AAET,wBAAG,uEAAuE,YAAY;AAhYxF;AAiYI,UAAM,SAAmB,CAAC;AAC1B,UAAM,KAAK,wBAAa,OAAO;AAAA,MAC7B,QAAQ;AAAA,MACR,MAAM;AAAA,MACN,MAAM;AAAA,IACR,CAAC;AACD,UAAM,CAAC,UAAU,UAAU,QAAI,yCAAsB;AAAA,MACnD,SAAS,CAAC;AAAA,MACV,cAAc,EAAE,IAAI,kBAAkB,YAAY,MAAM;AAAA,MAAC,EAAE;AAAA,MAC3D,SAAS,uBAAY,MAAM;AAAA,MAC3B,gBAAgB,yBAAyB,EAAE;AAAA,MAC3C,YAAY,IAAI,gBAAgB;AAAA,MAChC,wBAAwB,CAAC,SAAS,OAAO,KAAK,QAAQ,KAAK,MAAM,EAAE;AAAA,MACnE,0BAA0B,CAAC,WAAW,OAAO,KAAK,UAAU,OAAO,SAAS,MAAM,EAAE;AAAA,IACtF,CAAC;AAED,UAAM,SAAS;AAEf,8BAAO,MAAM,EAAE,QAAQ,CAAC,qBAAqB,qBAAqB,CAAC;AACnE,8BAAO,GAAG,IAAI,EAAE,KAAK,IAAI;AACzB,8BAAO,WAAW,uBAAuB,IAAI,EAAE,KAAK,IAAI;AACxD,+BAAO,gBAAW,OAAO,CAAC,MAAnB,mBAAsB,cAAc,EAAE,cAAc;AAAA,MACzD,QAAQ;AAAA,MACR,SAAS;AAAA,IACX,CAAC;AAAA,EACH,CAAC;AAED,wBAAG,2EAA2E,YAAY;AA5Z5F;AA6ZI,UAAM,uBAAuB,IAAI,gBAAgB;AAEjD,UAAM,WAAO,iBAAK;AAAA,MAChB,MAAM;AAAA,MACN,aAAa;AAAA,MACb,YAAY,aAAE,OAAO,EAAE,KAAK,aAAE,OAAO,EAAE,CAAC;AAAA,MACxC,SAAS,OAAO,EAAE,IAAI,MAAM,SAAS,GAAG;AAAA,IAC1C,CAAC;AAGD,UAAM,KAAK,wBAAa,OAAO;AAAA,MAC7B,QAAQ;AAAA,MACR,MAAM;AAAA,MACN,MAAM,KAAK,UAAU,EAAE,KAAK,IAAI,CAAC;AAAA,IACnC,CAAC;AACD,UAAM,iBAAiB,yBAAyB,EAAE;AAClD,UAAM,yBAAyB,iBAAG,GAAG;AAErC,UAAM,CAAC,UAAU,UAAU,QAAI,yCAAsB;AAAA,MACnD,SAAS,CAAC;AAAA,MACV,cAAc,EAAE,IAAI,kBAAkB,YAAY,MAAM;AAAA,MAAC,EAAE;AAAA,MAC3D,SAAS,IAAI,uBAAY,CAAC,IAAI,CAAC;AAAA,MAC/B;AAAA,MACA,YAAY;AAAA,MACZ;AAAA,IACF,CAAC;AAED,UAAM,SAAS;AACf,8BAAO,sBAAsB,EAAE,qBAAqB,EAAE;AACtD,8BAAO,KAAK,MAAM,GAAG,IAAI,CAAC,EAAE,QAAQ,EAAE,KAAK,IAAI,CAAC;AAChD,8BAAO,WAAW,OAAO,MAAM,EAAE,KAAK,CAAC;AACvC,UAAM,MAAM,WAAW,OAAO,CAAC;AAC/B,+BAAO,gCAAK,mBAAL,mBAAqB,OAAO,EAAE,KAAK,IAAI;AAG9C,UAAM,WAAS,gCAAK,mBAAL,mBAAqB,WAAU;AAC9C,8BAAO,MAAM,EAAE,UAAU,mBAAmB;AAC5C,8BAAO,MAAM,EAAE,UAAU,MAAM;AAC/B,8BAAO,MAAM,EAAE,UAAU,KAAK;AAC9B,8BAAO,MAAM,EAAE,IAAI,UAAU,4BAA4B;AAAA,EAC3D,CAAC;AAED,wBAAG,+CAA+C,YAAY;AAvchE;AAwcI,UAAM,uBAAuB,IAAI,gBAAgB;AAEjD,UAAM,WAAO,iBAAK;AAAA,MAChB,MAAM;AAAA,MACN,aAAa;AAAA,MACb,YAAY,aAAE,OAAO,EAAE,KAAK,aAAE,OAAO,EAAE,CAAC;AAAA,MACxC,SAAS,OAAO,EAAE,IAAI,MAAM,SAAS,GAAG;AAAA,IAC1C,CAAC;AAGD,UAAM,KAAK,wBAAa,OAAO;AAAA,MAC7B,QAAQ;AAAA,MACR,MAAM;AAAA,MACN,MAAM;AAAA,IACR,CAAC;AACD,UAAM,iBAAiB,yBAAyB,EAAE;AAElD,UAAM,CAAC,UAAU,UAAU,QAAI,yCAAsB;AAAA,MACnD,SAAS,CAAC;AAAA,MACV,cAAc,EAAE,IAAI,mBAAmB,YAAY,MAAM;AAAA,MAAC,EAAE;AAAA,MAC5D,SAAS,IAAI,uBAAY,CAAC,IAAI,CAAC;AAAA,MAC/B;AAAA,MACA,YAAY;AAAA,IACd,CAAC;AAED,UAAM,SAAS;AACf,8BAAO,GAAG,IAAI,EAAE,KAAK,IAAI;AACzB,8BAAO,WAAW,OAAO,MAAM,EAAE,KAAK,CAAC;AACvC,UAAM,MAAM,WAAW,OAAO,CAAC;AAC/B,+BAAO,gCAAK,mBAAL,mBAAqB,OAAO,EAAE,KAAK,IAAI;AAC9C,UAAM,WAAS,gCAAK,mBAAL,mBAAqB,WAAU;AAC9C,8BAAO,MAAM,EAAE,UAAU,mBAAmB;AAC5C,8BAAO,MAAM,EAAE,UAAU,MAAM;AAC/B,8BAAO,MAAM,EAAE,IAAI,UAAU,4BAA4B;AAAA,EAC3D,CAAC;AAED,wBAAG,gFAAgF,YAAY;AA5ejG;AA6eI,UAAM,uBAAuB,IAAI,gBAAgB;AAIjD,UAAM,gBAAY,iBAAK;AAAA,MACrB,MAAM;AAAA,MACN,aAAa;AAAA,MACb,YAAY,aAAE,OAAO,CAAC,CAAC;AAAA,MACvB,SAAS,YAAY;AACnB,cAAM,IAAI,MAAM,uEAAuE;AAAA,MACzF;AAAA,IACF,CAAC;AAED,UAAM,KAAK,wBAAa,OAAO;AAAA,MAC7B,QAAQ;AAAA,MACR,MAAM;AAAA,MACN,MAAM,KAAK,UAAU,CAAC,CAAC;AAAA,IACzB,CAAC;AACD,UAAM,iBAAiB,yBAAyB,EAAE;AAElD,UAAM,CAAC,UAAU,UAAU,QAAI,yCAAsB;AAAA,MACnD,SAAS,CAAC;AAAA,MACV,cAAc,EAAE,IAAI,sBAAsB,YAAY,MAAM;AAAA,MAAC,EAAE;AAAA,MAC/D,SAAS,IAAI,uBAAY,CAAC,SAAS,CAAC;AAAA,MACpC;AAAA,MACA,YAAY;AAAA,IACd,CAAC;AAED,UAAM,SAAS;AACf,8BAAO,WAAW,OAAO,MAAM,EAAE,KAAK,CAAC;AACvC,UAAM,MAAM,WAAW,OAAO,CAAC;AAC/B,+BAAO,gCAAK,mBAAL,mBAAqB,OAAO,EAAE,KAAK,IAAI;AAC9C,UAAM,WAAS,gCAAK,mBAAL,mBAAqB,WAAU;AAC9C,8BAAO,MAAM,EAAE,KAAK,4BAA4B;AAChD,8BAAO,MAAM,EAAE,IAAI,UAAU,UAAU;AACvC,8BAAO,MAAM,EAAE,IAAI,UAAU,SAAS;AACtC,8BAAO,MAAM,EAAE,IAAI,UAAU,UAAU;AAEvC,+BAAO,gCAAK,iBAAL,mBAAmB,OAAO,EAAE,UAAU,SAAS;AAAA,EACxD,CAAC;AAED,wBAAG,wEAAwE,YAAY;AAthBzF;AAuhBI,UAAM,uBAAuB,IAAI,gBAAgB;AAIjD,UAAM,cAAU,iBAAK;AAAA,MACnB,MAAM;AAAA,MACN,aAAa;AAAA,MACb,YAAY,aAAE,OAAO,EAAE,KAAK,aAAE,OAAO,EAAE,CAAC;AAAA,MACxC,SAAS,OAAO,EAAE,IAAI,MAAM;AAC1B,YAAI,OAAO,GAAG;AACZ,gBAAM,IAAI,qBAAU,mEAA8D;AAAA,QACpF;AACA,eAAO;AAAA,MACT;AAAA,IACF,CAAC;AAED,UAAM,KAAK,wBAAa,OAAO;AAAA,MAC7B,QAAQ;AAAA,MACR,MAAM;AAAA,MACN,MAAM,KAAK,UAAU,EAAE,KAAK,GAAG,CAAC;AAAA,IAClC,CAAC;AACD,UAAM,iBAAiB,yBAAyB,EAAE;AAElD,UAAM,CAAC,UAAU,UAAU,QAAI,yCAAsB;AAAA,MACnD,SAAS,CAAC;AAAA,MACV,cAAc,EAAE,IAAI,qBAAqB,YAAY,MAAM;AAAA,MAAC,EAAE;AAAA,MAC9D,SAAS,IAAI,uBAAY,CAAC,OAAO,CAAC;AAAA,MAClC;AAAA,MACA,YAAY;AAAA,IACd,CAAC;AAED,UAAM,SAAS;AACf,8BAAO,WAAW,OAAO,MAAM,EAAE,KAAK,CAAC;AACvC,UAAM,MAAM,WAAW,OAAO,CAAC;AAC/B,+BAAO,gCAAK,mBAAL,mBAAqB,OAAO,EAAE,KAAK,IAAI;AAC9C,+BAAO,gCAAK,mBAAL,mBAAqB,MAAM,EAAE;AAAA,MAClC;AAAA,IACF;AAAA,EACF,CAAC;AAED,wBAAG,4DAA4D,YAAY;AA/jB7E;AAgkBI,UAAM,uBAAuB,IAAI,gBAAgB;AAEjD,UAAM,UAAM,iBAAK;AAAA,MACf,MAAM;AAAA,MACN,aAAa;AAAA,MACb,YAAY,aAAE,OAAO,EAAE,GAAG,aAAE,OAAO,GAAG,GAAG,aAAE,OAAO,EAAE,CAAC;AAAA,MACrD,SAAS,OAAO,EAAE,GAAG,EAAE,MAAM,IAAI;AAAA,IACnC,CAAC;AACD,UAAM,YAAQ,iBAAK;AAAA,MACjB,MAAM;AAAA,MACN,aAAa;AAAA,MACb,YAAY,aAAE,OAAO,EAAE,GAAG,aAAE,OAAO,EAAE,CAAC;AAAA,MACtC,SAAS,OAAO,EAAE,EAAE,MAAM,EAAE,YAAY;AAAA,IAC1C,CAAC;AAED,UAAM,MAAM,wBAAa,OAAO;AAAA,MAC9B,QAAQ;AAAA,MACR,MAAM;AAAA,MACN,MAAM,KAAK,UAAU,EAAE,GAAG,GAAG,GAAG,EAAE,CAAC;AAAA,IACrC,CAAC;AACD,UAAM,MAAM,wBAAa,OAAO;AAAA,MAC9B,QAAQ;AAAA,MACR,MAAM;AAAA,MACN,MAAM,KAAK,UAAU,EAAE,GAAG,MAAM,CAAC;AAAA,IACnC,CAAC;AACD,UAAM,iBAAiB,kCAAkC,CAAC,KAAK,GAAG,CAAC;AAEnE,UAAM,CAAC,UAAU,UAAU,QAAI,yCAAsB;AAAA,MACnD,SAAS,CAAC;AAAA,MACV,cAAc,EAAE,IAAI,gBAAgB,YAAY,MAAM;AAAA,MAAC,EAAE;AAAA,MACzD,SAAS,IAAI,uBAAY,CAAC,KAAK,KAAK,CAAC;AAAA,MACrC;AAAA,MACA,YAAY;AAAA,IACd,CAAC;AAED,UAAM,SAAS;AACf,8BAAO,WAAW,OAAO,MAAM,EAAE,KAAK,CAAC;AAGvC,UAAM,SAAS,CAAC,GAAG,WAAW,MAAM,EAAE;AAAA,MAAK,CAAC,GAAG,MAC7C,EAAE,SAAS,OAAO,cAAc,EAAE,SAAS,MAAM;AAAA,IACnD;AAEA,+BAAO,YAAO,CAAC,MAAR,mBAAW,SAAS,IAAI,EAAE,KAAK,KAAK;AAC3C,+BAAO,kBAAO,CAAC,MAAR,mBAAW,mBAAX,mBAA2B,OAAO,EAAE,KAAK,KAAK;AACrD,+BAAO,kBAAO,CAAC,MAAR,mBAAW,mBAAX,mBAA2B,MAAM,EAAE,KAAK,GAAG;AAClD,+BAAO,YAAO,CAAC,MAAR,mBAAW,SAAS,IAAI,EAAE,KAAK,OAAO;AAC7C,+BAAO,kBAAO,CAAC,MAAR,mBAAW,mBAAX,mBAA2B,OAAO,EAAE,KAAK,KAAK;AACrD,+BAAO,kBAAO,CAAC,MAAR,mBAAW,mBAAX,mBAA2B,MAAM,EAAE,KAAK,OAAO;AAAA,EACxD,CAAC;AACH,CAAC;","names":["NodeReadableStream"]}