{"version":3,"file":"checkpoint.cjs","sources":["@gensx/core/../../../../src/checkpoint.ts"],"sourcesContent":["import { Buffer } from \"node:buffer\";\nimport { createHash } from \"node:crypto\";\nimport { join } from \"node:path\";\nimport { hrtime } from \"node:process\";\nimport { promisify } from \"node:util\";\nimport { gzip } from \"node:zlib\";\n\nimport {\n CheckpointWriter,\n ContentId,\n ExecutionNode,\n NodeId,\n PathId,\n STREAMING_PLACEHOLDER,\n} from \"./checkpoint-types.js\";\nimport { isAsyncIterable, isReadableStream } from \"./component.js\";\nimport { readConfig } from \"./utils/config.js\";\nimport { generateNodeId, stringifyProps } from \"./utils/nodeId.js\";\nimport { USER_AGENT } from \"./utils/user-agent.js\";\n\nexport type { CheckpointWriter, ExecutionNode, NodeId };\nexport { STREAMING_PLACEHOLDER };\n\nconst gzipAsync = promisify(gzip);\n\nclass NodeMap {\n // Primary lookup by full ID\n private idLookup = new Map();\n\n // Secondary lookups for fuzzy matching\n private pathLookup = new Map>(); // pathId -> Set\n private contentLookup = new Map>(); // contentId -> Set\n private pathContentLookup = new Map>(); // pathId:contentId -> Set\n\n set(node: T) {\n this.idLookup.set(node.id, node);\n\n // Update secondary lookups\n const pathId = getPathId(node.id);\n if (pathId) {\n if (!this.pathLookup.has(pathId)) {\n this.pathLookup.set(pathId, new Set());\n }\n this.pathLookup.get(pathId)!.add(node.id);\n }\n\n const contentId = getContentId(node.id);\n if (contentId) {\n if (!this.contentLookup.has(contentId)) {\n this.contentLookup.set(contentId, new Set());\n }\n this.contentLookup.get(contentId)!.add(node.id);\n }\n\n const pathContentId = `${pathId}:${contentId}`;\n if (!this.pathContentLookup.has(pathContentId)) {\n this.pathContentLookup.set(pathContentId, new Set());\n }\n this.pathContentLookup.get(pathContentId)!.add(node.id);\n }\n\n get(primaryIdOrNode: string | T): T | undefined {\n if (typeof primaryIdOrNode === \"string\") {\n return this.idLookup.get(primaryIdOrNode);\n }\n\n const node = primaryIdOrNode;\n return this.idLookup.get(node.id);\n }\n\n has(primaryIdOrNode: string | T): boolean {\n if (typeof primaryIdOrNode === \"string\") {\n return this.idLookup.has(primaryIdOrNode);\n }\n return this.get(primaryIdOrNode) !== undefined;\n }\n\n getByPathAndContent(pathId: string, contentId: string): T[] {\n const primaryIds =\n this.pathContentLookup.get(`${pathId}:${contentId}`) ?? new Set();\n return Array.from(primaryIds)\n .map((id) => this.idLookup.get(id))\n .filter((node): node is T => node !== undefined);\n }\n\n getByPath(pathId: string): T[] {\n const primaryIds = this.pathLookup.get(pathId) ?? new Set();\n return Array.from(primaryIds)\n .map((id) => this.idLookup.get(id))\n .filter((node): node is T => node !== undefined);\n }\n\n getByContent(contentId: string): T[] {\n const primaryIds = this.contentLookup.get(contentId) ?? new Set();\n return Array.from(primaryIds)\n .map((id) => this.idLookup.get(id))\n .filter((node): node is T => node !== undefined);\n }\n\n entries() {\n return Array.from(this.idLookup.entries());\n }\n\n clear() {\n this.idLookup.clear();\n this.pathLookup.clear();\n this.contentLookup.clear();\n this.pathContentLookup.clear();\n }\n}\n\nexport class CheckpointManager implements CheckpointWriter {\n private nodes = new NodeMap();\n private orphanedNodes = new Map>();\n private _secretValues = new Map>(); // Internal per-node secrets\n private currentNodeChain: ExecutionNode[] = []; // Track current execution context\n private readonly MIN_SECRET_LENGTH = 8;\n public root?: ExecutionNode;\n public checkpointsEnabled: boolean;\n public workflowName?: string;\n private activeCheckpoint: Promise | null = null;\n private pendingUpdate = false;\n private version = 1;\n private org: string;\n private apiKey: string;\n private apiBaseUrl: string;\n private consoleBaseUrl: string;\n private printUrl = false;\n private runtime?: \"cloud\" | \"sdk\";\n private runtimeVersion?: string;\n private checkpointListener?: (root: ExecutionNode) => Promise;\n\n private traceId?: string;\n private executionRunId?: string;\n\n // Replay functionality with enhanced fuzzy matching\n private replayLookup: ExecutionNode[] = [];\n\n // Provide unified view of all secrets\n get secretValues(): Set {\n const allSecrets = new Set();\n for (const secrets of this._secretValues.values()) {\n for (const secret of secrets) {\n allSecrets.add(secret);\n }\n }\n return allSecrets;\n }\n\n // Public getter for testing purposes\n get nodesForTesting(): Map {\n const legacyMap = new Map();\n for (const [primaryId, node] of this.nodes.entries()) {\n legacyMap.set(primaryId, node);\n }\n return legacyMap;\n }\n\n private callCounters = new Map();\n\n public getNextCallIndex(\n parentPath: string,\n componentName: string,\n props: Record,\n idPropsKeys: string[] | undefined,\n ): number {\n const contentContext = {\n name: componentName,\n props: stringifyProps(props, idPropsKeys),\n parent: parentPath,\n };\n const contentStr = JSON.stringify(contentContext);\n const contentHash = createHash(\"sha256\")\n .update(contentStr)\n .digest(\"hex\")\n .slice(0, 8);\n const key = `${parentPath}-${componentName}:${contentHash}`;\n const current = this.callCounters.get(key) ?? 0;\n this.callCounters.set(key, current + 1);\n return current;\n }\n\n constructor(opts?: {\n apiKey?: string;\n org?: string;\n disabled?: boolean;\n apiBaseUrl?: string;\n consoleBaseUrl?: string;\n executionRunId?: string;\n runtime?: \"cloud\" | \"sdk\";\n runtimeVersion?: string;\n checkpoint?: ExecutionNode;\n }) {\n // Priority order: constructor opts > env vars > config file\n const config = readConfig();\n const apiKey =\n opts?.apiKey ?? process.env.GENSX_API_KEY ?? config.api?.token;\n const org = opts?.org ?? process.env.GENSX_ORG ?? config.api?.org;\n const apiBaseUrl =\n opts?.apiBaseUrl ?? process.env.GENSX_API_BASE_URL ?? config.api?.baseUrl;\n const consoleBaseUrl =\n opts?.consoleBaseUrl ??\n process.env.GENSX_CONSOLE_URL ??\n config.console?.baseUrl;\n\n this.checkpointsEnabled = apiKey !== undefined;\n this.org = org ?? \"\";\n this.apiKey = apiKey ?? \"\";\n this.apiBaseUrl = apiBaseUrl ?? \"https://api.gensx.com\";\n this.consoleBaseUrl = consoleBaseUrl ?? \"https://app.gensx.com\";\n\n const runtime = opts?.runtime ?? process.env.GENSX_RUNTIME;\n if (runtime && runtime !== \"cloud\" && runtime !== \"sdk\") {\n throw new Error('Invalid runtime. Must be either \"cloud\" or \"sdk\"');\n }\n this.runtime = runtime as \"cloud\" | \"sdk\" | undefined;\n this.runtimeVersion =\n opts?.runtimeVersion ?? process.env.GENSX_RUNTIME_VERSION;\n\n this.executionRunId =\n opts?.executionRunId ?? process.env.GENSX_EXECUTION_RUN_ID;\n\n if (\n opts?.disabled ||\n process.env.GENSX_CHECKPOINTS === \"false\" ||\n process.env.GENSX_CHECKPOINTS === \"0\" ||\n process.env.GENSX_CHECKPOINTS === \"no\" ||\n process.env.GENSX_CHECKPOINTS === \"off\"\n ) {\n this.checkpointsEnabled = false;\n }\n\n if (this.checkpointsEnabled && !this.org) {\n throw new Error(\n \"Organization not set. Set it via constructor options, GENSX_ORG environment variable, or in ~/.config/gensx/config. You can disable checkpoints by setting GENSX_CHECKPOINTS=false or unsetting GENSX_API_KEY.\",\n );\n }\n\n if (opts?.checkpoint) {\n this.buildReplayLookup(opts.checkpoint);\n }\n }\n\n private attachToParent(\n nodeToUpdate: ExecutionNode,\n parentToUpdate: ExecutionNode,\n ) {\n const node = this.nodes.get(nodeToUpdate);\n if (!node) {\n throw new Error(\"Node not found\");\n }\n const parent = this.nodes.get(parentToUpdate);\n if (!parent) {\n throw new Error(\"Parent node not found\");\n }\n node.parentId = parent.id;\n if (!parent.children.some((child) => child.id === node.id)) {\n parent.children.push(node);\n }\n }\n\n private handleOrphanedNode(node: ExecutionNode, parent: ExecutionNode) {\n let orphans = this.orphanedNodes.get(parent.id);\n if (!orphans) {\n orphans = new Set();\n this.orphanedNodes.set(parent.id, orphans);\n }\n orphans.add(node);\n\n // Add diagnostic timeout to detect stuck orphans\n this.checkOrphanTimeout(node, parent);\n }\n\n private isNativeFunction(value: unknown): boolean {\n return (\n typeof value === \"function\" &&\n Function.prototype.toString.call(value).includes(\"[native code]\")\n );\n }\n\n private checkOrphanTimeout(\n expectedNode: ExecutionNode,\n expectedParent: ExecutionNode,\n ) {\n setTimeout(() => {\n const orphans = this.orphanedNodes.get(expectedParent.id);\n const node = this.nodes.get(expectedNode);\n if (!node) {\n console.warn(\n `[Checkpoint] Node ${expectedNode.id} (${expectedNode.componentName}) no longer exists`,\n );\n return;\n }\n if (orphans?.has(node)) {\n console.warn(\n `[Checkpoint] Node ${node.id} (${node.componentName}) still waiting for parent ${expectedParent.id} after 5s`,\n {\n node,\n existingNodes: Array.from(this.nodes.entries()).map(\n ([id, node]) => ({\n id,\n componentName: node.componentName,\n parentId: node.parentId,\n }),\n ),\n },\n );\n }\n }, 5000);\n }\n\n /**\n * Validates that the execution tree is in a complete state where:\n * 1. Root node exists\n * 2. No orphaned nodes are waiting for parents\n * 3. All parent-child relationships are properly connected\n */\n private isTreeValid(): boolean {\n // No root means tree isn't valid\n if (!this.root) return false;\n\n // If we have orphaned nodes, tree isn't complete\n if (this.orphanedNodes.size > 0) return false;\n\n // Verify all nodes in the tree have their parents\n const verifyNode = (node: ExecutionNode): boolean => {\n for (const child of node.children) {\n if (child.parentId !== node.id) return false;\n if (!verifyNode(child)) return false;\n }\n return true;\n };\n\n return verifyNode(this.root);\n }\n\n /**\n * Updates the checkpoint in a non-blocking manner while ensuring consistency.\n * Special care is taken to:\n * 1. Queue updates instead of writing immediately to minimize API calls\n * 2. Only write one checkpoint at a time to maintain order\n * 3. Track pending updates to ensure no state is lost\n * 4. Validate tree completeness before writing\n *\n * The flow is:\n * 1. If a write is in progress, mark pendingUpdate = true\n * 2. When write completes, check pendingUpdate and trigger another write if needed\n * 3. Only write if tree is valid (has root and no orphans)\n */\n private updateCheckpoint() {\n if (!this.checkpointsEnabled) {\n return;\n }\n\n // Only write if we have a valid tree\n if (!this.isTreeValid()) {\n this.pendingUpdate = true;\n return;\n }\n\n // If there's already a pending update, just mark that we need another update\n if (this.activeCheckpoint) {\n this.pendingUpdate = true;\n return;\n }\n\n // Start a new checkpoint write\n this.activeCheckpoint = this.writeCheckpoint().finally(() => {\n this.activeCheckpoint = null;\n\n // If there was a pending update requested while we were writing,\n // trigger another write\n if (this.pendingUpdate) {\n this.pendingUpdate = false;\n this.updateCheckpoint();\n }\n });\n }\n\n private havePrintedUrl = false;\n private async writeCheckpoint() {\n if (!this.root) return;\n\n await this.checkpointListener?.(this.root);\n\n try {\n // Create a deep copy of the execution tree for masking\n const cloneWithoutFunctions = (obj: unknown): unknown => {\n if (this.isNativeFunction(obj) || typeof obj === \"function\") {\n return \"[function]\";\n }\n if (Array.isArray(obj)) {\n return obj.map(cloneWithoutFunctions);\n }\n if (obj && typeof obj === \"object\" && !ArrayBuffer.isView(obj)) {\n return Object.fromEntries(\n Object.entries(obj).map(([key, value]) => [\n key,\n cloneWithoutFunctions(value),\n ]),\n );\n }\n return obj;\n };\n\n const treeCopy = cloneWithoutFunctions(this.root);\n const maskedRoot = this.maskExecutionTree(treeCopy as ExecutionNode);\n const steps = this.countSteps(this.root);\n\n function replacer(key: string, value: unknown): unknown {\n if (typeof value === \"function\") {\n console.warn(\"[GenSX] Unserializable function found in checkpoint\", {\n key,\n });\n return \"[function]\";\n }\n\n if (typeof value === \"object\" && value !== null) {\n if (isAsyncIterable(value)) {\n console.warn(\n \"[GenSX] Unserializable async iterable found in checkpoint\",\n {\n key,\n },\n );\n return \"[async-iterator]\";\n }\n if (isReadableStream(value)) {\n console.warn(\n \"[GenSX] Unserializable readable stream found in checkpoint\",\n {\n key,\n },\n );\n return \"[readable-stream]\";\n }\n }\n\n if (typeof value === \"symbol\") {\n return `[Symbol(${value.toString()})]`;\n }\n\n return value;\n }\n\n // Separately gzip the rawExecution data\n const compressedExecution = await gzipAsync(\n Buffer.from(\n JSON.stringify(\n {\n ...maskedRoot,\n updatedAt: Date.now(),\n },\n replacer,\n ),\n \"utf-8\",\n ),\n );\n const base64CompressedExecution =\n Buffer.from(compressedExecution).toString(\"base64\");\n\n const workflowName = this.workflowName ?? this.root.componentName;\n const payload = {\n executionId: this.executionRunId,\n version: this.version,\n schemaVersion: 2,\n workflowName,\n startedAt: this.root.startTime,\n completedAt: this.root.endTime,\n rawExecution: base64CompressedExecution,\n steps,\n runtime: this.runtime,\n runtimeVersion: this.runtimeVersion,\n executionRunId: this.executionRunId,\n };\n\n const compressedData = await gzipAsync(JSON.stringify(payload));\n\n let response: Response;\n if (!this.traceId) {\n // create the trace\n const url = join(this.apiBaseUrl, `/org/${this.org}/traces`);\n response = await fetch(url, {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n \"Content-Encoding\": \"gzip\",\n Authorization: `Bearer ${this.apiKey}`,\n \"accept-encoding\": \"gzip\",\n \"User-Agent\": USER_AGENT,\n },\n body: compressedData,\n });\n } else {\n const url = join(\n this.apiBaseUrl,\n `/org/${this.org}/traces/${this.traceId}`,\n );\n // otherwise update the trace\n response = await fetch(url, {\n method: \"PUT\",\n headers: {\n \"Content-Type\": \"application/json\",\n \"Content-Encoding\": \"gzip\",\n Authorization: `Bearer ${this.apiKey}`,\n \"accept-encoding\": \"gzip\",\n \"User-Agent\": USER_AGENT,\n },\n body: compressedData,\n });\n }\n\n if (!response.ok) {\n console.error(`[Checkpoint] Failed to save checkpoint, server error:`, {\n status: response.status,\n message: await response.text(),\n });\n return;\n }\n\n const responseBody = (await response.json()) as {\n executionId: string;\n traceId: string;\n workflowName: string;\n };\n\n this.traceId = responseBody.traceId;\n\n if (this.printUrl && !this.havePrintedUrl) {\n const executionUrl = new URL(\n `/${this.org}/default/executions/${responseBody.executionId}?workflowName=${responseBody.workflowName}`,\n this.consoleBaseUrl,\n );\n this.havePrintedUrl = true;\n console.info(\n `\\n\\n\\x1b[33m[GenSX] View execution at:\\x1b[0m \\x1b[1;34m${executionUrl.toString()}\\x1b[0m\\n\\n`,\n );\n }\n } catch (error) {\n console.error(`[Checkpoint] Failed to save checkpoint:`, { error });\n } finally {\n // Always increment, just in case the write was received by the server. The version value does not need to be\n // perfectly monotonic, just simply the next value needs to be greater than the previous value.\n this.version++;\n }\n }\n\n private countSteps(node: ExecutionNode): number {\n return node.children.reduce(\n (acc, child) => acc + this.countSteps(child),\n 1,\n );\n }\n\n private maskExecutionTree(node: ExecutionNode): ExecutionNode {\n // Mask props\n node.props = this.scrubSecrets(node.props, node) as Record;\n\n // Mask output if present\n if (node.output !== undefined) {\n node.output = this.scrubSecrets(node.output, node, \"output\");\n }\n\n // Mask metadata if present\n if (node.metadata) {\n node.metadata = this.scrubSecrets(\n node.metadata,\n node,\n \"metadata\",\n ) as Record;\n }\n\n // Recursively mask children\n node.children = node.children.map((child) => this.maskExecutionTree(child));\n\n return node;\n }\n\n private isEqual(a: unknown, b: unknown): boolean {\n // Handle primitives\n if (a === b) return true;\n\n // If either isn't an object, they're not equal\n if (!a || !b || typeof a !== \"object\" || typeof b !== \"object\") {\n return false;\n }\n\n // Handle arrays\n if (Array.isArray(a) && Array.isArray(b)) {\n return (\n a.length === b.length &&\n a.every((item, index) => this.isEqual(item, b[index]))\n );\n }\n\n // Handle objects\n if (!Array.isArray(a) && !Array.isArray(b)) {\n const aKeys = Object.keys(a);\n const bKeys = Object.keys(b);\n return (\n aKeys.length === bKeys.length &&\n aKeys.every((key) =>\n this.isEqual(a[key as keyof typeof a], b[key as keyof typeof b]),\n )\n );\n }\n\n return false;\n }\n\n private withNode(node: ExecutionNode, fn: () => T): T {\n this.currentNodeChain.push(node);\n try {\n return fn();\n } finally {\n this.currentNodeChain.pop();\n }\n }\n\n private getEffectiveSecrets(): Set {\n const allSecrets = new Set();\n for (const node of this.currentNodeChain) {\n const nodeSecrets = this._secretValues.get(node.id);\n if (nodeSecrets) {\n for (const secret of nodeSecrets) {\n allSecrets.add(secret);\n }\n }\n }\n return allSecrets;\n }\n\n private registerSecrets(\n props: Record,\n paths: string[],\n node: ExecutionNode,\n ) {\n this.withNode(node, () => {\n // Initialize secrets set for this node\n let nodeSecrets = this._secretValues.get(node.id);\n if (!nodeSecrets) {\n nodeSecrets = new Set();\n this._secretValues.set(node.id, nodeSecrets);\n }\n\n // Use paths purely for collection\n for (const path of paths) {\n const value = this.getValueAtPath(props, path);\n if (value !== undefined) {\n this.collectSecretValues(value, nodeSecrets);\n }\n }\n });\n }\n\n private collectSecretValues(\n data: unknown,\n nodeSecrets: Set,\n visited = new WeakSet(),\n ): void {\n // Skip if already visited to prevent cycles\n if (data && typeof data === \"object\") {\n if (visited.has(data)) {\n return;\n }\n visited.add(data);\n }\n\n // Handle primitive values\n if (typeof data === \"string\") {\n if (data.length >= this.MIN_SECRET_LENGTH) {\n nodeSecrets.add(data);\n }\n return;\n }\n\n // Skip other primitives\n if (!data || typeof data !== \"object\") {\n return;\n }\n\n // Handle arrays and objects (excluding ArrayBuffer views)\n if (Array.isArray(data) || !ArrayBuffer.isView(data)) {\n const values = Array.isArray(data) ? data : Object.values(data);\n values.forEach((value) => {\n this.collectSecretValues(value, nodeSecrets, visited);\n });\n }\n }\n\n private scrubSecrets(\n data: unknown,\n nodeToScrub: ExecutionNode,\n path = \"\",\n ): unknown {\n const node = this.nodes.get(nodeToScrub);\n if (!node) {\n throw new Error(\"Node not found\");\n }\n return this.withNode(node, () => {\n // Handle native functions\n if (this.isNativeFunction(data)) {\n return \"[native function]\";\n }\n\n // Handle functions\n if (typeof data === \"function\") {\n return \"[function]\";\n }\n\n // Handle primitive values\n if (typeof data === \"string\") {\n return this.scrubString(data);\n }\n\n // Skip other primitives\n if (!data || typeof data !== \"object\") {\n return data;\n }\n\n // Handle arrays\n if (Array.isArray(data)) {\n return data.map((item, index) =>\n this.scrubSecrets(item, node, path ? `${path}.${index}` : `${index}`),\n );\n }\n\n // Handle objects (excluding ArrayBuffer views)\n if (!ArrayBuffer.isView(data)) {\n return Object.fromEntries(\n Object.entries(data).map(([key, value]) => [\n key,\n this.scrubSecrets(value, node, path ? `${path}.${key}` : key),\n ]),\n );\n }\n\n // Handle objects that shouldn't be cloned\n if (ArrayBuffer.isView(data)) return data;\n\n return data;\n });\n }\n\n private scrubString(value: string): string {\n const effectiveSecrets = this.getEffectiveSecrets();\n let result = value;\n\n // Sort secrets by length (longest first) to handle overlapping secrets correctly\n const secrets = Array.from(effectiveSecrets)\n .filter(\n (s) => typeof s === \"string\" && s.length >= this.MIN_SECRET_LENGTH,\n )\n .sort((a, b) => String(b).length - String(a).length);\n\n // Replace each secret with [secret]\n for (const secret of secrets) {\n if (typeof secret === \"string\") {\n // Only replace if the secret is actually in the string\n if (result.includes(secret)) {\n const escapedSecret = secret.replace(/[.*+?^${}()|[\\]\\\\]/g, \"\\\\$&\");\n const regex = new RegExp(escapedSecret, \"g\");\n result = result.replace(regex, \"[secret]\");\n }\n }\n }\n\n return result;\n }\n\n private getValueAtPath(obj: Record, path: string): unknown {\n return path.split(\".\").reduce((curr: unknown, key: string) => {\n if (curr && typeof curr === \"object\") {\n return (curr as Record)[key];\n }\n return undefined;\n }, obj);\n }\n\n private cloneValue(value: unknown): unknown {\n // Handle null/undefined\n if (value == null) return value;\n\n // Don't clone functions\n if (typeof value === \"function\") return value;\n\n // Handle primitive values\n if (typeof value !== \"object\") return value;\n\n // Handle arrays\n if (Array.isArray(value)) {\n return value.map((item) => this.cloneValue(item));\n }\n\n // Handle objects that shouldn't be cloned\n if (ArrayBuffer.isView(value)) return value;\n\n // Check for toJSON method before doing regular object cloning\n const objValue = value as { toJSON?: () => unknown };\n if (typeof objValue.toJSON === \"function\") {\n return this.cloneValue(objValue.toJSON());\n }\n\n // For regular objects, clone each property\n return Object.fromEntries(\n Object.entries(value).map(([key, val]) => [key, this.cloneValue(val)]),\n );\n }\n\n /**\n * Due to the async nature of component execution, nodes can arrive in any order.\n * For example, in a tree like:\n * BlogWriter\n * └─ OpenAIProvider\n * └─ Research\n *\n * The Research component might execute before OpenAIProvider due to:\n * - Parallel execution of components\n * - Different resolution times for promises\n * - Network delays in API calls\n *\n * To handle this, we:\n * 1. Track orphaned nodes (children with parentIds where parents aren't yet in the graph) because:\n * - We need to maintain the true hierarchy regardless of arrival order\n * - We can't write incomplete checkpoints that would show incorrect relationships\n * - The tree structure is important for debugging and monitoring\n *\n * 2. Allow root replacement because:\n * - The first node to arrive might not be the true root\n * - We need to maintain correct component hierarchy for visualization\n * - Checkpoint consumers expect a complete, properly ordered tree\n *\n * This approach ensures that even if components resolve out of order,\n * the final checkpoint will always show the correct logical structure\n * of the execution.\n */\n addNode(\n partialNode: Partial & {\n id: NodeId;\n },\n parentNode?: ExecutionNode,\n { skipCheckpointUpdate }: { skipCheckpointUpdate?: boolean } = {},\n ): ExecutionNode {\n const clonedPartial = this.cloneValue(\n partialNode,\n ) as Partial & { id: NodeId };\n const node: ExecutionNode = {\n completed: false,\n componentName: \"Unknown\",\n startTime: Date.now(),\n // This gives us nanosecond precision for the start time, but without a stable epoch.\n // This lets us relatively compare the start time between nodes, but not absolutely know when it started (use startTime for that)\n startedAt: hrtime.bigint().toString(),\n children: [],\n props: {},\n ...clonedPartial, // Clone mutable state while preserving functions\n };\n\n // Register any secrets from componentOpts\n if (node.componentOpts?.secretProps) {\n this.registerSecrets(node.props, node.componentOpts.secretProps, node);\n }\n\n // Store enhanced node\n this.nodes.set(node);\n\n const parent = parentNode ? this.nodes.get(parentNode) : undefined;\n if (!parent && parentNode) {\n console.warn(\"[Checkpoint] Parent node not stored\", {\n parentNode: {\n id: parentNode.id,\n },\n });\n // Parent doesn't exist yet - track as orphaned\n node.parentId = parentNode.id;\n this.handleOrphanedNode(node, parentNode);\n }\n\n if (parent) {\n // Normal case - parent exists\n this.attachToParent(node, parent);\n } else {\n // Handle root node case\n if (!this.root) {\n this.root = node;\n } else if (this.root.parentId === node.id) {\n // Current root was waiting for this node as parent\n this.attachToParent(this.root, node);\n this.root = node;\n } else {\n console.warn(\n `[Checkpoint] Multiple root nodes detected: existing=${this.root.componentName}, new=${node.componentName}`,\n );\n }\n }\n\n // Check if this node is a parent any orphans are waiting for\n const waitingChildren = this.orphanedNodes.get(node.id);\n if (waitingChildren) {\n // Attach all waiting children\n for (const orphan of waitingChildren) {\n this.attachToParent(orphan, node);\n }\n // Clear the orphans list for this parent\n this.orphanedNodes.delete(node.id);\n }\n\n if (!skipCheckpointUpdate) {\n this.updateCheckpoint();\n }\n return node;\n }\n\n private addCachedNodeRecursively(\n node: ExecutionNode,\n parentNode?: ExecutionNode,\n ) {\n const parentPath = parentNode?.id ? getPathId(parentNode.id) : \"\";\n const nodeId = generateNodeId(\n node.componentName,\n node.props,\n node.componentOpts?.idPropsKeys,\n parentPath,\n this.getNextCallIndex(\n parentPath,\n node.componentName,\n node.props,\n node.componentOpts?.idPropsKeys,\n ),\n );\n // Check if this node already exists in the current checkpoint\n if (this.nodes.has(nodeId)) {\n console.debug(`[Replay] Node ${nodeId} already exists, skipping subtree`);\n return;\n }\n\n // Create a copy of the node to avoid modifying the original\n const nodeCopy: ExecutionNode = {\n ...node,\n id: nodeId,\n startedAt: hrtime.bigint().toString(),\n children: [], // We'll add children recursively\n };\n\n // Add this node to the current checkpoint\n this.nodes.set(nodeCopy);\n\n const parent = parentNode ? this.nodes.get(parentNode) : undefined;\n if (parentNode && !parent) {\n console.warn(\"[Checkpoint] Parent node not stored\", {\n parentNode: {\n id: parentNode.id,\n },\n });\n\n // Parent doesn't exist yet - track as orphaned\n this.handleOrphanedNode(nodeCopy, parentNode);\n }\n\n // Handle parent-child relationships\n if (parent) {\n this.attachToParent(nodeCopy, parent);\n } else {\n // This is a root node\n this.root ??= nodeCopy;\n }\n\n // Check if this node resolves any orphaned children\n const waitingChildren = this.orphanedNodes.get(nodeCopy.id);\n if (waitingChildren) {\n for (const orphan of waitingChildren) {\n this.attachToParent(orphan, nodeCopy);\n }\n this.orphanedNodes.delete(nodeCopy.id);\n }\n\n // Recursively add all children\n node.children.forEach((child) => {\n if (child.completed) {\n this.addCachedNodeRecursively(child, nodeCopy);\n }\n });\n }\n\n completeNode(\n nodeToUpdate: ExecutionNode,\n output: unknown,\n { wrapInPromise }: { wrapInPromise?: boolean } = {},\n ) {\n const node = this.nodes.get(nodeToUpdate);\n\n if (node) {\n node.completed = true;\n node.endTime = Date.now();\n node.output = this.cloneValue(output);\n\n if (wrapInPromise) {\n node.output = {\n __gensxSerialized: true,\n type: \"promise\",\n\n value: node.output,\n };\n }\n\n if (\n node.componentOpts?.secretOutputs &&\n output !== STREAMING_PLACEHOLDER\n ) {\n this.withNode(node, () => {\n let nodeSecrets = this._secretValues.get(node.id);\n if (!nodeSecrets) {\n nodeSecrets = new Set();\n this._secretValues.set(node.id, nodeSecrets);\n }\n this.collectSecretValues(output, nodeSecrets);\n });\n }\n\n this.updateCheckpoint();\n } else {\n console.warn(`[Tracker] Attempted to complete unknown node:`, {\n id: nodeToUpdate.id,\n });\n }\n }\n\n addMetadata(nodeToUpdate: ExecutionNode, metadata: Record) {\n const node = this.nodes.get(nodeToUpdate);\n if (node) {\n node.metadata = {\n ...node.metadata,\n ...metadata,\n };\n this.updateCheckpoint();\n }\n }\n\n // TODO: What if we have already sent some checkpoints?\n setWorkflowName(name: string) {\n this.workflowName = name;\n }\n\n setPrintUrl(printUrl: boolean) {\n this.printUrl = printUrl;\n }\n\n updateNode(nodeToUpdate: ExecutionNode, updates: Partial) {\n const node = this.nodes.get(nodeToUpdate);\n if (node) {\n if (\n \"output\" in updates &&\n node.componentOpts?.secretOutputs &&\n updates.output !== STREAMING_PLACEHOLDER\n ) {\n this.withNode(node, () => {\n let nodeSecrets = this._secretValues.get(node.id);\n if (!nodeSecrets) {\n nodeSecrets = new Set();\n this._secretValues.set(node.id, nodeSecrets);\n }\n this.collectSecretValues(updates.output, nodeSecrets);\n });\n }\n\n Object.assign(node, this.cloneValue(updates));\n this.updateCheckpoint();\n } else {\n console.warn(`[Tracker] Attempted to update unknown node:`, {\n id: nodeToUpdate.id,\n });\n }\n }\n\n write() {\n this.updateCheckpoint();\n }\n\n async waitForPendingUpdates(): Promise {\n // If there's an active checkpoint, wait for it\n if (this.activeCheckpoint) {\n await this.activeCheckpoint;\n }\n // If that checkpoint triggered another update, wait again\n if (this.pendingUpdate || this.activeCheckpoint) {\n await this.waitForPendingUpdates();\n }\n }\n\n private buildReplayLookup(node: ExecutionNode) {\n this.addToReplayLookup(node);\n\n // Ensure all the nodes are in order of when they started, so we can just pick the appropriate node off the front of the list\n this.replayLookup.sort((a, b) =>\n Number(BigInt(a.startedAt) - BigInt(b.startedAt)),\n );\n }\n\n private addToReplayLookup(node: ExecutionNode) {\n this.replayLookup.push(node);\n\n node.children.forEach((child) => {\n this.addToReplayLookup(child);\n });\n }\n\n /**\n * 1. Check the first node in the list. If it has the same path, content ID and call index use it.\n * 2. If something does not match, look through the list to find a potential match (and warn about non-deterministic behavior if there is a match):\n * a. Look for the first node that has the same path, content ID and call index.\n * b. Look for the first node that has the same path and content ID.\n * c. Look for the first node that has the same content ID.\n * d. Look for the first node that has the same component name.\n * 3. If no match is found, this component is probably not in the checkpoint. If there are nodes in the checkpoint, this indicates non-deterministic behavior.\n * @param nodeId\n * @returns\n */\n getNodeFromCheckpoint(\n nodeId: NodeId,\n ):\n | { found: false; node?: ExecutionNode }\n | { found: true; node: ExecutionNode } {\n if (!this.replayLookup.length) {\n return { found: false };\n }\n\n const [pathId, contentId] = nodeId.split(\":\");\n const componentName = pathId.split(\"-\").pop();\n\n // Strategy 1: Exact Node ID Match\n const exactNode = this.replayLookup.find((node) => node.id === nodeId);\n if (exactNode) {\n if (this.replayLookup.indexOf(exactNode) !== 0) {\n console.debug(\n `[Replay] Non-deterministic behavior detected ${exactNode.id} is not the next node in the checkpoint (next: ${this.replayLookup[0].id})`,\n );\n }\n this.replayLookup.splice(this.replayLookup.indexOf(exactNode), 1);\n return { found: true, node: exactNode };\n }\n\n // Strategy 2: Path/Content matching (same path, same content, different call index)\n const pathContentNode = this.replayLookup.find((node) => {\n const [nodePathId, nodeContentId] = node.id.split(\":\");\n return nodePathId === pathId && nodeContentId === contentId;\n });\n if (pathContentNode) {\n console.debug(\n `[Replay] Non-deterministic behavior detected: Found node with same path and content but different call index (target: ${nodeId}, found: ${pathContentNode.id})`,\n );\n this.replayLookup.splice(this.replayLookup.indexOf(pathContentNode), 1);\n return { found: true, node: pathContentNode };\n }\n\n // Strategy 3: Content-based matching (same content/component name, different path)\n const contentNode = this.replayLookup.find((node) => {\n const nodeContentId = getContentId(node.id);\n return (\n node.componentName === componentName && nodeContentId === contentId\n );\n });\n if (contentNode) {\n console.debug(\n `[Replay] Non-deterministic behavior detected: Found node with same content but different path (target: ${nodeId}, found: ${contentNode.id})`,\n );\n this.replayLookup.splice(this.replayLookup.indexOf(contentNode), 1);\n return { found: true, node: contentNode };\n }\n\n console.debug(\n `[Replay] No match found for node ${nodeId}, but there are unused nodes in the checkpoint. This may indicate non-deterministic behavior.`,\n JSON.stringify(\n // eslint-disable-next-line @typescript-eslint/no-unsafe-return\n this.replayLookup.map((node) => this.slimCheckpoint(node)),\n null,\n 2,\n ),\n );\n return { found: false };\n }\n\n // eslint-disable-next-line @typescript-eslint/no-explicit-any\n public slimCheckpoint(checkpoint?: ExecutionNode): any {\n if (!checkpoint) return undefined;\n const slimmed = {\n id: checkpoint.id,\n completed: checkpoint.completed,\n startedAt: checkpoint.startedAt,\n // eslint-disable-next-line @typescript-eslint/no-unsafe-return\n children: checkpoint.children.map((child) => this.slimCheckpoint(child)),\n };\n return slimmed;\n }\n\n // Checkpoint reconstruction methods\n addCachedSubtreeToCheckpoint(node: ExecutionNode, parent?: ExecutionNode) {\n console.debug(\n `[Replay] Adding cached subtree for ${node.componentName} (${node.id})`,\n );\n\n if (!node.completed) {\n return;\n }\n\n this.addCachedNodeRecursively(node, parent);\n\n // Validate tree structure after adding cached nodes\n if (!this.isTreeValid()) {\n console.warn(\n `[Replay] Tree validation failed after adding cached subtree for ${node.componentName}`,\n );\n }\n }\n}\n\nconst pathIdsMap = new Map();\nconst contentIdsMap = new Map();\n\n// Helpers for working with node IDs\n// eg. \"Workflow/Component:456:789\" -> \"Workflow/Component\", \"456\", \"789\"\nfunction getPathId(id: NodeId): PathId {\n const pathId = pathIdsMap.get(id) ?? id.split(\":\")[0];\n pathIdsMap.set(id, pathId);\n return pathId;\n}\n\nfunction getContentId(id: NodeId): ContentId {\n const contentId = contentIdsMap.get(id) ?? id.split(\":\")[1];\n contentIdsMap.set(id, contentId);\n return contentId;\n}\n"],"names":["promisify","gzip","stringifyProps","createHash","config","readConfig","isAsyncIterable","isReadableStream","Buffer","join","USER_AGENT","hrtime","nodeId","generateNodeId","STREAMING_PLACEHOLDER"],"mappings":";;;;;;;;;;;;;;;;;;;;AAuBA,MAAM,SAAS,GAAGA,mBAAS,CAACC,cAAI,CAAC;AAEjC,MAAM,OAAO,CAAA;;AAEH,IAAA,QAAQ,GAAG,IAAI,GAAG,EAAa;;AAG/B,IAAA,UAAU,GAAG,IAAI,GAAG,EAAuB,CAAC;AAC5C,IAAA,aAAa,GAAG,IAAI,GAAG,EAAuB,CAAC;AAC/C,IAAA,iBAAiB,GAAG,IAAI,GAAG,EAAuB,CAAC;AAE3D,IAAA,GAAG,CAAC,IAAO,EAAA;QACT,IAAI,CAAC,QAAQ,CAAC,GAAG,CAAC,IAAI,CAAC,EAAE,EAAE,IAAI,CAAC;;QAGhC,MAAM,MAAM,GAAG,SAAS,CAAC,IAAI,CAAC,EAAE,CAAC;QACjC,IAAI,MAAM,EAAE;YACV,IAAI,CAAC,IAAI,CAAC,UAAU,CAAC,GAAG,CAAC,MAAM,CAAC,EAAE;gBAChC,IAAI,CAAC,UAAU,CAAC,GAAG,CAAC,MAAM,EAAE,IAAI,GAAG,EAAE,CAAC;;AAExC,YAAA,IAAI,CAAC,UAAU,CAAC,GAAG,CAAC,MAAM,CAAE,CAAC,GAAG,CAAC,IAAI,CAAC,EAAE,CAAC;;QAG3C,MAAM,SAAS,GAAG,YAAY,CAAC,IAAI,CAAC,EAAE,CAAC;QACvC,IAAI,SAAS,EAAE;YACb,IAAI,CAAC,IAAI,CAAC,aAAa,CAAC,GAAG,CAAC,SAAS,CAAC,EAAE;gBACtC,IAAI,CAAC,aAAa,CAAC,GAAG,CAAC,SAAS,EAAE,IAAI,GAAG,EAAE,CAAC;;AAE9C,YAAA,IAAI,CAAC,aAAa,CAAC,GAAG,CAAC,SAAS,CAAE,CAAC,GAAG,CAAC,IAAI,CAAC,EAAE,CAAC;;AAGjD,QAAA,MAAM,aAAa,GAAG,CAAA,EAAG,MAAM,CAAI,CAAA,EAAA,SAAS,EAAE;QAC9C,IAAI,CAAC,IAAI,CAAC,iBAAiB,CAAC,GAAG,CAAC,aAAa,CAAC,EAAE;YAC9C,IAAI,CAAC,iBAAiB,CAAC,GAAG,CAAC,aAAa,EAAE,IAAI,GAAG,EAAE,CAAC;;AAEtD,QAAA,IAAI,CAAC,iBAAiB,CAAC,GAAG,CAAC,aAAa,CAAE,CAAC,GAAG,CAAC,IAAI,CAAC,EAAE,CAAC;;AAGzD,IAAA,GAAG,CAAC,eAA2B,EAAA;AAC7B,QAAA,IAAI,OAAO,eAAe,KAAK,QAAQ,EAAE;YACvC,OAAO,IAAI,CAAC,QAAQ,CAAC,GAAG,CAAC,eAAe,CAAC;;QAG3C,MAAM,IAAI,GAAG,eAAe;QAC5B,OAAO,IAAI,CAAC,QAAQ,CAAC,GAAG,CAAC,IAAI,CAAC,EAAE,CAAC;;AAGnC,IAAA,GAAG,CAAC,eAA2B,EAAA;AAC7B,QAAA,IAAI,OAAO,eAAe,KAAK,QAAQ,EAAE;YACvC,OAAO,IAAI,CAAC,QAAQ,CAAC,GAAG,CAAC,eAAe,CAAC;;QAE3C,OAAO,IAAI,CAAC,GAAG,CAAC,eAAe,CAAC,KAAK,SAAS;;IAGhD,mBAAmB,CAAC,MAAc,EAAE,SAAiB,EAAA;AACnD,QAAA,MAAM,UAAU,GACd,IAAI,CAAC,iBAAiB,CAAC,GAAG,CAAC,CAAA,EAAG,MAAM,CAAA,CAAA,EAAI,SAAS,CAAE,CAAA,CAAC,IAAI,IAAI,GAAG,EAAE;AACnE,QAAA,OAAO,KAAK,CAAC,IAAI,CAAC,UAAU;AACzB,aAAA,GAAG,CAAC,CAAC,EAAE,KAAK,IAAI,CAAC,QAAQ,CAAC,GAAG,CAAC,EAAE,CAAC;aACjC,MAAM,CAAC,CAAC,IAAI,KAAgB,IAAI,KAAK,SAAS,CAAC;;AAGpD,IAAA,SAAS,CAAC,MAAc,EAAA;AACtB,QAAA,MAAM,UAAU,GAAG,IAAI,CAAC,UAAU,CAAC,GAAG,CAAC,MAAM,CAAC,IAAI,IAAI,GAAG,EAAE;AAC3D,QAAA,OAAO,KAAK,CAAC,IAAI,CAAC,UAAU;AACzB,aAAA,GAAG,CAAC,CAAC,EAAE,KAAK,IAAI,CAAC,QAAQ,CAAC,GAAG,CAAC,EAAE,CAAC;aACjC,MAAM,CAAC,CAAC,IAAI,KAAgB,IAAI,KAAK,SAAS,CAAC;;AAGpD,IAAA,YAAY,CAAC,SAAiB,EAAA;AAC5B,QAAA,MAAM,UAAU,GAAG,IAAI,CAAC,aAAa,CAAC,GAAG,CAAC,SAAS,CAAC,IAAI,IAAI,GAAG,EAAE;AACjE,QAAA,OAAO,KAAK,CAAC,IAAI,CAAC,UAAU;AACzB,aAAA,GAAG,CAAC,CAAC,EAAE,KAAK,IAAI,CAAC,QAAQ,CAAC,GAAG,CAAC,EAAE,CAAC;aACjC,MAAM,CAAC,CAAC,IAAI,KAAgB,IAAI,KAAK,SAAS,CAAC;;IAGpD,OAAO,GAAA;QACL,OAAO,KAAK,CAAC,IAAI,CAAC,IAAI,CAAC,QAAQ,CAAC,OAAO,EAAE,CAAC;;IAG5C,KAAK,GAAA;AACH,QAAA,IAAI,CAAC,QAAQ,CAAC,KAAK,EAAE;AACrB,QAAA,IAAI,CAAC,UAAU,CAAC,KAAK,EAAE;AACvB,QAAA,IAAI,CAAC,aAAa,CAAC,KAAK,EAAE;AAC1B,QAAA,IAAI,CAAC,iBAAiB,CAAC,KAAK,EAAE;;AAEjC;MAEY,iBAAiB,CAAA;AACpB,IAAA,KAAK,GAAG,IAAI,OAAO,EAAiB;AACpC,IAAA,aAAa,GAAG,IAAI,GAAG,EAA8B;AACrD,IAAA,aAAa,GAAG,IAAI,GAAG,EAAwB,CAAC;AAChD,IAAA,gBAAgB,GAAoB,EAAE,CAAC;IAC9B,iBAAiB,GAAG,CAAC;AAC/B,IAAA,IAAI;AACJ,IAAA,kBAAkB;AAClB,IAAA,YAAY;IACX,gBAAgB,GAAyB,IAAI;IAC7C,aAAa,GAAG,KAAK;IACrB,OAAO,GAAG,CAAC;AACX,IAAA,GAAG;AACH,IAAA,MAAM;AACN,IAAA,UAAU;AACV,IAAA,cAAc;IACd,QAAQ,GAAG,KAAK;AAChB,IAAA,OAAO;AACP,IAAA,cAAc;AACd,IAAA,kBAAkB;AAElB,IAAA,OAAO;AACP,IAAA,cAAc;;IAGd,YAAY,GAAoB,EAAE;;AAG1C,IAAA,IAAI,YAAY,GAAA;AACd,QAAA,MAAM,UAAU,GAAG,IAAI,GAAG,EAAW;QACrC,KAAK,MAAM,OAAO,IAAI,IAAI,CAAC,aAAa,CAAC,MAAM,EAAE,EAAE;AACjD,YAAA,KAAK,MAAM,MAAM,IAAI,OAAO,EAAE;AAC5B,gBAAA,UAAU,CAAC,GAAG,CAAC,MAAM,CAAC;;;AAG1B,QAAA,OAAO,UAAU;;;AAInB,IAAA,IAAI,eAAe,GAAA;AACjB,QAAA,MAAM,SAAS,GAAG,IAAI,GAAG,EAAyB;AAClD,QAAA,KAAK,MAAM,CAAC,SAAS,EAAE,IAAI,CAAC,IAAI,IAAI,CAAC,KAAK,CAAC,OAAO,EAAE,EAAE;AACpD,YAAA,SAAS,CAAC,GAAG,CAAC,SAAS,EAAE,IAAI,CAAC;;AAEhC,QAAA,OAAO,SAAS;;AAGV,IAAA,YAAY,GAAG,IAAI,GAAG,EAAkB;AAEzC,IAAA,gBAAgB,CACrB,UAAkB,EAClB,aAAqB,EACrB,KAA8B,EAC9B,WAAiC,EAAA;AAEjC,QAAA,MAAM,cAAc,GAAG;AACrB,YAAA,IAAI,EAAE,aAAa;AACnB,YAAA,KAAK,EAAEC,qBAAc,CAAC,KAAK,EAAE,WAAW,CAAC;AACzC,YAAA,MAAM,EAAE,UAAU;SACnB;QACD,MAAM,UAAU,GAAG,IAAI,CAAC,SAAS,CAAC,cAAc,CAAC;AACjD,QAAA,MAAM,WAAW,GAAGC,sBAAU,CAAC,QAAQ;aACpC,MAAM,CAAC,UAAU;aACjB,MAAM,CAAC,KAAK;AACZ,aAAA,KAAK,CAAC,CAAC,EAAE,CAAC,CAAC;QACd,MAAM,GAAG,GAAG,CAAG,EAAA,UAAU,IAAI,aAAa,CAAA,CAAA,EAAI,WAAW,CAAA,CAAE;AAC3D,QAAA,MAAM,OAAO,GAAG,IAAI,CAAC,YAAY,CAAC,GAAG,CAAC,GAAG,CAAC,IAAI,CAAC;QAC/C,IAAI,CAAC,YAAY,CAAC,GAAG,CAAC,GAAG,EAAE,OAAO,GAAG,CAAC,CAAC;AACvC,QAAA,OAAO,OAAO;;AAGhB,IAAA,WAAA,CAAY,IAUX,EAAA;;AAEC,QAAA,MAAMC,QAAM,GAAGC,iBAAU,EAAE;AAC3B,QAAA,MAAM,MAAM,GACV,IAAI,EAAE,MAAM,IAAI,OAAO,CAAC,GAAG,CAAC,aAAa,IAAID,QAAM,CAAC,GAAG,EAAE,KAAK;AAChE,QAAA,MAAM,GAAG,GAAG,IAAI,EAAE,GAAG,IAAI,OAAO,CAAC,GAAG,CAAC,SAAS,IAAIA,QAAM,CAAC,GAAG,EAAE,GAAG;AACjE,QAAA,MAAM,UAAU,GACd,IAAI,EAAE,UAAU,IAAI,OAAO,CAAC,GAAG,CAAC,kBAAkB,IAAIA,QAAM,CAAC,GAAG,EAAE,OAAO;AAC3E,QAAA,MAAM,cAAc,GAClB,IAAI,EAAE,cAAc;YACpB,OAAO,CAAC,GAAG,CAAC,iBAAiB;AAC7B,YAAAA,QAAM,CAAC,OAAO,EAAE,OAAO;AAEzB,QAAA,IAAI,CAAC,kBAAkB,GAAG,MAAM,KAAK,SAAS;AAC9C,QAAA,IAAI,CAAC,GAAG,GAAG,GAAG,IAAI,EAAE;AACpB,QAAA,IAAI,CAAC,MAAM,GAAG,MAAM,IAAI,EAAE;AAC1B,QAAA,IAAI,CAAC,UAAU,GAAG,UAAU,IAAI,uBAAuB;AACvD,QAAA,IAAI,CAAC,cAAc,GAAG,cAAc,IAAI,uBAAuB;QAE/D,MAAM,OAAO,GAAG,IAAI,EAAE,OAAO,IAAI,OAAO,CAAC,GAAG,CAAC,aAAa;QAC1D,IAAI,OAAO,IAAI,OAAO,KAAK,OAAO,IAAI,OAAO,KAAK,KAAK,EAAE;AACvD,YAAA,MAAM,IAAI,KAAK,CAAC,kDAAkD,CAAC;;AAErE,QAAA,IAAI,CAAC,OAAO,GAAG,OAAsC;AACrD,QAAA,IAAI,CAAC,cAAc;YACjB,IAAI,EAAE,cAAc,IAAI,OAAO,CAAC,GAAG,CAAC,qBAAqB;AAE3D,QAAA,IAAI,CAAC,cAAc;YACjB,IAAI,EAAE,cAAc,IAAI,OAAO,CAAC,GAAG,CAAC,sBAAsB;QAE5D,IACE,IAAI,EAAE,QAAQ;AACd,YAAA,OAAO,CAAC,GAAG,CAAC,iBAAiB,KAAK,OAAO;AACzC,YAAA,OAAO,CAAC,GAAG,CAAC,iBAAiB,KAAK,GAAG;AACrC,YAAA,OAAO,CAAC,GAAG,CAAC,iBAAiB,KAAK,IAAI;AACtC,YAAA,OAAO,CAAC,GAAG,CAAC,iBAAiB,KAAK,KAAK,EACvC;AACA,YAAA,IAAI,CAAC,kBAAkB,GAAG,KAAK;;QAGjC,IAAI,IAAI,CAAC,kBAAkB,IAAI,CAAC,IAAI,CAAC,GAAG,EAAE;AACxC,YAAA,MAAM,IAAI,KAAK,CACb,gNAAgN,CACjN;;AAGH,QAAA,IAAI,IAAI,EAAE,UAAU,EAAE;AACpB,YAAA,IAAI,CAAC,iBAAiB,CAAC,IAAI,CAAC,UAAU,CAAC;;;IAInC,cAAc,CACpB,YAA2B,EAC3B,cAA6B,EAAA;QAE7B,MAAM,IAAI,GAAG,IAAI,CAAC,KAAK,CAAC,GAAG,CAAC,YAAY,CAAC;QACzC,IAAI,CAAC,IAAI,EAAE;AACT,YAAA,MAAM,IAAI,KAAK,CAAC,gBAAgB,CAAC;;QAEnC,MAAM,MAAM,GAAG,IAAI,CAAC,KAAK,CAAC,GAAG,CAAC,cAAc,CAAC;QAC7C,IAAI,CAAC,MAAM,EAAE;AACX,YAAA,MAAM,IAAI,KAAK,CAAC,uBAAuB,CAAC;;AAE1C,QAAA,IAAI,CAAC,QAAQ,GAAG,MAAM,CAAC,EAAE;QACzB,IAAI,CAAC,MAAM,CAAC,QAAQ,CAAC,IAAI,CAAC,CAAC,KAAK,KAAK,KAAK,CAAC,EAAE,KAAK,IAAI,CAAC,EAAE,CAAC,EAAE;AAC1D,YAAA,MAAM,CAAC,QAAQ,CAAC,IAAI,CAAC,IAAI,CAAC;;;IAItB,kBAAkB,CAAC,IAAmB,EAAE,MAAqB,EAAA;AACnE,QAAA,IAAI,OAAO,GAAG,IAAI,CAAC,aAAa,CAAC,GAAG,CAAC,MAAM,CAAC,EAAE,CAAC;QAC/C,IAAI,CAAC,OAAO,EAAE;AACZ,YAAA,OAAO,GAAG,IAAI,GAAG,EAAE;YACnB,IAAI,CAAC,aAAa,CAAC,GAAG,CAAC,MAAM,CAAC,EAAE,EAAE,OAAO,CAAC;;AAE5C,QAAA,OAAO,CAAC,GAAG,CAAC,IAAI,CAAC;;AAGjB,QAAA,IAAI,CAAC,kBAAkB,CAAC,IAAI,EAAE,MAAM,CAAC;;AAG/B,IAAA,gBAAgB,CAAC,KAAc,EAAA;AACrC,QAAA,QACE,OAAO,KAAK,KAAK,UAAU;AAC3B,YAAA,QAAQ,CAAC,SAAS,CAAC,QAAQ,CAAC,IAAI,CAAC,KAAK,CAAC,CAAC,QAAQ,CAAC,eAAe,CAAC;;IAI7D,kBAAkB,CACxB,YAA2B,EAC3B,cAA6B,EAAA;QAE7B,UAAU,CAAC,MAAK;AACd,YAAA,MAAM,OAAO,GAAG,IAAI,CAAC,aAAa,CAAC,GAAG,CAAC,cAAc,CAAC,EAAE,CAAC;YACzD,MAAM,IAAI,GAAG,IAAI,CAAC,KAAK,CAAC,GAAG,CAAC,YAAY,CAAC;YACzC,IAAI,CAAC,IAAI,EAAE;AACT,gBAAA,OAAO,CAAC,IAAI,CACV,CAAA,kBAAA,EAAqB,YAAY,CAAC,EAAE,CAAA,EAAA,EAAK,YAAY,CAAC,aAAa,CAAA,kBAAA,CAAoB,CACxF;gBACD;;AAEF,YAAA,IAAI,OAAO,EAAE,GAAG,CAAC,IAAI,CAAC,EAAE;AACtB,gBAAA,OAAO,CAAC,IAAI,CACV,CAAqB,kBAAA,EAAA,IAAI,CAAC,EAAE,CAAA,EAAA,EAAK,IAAI,CAAC,aAAa,CAA8B,2BAAA,EAAA,cAAc,CAAC,EAAE,WAAW,EAC7G;oBACE,IAAI;oBACJ,aAAa,EAAE,KAAK,CAAC,IAAI,CAAC,IAAI,CAAC,KAAK,CAAC,OAAO,EAAE,CAAC,CAAC,GAAG,CACjD,CAAC,CAAC,EAAE,EAAE,IAAI,CAAC,MAAM;wBACf,EAAE;wBACF,aAAa,EAAE,IAAI,CAAC,aAAa;wBACjC,QAAQ,EAAE,IAAI,CAAC,QAAQ;AACxB,qBAAA,CAAC,CACH;AACF,iBAAA,CACF;;SAEJ,EAAE,IAAI,CAAC;;AAGV;;;;;AAKG;IACK,WAAW,GAAA;;QAEjB,IAAI,CAAC,IAAI,CAAC,IAAI;AAAE,YAAA,OAAO,KAAK;;AAG5B,QAAA,IAAI,IAAI,CAAC,aAAa,CAAC,IAAI,GAAG,CAAC;AAAE,YAAA,OAAO,KAAK;;AAG7C,QAAA,MAAM,UAAU,GAAG,CAAC,IAAmB,KAAa;AAClD,YAAA,KAAK,MAAM,KAAK,IAAI,IAAI,CAAC,QAAQ,EAAE;AACjC,gBAAA,IAAI,KAAK,CAAC,QAAQ,KAAK,IAAI,CAAC,EAAE;AAAE,oBAAA,OAAO,KAAK;AAC5C,gBAAA,IAAI,CAAC,UAAU,CAAC,KAAK,CAAC;AAAE,oBAAA,OAAO,KAAK;;AAEtC,YAAA,OAAO,IAAI;AACb,SAAC;AAED,QAAA,OAAO,UAAU,CAAC,IAAI,CAAC,IAAI,CAAC;;AAG9B;;;;;;;;;;;;AAYG;IACK,gBAAgB,GAAA;AACtB,QAAA,IAAI,CAAC,IAAI,CAAC,kBAAkB,EAAE;YAC5B;;;AAIF,QAAA,IAAI,CAAC,IAAI,CAAC,WAAW,EAAE,EAAE;AACvB,YAAA,IAAI,CAAC,aAAa,GAAG,IAAI;YACzB;;;AAIF,QAAA,IAAI,IAAI,CAAC,gBAAgB,EAAE;AACzB,YAAA,IAAI,CAAC,aAAa,GAAG,IAAI;YACzB;;;QAIF,IAAI,CAAC,gBAAgB,GAAG,IAAI,CAAC,eAAe,EAAE,CAAC,OAAO,CAAC,MAAK;AAC1D,YAAA,IAAI,CAAC,gBAAgB,GAAG,IAAI;;;AAI5B,YAAA,IAAI,IAAI,CAAC,aAAa,EAAE;AACtB,gBAAA,IAAI,CAAC,aAAa,GAAG,KAAK;gBAC1B,IAAI,CAAC,gBAAgB,EAAE;;AAE3B,SAAC,CAAC;;IAGI,cAAc,GAAG,KAAK;AACtB,IAAA,MAAM,eAAe,GAAA;QAC3B,IAAI,CAAC,IAAI,CAAC,IAAI;YAAE;QAEhB,MAAM,IAAI,CAAC,kBAAkB,GAAG,IAAI,CAAC,IAAI,CAAC;AAE1C,QAAA,IAAI;;AAEF,YAAA,MAAM,qBAAqB,GAAG,CAAC,GAAY,KAAa;AACtD,gBAAA,IAAI,IAAI,CAAC,gBAAgB,CAAC,GAAG,CAAC,IAAI,OAAO,GAAG,KAAK,UAAU,EAAE;AAC3D,oBAAA,OAAO,YAAY;;AAErB,gBAAA,IAAI,KAAK,CAAC,OAAO,CAAC,GAAG,CAAC,EAAE;AACtB,oBAAA,OAAO,GAAG,CAAC,GAAG,CAAC,qBAAqB,CAAC;;AAEvC,gBAAA,IAAI,GAAG,IAAI,OAAO,GAAG,KAAK,QAAQ,IAAI,CAAC,WAAW,CAAC,MAAM,CAAC,GAAG,CAAC,EAAE;oBAC9D,OAAO,MAAM,CAAC,WAAW,CACvB,MAAM,CAAC,OAAO,CAAC,GAAG,CAAC,CAAC,GAAG,CAAC,CAAC,CAAC,GAAG,EAAE,KAAK,CAAC,KAAK;wBACxC,GAAG;wBACH,qBAAqB,CAAC,KAAK,CAAC;AAC7B,qBAAA,CAAC,CACH;;AAEH,gBAAA,OAAO,GAAG;AACZ,aAAC;YAED,MAAM,QAAQ,GAAG,qBAAqB,CAAC,IAAI,CAAC,IAAI,CAAC;YACjD,MAAM,UAAU,GAAG,IAAI,CAAC,iBAAiB,CAAC,QAAyB,CAAC;YACpE,MAAM,KAAK,GAAG,IAAI,CAAC,UAAU,CAAC,IAAI,CAAC,IAAI,CAAC;AAExC,YAAA,SAAS,QAAQ,CAAC,GAAW,EAAE,KAAc,EAAA;AAC3C,gBAAA,IAAI,OAAO,KAAK,KAAK,UAAU,EAAE;AAC/B,oBAAA,OAAO,CAAC,IAAI,CAAC,qDAAqD,EAAE;wBAClE,GAAG;AACJ,qBAAA,CAAC;AACF,oBAAA,OAAO,YAAY;;gBAGrB,IAAI,OAAO,KAAK,KAAK,QAAQ,IAAI,KAAK,KAAK,IAAI,EAAE;AAC/C,oBAAA,IAAIE,yBAAe,CAAC,KAAK,CAAC,EAAE;AAC1B,wBAAA,OAAO,CAAC,IAAI,CACV,2DAA2D,EAC3D;4BACE,GAAG;AACJ,yBAAA,CACF;AACD,wBAAA,OAAO,kBAAkB;;AAE3B,oBAAA,IAAIC,0BAAgB,CAAC,KAAK,CAAC,EAAE;AAC3B,wBAAA,OAAO,CAAC,IAAI,CACV,4DAA4D,EAC5D;4BACE,GAAG;AACJ,yBAAA,CACF;AACD,wBAAA,OAAO,mBAAmB;;;AAI9B,gBAAA,IAAI,OAAO,KAAK,KAAK,QAAQ,EAAE;AAC7B,oBAAA,OAAO,WAAW,KAAK,CAAC,QAAQ,EAAE,IAAI;;AAGxC,gBAAA,OAAO,KAAK;;;AAId,YAAA,MAAM,mBAAmB,GAAG,MAAM,SAAS,CACzCC,kBAAM,CAAC,IAAI,CACT,IAAI,CAAC,SAAS,CACZ;AACE,gBAAA,GAAG,UAAU;AACb,gBAAA,SAAS,EAAE,IAAI,CAAC,GAAG,EAAE;AACtB,aAAA,EACD,QAAQ,CACT,EACD,OAAO,CACR,CACF;AACD,YAAA,MAAM,yBAAyB,GAC7BA,kBAAM,CAAC,IAAI,CAAC,mBAAmB,CAAC,CAAC,QAAQ,CAAC,QAAQ,CAAC;YAErD,MAAM,YAAY,GAAG,IAAI,CAAC,YAAY,IAAI,IAAI,CAAC,IAAI,CAAC,aAAa;AACjE,YAAA,MAAM,OAAO,GAAG;gBACd,WAAW,EAAE,IAAI,CAAC,cAAc;gBAChC,OAAO,EAAE,IAAI,CAAC,OAAO;AACrB,gBAAA,aAAa,EAAE,CAAC;gBAChB,YAAY;AACZ,gBAAA,SAAS,EAAE,IAAI,CAAC,IAAI,CAAC,SAAS;AAC9B,gBAAA,WAAW,EAAE,IAAI,CAAC,IAAI,CAAC,OAAO;AAC9B,gBAAA,YAAY,EAAE,yBAAyB;gBACvC,KAAK;gBACL,OAAO,EAAE,IAAI,CAAC,OAAO;gBACrB,cAAc,EAAE,IAAI,CAAC,cAAc;gBACnC,cAAc,EAAE,IAAI,CAAC,cAAc;aACpC;AAED,YAAA,MAAM,cAAc,GAAG,MAAM,SAAS,CAAC,IAAI,CAAC,SAAS,CAAC,OAAO,CAAC,CAAC;AAE/D,YAAA,IAAI,QAAkB;AACtB,YAAA,IAAI,CAAC,IAAI,CAAC,OAAO,EAAE;;AAEjB,gBAAA,MAAM,GAAG,GAAGC,SAAI,CAAC,IAAI,CAAC,UAAU,EAAE,CAAA,KAAA,EAAQ,IAAI,CAAC,GAAG,CAAA,OAAA,CAAS,CAAC;AAC5D,gBAAA,QAAQ,GAAG,MAAM,KAAK,CAAC,GAAG,EAAE;AAC1B,oBAAA,MAAM,EAAE,MAAM;AACd,oBAAA,OAAO,EAAE;AACP,wBAAA,cAAc,EAAE,kBAAkB;AAClC,wBAAA,kBAAkB,EAAE,MAAM;AAC1B,wBAAA,aAAa,EAAE,CAAA,OAAA,EAAU,IAAI,CAAC,MAAM,CAAE,CAAA;AACtC,wBAAA,iBAAiB,EAAE,MAAM;AACzB,wBAAA,YAAY,EAAEC,oBAAU;AACzB,qBAAA;AACD,oBAAA,IAAI,EAAE,cAAc;AACrB,iBAAA,CAAC;;iBACG;AACL,gBAAA,MAAM,GAAG,GAAGD,SAAI,CACd,IAAI,CAAC,UAAU,EACf,CAAA,KAAA,EAAQ,IAAI,CAAC,GAAG,CAAW,QAAA,EAAA,IAAI,CAAC,OAAO,CAAA,CAAE,CAC1C;;AAED,gBAAA,QAAQ,GAAG,MAAM,KAAK,CAAC,GAAG,EAAE;AAC1B,oBAAA,MAAM,EAAE,KAAK;AACb,oBAAA,OAAO,EAAE;AACP,wBAAA,cAAc,EAAE,kBAAkB;AAClC,wBAAA,kBAAkB,EAAE,MAAM;AAC1B,wBAAA,aAAa,EAAE,CAAA,OAAA,EAAU,IAAI,CAAC,MAAM,CAAE,CAAA;AACtC,wBAAA,iBAAiB,EAAE,MAAM;AACzB,wBAAA,YAAY,EAAEC,oBAAU;AACzB,qBAAA;AACD,oBAAA,IAAI,EAAE,cAAc;AACrB,iBAAA,CAAC;;AAGJ,YAAA,IAAI,CAAC,QAAQ,CAAC,EAAE,EAAE;AAChB,gBAAA,OAAO,CAAC,KAAK,CAAC,CAAA,qDAAA,CAAuD,EAAE;oBACrE,MAAM,EAAE,QAAQ,CAAC,MAAM;AACvB,oBAAA,OAAO,EAAE,MAAM,QAAQ,CAAC,IAAI,EAAE;AAC/B,iBAAA,CAAC;gBACF;;YAGF,MAAM,YAAY,IAAI,MAAM,QAAQ,CAAC,IAAI,EAAE,CAI1C;AAED,YAAA,IAAI,CAAC,OAAO,GAAG,YAAY,CAAC,OAAO;YAEnC,IAAI,IAAI,CAAC,QAAQ,IAAI,CAAC,IAAI,CAAC,cAAc,EAAE;gBACzC,MAAM,YAAY,GAAG,IAAI,GAAG,CAC1B,CAAI,CAAA,EAAA,IAAI,CAAC,GAAG,CAAuB,oBAAA,EAAA,YAAY,CAAC,WAAW,CAAA,cAAA,EAAiB,YAAY,CAAC,YAAY,CAAA,CAAE,EACvG,IAAI,CAAC,cAAc,CACpB;AACD,gBAAA,IAAI,CAAC,cAAc,GAAG,IAAI;gBAC1B,OAAO,CAAC,IAAI,CACV,CAA2D,wDAAA,EAAA,YAAY,CAAC,QAAQ,EAAE,CAAa,WAAA,CAAA,CAChG;;;QAEH,OAAO,KAAK,EAAE;YACd,OAAO,CAAC,KAAK,CAAC,CAAA,uCAAA,CAAyC,EAAE,EAAE,KAAK,EAAE,CAAC;;gBAC3D;;;YAGR,IAAI,CAAC,OAAO,EAAE;;;AAIV,IAAA,UAAU,CAAC,IAAmB,EAAA;QACpC,OAAO,IAAI,CAAC,QAAQ,CAAC,MAAM,CACzB,CAAC,GAAG,EAAE,KAAK,KAAK,GAAG,GAAG,IAAI,CAAC,UAAU,CAAC,KAAK,CAAC,EAC5C,CAAC,CACF;;AAGK,IAAA,iBAAiB,CAAC,IAAmB,EAAA;;AAE3C,QAAA,IAAI,CAAC,KAAK,GAAG,IAAI,CAAC,YAAY,CAAC,IAAI,CAAC,KAAK,EAAE,IAAI,CAA4B;;AAG3E,QAAA,IAAI,IAAI,CAAC,MAAM,KAAK,SAAS,EAAE;AAC7B,YAAA,IAAI,CAAC,MAAM,GAAG,IAAI,CAAC,YAAY,CAAC,IAAI,CAAC,MAAM,EAAE,IAAI,EAAE,QAAQ,CAAC;;;AAI9D,QAAA,IAAI,IAAI,CAAC,QAAQ,EAAE;AACjB,YAAA,IAAI,CAAC,QAAQ,GAAG,IAAI,CAAC,YAAY,CAC/B,IAAI,CAAC,QAAQ,EACb,IAAI,EACJ,UAAU,CACgB;;;QAI9B,IAAI,CAAC,QAAQ,GAAG,IAAI,CAAC,QAAQ,CAAC,GAAG,CAAC,CAAC,KAAK,KAAK,IAAI,CAAC,iBAAiB,CAAC,KAAK,CAAC,CAAC;AAE3E,QAAA,OAAO,IAAI;;IAGL,OAAO,CAAC,CAAU,EAAE,CAAU,EAAA;;QAEpC,IAAI,CAAC,KAAK,CAAC;AAAE,YAAA,OAAO,IAAI;;AAGxB,QAAA,IAAI,CAAC,CAAC,IAAI,CAAC,CAAC,IAAI,OAAO,CAAC,KAAK,QAAQ,IAAI,OAAO,CAAC,KAAK,QAAQ,EAAE;AAC9D,YAAA,OAAO,KAAK;;;AAId,QAAA,IAAI,KAAK,CAAC,OAAO,CAAC,CAAC,CAAC,IAAI,KAAK,CAAC,OAAO,CAAC,CAAC,CAAC,EAAE;AACxC,YAAA,QACE,CAAC,CAAC,MAAM,KAAK,CAAC,CAAC,MAAM;gBACrB,CAAC,CAAC,KAAK,CAAC,CAAC,IAAI,EAAE,KAAK,KAAK,IAAI,CAAC,OAAO,CAAC,IAAI,EAAE,CAAC,CAAC,KAAK,CAAC,CAAC,CAAC;;;AAK1D,QAAA,IAAI,CAAC,KAAK,CAAC,OAAO,CAAC,CAAC,CAAC,IAAI,CAAC,KAAK,CAAC,OAAO,CAAC,CAAC,CAAC,EAAE;YAC1C,MAAM,KAAK,GAAG,MAAM,CAAC,IAAI,CAAC,CAAC,CAAC;YAC5B,MAAM,KAAK,GAAG,MAAM,CAAC,IAAI,CAAC,CAAC,CAAC;AAC5B,YAAA,QACE,KAAK,CAAC,MAAM,KAAK,KAAK,CAAC,MAAM;gBAC7B,KAAK,CAAC,KAAK,CAAC,CAAC,GAAG,KACd,IAAI,CAAC,OAAO,CAAC,CAAC,CAAC,GAAqB,CAAC,EAAE,CAAC,CAAC,GAAqB,CAAC,CAAC,CACjE;;AAIL,QAAA,OAAO,KAAK;;IAGN,QAAQ,CAAI,IAAmB,EAAE,EAAW,EAAA;AAClD,QAAA,IAAI,CAAC,gBAAgB,CAAC,IAAI,CAAC,IAAI,CAAC;AAChC,QAAA,IAAI;YACF,OAAO,EAAE,EAAE;;gBACH;AACR,YAAA,IAAI,CAAC,gBAAgB,CAAC,GAAG,EAAE;;;IAIvB,mBAAmB,GAAA;AACzB,QAAA,MAAM,UAAU,GAAG,IAAI,GAAG,EAAW;AACrC,QAAA,KAAK,MAAM,IAAI,IAAI,IAAI,CAAC,gBAAgB,EAAE;AACxC,YAAA,MAAM,WAAW,GAAG,IAAI,CAAC,aAAa,CAAC,GAAG,CAAC,IAAI,CAAC,EAAE,CAAC;YACnD,IAAI,WAAW,EAAE;AACf,gBAAA,KAAK,MAAM,MAAM,IAAI,WAAW,EAAE;AAChC,oBAAA,UAAU,CAAC,GAAG,CAAC,MAAM,CAAC;;;;AAI5B,QAAA,OAAO,UAAU;;AAGX,IAAA,eAAe,CACrB,KAA8B,EAC9B,KAAe,EACf,IAAmB,EAAA;AAEnB,QAAA,IAAI,CAAC,QAAQ,CAAC,IAAI,EAAE,MAAK;;AAEvB,YAAA,IAAI,WAAW,GAAG,IAAI,CAAC,aAAa,CAAC,GAAG,CAAC,IAAI,CAAC,EAAE,CAAC;YACjD,IAAI,CAAC,WAAW,EAAE;AAChB,gBAAA,WAAW,GAAG,IAAI,GAAG,EAAE;gBACvB,IAAI,CAAC,aAAa,CAAC,GAAG,CAAC,IAAI,CAAC,EAAE,EAAE,WAAW,CAAC;;;AAI9C,YAAA,KAAK,MAAM,IAAI,IAAI,KAAK,EAAE;gBACxB,MAAM,KAAK,GAAG,IAAI,CAAC,cAAc,CAAC,KAAK,EAAE,IAAI,CAAC;AAC9C,gBAAA,IAAI,KAAK,KAAK,SAAS,EAAE;AACvB,oBAAA,IAAI,CAAC,mBAAmB,CAAC,KAAK,EAAE,WAAW,CAAC;;;AAGlD,SAAC,CAAC;;IAGI,mBAAmB,CACzB,IAAa,EACb,WAAyB,EACzB,OAAO,GAAG,IAAI,OAAO,EAAE,EAAA;;AAGvB,QAAA,IAAI,IAAI,IAAI,OAAO,IAAI,KAAK,QAAQ,EAAE;AACpC,YAAA,IAAI,OAAO,CAAC,GAAG,CAAC,IAAI,CAAC,EAAE;gBACrB;;AAEF,YAAA,OAAO,CAAC,GAAG,CAAC,IAAI,CAAC;;;AAInB,QAAA,IAAI,OAAO,IAAI,KAAK,QAAQ,EAAE;YAC5B,IAAI,IAAI,CAAC,MAAM,IAAI,IAAI,CAAC,iBAAiB,EAAE;AACzC,gBAAA,WAAW,CAAC,GAAG,CAAC,IAAI,CAAC;;YAEvB;;;QAIF,IAAI,CAAC,IAAI,IAAI,OAAO,IAAI,KAAK,QAAQ,EAAE;YACrC;;;AAIF,QAAA,IAAI,KAAK,CAAC,OAAO,CAAC,IAAI,CAAC,IAAI,CAAC,WAAW,CAAC,MAAM,CAAC,IAAI,CAAC,EAAE;YACpD,MAAM,MAAM,GAAG,KAAK,CAAC,OAAO,CAAC,IAAI,CAAC,GAAG,IAAI,GAAG,MAAM,CAAC,MAAM,CAAC,IAAI,CAAC;AAC/D,YAAA,MAAM,CAAC,OAAO,CAAC,CAAC,KAAK,KAAI;gBACvB,IAAI,CAAC,mBAAmB,CAAC,KAAK,EAAE,WAAW,EAAE,OAAO,CAAC;AACvD,aAAC,CAAC;;;AAIE,IAAA,YAAY,CAClB,IAAa,EACb,WAA0B,EAC1B,IAAI,GAAG,EAAE,EAAA;QAET,MAAM,IAAI,GAAG,IAAI,CAAC,KAAK,CAAC,GAAG,CAAC,WAAW,CAAC;QACxC,IAAI,CAAC,IAAI,EAAE;AACT,YAAA,MAAM,IAAI,KAAK,CAAC,gBAAgB,CAAC;;AAEnC,QAAA,OAAO,IAAI,CAAC,QAAQ,CAAC,IAAI,EAAE,MAAK;;AAE9B,YAAA,IAAI,IAAI,CAAC,gBAAgB,CAAC,IAAI,CAAC,EAAE;AAC/B,gBAAA,OAAO,mBAAmB;;;AAI5B,YAAA,IAAI,OAAO,IAAI,KAAK,UAAU,EAAE;AAC9B,gBAAA,OAAO,YAAY;;;AAIrB,YAAA,IAAI,OAAO,IAAI,KAAK,QAAQ,EAAE;AAC5B,gBAAA,OAAO,IAAI,CAAC,WAAW,CAAC,IAAI,CAAC;;;YAI/B,IAAI,CAAC,IAAI,IAAI,OAAO,IAAI,KAAK,QAAQ,EAAE;AACrC,gBAAA,OAAO,IAAI;;;AAIb,YAAA,IAAI,KAAK,CAAC,OAAO,CAAC,IAAI,CAAC,EAAE;AACvB,gBAAA,OAAO,IAAI,CAAC,GAAG,CAAC,CAAC,IAAI,EAAE,KAAK,KAC1B,IAAI,CAAC,YAAY,CAAC,IAAI,EAAE,IAAI,EAAE,IAAI,GAAG,CAAG,EAAA,IAAI,IAAI,KAAK,CAAA,CAAE,GAAG,CAAG,EAAA,KAAK,CAAE,CAAA,CAAC,CACtE;;;YAIH,IAAI,CAAC,WAAW,CAAC,MAAM,CAAC,IAAI,CAAC,EAAE;gBAC7B,OAAO,MAAM,CAAC,WAAW,CACvB,MAAM,CAAC,OAAO,CAAC,IAAI,CAAC,CAAC,GAAG,CAAC,CAAC,CAAC,GAAG,EAAE,KAAK,CAAC,KAAK;oBACzC,GAAG;oBACH,IAAI,CAAC,YAAY,CAAC,KAAK,EAAE,IAAI,EAAE,IAAI,GAAG,CAAG,EAAA,IAAI,IAAI,GAAG,CAAA,CAAE,GAAG,GAAG,CAAC;AAC9D,iBAAA,CAAC,CACH;;;AAIH,YAAA,IAAI,WAAW,CAAC,MAAM,CAAC,IAAI,CAAC;AAAE,gBAAA,OAAO,IAAI;AAEzC,YAAA,OAAO,IAAI;AACb,SAAC,CAAC;;AAGI,IAAA,WAAW,CAAC,KAAa,EAAA;AAC/B,QAAA,MAAM,gBAAgB,GAAG,IAAI,CAAC,mBAAmB,EAAE;QACnD,IAAI,MAAM,GAAG,KAAK;;AAGlB,QAAA,MAAM,OAAO,GAAG,KAAK,CAAC,IAAI,CAAC,gBAAgB;AACxC,aAAA,MAAM,CACL,CAAC,CAAC,KAAK,OAAO,CAAC,KAAK,QAAQ,IAAI,CAAC,CAAC,MAAM,IAAI,IAAI,CAAC,iBAAiB;aAEnE,IAAI,CAAC,CAAC,CAAC,EAAE,CAAC,KAAK,MAAM,CAAC,CAAC,CAAC,CAAC,MAAM,GAAG,MAAM,CAAC,CAAC,CAAC,CAAC,MAAM,CAAC;;AAGtD,QAAA,KAAK,MAAM,MAAM,IAAI,OAAO,EAAE;AAC5B,YAAA,IAAI,OAAO,MAAM,KAAK,QAAQ,EAAE;;AAE9B,gBAAA,IAAI,MAAM,CAAC,QAAQ,CAAC,MAAM,CAAC,EAAE;oBAC3B,MAAM,aAAa,GAAG,MAAM,CAAC,OAAO,CAAC,qBAAqB,EAAE,MAAM,CAAC;oBACnE,MAAM,KAAK,GAAG,IAAI,MAAM,CAAC,aAAa,EAAE,GAAG,CAAC;oBAC5C,MAAM,GAAG,MAAM,CAAC,OAAO,CAAC,KAAK,EAAE,UAAU,CAAC;;;;AAKhD,QAAA,OAAO,MAAM;;IAGP,cAAc,CAAC,GAA4B,EAAE,IAAY,EAAA;AAC/D,QAAA,OAAO,IAAI,CAAC,KAAK,CAAC,GAAG,CAAC,CAAC,MAAM,CAAU,CAAC,IAAa,EAAE,GAAW,KAAI;AACpE,YAAA,IAAI,IAAI,IAAI,OAAO,IAAI,KAAK,QAAQ,EAAE;AACpC,gBAAA,OAAQ,IAAgC,CAAC,GAAG,CAAC;;AAE/C,YAAA,OAAO,SAAS;SACjB,EAAE,GAAG,CAAC;;AAGD,IAAA,UAAU,CAAC,KAAc,EAAA;;QAE/B,IAAI,KAAK,IAAI,IAAI;AAAE,YAAA,OAAO,KAAK;;QAG/B,IAAI,OAAO,KAAK,KAAK,UAAU;AAAE,YAAA,OAAO,KAAK;;QAG7C,IAAI,OAAO,KAAK,KAAK,QAAQ;AAAE,YAAA,OAAO,KAAK;;AAG3C,QAAA,IAAI,KAAK,CAAC,OAAO,CAAC,KAAK,CAAC,EAAE;AACxB,YAAA,OAAO,KAAK,CAAC,GAAG,CAAC,CAAC,IAAI,KAAK,IAAI,CAAC,UAAU,CAAC,IAAI,CAAC,CAAC;;;AAInD,QAAA,IAAI,WAAW,CAAC,MAAM,CAAC,KAAK,CAAC;AAAE,YAAA,OAAO,KAAK;;QAG3C,MAAM,QAAQ,GAAG,KAAmC;AACpD,QAAA,IAAI,OAAO,QAAQ,CAAC,MAAM,KAAK,UAAU,EAAE;YACzC,OAAO,IAAI,CAAC,UAAU,CAAC,QAAQ,CAAC,MAAM,EAAE,CAAC;;;AAI3C,QAAA,OAAO,MAAM,CAAC,WAAW,CACvB,MAAM,CAAC,OAAO,CAAC,KAAK,CAAC,CAAC,GAAG,CAAC,CAAC,CAAC,GAAG,EAAE,GAAG,CAAC,KAAK,CAAC,GAAG,EAAE,IAAI,CAAC,UAAU,CAAC,GAAG,CAAC,CAAC,CAAC,CACvE;;AAGH;;;;;;;;;;;;;;;;;;;;;;;;;;AA0BG;IACH,OAAO,CACL,WAEC,EACD,UAA0B,EAC1B,EAAE,oBAAoB,KAAyC,EAAE,EAAA;QAEjE,MAAM,aAAa,GAAG,IAAI,CAAC,UAAU,CACnC,WAAW,CAC+B;AAC5C,QAAA,MAAM,IAAI,GAAkB;AAC1B,YAAA,SAAS,EAAE,KAAK;AAChB,YAAA,aAAa,EAAE,SAAS;AACxB,YAAA,SAAS,EAAE,IAAI,CAAC,GAAG,EAAE;;;AAGrB,YAAA,SAAS,EAAEC,mBAAM,CAAC,MAAM,EAAE,CAAC,QAAQ,EAAE;AACrC,YAAA,QAAQ,EAAE,EAAE;AACZ,YAAA,KAAK,EAAE,EAAE;YACT,GAAG,aAAa;SACjB;;AAGD,QAAA,IAAI,IAAI,CAAC,aAAa,EAAE,WAAW,EAAE;AACnC,YAAA,IAAI,CAAC,eAAe,CAAC,IAAI,CAAC,KAAK,EAAE,IAAI,CAAC,aAAa,CAAC,WAAW,EAAE,IAAI,CAAC;;;AAIxE,QAAA,IAAI,CAAC,KAAK,CAAC,GAAG,CAAC,IAAI,CAAC;AAEpB,QAAA,MAAM,MAAM,GAAG,UAAU,GAAG,IAAI,CAAC,KAAK,CAAC,GAAG,CAAC,UAAU,CAAC,GAAG,SAAS;AAClE,QAAA,IAAI,CAAC,MAAM,IAAI,UAAU,EAAE;AACzB,YAAA,OAAO,CAAC,IAAI,CAAC,qCAAqC,EAAE;AAClD,gBAAA,UAAU,EAAE;oBACV,EAAE,EAAE,UAAU,CAAC,EAAE;AAClB,iBAAA;AACF,aAAA,CAAC;;AAEF,YAAA,IAAI,CAAC,QAAQ,GAAG,UAAU,CAAC,EAAE;AAC7B,YAAA,IAAI,CAAC,kBAAkB,CAAC,IAAI,EAAE,UAAU,CAAC;;QAG3C,IAAI,MAAM,EAAE;;AAEV,YAAA,IAAI,CAAC,cAAc,CAAC,IAAI,EAAE,MAAM,CAAC;;aAC5B;;AAEL,YAAA,IAAI,CAAC,IAAI,CAAC,IAAI,EAAE;AACd,gBAAA,IAAI,CAAC,IAAI,GAAG,IAAI;;iBACX,IAAI,IAAI,CAAC,IAAI,CAAC,QAAQ,KAAK,IAAI,CAAC,EAAE,EAAE;;gBAEzC,IAAI,CAAC,cAAc,CAAC,IAAI,CAAC,IAAI,EAAE,IAAI,CAAC;AACpC,gBAAA,IAAI,CAAC,IAAI,GAAG,IAAI;;iBACX;AACL,gBAAA,OAAO,CAAC,IAAI,CACV,CAAA,oDAAA,EAAuD,IAAI,CAAC,IAAI,CAAC,aAAa,SAAS,IAAI,CAAC,aAAa,CAAA,CAAE,CAC5G;;;;AAKL,QAAA,MAAM,eAAe,GAAG,IAAI,CAAC,aAAa,CAAC,GAAG,CAAC,IAAI,CAAC,EAAE,CAAC;QACvD,IAAI,eAAe,EAAE;;AAEnB,YAAA,KAAK,MAAM,MAAM,IAAI,eAAe,EAAE;AACpC,gBAAA,IAAI,CAAC,cAAc,CAAC,MAAM,EAAE,IAAI,CAAC;;;YAGnC,IAAI,CAAC,aAAa,CAAC,MAAM,CAAC,IAAI,CAAC,EAAE,CAAC;;QAGpC,IAAI,CAAC,oBAAoB,EAAE;YACzB,IAAI,CAAC,gBAAgB,EAAE;;AAEzB,QAAA,OAAO,IAAI;;IAGL,wBAAwB,CAC9B,IAAmB,EACnB,UAA0B,EAAA;AAE1B,QAAA,MAAM,UAAU,GAAG,UAAU,EAAE,EAAE,GAAG,SAAS,CAAC,UAAU,CAAC,EAAE,CAAC,GAAG,EAAE;AACjE,QAAA,MAAMC,QAAM,GAAGC,qBAAc,CAC3B,IAAI,CAAC,aAAa,EAClB,IAAI,CAAC,KAAK,EACV,IAAI,CAAC,aAAa,EAAE,WAAW,EAC/B,UAAU,EACV,IAAI,CAAC,gBAAgB,CACnB,UAAU,EACV,IAAI,CAAC,aAAa,EAClB,IAAI,CAAC,KAAK,EACV,IAAI,CAAC,aAAa,EAAE,WAAW,CAChC,CACF;;QAED,IAAI,IAAI,CAAC,KAAK,CAAC,GAAG,CAACD,QAAM,CAAC,EAAE;AAC1B,YAAA,OAAO,CAAC,KAAK,CAAC,iBAAiBA,QAAM,CAAA,iCAAA,CAAmC,CAAC;YACzE;;;AAIF,QAAA,MAAM,QAAQ,GAAkB;AAC9B,YAAA,GAAG,IAAI;AACP,YAAA,EAAE,EAAEA,QAAM;AACV,YAAA,SAAS,EAAED,mBAAM,CAAC,MAAM,EAAE,CAAC,QAAQ,EAAE;YACrC,QAAQ,EAAE,EAAE;SACb;;AAGD,QAAA,IAAI,CAAC,KAAK,CAAC,GAAG,CAAC,QAAQ,CAAC;AAExB,QAAA,MAAM,MAAM,GAAG,UAAU,GAAG,IAAI,CAAC,KAAK,CAAC,GAAG,CAAC,UAAU,CAAC,GAAG,SAAS;AAClE,QAAA,IAAI,UAAU,IAAI,CAAC,MAAM,EAAE;AACzB,YAAA,OAAO,CAAC,IAAI,CAAC,qCAAqC,EAAE;AAClD,gBAAA,UAAU,EAAE;oBACV,EAAE,EAAE,UAAU,CAAC,EAAE;AAClB,iBAAA;AACF,aAAA,CAAC;;AAGF,YAAA,IAAI,CAAC,kBAAkB,CAAC,QAAQ,EAAE,UAAU,CAAC;;;QAI/C,IAAI,MAAM,EAAE;AACV,YAAA,IAAI,CAAC,cAAc,CAAC,QAAQ,EAAE,MAAM,CAAC;;aAChC;;AAEL,YAAA,IAAI,CAAC,IAAI,KAAK,QAAQ;;;AAIxB,QAAA,MAAM,eAAe,GAAG,IAAI,CAAC,aAAa,CAAC,GAAG,CAAC,QAAQ,CAAC,EAAE,CAAC;QAC3D,IAAI,eAAe,EAAE;AACnB,YAAA,KAAK,MAAM,MAAM,IAAI,eAAe,EAAE;AACpC,gBAAA,IAAI,CAAC,cAAc,CAAC,MAAM,EAAE,QAAQ,CAAC;;YAEvC,IAAI,CAAC,aAAa,CAAC,MAAM,CAAC,QAAQ,CAAC,EAAE,CAAC;;;QAIxC,IAAI,CAAC,QAAQ,CAAC,OAAO,CAAC,CAAC,KAAK,KAAI;AAC9B,YAAA,IAAI,KAAK,CAAC,SAAS,EAAE;AACnB,gBAAA,IAAI,CAAC,wBAAwB,CAAC,KAAK,EAAE,QAAQ,CAAC;;AAElD,SAAC,CAAC;;IAGJ,YAAY,CACV,YAA2B,EAC3B,MAAe,EACf,EAAE,aAAa,KAAkC,EAAE,EAAA;QAEnD,MAAM,IAAI,GAAG,IAAI,CAAC,KAAK,CAAC,GAAG,CAAC,YAAY,CAAC;QAEzC,IAAI,IAAI,EAAE;AACR,YAAA,IAAI,CAAC,SAAS,GAAG,IAAI;AACrB,YAAA,IAAI,CAAC,OAAO,GAAG,IAAI,CAAC,GAAG,EAAE;YACzB,IAAI,CAAC,MAAM,GAAG,IAAI,CAAC,UAAU,CAAC,MAAM,CAAC;YAErC,IAAI,aAAa,EAAE;gBACjB,IAAI,CAAC,MAAM,GAAG;AACZ,oBAAA,iBAAiB,EAAE,IAAI;AACvB,oBAAA,IAAI,EAAE,SAAS;oBAEf,KAAK,EAAE,IAAI,CAAC,MAAM;iBACnB;;AAGH,YAAA,IACE,IAAI,CAAC,aAAa,EAAE,aAAa;gBACjC,MAAM,KAAKG,qCAAqB,EAChC;AACA,gBAAA,IAAI,CAAC,QAAQ,CAAC,IAAI,EAAE,MAAK;AACvB,oBAAA,IAAI,WAAW,GAAG,IAAI,CAAC,aAAa,CAAC,GAAG,CAAC,IAAI,CAAC,EAAE,CAAC;oBACjD,IAAI,CAAC,WAAW,EAAE;AAChB,wBAAA,WAAW,GAAG,IAAI,GAAG,EAAE;wBACvB,IAAI,CAAC,aAAa,CAAC,GAAG,CAAC,IAAI,CAAC,EAAE,EAAE,WAAW,CAAC;;AAE9C,oBAAA,IAAI,CAAC,mBAAmB,CAAC,MAAM,EAAE,WAAW,CAAC;AAC/C,iBAAC,CAAC;;YAGJ,IAAI,CAAC,gBAAgB,EAAE;;aAClB;AACL,YAAA,OAAO,CAAC,IAAI,CAAC,CAAA,6CAAA,CAA+C,EAAE;gBAC5D,EAAE,EAAE,YAAY,CAAC,EAAE;AACpB,aAAA,CAAC;;;IAIN,WAAW,CAAC,YAA2B,EAAE,QAAiC,EAAA;QACxE,MAAM,IAAI,GAAG,IAAI,CAAC,KAAK,CAAC,GAAG,CAAC,YAAY,CAAC;QACzC,IAAI,IAAI,EAAE;YACR,IAAI,CAAC,QAAQ,GAAG;gBACd,GAAG,IAAI,CAAC,QAAQ;AAChB,gBAAA,GAAG,QAAQ;aACZ;YACD,IAAI,CAAC,gBAAgB,EAAE;;;;AAK3B,IAAA,eAAe,CAAC,IAAY,EAAA;AAC1B,QAAA,IAAI,CAAC,YAAY,GAAG,IAAI;;AAG1B,IAAA,WAAW,CAAC,QAAiB,EAAA;AAC3B,QAAA,IAAI,CAAC,QAAQ,GAAG,QAAQ;;IAG1B,UAAU,CAAC,YAA2B,EAAE,OAA+B,EAAA;QACrE,MAAM,IAAI,GAAG,IAAI,CAAC,KAAK,CAAC,GAAG,CAAC,YAAY,CAAC;QACzC,IAAI,IAAI,EAAE;YACR,IACE,QAAQ,IAAI,OAAO;gBACnB,IAAI,CAAC,aAAa,EAAE,aAAa;AACjC,gBAAA,OAAO,CAAC,MAAM,KAAKA,qCAAqB,EACxC;AACA,gBAAA,IAAI,CAAC,QAAQ,CAAC,IAAI,EAAE,MAAK;AACvB,oBAAA,IAAI,WAAW,GAAG,IAAI,CAAC,aAAa,CAAC,GAAG,CAAC,IAAI,CAAC,EAAE,CAAC;oBACjD,IAAI,CAAC,WAAW,EAAE;AAChB,wBAAA,WAAW,GAAG,IAAI,GAAG,EAAE;wBACvB,IAAI,CAAC,aAAa,CAAC,GAAG,CAAC,IAAI,CAAC,EAAE,EAAE,WAAW,CAAC;;oBAE9C,IAAI,CAAC,mBAAmB,CAAC,OAAO,CAAC,MAAM,EAAE,WAAW,CAAC;AACvD,iBAAC,CAAC;;AAGJ,YAAA,MAAM,CAAC,MAAM,CAAC,IAAI,EAAE,IAAI,CAAC,UAAU,CAAC,OAAO,CAAC,CAAC;YAC7C,IAAI,CAAC,gBAAgB,EAAE;;aAClB;AACL,YAAA,OAAO,CAAC,IAAI,CAAC,CAAA,2CAAA,CAA6C,EAAE;gBAC1D,EAAE,EAAE,YAAY,CAAC,EAAE;AACpB,aAAA,CAAC;;;IAIN,KAAK,GAAA;QACH,IAAI,CAAC,gBAAgB,EAAE;;AAGzB,IAAA,MAAM,qBAAqB,GAAA;;AAEzB,QAAA,IAAI,IAAI,CAAC,gBAAgB,EAAE;YACzB,MAAM,IAAI,CAAC,gBAAgB;;;QAG7B,IAAI,IAAI,CAAC,aAAa,IAAI,IAAI,CAAC,gBAAgB,EAAE;AAC/C,YAAA,MAAM,IAAI,CAAC,qBAAqB,EAAE;;;AAI9B,IAAA,iBAAiB,CAAC,IAAmB,EAAA;AAC3C,QAAA,IAAI,CAAC,iBAAiB,CAAC,IAAI,CAAC;;AAG5B,QAAA,IAAI,CAAC,YAAY,CAAC,IAAI,CAAC,CAAC,CAAC,EAAE,CAAC,KAC1B,MAAM,CAAC,MAAM,CAAC,CAAC,CAAC,SAAS,CAAC,GAAG,MAAM,CAAC,CAAC,CAAC,SAAS,CAAC,CAAC,CAClD;;AAGK,IAAA,iBAAiB,CAAC,IAAmB,EAAA;AAC3C,QAAA,IAAI,CAAC,YAAY,CAAC,IAAI,CAAC,IAAI,CAAC;QAE5B,IAAI,CAAC,QAAQ,CAAC,OAAO,CAAC,CAAC,KAAK,KAAI;AAC9B,YAAA,IAAI,CAAC,iBAAiB,CAAC,KAAK,CAAC;AAC/B,SAAC,CAAC;;AAGJ;;;;;;;;;;AAUG;AACH,IAAA,qBAAqB,CACnB,MAAc,EAAA;AAId,QAAA,IAAI,CAAC,IAAI,CAAC,YAAY,CAAC,MAAM,EAAE;AAC7B,YAAA,OAAO,EAAE,KAAK,EAAE,KAAK,EAAE;;AAGzB,QAAA,MAAM,CAAC,MAAM,EAAE,SAAS,CAAC,GAAG,MAAM,CAAC,KAAK,CAAC,GAAG,CAAC;QAC7C,MAAM,aAAa,GAAG,MAAM,CAAC,KAAK,CAAC,GAAG,CAAC,CAAC,GAAG,EAAE;;AAG7C,QAAA,MAAM,SAAS,GAAG,IAAI,CAAC,YAAY,CAAC,IAAI,CAAC,CAAC,IAAI,KAAK,IAAI,CAAC,EAAE,KAAK,MAAM,CAAC;QACtE,IAAI,SAAS,EAAE;YACb,IAAI,IAAI,CAAC,YAAY,CAAC,OAAO,CAAC,SAAS,CAAC,KAAK,CAAC,EAAE;AAC9C,gBAAA,OAAO,CAAC,KAAK,CACX,gDAAgD,SAAS,CAAC,EAAE,CAAkD,+CAAA,EAAA,IAAI,CAAC,YAAY,CAAC,CAAC,CAAC,CAAC,EAAE,CAAA,CAAA,CAAG,CACzI;;AAEH,YAAA,IAAI,CAAC,YAAY,CAAC,MAAM,CAAC,IAAI,CAAC,YAAY,CAAC,OAAO,CAAC,SAAS,CAAC,EAAE,CAAC,CAAC;YACjE,OAAO,EAAE,KAAK,EAAE,IAAI,EAAE,IAAI,EAAE,SAAS,EAAE;;;QAIzC,MAAM,eAAe,GAAG,IAAI,CAAC,YAAY,CAAC,IAAI,CAAC,CAAC,IAAI,KAAI;AACtD,YAAA,MAAM,CAAC,UAAU,EAAE,aAAa,CAAC,GAAG,IAAI,CAAC,EAAE,CAAC,KAAK,CAAC,GAAG,CAAC;AACtD,YAAA,OAAO,UAAU,KAAK,MAAM,IAAI,aAAa,KAAK,SAAS;AAC7D,SAAC,CAAC;QACF,IAAI,eAAe,EAAE;YACnB,OAAO,CAAC,KAAK,CACX,CAAyH,sHAAA,EAAA,MAAM,CAAY,SAAA,EAAA,eAAe,CAAC,EAAE,CAAG,CAAA,CAAA,CACjK;AACD,YAAA,IAAI,CAAC,YAAY,CAAC,MAAM,CAAC,IAAI,CAAC,YAAY,CAAC,OAAO,CAAC,eAAe,CAAC,EAAE,CAAC,CAAC;YACvE,OAAO,EAAE,KAAK,EAAE,IAAI,EAAE,IAAI,EAAE,eAAe,EAAE;;;QAI/C,MAAM,WAAW,GAAG,IAAI,CAAC,YAAY,CAAC,IAAI,CAAC,CAAC,IAAI,KAAI;YAClD,MAAM,aAAa,GAAG,YAAY,CAAC,IAAI,CAAC,EAAE,CAAC;YAC3C,QACE,IAAI,CAAC,aAAa,KAAK,aAAa,IAAI,aAAa,KAAK,SAAS;AAEvE,SAAC,CAAC;QACF,IAAI,WAAW,EAAE;YACf,OAAO,CAAC,KAAK,CACX,CAA0G,uGAAA,EAAA,MAAM,CAAY,SAAA,EAAA,WAAW,CAAC,EAAE,CAAG,CAAA,CAAA,CAC9I;AACD,YAAA,IAAI,CAAC,YAAY,CAAC,MAAM,CAAC,IAAI,CAAC,YAAY,CAAC,OAAO,CAAC,WAAW,CAAC,EAAE,CAAC,CAAC;YACnE,OAAO,EAAE,KAAK,EAAE,IAAI,EAAE,IAAI,EAAE,WAAW,EAAE;;QAG3C,OAAO,CAAC,KAAK,CACX,CAAA,iCAAA,EAAoC,MAAM,CAA+F,6FAAA,CAAA,EACzI,IAAI,CAAC,SAAS;;QAEZ,IAAI,CAAC,YAAY,CAAC,GAAG,CAAC,CAAC,IAAI,KAAK,IAAI,CAAC,cAAc,CAAC,IAAI,CAAC,CAAC,EAC1D,IAAI,EACJ,CAAC,CACF,CACF;AACD,QAAA,OAAO,EAAE,KAAK,EAAE,KAAK,EAAE;;;AAIlB,IAAA,cAAc,CAAC,UAA0B,EAAA;AAC9C,QAAA,IAAI,CAAC,UAAU;AAAE,YAAA,OAAO,SAAS;AACjC,QAAA,MAAM,OAAO,GAAG;YACd,EAAE,EAAE,UAAU,CAAC,EAAE;YACjB,SAAS,EAAE,UAAU,CAAC,SAAS;YAC/B,SAAS,EAAE,UAAU,CAAC,SAAS;;AAE/B,YAAA,QAAQ,EAAE,UAAU,CAAC,QAAQ,CAAC,GAAG,CAAC,CAAC,KAAK,KAAK,IAAI,CAAC,cAAc,CAAC,KAAK,CAAC,CAAC;SACzE;AACD,QAAA,OAAO,OAAO;;;IAIhB,4BAA4B,CAAC,IAAmB,EAAE,MAAsB,EAAA;AACtE,QAAA,OAAO,CAAC,KAAK,CACX,CAAA,mCAAA,EAAsC,IAAI,CAAC,aAAa,CAAA,EAAA,EAAK,IAAI,CAAC,EAAE,CAAA,CAAA,CAAG,CACxE;AAED,QAAA,IAAI,CAAC,IAAI,CAAC,SAAS,EAAE;YACnB;;AAGF,QAAA,IAAI,CAAC,wBAAwB,CAAC,IAAI,EAAE,MAAM,CAAC;;AAG3C,QAAA,IAAI,CAAC,IAAI,CAAC,WAAW,EAAE,EAAE;YACvB,OAAO,CAAC,IAAI,CACV,CAAA,gEAAA,EAAmE,IAAI,CAAC,aAAa,CAAE,CAAA,CACxF;;;AAGN;AAED,MAAM,UAAU,GAAG,IAAI,GAAG,EAAkB;AAC5C,MAAM,aAAa,GAAG,IAAI,GAAG,EAAqB;AAElD;AACA;AACA,SAAS,SAAS,CAAC,EAAU,EAAA;AAC3B,IAAA,MAAM,MAAM,GAAG,UAAU,CAAC,GAAG,CAAC,EAAE,CAAC,IAAI,EAAE,CAAC,KAAK,CAAC,GAAG,CAAC,CAAC,CAAC,CAAC;AACrD,IAAA,UAAU,CAAC,GAAG,CAAC,EAAE,EAAE,MAAM,CAAC;AAC1B,IAAA,OAAO,MAAM;AACf;AAEA,SAAS,YAAY,CAAC,EAAU,EAAA;AAC9B,IAAA,MAAM,SAAS,GAAG,aAAa,CAAC,GAAG,CAAC,EAAE,CAAC,IAAI,EAAE,CAAC,KAAK,CAAC,GAAG,CAAC,CAAC,CAAC,CAAC;AAC3D,IAAA,aAAa,CAAC,GAAG,CAAC,EAAE,EAAE,SAAS,CAAC;AAChC,IAAA,OAAO,SAAS;AAClB;;;;;"}