{"version":3,"sources":["../../src/streaming/index.ts","../../src/streaming/MemoryMeshStream.ts","../../src/streaming/MeshStreamSerializer.ts","../../src/registry/redis/SimpleRedisClient.ts","../../src/streaming/MeshStreamChannels.ts","../../src/streaming/redis/RedisPubSubConnection.ts","../../src/streaming/redis/RedisMeshStream.ts","../../src/streaming/MeshStreamFactory.ts","../../src/streaming/StreamCommand.ts","../../src/core/errors.ts","../../src/ids/InstanceIdResolver.ts","../../src/state/MeshStateStore.ts","../../src/utils/fs.ts","../../src/utils/time.ts","../../src/registry/RegistryRecordTools.ts","../../src/registry/FileMeshRegistry.ts","../../src/registry/RegistrationSigner.ts","../../src/registry/redis/RedisMeshRegistry.ts","../../src/registry/RegistryFactory.ts"],"sourcesContent":["export { MeshStreamFactory } from './MeshStreamFactory.js'\nexport { MeshStreamChannels } from './MeshStreamChannels.js'\nexport { MeshStreamSerializer } from './MeshStreamSerializer.js'\nexport { MemoryMeshStream } from './MemoryMeshStream.js'\nexport { StreamCommand } from './StreamCommand.js'\nexport { RedisMeshStream } from './redis/RedisMeshStream.js'\nexport { RedisPubSubConnection } from './redis/RedisPubSubConnection.js'\nexport type {\n MeshLifecycleStreamPayload,\n MeshLogPublishInput,\n MeshLogStreamName,\n MeshLogStreamPayload,\n MeshStreamEnvelope,\n MeshStreamHandler,\n MeshStreamKind,\n MeshStreamPublisher,\n MeshStreamSubscribeOptions,\n MeshStreamSubscriber\n} from './types.js'\n","import { EventEmitter } from 'node:events'\nimport type { NormalizedMeshConfig } from '../core/types.js'\nimport { MeshStreamSerializer } from './MeshStreamSerializer.js'\nimport type { MeshLogPublishInput, MeshLogStreamPayload, MeshStreamEnvelope, MeshStreamHandler, MeshStreamPublisher, MeshStreamSubscriber } from './types.js'\n\nclass MemoryMeshStreamHub {\n public readonly emitter = new EventEmitter()\n}\n\nconst hubs = new Map()\n\nfunction hubFor(app: string): MemoryMeshStreamHub {\n const existing = hubs.get(app)\n if (existing) return existing\n const created = new MemoryMeshStreamHub()\n hubs.set(app, created)\n return created\n}\n\nexport class MemoryMeshStream implements MeshStreamPublisher, MeshStreamSubscriber {\n private readonly serializer = new MeshStreamSerializer()\n private readonly hub: MemoryMeshStreamHub\n private logSequence = 0\n\n public constructor(private readonly config: NormalizedMeshConfig) {\n this.hub = hubFor(config.app)\n }\n\n public async publish(input: Omit, 'id' | 'emittedAt' | 'app'> & { readonly app?: string }): Promise> {\n const envelope = this.serializer.create(this.config.app, input)\n this.hub.emitter.emit(envelope.type, envelope)\n this.hub.emitter.emit('*', envelope)\n return envelope\n }\n\n public async publishLog(input: MeshLogPublishInput): Promise | null> {\n if (!this.config.streaming.enabled || !this.config.streaming.logs) return null\n const raw = Buffer.isBuffer(input.chunk) ? input.chunk.toString('utf8') : input.chunk\n const max = this.config.streaming.maxLogChunkBytes\n const chunk = raw.length > max ? raw.slice(0, max) : raw\n return this.publish({\n kind: 'log',\n type: 'mesh.log',\n ...(input.source !== undefined ? { source: input.source } : {}),\n instanceId: input.instanceId,\n service: input.service,\n payload: {\n stream: input.stream,\n chunk,\n sequence: this.logSequence += 1,\n truncated: raw.length > max,\n ...(input.serviceType !== undefined ? { serviceType: input.serviceType } : {})\n }\n })\n }\n\n public async subscribe(types: readonly string[], handler: MeshStreamHandler): Promise<() => void> {\n const eventNames = types.length > 0 ? types : ['*']\n const wrapped = (event: MeshStreamEnvelope): void => { void handler(event) }\n for (const type of eventNames) this.hub.emitter.on(type, wrapped)\n return () => {\n for (const type of eventNames) this.hub.emitter.off(type, wrapped)\n }\n }\n}\n","import { randomUUID } from 'node:crypto'\nimport type { MeshStreamEnvelope } from './types.js'\n\nexport class MeshStreamSerializer {\n public create(app: string, input: Omit, 'id' | 'emittedAt' | 'app'> & { readonly app?: string }): MeshStreamEnvelope {\n return {\n id: randomUUID(),\n app: input.app ?? app,\n kind: input.kind,\n type: input.type,\n payload: input.payload,\n emittedAt: new Date().toISOString(),\n ...(input.source !== undefined ? { source: input.source } : {}),\n ...(input.instanceId !== undefined ? { instanceId: input.instanceId } : {}),\n ...(input.service !== undefined ? { service: input.service } : {})\n }\n }\n\n public encode(event: MeshStreamEnvelope): string {\n return JSON.stringify(event)\n }\n\n public decode(value: string): MeshStreamEnvelope | null {\n try {\n const parsed = JSON.parse(value) as Partial\n if (!parsed || typeof parsed !== 'object') return null\n if (typeof parsed.id !== 'string' || typeof parsed.app !== 'string' || typeof parsed.kind !== 'string' || typeof parsed.type !== 'string') return null\n return parsed as MeshStreamEnvelope\n } catch {\n return null\n }\n }\n}\n","import net from 'node:net'\nimport tls from 'node:tls'\n\nexport type RedisCommandArg = string | number\n\nexport interface SimpleRedisClientOptions {\n readonly url: string\n readonly connectTimeoutMs?: number\n}\n\nexport class SimpleRedisClient {\n private readonly url: URL\n private readonly timeoutMs: number\n\n public constructor(options: SimpleRedisClientOptions) {\n this.url = new URL(options.url)\n this.timeoutMs = options.connectTimeoutMs ?? 5_000\n }\n\n public async command(args: readonly RedisCommandArg[]): Promise {\n const socket = await this.connect()\n try {\n const reader = new RespReader(socket)\n socket.write(this.encode(args))\n return await reader.read()\n } finally {\n socket.end()\n }\n }\n\n private async connect(): Promise {\n const port = Number(this.url.port || (this.url.protocol === 'rediss:' ? 6380 : 6379))\n const host = this.url.hostname || '127.0.0.1'\n const socket = this.url.protocol === 'rediss:' ? tls.connect({ port, host }) : net.connect({ port, host })\n\n await new Promise((resolve, reject) => {\n const timer = setTimeout(() => {\n socket.destroy(new Error('Redis connection timed out.'))\n }, this.timeoutMs)\n socket.once('connect', () => {\n clearTimeout(timer)\n resolve()\n })\n socket.once('error', error => {\n clearTimeout(timer)\n reject(error)\n })\n })\n\n if (this.url.password) {\n if (this.url.username) await this.commandOnSocket(socket, ['AUTH', decodeURIComponent(this.url.username), decodeURIComponent(this.url.password)])\n else await this.commandOnSocket(socket, ['AUTH', decodeURIComponent(this.url.password)])\n }\n\n const db = this.url.pathname.replace(/^\\//, '')\n if (db) await this.commandOnSocket(socket, ['SELECT', db])\n return socket\n }\n\n private async commandOnSocket(socket: net.Socket, args: readonly RedisCommandArg[]): Promise {\n const reader = new RespReader(socket)\n socket.write(this.encode(args))\n return reader.read()\n }\n\n private encode(args: readonly RedisCommandArg[]): string {\n return `*${args.length}\\r\\n${args.map(arg => {\n const value = String(arg)\n return `$${Buffer.byteLength(value)}\\r\\n${value}\\r\\n`\n }).join('')}`\n }\n}\n\nclass RespReader {\n private buffer = Buffer.alloc(0)\n private waiters: Array<() => void> = []\n\n public constructor(private readonly socket: net.Socket) {\n socket.on('data', chunk => {\n this.buffer = Buffer.concat([this.buffer, chunk])\n for (const waiter of this.waiters.splice(0)) waiter()\n })\n }\n\n public async read(): Promise {\n while (true) {\n const parsed = this.tryParse(0)\n if (parsed) {\n this.buffer = this.buffer.subarray(parsed.offset)\n if (parsed.value instanceof RedisError) throw parsed.value\n return parsed.value\n }\n await new Promise((resolve, reject) => {\n const onError = (error: Error): void => {\n cleanup()\n reject(error)\n }\n const onClose = (): void => {\n cleanup()\n reject(new Error('Redis socket closed before response.'))\n }\n const wake = (): void => {\n cleanup()\n resolve()\n }\n const cleanup = (): void => {\n this.socket.off('error', onError)\n this.socket.off('close', onClose)\n const index = this.waiters.indexOf(wake)\n if (index >= 0) this.waiters.splice(index, 1)\n }\n this.socket.once('error', onError)\n this.socket.once('close', onClose)\n this.waiters.push(wake)\n })\n }\n }\n\n private tryParse(offset: number): { value: unknown; offset: number } | null {\n if (offset >= this.buffer.length) return null\n const type = String.fromCharCode(this.buffer[offset]!)\n const line = this.readLine(offset + 1)\n if (!line) return null\n\n if (type === '+') return { value: line.text, offset: line.offset }\n if (type === '-') return { value: new RedisError(line.text), offset: line.offset }\n if (type === ':') return { value: Number(line.text), offset: line.offset }\n if (type === '$') {\n const length = Number(line.text)\n if (length === -1) return { value: null, offset: line.offset }\n const end = line.offset + length\n if (this.buffer.length < end + 2) return null\n return { value: this.buffer.subarray(line.offset, end).toString('utf8'), offset: end + 2 }\n }\n if (type === '*') {\n const count = Number(line.text)\n if (count === -1) return { value: null, offset: line.offset }\n const values: unknown[] = []\n let current = line.offset\n for (let index = 0; index < count; index += 1) {\n const item = this.tryParse(current)\n if (!item) return null\n values.push(item.value)\n current = item.offset\n }\n return { value: values, offset: current }\n }\n return null\n }\n\n private readLine(offset: number): { text: string; offset: number } | null {\n const end = this.buffer.indexOf('\\r\\n', offset)\n if (end < 0) return null\n return { text: this.buffer.subarray(offset, end).toString('utf8'), offset: end + 2 }\n }\n}\n\nclass RedisError extends Error {\n public constructor(message: string) {\n super(message)\n this.name = 'RedisError'\n }\n}\n","import type { NormalizedMeshStreamingConfig } from '../core/types.js'\n\nexport class MeshStreamChannels {\n public constructor(private readonly config: NormalizedMeshStreamingConfig) {}\n\n public logs(): string {\n return `${this.config.keyPrefix}:stream:logs`\n }\n\n public events(): string {\n return `${this.config.keyPrefix}:stream:events`\n }\n\n public all(): readonly string[] {\n return [this.logs(), this.events()]\n }\n}\n","import net from 'node:net'\nimport tls from 'node:tls'\nimport type { RedisCommandArg } from '../../registry/redis/SimpleRedisClient.js'\n\nexport interface RedisPubSubConnectionOptions {\n readonly url: string\n readonly connectTimeoutMs?: number\n}\n\nexport class RedisPubSubConnection {\n private socket: net.Socket | null = null\n private reader: RespStreamReader | null = null\n private closed = false\n\n public constructor(private readonly options: RedisPubSubConnectionOptions) {}\n\n public async subscribe(channels: readonly string[], onMessage: (channel: string, message: string) => void): Promise<() => Promise> {\n if (channels.length === 0) throw new Error('RedisPubSubConnection.subscribe requires at least one channel.')\n const socket = await this.connect()\n this.socket = socket\n this.reader = new RespStreamReader(socket)\n socket.write(encode(['SUBSCRIBE', ...channels]))\n\n void this.readLoop(onMessage)\n\n return async () => {\n this.closed = true\n if (!socket.destroyed) {\n try { socket.write(encode(['UNSUBSCRIBE', ...channels])) } catch { /* noop */ }\n socket.end()\n }\n }\n }\n\n private async readLoop(onMessage: (channel: string, message: string) => void): Promise {\n const reader = this.reader\n if (!reader) return\n while (!this.closed) {\n try {\n const value = await reader.read()\n if (!Array.isArray(value) || value.length < 3) continue\n const [kind, channel, message] = value\n if (kind === 'message' && typeof channel === 'string' && typeof message === 'string') {\n onMessage(channel, message)\n }\n } catch {\n if (!this.closed) this.closed = true\n }\n }\n }\n\n private async connect(): Promise {\n const url = new URL(this.options.url)\n const port = Number(url.port || (url.protocol === 'rediss:' ? 6380 : 6379))\n const host = url.hostname || '127.0.0.1'\n const socket = url.protocol === 'rediss:' ? tls.connect({ port, host }) : net.connect({ port, host })\n const timeoutMs = this.options.connectTimeoutMs ?? 5_000\n\n await new Promise((resolve, reject) => {\n const timer = setTimeout(() => {\n socket.destroy(new Error('Redis pub/sub connection timed out.'))\n }, timeoutMs)\n socket.once('connect', () => {\n clearTimeout(timer)\n resolve()\n })\n socket.once('error', error => {\n clearTimeout(timer)\n reject(error)\n })\n })\n\n if (url.password) {\n if (url.username) await commandOnSocket(socket, ['AUTH', decodeURIComponent(url.username), decodeURIComponent(url.password)])\n else await commandOnSocket(socket, ['AUTH', decodeURIComponent(url.password)])\n }\n const db = url.pathname.replace(/^\\//, '')\n if (db) await commandOnSocket(socket, ['SELECT', db])\n return socket\n }\n}\n\nasync function commandOnSocket(socket: net.Socket, args: readonly RedisCommandArg[]): Promise {\n const reader = new RespStreamReader(socket)\n socket.write(encode(args))\n return reader.read()\n}\n\nfunction encode(args: readonly RedisCommandArg[]): string {\n return `*${args.length}\\r\\n${args.map(arg => {\n const value = String(arg)\n return `$${Buffer.byteLength(value)}\\r\\n${value}\\r\\n`\n }).join('')}`\n}\n\nclass RespStreamReader {\n private buffer = Buffer.alloc(0)\n private waiters: Array<() => void> = []\n\n public constructor(private readonly socket: net.Socket) {\n socket.on('data', chunk => {\n this.buffer = Buffer.concat([this.buffer, chunk])\n for (const waiter of this.waiters.splice(0)) waiter()\n })\n }\n\n public async read(): Promise {\n while (true) {\n const parsed = this.tryParse(0)\n if (parsed) {\n this.buffer = this.buffer.subarray(parsed.offset)\n return parsed.value\n }\n await new Promise((resolve, reject) => {\n const onError = (error: Error): void => {\n cleanup()\n reject(error)\n }\n const onClose = (): void => {\n cleanup()\n reject(new Error('Redis socket closed before response.'))\n }\n const wake = (): void => {\n cleanup()\n resolve()\n }\n const cleanup = (): void => {\n this.socket.off('error', onError)\n this.socket.off('close', onClose)\n const index = this.waiters.indexOf(wake)\n if (index >= 0) this.waiters.splice(index, 1)\n }\n this.socket.once('error', onError)\n this.socket.once('close', onClose)\n this.waiters.push(wake)\n })\n }\n }\n\n private tryParse(offset: number): { value: unknown; offset: number } | null {\n if (offset >= this.buffer.length) return null\n const type = String.fromCharCode(this.buffer[offset]!)\n const line = this.readLine(offset + 1)\n if (!line) return null\n if (type === '+') return { value: line.text, offset: line.offset }\n if (type === '-') throw new Error(line.text)\n if (type === ':') return { value: Number(line.text), offset: line.offset }\n if (type === '$') {\n const length = Number(line.text)\n if (length === -1) return { value: null, offset: line.offset }\n const end = line.offset + length\n if (this.buffer.length < end + 2) return null\n return { value: this.buffer.subarray(line.offset, end).toString('utf8'), offset: end + 2 }\n }\n if (type === '*') {\n const count = Number(line.text)\n if (count === -1) return { value: null, offset: line.offset }\n const values: unknown[] = []\n let current = line.offset\n for (let index = 0; index < count; index += 1) {\n const item = this.tryParse(current)\n if (!item) return null\n values.push(item.value)\n current = item.offset\n }\n return { value: values, offset: current }\n }\n return null\n }\n\n private readLine(offset: number): { text: string; offset: number } | null {\n const end = this.buffer.indexOf('\\r\\n', offset)\n if (end < 0) return null\n return { text: this.buffer.subarray(offset, end).toString('utf8'), offset: end + 2 }\n }\n}\n","import type { NormalizedMeshConfig } from '../../core/types.js'\nimport { SimpleRedisClient } from '../../registry/redis/SimpleRedisClient.js'\nimport { MeshStreamChannels } from '../MeshStreamChannels.js'\nimport { MeshStreamSerializer } from '../MeshStreamSerializer.js'\nimport type { MeshLogPublishInput, MeshLogStreamPayload, MeshStreamEnvelope, MeshStreamHandler, MeshStreamPublisher, MeshStreamSubscriber } from '../types.js'\nimport { RedisPubSubConnection } from './RedisPubSubConnection.js'\n\nexport class RedisMeshStream implements MeshStreamPublisher, MeshStreamSubscriber {\n private readonly client: SimpleRedisClient\n private readonly channels: MeshStreamChannels\n private readonly serializer = new MeshStreamSerializer()\n private logSequence = 0\n\n public constructor(private readonly config: NormalizedMeshConfig) {\n this.client = new SimpleRedisClient({ url: config.streaming.url, connectTimeoutMs: config.streaming.connectTimeoutMs })\n this.channels = new MeshStreamChannels(config.streaming)\n }\n\n public async publish(input: Omit, 'id' | 'emittedAt' | 'app'> & { readonly app?: string }): Promise> {\n const envelope = this.serializer.create(this.config.app, input)\n const channel = envelope.kind === 'log' ? this.channels.logs() : this.channels.events()\n await this.client.command(['PUBLISH', channel, this.serializer.encode(envelope)])\n return envelope\n }\n\n public async publishLog(input: MeshLogPublishInput): Promise | null> {\n if (!this.config.streaming.enabled || !this.config.streaming.logs) return null\n const raw = Buffer.isBuffer(input.chunk) ? input.chunk.toString('utf8') : input.chunk\n const max = this.config.streaming.maxLogChunkBytes\n const chunk = raw.length > max ? raw.slice(0, max) : raw\n return this.publish({\n kind: 'log',\n type: 'mesh.log',\n ...(input.source !== undefined ? { source: input.source } : {}),\n instanceId: input.instanceId,\n service: input.service,\n payload: {\n stream: input.stream,\n chunk,\n sequence: this.logSequence += 1,\n truncated: raw.length > max,\n ...(input.serviceType !== undefined ? { serviceType: input.serviceType } : {})\n }\n })\n }\n\n public async subscribe(types: readonly string[], handler: MeshStreamHandler): Promise<() => Promise> {\n const channels = this.channels.all()\n const wanted = new Set(types)\n const any = wanted.size === 0 || wanted.has('*')\n const connection = new RedisPubSubConnection({ url: this.config.streaming.url, connectTimeoutMs: this.config.streaming.connectTimeoutMs })\n return connection.subscribe(channels, (_channel, message) => {\n const envelope = this.serializer.decode(message)\n if (!envelope) return\n if (!any && !wanted.has(envelope.type) && !wanted.has(envelope.kind)) return\n void handler(envelope)\n })\n }\n}\n","import type { NormalizedMeshConfig } from '../core/types.js'\nimport { MemoryMeshStream } from './MemoryMeshStream.js'\nimport { RedisMeshStream } from './redis/RedisMeshStream.js'\nimport type { MeshStreamPublisher, MeshStreamSubscriber } from './types.js'\n\nexport class MeshStreamFactory {\n public createPublisher(config: NormalizedMeshConfig): MeshStreamPublisher | null {\n if (!config.streaming.enabled) return null\n if (config.streaming.transport === 'redis') return new RedisMeshStream(config)\n return new MemoryMeshStream(config)\n }\n\n public createSubscriber(config: NormalizedMeshConfig): MeshStreamSubscriber | null {\n if (!config.streaming.enabled) return null\n if (config.streaming.transport === 'redis') return new RedisMeshStream(config)\n return new MemoryMeshStream(config)\n }\n}\n","import process from 'node:process'\nimport type { NormalizedMeshConfig } from '../core/types.js'\nimport { InstanceIdResolver } from '../ids/InstanceIdResolver.js'\nimport { RegistryFactory } from '../registry/RegistryFactory.js'\nimport { MeshStreamFactory } from './MeshStreamFactory.js'\nimport type { MeshLogStreamPayload, MeshStreamEnvelope, MeshStreamSubscribeOptions } from './types.js'\n\nexport interface MeshStreamCommandOptions extends MeshStreamSubscribeOptions {\n readonly json?: boolean\n readonly raw?: boolean\n}\n\nexport class StreamCommand {\n public constructor(private readonly config: NormalizedMeshConfig) {}\n\n public async run(options: MeshStreamCommandOptions = {}): Promise {\n const subscriber = new MeshStreamFactory().createSubscriber(this.config)\n if (!subscriber) throw new Error('Mesh streaming is disabled. Enable streaming in mesh.config.ts.')\n const filters = await this.resolveFilters(options)\n const stop = await subscriber.subscribe(options.types ?? [], event => {\n if (!this.matches(event, filters)) return\n process.stdout.write(this.format(event, options))\n })\n const close = (): void => { void Promise.resolve(stop()).finally(() => process.exit(0)) }\n process.once('SIGINT', close)\n process.once('SIGTERM', close)\n await new Promise(() => undefined)\n }\n\n private async resolveFilters(options: MeshStreamCommandOptions): Promise {\n if (!options.instances || options.instances.length === 0) return options\n const registry = new RegistryFactory().create(this.config)\n const instances = await registry.list({ includeExpired: true })\n const resolver = new InstanceIdResolver()\n return {\n ...options,\n instances: options.instances.map(prefix => resolver.resolve(instances, prefix).id)\n }\n }\n\n private matches(event: MeshStreamEnvelope, options: MeshStreamSubscribeOptions): boolean {\n if (options.kinds && options.kinds.length > 0 && !options.kinds.includes(event.kind)) return false\n if (options.services && options.services.length > 0 && (!event.service || !options.services.includes(event.service))) return false\n if (options.instances && options.instances.length > 0 && (!event.instanceId || !options.instances.includes(event.instanceId))) return false\n return true\n }\n\n private format(event: MeshStreamEnvelope, options: MeshStreamCommandOptions): string {\n if (options.json) return `${JSON.stringify(event)}\\n`\n if (options.raw && event.kind === 'log') return (event.payload as MeshLogStreamPayload).chunk\n if (event.kind === 'log') {\n const payload = event.payload as MeshLogStreamPayload\n const id = event.instanceId ?? 'unknown'\n return `[${id}:${payload.stream}] ${payload.chunk}`\n }\n return `[${event.kind}:${event.type}] ${event.service ?? '-'} ${event.instanceId ?? '-'} ${JSON.stringify(event.payload)}\\n`\n }\n}\n","export class MeshError extends Error {\n public constructor(message: string) {\n super(message)\n this.name = new.target.name\n }\n}\n\nexport class MeshConfigError extends MeshError {}\nexport class MeshStateError extends MeshError {}\nexport class MeshProcessError extends MeshError {}\nexport class MeshIdResolutionError extends MeshError {}\n","import { MeshIdResolutionError } from '../core/errors.js'\nimport type { MeshInstanceRecord } from '../core/types.js'\n\nexport class InstanceIdResolver {\n public resolve(instances: readonly MeshInstanceRecord[], prefix: string): MeshInstanceRecord {\n const normalized = prefix.trim()\n if (!normalized) throw new MeshIdResolutionError('Instance id prefix is required.')\n\n const matches = instances.filter(instance => instance.id.startsWith(normalized) || instance.id.includes(normalized))\n if (matches.length === 0) throw new MeshIdResolutionError(`No instance matches \"${prefix}\".`)\n if (matches.length > 1) {\n throw new MeshIdResolutionError(`Ambiguous instance id \"${prefix}\": ${matches.map(match => match.id).join(', ')}`)\n }\n return matches[0]!\n }\n}\n","import fs from 'node:fs'\nimport path from 'node:path'\nimport { MeshStateError } from '../core/errors.js'\nimport type { MeshInstanceRecord, MeshStateFile } from '../core/types.js'\nimport { atomicWriteJson, ensureDir, pathExists } from '../utils/fs.js'\nimport { nowIso } from '../utils/time.js'\n\nexport class MeshStateStore {\n public constructor(\n private readonly app: string,\n private readonly stateDir: string\n ) {}\n\n public get statePath(): string {\n return path.join(this.stateDir, 'state.json')\n }\n\n public async read(): Promise {\n if (!(await pathExists(this.statePath))) {\n return this.empty()\n }\n try {\n const text = await fs.promises.readFile(this.statePath, 'utf8')\n const parsed = this.parseState(text)\n if (parsed.version !== 1) throw new MeshStateError(`Unsupported mesh state version: ${String(parsed.version)}`)\n return parsed\n } catch (error) {\n if (error instanceof SyntaxError) {\n const recovered = await this.recoverCorruptedState()\n if (recovered) return recovered\n }\n if (error instanceof MeshStateError) throw error\n throw new MeshStateError(`Failed to read mesh state: ${(error as Error).message}`)\n }\n }\n\n public async write(instances: readonly MeshInstanceRecord[]): Promise {\n await ensureDir(this.stateDir)\n await atomicWriteJson(this.statePath, {\n version: 1,\n app: this.app,\n updatedAt: nowIso(),\n instances\n } satisfies MeshStateFile)\n }\n\n public async upsert(instance: MeshInstanceRecord): Promise {\n const state = await this.read()\n const others = state.instances.filter(item => item.id !== instance.id)\n await this.write([...others, instance])\n }\n\n public async update(instanceId: string, patch: Partial): Promise {\n const state = await this.read()\n const current = state.instances.find(item => item.id === instanceId)\n if (!current) throw new MeshStateError(`Instance not found in state: ${instanceId}`)\n const next = { ...current, ...patch } as MeshInstanceRecord\n await this.write(state.instances.map(item => item.id === instanceId ? next : item))\n return next\n }\n\n public async remove(instanceIds: readonly string[]): Promise {\n const set = new Set(instanceIds)\n const state = await this.read()\n await this.write(state.instances.filter(instance => !set.has(instance.id)))\n }\n\n public empty(): MeshStateFile {\n return {\n version: 1,\n app: this.app,\n updatedAt: nowIso(),\n instances: []\n }\n }\n\n private parseState(text: string): MeshStateFile {\n return JSON.parse(text) as MeshStateFile\n }\n\n private async recoverCorruptedState(): Promise {\n const text = await fs.promises.readFile(this.statePath, 'utf8')\n const prefix = this.extractRootJsonPrefix(text)\n if (!prefix) return null\n\n try {\n const parsed = this.parseState(prefix)\n if (parsed.version !== 1) throw new MeshStateError(`Unsupported mesh state version: ${String(parsed.version)}`)\n await atomicWriteJson(this.statePath, parsed)\n return parsed\n } catch {\n return null\n }\n }\n\n private extractRootJsonPrefix(text: string): string | null {\n const start = text.search(/\\s*[{[]/)\n if (start < 0) return null\n\n let depth = 0\n let inString = false\n let escaped = false\n\n for (let index = start; index < text.length; index += 1) {\n const char = text[index]\n\n if (inString) {\n if (escaped) {\n escaped = false\n continue\n }\n if (char === '\\\\') {\n escaped = true\n continue\n }\n if (char === '\"') inString = false\n continue\n }\n\n if (char === '\"') {\n inString = true\n continue\n }\n\n if (char === '{' || char === '[') {\n depth += 1\n continue\n }\n\n if (char === '}' || char === ']') {\n depth -= 1\n if (depth === 0) {\n return text.slice(start, index + 1)\n }\n }\n }\n\n return null\n }\n}\n","import fs from 'node:fs'\nimport path from 'node:path'\n\nexport async function ensureDir(dir: string): Promise {\n await fs.promises.mkdir(dir, { recursive: true })\n}\n\nexport async function pathExists(filePath: string): Promise {\n try {\n await fs.promises.access(filePath)\n return true\n } catch {\n return false\n }\n}\n\nexport async function atomicWriteJson(filePath: string, value: unknown): Promise {\n await ensureDir(path.dirname(filePath))\n const tempPath = `${filePath}.${process.pid}.${Date.now()}.tmp`\n await fs.promises.writeFile(tempPath, `${JSON.stringify(value, null, 2)}\\n`, 'utf8')\n await fs.promises.rename(tempPath, filePath)\n}\n","export function nowIso(): string {\n return new Date().toISOString()\n}\n\nexport function formatDurationSince(iso: string): string {\n const started = new Date(iso).getTime()\n const diff = Math.max(0, Date.now() - started)\n const seconds = Math.floor(diff / 1000)\n if (seconds < 60) return `${seconds}s`\n const minutes = Math.floor(seconds / 60)\n if (minutes < 60) return `${minutes}m`\n const hours = Math.floor(minutes / 60)\n if (hours < 24) return `${hours}h`\n const days = Math.floor(hours / 24)\n return `${days}d`\n}\n\nexport async function sleep(ms: number): Promise {\n if (ms <= 0) return\n await new Promise(resolve => setTimeout(resolve, ms))\n}\n","import type { MeshInstanceRecord, MeshInstanceStatus } from '../core/types.js'\n\nexport class RegistryRecordTools {\n public static touch(instance: MeshInstanceRecord, ttlMs: number, now = Date.now()): MeshInstanceRecord {\n return {\n ...instance,\n status: instance.status === 'expired' ? 'running' : instance.status,\n lastSeenAt: new Date(now).toISOString(),\n expiresAt: new Date(now + ttlMs).toISOString()\n }\n }\n\n public static markExpired(instance: MeshInstanceRecord, now = Date.now()): MeshInstanceRecord {\n if (!this.isExpired(instance, now)) return instance\n return { ...instance, status: 'expired' as MeshInstanceStatus }\n }\n\n public static isExpired(instance: MeshInstanceRecord, now = Date.now()): boolean {\n if (!instance.expiresAt) return false\n return new Date(instance.expiresAt).getTime() <= now\n }\n\n public static isRoutable(instance: MeshInstanceRecord, now = Date.now()): boolean {\n return instance.status === 'running'\n && instance.url !== null\n && instance.serviceType !== 'worker'\n && instance.serviceType !== 'router'\n && !this.isExpired(instance, now)\n }\n}\n","import type { MeshInstanceRecord } from '../core/types.js'\nimport { MeshStateStore } from '../state/MeshStateStore.js'\nimport type { MeshRegistry, MeshRegistryHeartbeatOptions, MeshRegistryListOptions, MeshRegistryRegisterOptions } from './types.js'\nimport { RegistryRecordTools } from './RegistryRecordTools.js'\n\nexport class FileMeshRegistry implements MeshRegistry {\n public readonly kind = 'file'\n private readonly store: MeshStateStore\n\n public constructor(app: string, stateDir: string) {\n this.store = new MeshStateStore(app, stateDir)\n }\n\n public async register(instance: MeshInstanceRecord, options: MeshRegistryRegisterOptions = {}): Promise {\n const record = options.ttlMs ? RegistryRecordTools.touch(instance, options.ttlMs) : instance\n await this.store.upsert(record)\n return record\n }\n\n public async heartbeat(instanceId: string, options: MeshRegistryHeartbeatOptions = {}): Promise {\n const current = await this.get(instanceId)\n if (!current) return null\n const patched = { ...current, ...(options.patch ?? {}) } as MeshInstanceRecord\n const next = options.ttlMs ? RegistryRecordTools.touch(patched, options.ttlMs) : patched\n await this.store.upsert(next)\n return next\n }\n\n public async list(options: MeshRegistryListOptions = {}): Promise {\n const state = await this.store.read()\n const refreshed = state.instances.map(instance => RegistryRecordTools.markExpired(instance))\n if (refreshed.some((instance, index) => instance !== state.instances[index])) {\n await this.store.write(refreshed)\n }\n return refreshed.filter(instance => {\n if (options.service && instance.service !== options.service) return false\n if (!options.includeExpired && instance.status === 'expired') return false\n return true\n })\n }\n\n public async get(instanceId: string): Promise {\n const state = await this.store.read()\n return state.instances.find(instance => instance.id === instanceId) ?? null\n }\n\n public async markDraining(instanceId: string): Promise {\n const current = await this.get(instanceId)\n if (!current) return null\n const next = { ...current, status: 'draining' as const }\n await this.store.upsert(next)\n return next\n }\n\n public async unregister(instanceId: string): Promise {\n await this.store.remove([instanceId])\n }\n}\n","import crypto from 'node:crypto'\nimport type { MeshInstanceRecord } from '../core/types.js'\n\nexport interface RegistrationSignaturePayload {\n readonly app: string\n readonly id: string\n readonly service: string\n readonly serviceType: string\n readonly url: string | null\n readonly pid: number | null\n readonly issuedAt: string\n}\n\nexport class RegistrationSigner {\n public constructor(\n private readonly app: string,\n private readonly secret: string\n ) {}\n\n public sign(instance: MeshInstanceRecord, issuedAt = new Date().toISOString()): string {\n return this.hmac(this.payload(instance, issuedAt))\n }\n\n public attach(instance: MeshInstanceRecord, issuedAt = new Date().toISOString()): MeshInstanceRecord {\n const signature = this.sign(instance, issuedAt)\n return {\n ...instance,\n metadata: {\n ...(instance.metadata ?? {}),\n registration: {\n app: this.app,\n issuedAt,\n signature\n }\n }\n }\n }\n\n public verify(instance: MeshInstanceRecord): boolean {\n const registration = this.registration(instance)\n if (!registration) return false\n const expected = this.sign(instance, registration.issuedAt)\n return this.safeEqual(expected, registration.signature)\n }\n\n private payload(instance: MeshInstanceRecord, issuedAt: string): RegistrationSignaturePayload {\n return {\n app: this.app,\n id: instance.id,\n service: instance.service,\n serviceType: instance.serviceType,\n url: instance.url,\n pid: instance.pid,\n issuedAt\n }\n }\n\n private hmac(payload: RegistrationSignaturePayload): string {\n return crypto.createHmac('sha256', this.secret).update(JSON.stringify(payload)).digest('base64url')\n }\n\n private registration(instance: MeshInstanceRecord): { issuedAt: string; signature: string } | null {\n const value = instance.metadata?.registration\n if (!value || typeof value !== 'object') return null\n const record = value as Record\n if (record.app !== this.app || typeof record.issuedAt !== 'string' || typeof record.signature !== 'string') return null\n return { issuedAt: record.issuedAt, signature: record.signature }\n }\n\n private safeEqual(a: string, b: string): boolean {\n const left = Buffer.from(a)\n const right = Buffer.from(b)\n return left.length === right.length && crypto.timingSafeEqual(left, right)\n }\n}\n","import type { MeshInstanceRecord } from '../../core/types.js'\nimport type { MeshRegistry, MeshRegistryHeartbeatOptions, MeshRegistryListOptions, MeshRegistryRegisterOptions } from '../types.js'\nimport { RegistryRecordTools } from '../RegistryRecordTools.js'\nimport { RegistrationSigner } from '../RegistrationSigner.js'\nimport { SimpleRedisClient, type SimpleRedisClientOptions } from './SimpleRedisClient.js'\n\nexport interface RedisMeshRegistryOptions extends SimpleRedisClientOptions {\n readonly app: string\n readonly secret?: string\n readonly keyPrefix?: string\n readonly requireSignature?: boolean\n}\n\nexport class RedisMeshRegistry implements MeshRegistry {\n public readonly kind = 'redis'\n private readonly client: SimpleRedisClient\n private readonly prefix: string\n private readonly signer: RegistrationSigner | undefined\n private readonly requireSignature: boolean\n\n public constructor(private readonly options: RedisMeshRegistryOptions) {\n this.client = new SimpleRedisClient(options)\n this.prefix = options.keyPrefix ?? `mesh:${options.app}`\n this.signer = options.secret ? new RegistrationSigner(options.app, options.secret) : undefined\n this.requireSignature = options.requireSignature ?? Boolean(options.secret)\n }\n\n public async register(instance: MeshInstanceRecord, options: MeshRegistryRegisterOptions = {}): Promise {\n const ttlMs = options.ttlMs ?? 15_000\n const touched = RegistryRecordTools.touch(instance, ttlMs)\n const signed = this.signer ? this.signer.attach(touched) : touched\n await this.client.command(['SADD', this.indexKey(), signed.id])\n await this.client.command(['SET', this.instanceKey(signed.id), JSON.stringify(signed), 'PX', ttlMs])\n return signed\n }\n\n public async heartbeat(instanceId: string, options: MeshRegistryHeartbeatOptions = {}): Promise {\n const current = await this.get(instanceId)\n if (!current) return null\n const ttlMs = options.ttlMs ?? this.remainingTtl(current) ?? 15_000\n const patched = { ...current, ...(options.patch ?? {}) } as MeshInstanceRecord\n const touched = RegistryRecordTools.touch(patched, ttlMs)\n const signed = this.signer ? this.signer.attach(touched) : touched\n await this.client.command(['SET', this.instanceKey(instanceId), JSON.stringify(signed), 'PX', ttlMs])\n return signed\n }\n\n public async list(options: MeshRegistryListOptions = {}): Promise {\n const ids = await this.ids()\n const items = await Promise.all(ids.map(id => this.get(id)))\n const now = Date.now()\n const alive: MeshInstanceRecord[] = []\n const staleIds: string[] = []\n\n for (let index = 0; index < ids.length; index += 1) {\n const id = ids[index]!\n const item = items[index]\n if (!item) {\n staleIds.push(id)\n continue\n }\n const refreshed = RegistryRecordTools.markExpired(item, now)\n if (options.service && refreshed.service !== options.service) continue\n if (!options.includeExpired && refreshed.status === 'expired') continue\n alive.push(refreshed)\n }\n\n if (staleIds.length > 0) await this.client.command(['SREM', this.indexKey(), ...staleIds])\n return alive\n }\n\n public async get(instanceId: string): Promise {\n const raw = await this.client.command(['GET', this.instanceKey(instanceId)])\n if (typeof raw !== 'string') return null\n const parsed = JSON.parse(raw) as MeshInstanceRecord\n if (this.requireSignature && (!this.signer || !this.signer.verify(parsed))) return null\n return parsed\n }\n\n public async markDraining(instanceId: string): Promise {\n const current = await this.get(instanceId)\n if (!current) return null\n return this.heartbeat(instanceId, { patch: { status: 'draining' } })\n }\n\n public async unregister(instanceId: string): Promise {\n await this.client.command(['DEL', this.instanceKey(instanceId)])\n await this.client.command(['SREM', this.indexKey(), instanceId])\n }\n\n private async ids(): Promise {\n const value = await this.client.command(['SMEMBERS', this.indexKey()])\n return Array.isArray(value) ? value.filter((item): item is string => typeof item === 'string') : []\n }\n\n private remainingTtl(instance: MeshInstanceRecord): number | null {\n if (!instance.expiresAt) return null\n return Math.max(1_000, new Date(instance.expiresAt).getTime() - Date.now())\n }\n\n private indexKey(): string {\n return `${this.prefix}:instances`\n }\n\n private instanceKey(id: string): string {\n return `${this.prefix}:instance:${id}`\n }\n}\n","import { FileMeshRegistry } from './FileMeshRegistry.js'\nimport type { MeshRegistry } from './types.js'\nimport type { NormalizedMeshConfig } from '../core/types.js'\nimport { RedisMeshRegistry } from './redis/RedisMeshRegistry.js'\n\nexport class RegistryFactory {\n public create(config: NormalizedMeshConfig): MeshRegistry {\n if (config.registry.type === 'file') {\n return new FileMeshRegistry(config.app, config.runtime.stateDir)\n }\n return new RedisMeshRegistry({\n app: config.app,\n url: config.registry.url,\n ...(config.registry.keyPrefix !== undefined ? { keyPrefix: config.registry.keyPrefix } : {}),\n ...(config.registry.secret !== undefined ? { secret: config.registry.secret } : {}),\n requireSignature: config.registry.requireSignature,\n connectTimeoutMs: config.registry.connectTimeoutMs\n })\n }\n}\n"],"mappings":";;;;;;;;;;;;;;;;;;;;;;;;;;;;;;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA;;;ACAA,yBAA6B;;;ACA7B,yBAA2B;AAGpB,IAAM,uBAAN,MAA2B;AAAA,EACzB,OAAiB,KAAa,OAAiI;AACpK,WAAO;AAAA,MACL,QAAI,+BAAW;AAAA,MACf,KAAK,MAAM,OAAO;AAAA,MAClB,MAAM,MAAM;AAAA,MACZ,MAAM,MAAM;AAAA,MACZ,SAAS,MAAM;AAAA,MACf,YAAW,oBAAI,KAAK,GAAE,YAAY;AAAA,MAClC,GAAI,MAAM,WAAW,SAAY,EAAE,QAAQ,MAAM,OAAO,IAAI,CAAC;AAAA,MAC7D,GAAI,MAAM,eAAe,SAAY,EAAE,YAAY,MAAM,WAAW,IAAI,CAAC;AAAA,MACzE,GAAI,MAAM,YAAY,SAAY,EAAE,SAAS,MAAM,QAAQ,IAAI,CAAC;AAAA,IAClE;AAAA,EACF;AAAA,EAEO,OAAO,OAAmC;AAC/C,WAAO,KAAK,UAAU,KAAK;AAAA,EAC7B;AAAA,EAEO,OAAO,OAA0C;AACtD,QAAI;AACF,YAAM,SAAS,KAAK,MAAM,KAAK;AAC/B,UAAI,CAAC,UAAU,OAAO,WAAW,SAAU,QAAO;AAClD,UAAI,OAAO,OAAO,OAAO,YAAY,OAAO,OAAO,QAAQ,YAAY,OAAO,OAAO,SAAS,YAAY,OAAO,OAAO,SAAS,SAAU,QAAO;AAClJ,aAAO;AAAA,IACT,QAAQ;AACN,aAAO;AAAA,IACT;AAAA,EACF;AACF;;;AD3BA,IAAM,sBAAN,MAA0B;AAAA,EACR,UAAU,IAAI,gCAAa;AAC7C;AAEA,IAAM,OAAO,oBAAI,IAAiC;AAElD,SAAS,OAAO,KAAkC;AAChD,QAAM,WAAW,KAAK,IAAI,GAAG;AAC7B,MAAI,SAAU,QAAO;AACrB,QAAM,UAAU,IAAI,oBAAoB;AACxC,OAAK,IAAI,KAAK,OAAO;AACrB,SAAO;AACT;AAEO,IAAM,mBAAN,MAA4E;AAAA,EAK1E,YAA6B,QAA8B;AAA9B;AAClC,SAAK,MAAM,OAAO,OAAO,GAAG;AAAA,EAC9B;AAAA,EAFoC;AAAA,EAJnB,aAAa,IAAI,qBAAqB;AAAA,EACtC;AAAA,EACT,cAAc;AAAA,EAMtB,MAAa,QAAkB,OAA0I;AACvK,UAAM,WAAW,KAAK,WAAW,OAAO,KAAK,OAAO,KAAK,KAAK;AAC9D,SAAK,IAAI,QAAQ,KAAK,SAAS,MAAM,QAAQ;AAC7C,SAAK,IAAI,QAAQ,KAAK,KAAK,QAAQ;AACnC,WAAO;AAAA,EACT;AAAA,EAEA,MAAa,WAAW,OAAsF;AAC5G,QAAI,CAAC,KAAK,OAAO,UAAU,WAAW,CAAC,KAAK,OAAO,UAAU,KAAM,QAAO;AAC1E,UAAM,MAAM,OAAO,SAAS,MAAM,KAAK,IAAI,MAAM,MAAM,SAAS,MAAM,IAAI,MAAM;AAChF,UAAM,MAAM,KAAK,OAAO,UAAU;AAClC,UAAM,QAAQ,IAAI,SAAS,MAAM,IAAI,MAAM,GAAG,GAAG,IAAI;AACrD,WAAO,KAAK,QAA8B;AAAA,MACxC,MAAM;AAAA,MACN,MAAM;AAAA,MACN,GAAI,MAAM,WAAW,SAAY,EAAE,QAAQ,MAAM,OAAO,IAAI,CAAC;AAAA,MAC7D,YAAY,MAAM;AAAA,MAClB,SAAS,MAAM;AAAA,MACf,SAAS;AAAA,QACP,QAAQ,MAAM;AAAA,QACd;AAAA,QACA,UAAU,KAAK,eAAe;AAAA,QAC9B,WAAW,IAAI,SAAS;AAAA,QACxB,GAAI,MAAM,gBAAgB,SAAY,EAAE,aAAa,MAAM,YAAY,IAAI,CAAC;AAAA,MAC9E;AAAA,IACF,CAAC;AAAA,EACH;AAAA,EAEA,MAAa,UAAU,OAA0B,SAAiD;AAChG,UAAM,aAAa,MAAM,SAAS,IAAI,QAAQ,CAAC,GAAG;AAClD,UAAM,UAAU,CAAC,UAAoC;AAAE,WAAK,QAAQ,KAAK;AAAA,IAAE;AAC3E,eAAW,QAAQ,WAAY,MAAK,IAAI,QAAQ,GAAG,MAAM,OAAO;AAChE,WAAO,MAAM;AACX,iBAAW,QAAQ,WAAY,MAAK,IAAI,QAAQ,IAAI,MAAM,OAAO;AAAA,IACnE;AAAA,EACF;AACF;;;AEhEA,sBAAgB;AAChB,sBAAgB;AAST,IAAM,oBAAN,MAAwB;AAAA,EACZ;AAAA,EACA;AAAA,EAEV,YAAY,SAAmC;AACpD,SAAK,MAAM,IAAI,IAAI,QAAQ,GAAG;AAC9B,SAAK,YAAY,QAAQ,oBAAoB;AAAA,EAC/C;AAAA,EAEA,MAAa,QAAQ,MAAoD;AACvE,UAAM,SAAS,MAAM,KAAK,QAAQ;AAClC,QAAI;AACF,YAAM,SAAS,IAAI,WAAW,MAAM;AACpC,aAAO,MAAM,KAAK,OAAO,IAAI,CAAC;AAC9B,aAAO,MAAM,OAAO,KAAK;AAAA,IAC3B,UAAE;AACA,aAAO,IAAI;AAAA,IACb;AAAA,EACF;AAAA,EAEA,MAAc,UAA+B;AAC3C,UAAM,OAAO,OAAO,KAAK,IAAI,SAAS,KAAK,IAAI,aAAa,YAAY,OAAO,KAAK;AACpF,UAAM,OAAO,KAAK,IAAI,YAAY;AAClC,UAAM,SAAS,KAAK,IAAI,aAAa,YAAY,gBAAAA,QAAI,QAAQ,EAAE,MAAM,KAAK,CAAC,IAAI,gBAAAC,QAAI,QAAQ,EAAE,MAAM,KAAK,CAAC;AAEzG,UAAM,IAAI,QAAc,CAAC,SAAS,WAAW;AAC3C,YAAM,QAAQ,WAAW,MAAM;AAC7B,eAAO,QAAQ,IAAI,MAAM,6BAA6B,CAAC;AAAA,MACzD,GAAG,KAAK,SAAS;AACjB,aAAO,KAAK,WAAW,MAAM;AAC3B,qBAAa,KAAK;AAClB,gBAAQ;AAAA,MACV,CAAC;AACD,aAAO,KAAK,SAAS,WAAS;AAC5B,qBAAa,KAAK;AAClB,eAAO,KAAK;AAAA,MACd,CAAC;AAAA,IACH,CAAC;AAED,QAAI,KAAK,IAAI,UAAU;AACrB,UAAI,KAAK,IAAI,SAAU,OAAM,KAAK,gBAAgB,QAAQ,CAAC,QAAQ,mBAAmB,KAAK,IAAI,QAAQ,GAAG,mBAAmB,KAAK,IAAI,QAAQ,CAAC,CAAC;AAAA,UAC3I,OAAM,KAAK,gBAAgB,QAAQ,CAAC,QAAQ,mBAAmB,KAAK,IAAI,QAAQ,CAAC,CAAC;AAAA,IACzF;AAEA,UAAM,KAAK,KAAK,IAAI,SAAS,QAAQ,OAAO,EAAE;AAC9C,QAAI,GAAI,OAAM,KAAK,gBAAgB,QAAQ,CAAC,UAAU,EAAE,CAAC;AACzD,WAAO;AAAA,EACT;AAAA,EAEA,MAAc,gBAAgB,QAAoB,MAAoD;AACpG,UAAM,SAAS,IAAI,WAAW,MAAM;AACpC,WAAO,MAAM,KAAK,OAAO,IAAI,CAAC;AAC9B,WAAO,OAAO,KAAK;AAAA,EACrB;AAAA,EAEQ,OAAO,MAA0C;AACvD,WAAO,IAAI,KAAK,MAAM;AAAA,EAAO,KAAK,IAAI,SAAO;AAC3C,YAAM,QAAQ,OAAO,GAAG;AACxB,aAAO,IAAI,OAAO,WAAW,KAAK,CAAC;AAAA,EAAO,KAAK;AAAA;AAAA,IACjD,CAAC,EAAE,KAAK,EAAE,CAAC;AAAA,EACb;AACF;AAEA,IAAM,aAAN,MAAiB;AAAA,EAIR,YAA6B,QAAoB;AAApB;AAClC,WAAO,GAAG,QAAQ,WAAS;AACzB,WAAK,SAAS,OAAO,OAAO,CAAC,KAAK,QAAQ,KAAK,CAAC;AAChD,iBAAW,UAAU,KAAK,QAAQ,OAAO,CAAC,EAAG,QAAO;AAAA,IACtD,CAAC;AAAA,EACH;AAAA,EALoC;AAAA,EAH5B,SAAS,OAAO,MAAM,CAAC;AAAA,EACvB,UAA6B,CAAC;AAAA,EAStC,MAAa,OAAyB;AACpC,WAAO,MAAM;AACX,YAAM,SAAS,KAAK,SAAS,CAAC;AAC9B,UAAI,QAAQ;AACV,aAAK,SAAS,KAAK,OAAO,SAAS,OAAO,MAAM;AAChD,YAAI,OAAO,iBAAiB,WAAY,OAAM,OAAO;AACrD,eAAO,OAAO;AAAA,MAChB;AACA,YAAM,IAAI,QAAc,CAAC,SAAS,WAAW;AAC3C,cAAM,UAAU,CAAC,UAAuB;AACtC,kBAAQ;AACR,iBAAO,KAAK;AAAA,QACd;AACA,cAAM,UAAU,MAAY;AAC1B,kBAAQ;AACR,iBAAO,IAAI,MAAM,sCAAsC,CAAC;AAAA,QAC1D;AACA,cAAM,OAAO,MAAY;AACvB,kBAAQ;AACR,kBAAQ;AAAA,QACV;AACA,cAAM,UAAU,MAAY;AAC1B,eAAK,OAAO,IAAI,SAAS,OAAO;AAChC,eAAK,OAAO,IAAI,SAAS,OAAO;AAChC,gBAAM,QAAQ,KAAK,QAAQ,QAAQ,IAAI;AACvC,cAAI,SAAS,EAAG,MAAK,QAAQ,OAAO,OAAO,CAAC;AAAA,QAC9C;AACA,aAAK,OAAO,KAAK,SAAS,OAAO;AACjC,aAAK,OAAO,KAAK,SAAS,OAAO;AACjC,aAAK,QAAQ,KAAK,IAAI;AAAA,MACxB,CAAC;AAAA,IACH;AAAA,EACF;AAAA,EAEQ,SAAS,QAA2D;AAC1E,QAAI,UAAU,KAAK,OAAO,OAAQ,QAAO;AACzC,UAAM,OAAO,OAAO,aAAa,KAAK,OAAO,MAAM,CAAE;AACrD,UAAM,OAAO,KAAK,SAAS,SAAS,CAAC;AACrC,QAAI,CAAC,KAAM,QAAO;AAElB,QAAI,SAAS,IAAK,QAAO,EAAE,OAAO,KAAK,MAAM,QAAQ,KAAK,OAAO;AACjE,QAAI,SAAS,IAAK,QAAO,EAAE,OAAO,IAAI,WAAW,KAAK,IAAI,GAAG,QAAQ,KAAK,OAAO;AACjF,QAAI,SAAS,IAAK,QAAO,EAAE,OAAO,OAAO,KAAK,IAAI,GAAG,QAAQ,KAAK,OAAO;AACzE,QAAI,SAAS,KAAK;AAChB,YAAM,SAAS,OAAO,KAAK,IAAI;AAC/B,UAAI,WAAW,GAAI,QAAO,EAAE,OAAO,MAAM,QAAQ,KAAK,OAAO;AAC7D,YAAM,MAAM,KAAK,SAAS;AAC1B,UAAI,KAAK,OAAO,SAAS,MAAM,EAAG,QAAO;AACzC,aAAO,EAAE,OAAO,KAAK,OAAO,SAAS,KAAK,QAAQ,GAAG,EAAE,SAAS,MAAM,GAAG,QAAQ,MAAM,EAAE;AAAA,IAC3F;AACA,QAAI,SAAS,KAAK;AAChB,YAAM,QAAQ,OAAO,KAAK,IAAI;AAC9B,UAAI,UAAU,GAAI,QAAO,EAAE,OAAO,MAAM,QAAQ,KAAK,OAAO;AAC5D,YAAM,SAAoB,CAAC;AAC3B,UAAI,UAAU,KAAK;AACnB,eAAS,QAAQ,GAAG,QAAQ,OAAO,SAAS,GAAG;AAC7C,cAAM,OAAO,KAAK,SAAS,OAAO;AAClC,YAAI,CAAC,KAAM,QAAO;AAClB,eAAO,KAAK,KAAK,KAAK;AACtB,kBAAU,KAAK;AAAA,MACjB;AACA,aAAO,EAAE,OAAO,QAAQ,QAAQ,QAAQ;AAAA,IAC1C;AACA,WAAO;AAAA,EACT;AAAA,EAEQ,SAAS,QAAyD;AACxE,UAAM,MAAM,KAAK,OAAO,QAAQ,QAAQ,MAAM;AAC9C,QAAI,MAAM,EAAG,QAAO;AACpB,WAAO,EAAE,MAAM,KAAK,OAAO,SAAS,QAAQ,GAAG,EAAE,SAAS,MAAM,GAAG,QAAQ,MAAM,EAAE;AAAA,EACrF;AACF;AAEA,IAAM,aAAN,cAAyB,MAAM;AAAA,EACtB,YAAY,SAAiB;AAClC,UAAM,OAAO;AACb,SAAK,OAAO;AAAA,EACd;AACF;;;AChKO,IAAM,qBAAN,MAAyB;AAAA,EACvB,YAA6B,QAAuC;AAAvC;AAAA,EAAwC;AAAA,EAAxC;AAAA,EAE7B,OAAe;AACpB,WAAO,GAAG,KAAK,OAAO,SAAS;AAAA,EACjC;AAAA,EAEO,SAAiB;AACtB,WAAO,GAAG,KAAK,OAAO,SAAS;AAAA,EACjC;AAAA,EAEO,MAAyB;AAC9B,WAAO,CAAC,KAAK,KAAK,GAAG,KAAK,OAAO,CAAC;AAAA,EACpC;AACF;;;AChBA,IAAAC,mBAAgB;AAChB,IAAAC,mBAAgB;AAQT,IAAM,wBAAN,MAA4B;AAAA,EAK1B,YAA6B,SAAuC;AAAvC;AAAA,EAAwC;AAAA,EAAxC;AAAA,EAJ5B,SAA4B;AAAA,EAC5B,SAAkC;AAAA,EAClC,SAAS;AAAA,EAIjB,MAAa,UAAU,UAA6B,WAAqF;AACvI,QAAI,SAAS,WAAW,EAAG,OAAM,IAAI,MAAM,gEAAgE;AAC3G,UAAM,SAAS,MAAM,KAAK,QAAQ;AAClC,SAAK,SAAS;AACd,SAAK,SAAS,IAAI,iBAAiB,MAAM;AACzC,WAAO,MAAM,OAAO,CAAC,aAAa,GAAG,QAAQ,CAAC,CAAC;AAE/C,SAAK,KAAK,SAAS,SAAS;AAE5B,WAAO,YAAY;AACjB,WAAK,SAAS;AACd,UAAI,CAAC,OAAO,WAAW;AACrB,YAAI;AAAE,iBAAO,MAAM,OAAO,CAAC,eAAe,GAAG,QAAQ,CAAC,CAAC;AAAA,QAAE,QAAQ;AAAA,QAAa;AAC9E,eAAO,IAAI;AAAA,MACb;AAAA,IACF;AAAA,EACF;AAAA,EAEA,MAAc,SAAS,WAAsE;AAC3F,UAAM,SAAS,KAAK;AACpB,QAAI,CAAC,OAAQ;AACb,WAAO,CAAC,KAAK,QAAQ;AACnB,UAAI;AACF,cAAM,QAAQ,MAAM,OAAO,KAAK;AAChC,YAAI,CAAC,MAAM,QAAQ,KAAK,KAAK,MAAM,SAAS,EAAG;AAC/C,cAAM,CAAC,MAAM,SAAS,OAAO,IAAI;AACjC,YAAI,SAAS,aAAa,OAAO,YAAY,YAAY,OAAO,YAAY,UAAU;AACpF,oBAAU,SAAS,OAAO;AAAA,QAC5B;AAAA,MACF,QAAQ;AACN,YAAI,CAAC,KAAK,OAAQ,MAAK,SAAS;AAAA,MAClC;AAAA,IACF;AAAA,EACF;AAAA,EAEA,MAAc,UAA+B;AAC3C,UAAM,MAAM,IAAI,IAAI,KAAK,QAAQ,GAAG;AACpC,UAAM,OAAO,OAAO,IAAI,SAAS,IAAI,aAAa,YAAY,OAAO,KAAK;AAC1E,UAAM,OAAO,IAAI,YAAY;AAC7B,UAAM,SAAS,IAAI,aAAa,YAAY,iBAAAC,QAAI,QAAQ,EAAE,MAAM,KAAK,CAAC,IAAI,iBAAAC,QAAI,QAAQ,EAAE,MAAM,KAAK,CAAC;AACpG,UAAM,YAAY,KAAK,QAAQ,oBAAoB;AAEnD,UAAM,IAAI,QAAc,CAAC,SAAS,WAAW;AAC3C,YAAM,QAAQ,WAAW,MAAM;AAC7B,eAAO,QAAQ,IAAI,MAAM,qCAAqC,CAAC;AAAA,MACjE,GAAG,SAAS;AACZ,aAAO,KAAK,WAAW,MAAM;AAC3B,qBAAa,KAAK;AAClB,gBAAQ;AAAA,MACV,CAAC;AACD,aAAO,KAAK,SAAS,WAAS;AAC5B,qBAAa,KAAK;AAClB,eAAO,KAAK;AAAA,MACd,CAAC;AAAA,IACH,CAAC;AAED,QAAI,IAAI,UAAU;AAChB,UAAI,IAAI,SAAU,OAAM,gBAAgB,QAAQ,CAAC,QAAQ,mBAAmB,IAAI,QAAQ,GAAG,mBAAmB,IAAI,QAAQ,CAAC,CAAC;AAAA,UACvH,OAAM,gBAAgB,QAAQ,CAAC,QAAQ,mBAAmB,IAAI,QAAQ,CAAC,CAAC;AAAA,IAC/E;AACA,UAAM,KAAK,IAAI,SAAS,QAAQ,OAAO,EAAE;AACzC,QAAI,GAAI,OAAM,gBAAgB,QAAQ,CAAC,UAAU,EAAE,CAAC;AACpD,WAAO;AAAA,EACT;AACF;AAEA,eAAe,gBAAgB,QAAoB,MAAoD;AACrG,QAAM,SAAS,IAAI,iBAAiB,MAAM;AAC1C,SAAO,MAAM,OAAO,IAAI,CAAC;AACzB,SAAO,OAAO,KAAK;AACrB;AAEA,SAAS,OAAO,MAA0C;AACxD,SAAO,IAAI,KAAK,MAAM;AAAA,EAAO,KAAK,IAAI,SAAO;AAC3C,UAAM,QAAQ,OAAO,GAAG;AACxB,WAAO,IAAI,OAAO,WAAW,KAAK,CAAC;AAAA,EAAO,KAAK;AAAA;AAAA,EACjD,CAAC,EAAE,KAAK,EAAE,CAAC;AACb;AAEA,IAAM,mBAAN,MAAuB;AAAA,EAId,YAA6B,QAAoB;AAApB;AAClC,WAAO,GAAG,QAAQ,WAAS;AACzB,WAAK,SAAS,OAAO,OAAO,CAAC,KAAK,QAAQ,KAAK,CAAC;AAChD,iBAAW,UAAU,KAAK,QAAQ,OAAO,CAAC,EAAG,QAAO;AAAA,IACtD,CAAC;AAAA,EACH;AAAA,EALoC;AAAA,EAH5B,SAAS,OAAO,MAAM,CAAC;AAAA,EACvB,UAA6B,CAAC;AAAA,EAStC,MAAa,OAAyB;AACpC,WAAO,MAAM;AACX,YAAM,SAAS,KAAK,SAAS,CAAC;AAC9B,UAAI,QAAQ;AACV,aAAK,SAAS,KAAK,OAAO,SAAS,OAAO,MAAM;AAChD,eAAO,OAAO;AAAA,MAChB;AACA,YAAM,IAAI,QAAc,CAAC,SAAS,WAAW;AAC3C,cAAM,UAAU,CAAC,UAAuB;AACtC,kBAAQ;AACR,iBAAO,KAAK;AAAA,QACd;AACA,cAAM,UAAU,MAAY;AAC1B,kBAAQ;AACR,iBAAO,IAAI,MAAM,sCAAsC,CAAC;AAAA,QAC1D;AACA,cAAM,OAAO,MAAY;AACvB,kBAAQ;AACR,kBAAQ;AAAA,QACV;AACA,cAAM,UAAU,MAAY;AAC1B,eAAK,OAAO,IAAI,SAAS,OAAO;AAChC,eAAK,OAAO,IAAI,SAAS,OAAO;AAChC,gBAAM,QAAQ,KAAK,QAAQ,QAAQ,IAAI;AACvC,cAAI,SAAS,EAAG,MAAK,QAAQ,OAAO,OAAO,CAAC;AAAA,QAC9C;AACA,aAAK,OAAO,KAAK,SAAS,OAAO;AACjC,aAAK,OAAO,KAAK,SAAS,OAAO;AACjC,aAAK,QAAQ,KAAK,IAAI;AAAA,MACxB,CAAC;AAAA,IACH;AAAA,EACF;AAAA,EAEQ,SAAS,QAA2D;AAC1E,QAAI,UAAU,KAAK,OAAO,OAAQ,QAAO;AACzC,UAAM,OAAO,OAAO,aAAa,KAAK,OAAO,MAAM,CAAE;AACrD,UAAM,OAAO,KAAK,SAAS,SAAS,CAAC;AACrC,QAAI,CAAC,KAAM,QAAO;AAClB,QAAI,SAAS,IAAK,QAAO,EAAE,OAAO,KAAK,MAAM,QAAQ,KAAK,OAAO;AACjE,QAAI,SAAS,IAAK,OAAM,IAAI,MAAM,KAAK,IAAI;AAC3C,QAAI,SAAS,IAAK,QAAO,EAAE,OAAO,OAAO,KAAK,IAAI,GAAG,QAAQ,KAAK,OAAO;AACzE,QAAI,SAAS,KAAK;AAChB,YAAM,SAAS,OAAO,KAAK,IAAI;AAC/B,UAAI,WAAW,GAAI,QAAO,EAAE,OAAO,MAAM,QAAQ,KAAK,OAAO;AAC7D,YAAM,MAAM,KAAK,SAAS;AAC1B,UAAI,KAAK,OAAO,SAAS,MAAM,EAAG,QAAO;AACzC,aAAO,EAAE,OAAO,KAAK,OAAO,SAAS,KAAK,QAAQ,GAAG,EAAE,SAAS,MAAM,GAAG,QAAQ,MAAM,EAAE;AAAA,IAC3F;AACA,QAAI,SAAS,KAAK;AAChB,YAAM,QAAQ,OAAO,KAAK,IAAI;AAC9B,UAAI,UAAU,GAAI,QAAO,EAAE,OAAO,MAAM,QAAQ,KAAK,OAAO;AAC5D,YAAM,SAAoB,CAAC;AAC3B,UAAI,UAAU,KAAK;AACnB,eAAS,QAAQ,GAAG,QAAQ,OAAO,SAAS,GAAG;AAC7C,cAAM,OAAO,KAAK,SAAS,OAAO;AAClC,YAAI,CAAC,KAAM,QAAO;AAClB,eAAO,KAAK,KAAK,KAAK;AACtB,kBAAU,KAAK;AAAA,MACjB;AACA,aAAO,EAAE,OAAO,QAAQ,QAAQ,QAAQ;AAAA,IAC1C;AACA,WAAO;AAAA,EACT;AAAA,EAEQ,SAAS,QAAyD;AACxE,UAAM,MAAM,KAAK,OAAO,QAAQ,QAAQ,MAAM;AAC9C,QAAI,MAAM,EAAG,QAAO;AACpB,WAAO,EAAE,MAAM,KAAK,OAAO,SAAS,QAAQ,GAAG,EAAE,SAAS,MAAM,GAAG,QAAQ,MAAM,EAAE;AAAA,EACrF;AACF;;;ACxKO,IAAM,kBAAN,MAA2E;AAAA,EAMzE,YAA6B,QAA8B;AAA9B;AAClC,SAAK,SAAS,IAAI,kBAAkB,EAAE,KAAK,OAAO,UAAU,KAAK,kBAAkB,OAAO,UAAU,iBAAiB,CAAC;AACtH,SAAK,WAAW,IAAI,mBAAmB,OAAO,SAAS;AAAA,EACzD;AAAA,EAHoC;AAAA,EALnB;AAAA,EACA;AAAA,EACA,aAAa,IAAI,qBAAqB;AAAA,EAC/C,cAAc;AAAA,EAOtB,MAAa,QAAkB,OAA0I;AACvK,UAAM,WAAW,KAAK,WAAW,OAAO,KAAK,OAAO,KAAK,KAAK;AAC9D,UAAM,UAAU,SAAS,SAAS,QAAQ,KAAK,SAAS,KAAK,IAAI,KAAK,SAAS,OAAO;AACtF,UAAM,KAAK,OAAO,QAAQ,CAAC,WAAW,SAAS,KAAK,WAAW,OAAO,QAAQ,CAAC,CAAC;AAChF,WAAO;AAAA,EACT;AAAA,EAEA,MAAa,WAAW,OAAsF;AAC5G,QAAI,CAAC,KAAK,OAAO,UAAU,WAAW,CAAC,KAAK,OAAO,UAAU,KAAM,QAAO;AAC1E,UAAM,MAAM,OAAO,SAAS,MAAM,KAAK,IAAI,MAAM,MAAM,SAAS,MAAM,IAAI,MAAM;AAChF,UAAM,MAAM,KAAK,OAAO,UAAU;AAClC,UAAM,QAAQ,IAAI,SAAS,MAAM,IAAI,MAAM,GAAG,GAAG,IAAI;AACrD,WAAO,KAAK,QAA8B;AAAA,MACxC,MAAM;AAAA,MACN,MAAM;AAAA,MACN,GAAI,MAAM,WAAW,SAAY,EAAE,QAAQ,MAAM,OAAO,IAAI,CAAC;AAAA,MAC7D,YAAY,MAAM;AAAA,MAClB,SAAS,MAAM;AAAA,MACf,SAAS;AAAA,QACP,QAAQ,MAAM;AAAA,QACd;AAAA,QACA,UAAU,KAAK,eAAe;AAAA,QAC9B,WAAW,IAAI,SAAS;AAAA,QACxB,GAAI,MAAM,gBAAgB,SAAY,EAAE,aAAa,MAAM,YAAY,IAAI,CAAC;AAAA,MAC9E;AAAA,IACF,CAAC;AAAA,EACH;AAAA,EAEA,MAAa,UAAU,OAA0B,SAA0D;AACzG,UAAM,WAAW,KAAK,SAAS,IAAI;AACnC,UAAM,SAAS,IAAI,IAAI,KAAK;AAC5B,UAAM,MAAM,OAAO,SAAS,KAAK,OAAO,IAAI,GAAG;AAC/C,UAAM,aAAa,IAAI,sBAAsB,EAAE,KAAK,KAAK,OAAO,UAAU,KAAK,kBAAkB,KAAK,OAAO,UAAU,iBAAiB,CAAC;AACzI,WAAO,WAAW,UAAU,UAAU,CAAC,UAAU,YAAY;AAC3D,YAAM,WAAW,KAAK,WAAW,OAAO,OAAO;AAC/C,UAAI,CAAC,SAAU;AACf,UAAI,CAAC,OAAO,CAAC,OAAO,IAAI,SAAS,IAAI,KAAK,CAAC,OAAO,IAAI,SAAS,IAAI,EAAG;AACtE,WAAK,QAAQ,QAAQ;AAAA,IACvB,CAAC;AAAA,EACH;AACF;;;ACrDO,IAAM,oBAAN,MAAwB;AAAA,EACtB,gBAAgB,QAA0D;AAC/E,QAAI,CAAC,OAAO,UAAU,QAAS,QAAO;AACtC,QAAI,OAAO,UAAU,cAAc,QAAS,QAAO,IAAI,gBAAgB,MAAM;AAC7E,WAAO,IAAI,iBAAiB,MAAM;AAAA,EACpC;AAAA,EAEO,iBAAiB,QAA2D;AACjF,QAAI,CAAC,OAAO,UAAU,QAAS,QAAO;AACtC,QAAI,OAAO,UAAU,cAAc,QAAS,QAAO,IAAI,gBAAgB,MAAM;AAC7E,WAAO,IAAI,iBAAiB,MAAM;AAAA,EACpC;AACF;;;ACjBA,0BAAoB;;;ACAb,IAAM,YAAN,cAAwB,MAAM;AAAA,EAC5B,YAAY,SAAiB;AAClC,UAAM,OAAO;AACb,SAAK,OAAO,WAAW;AAAA,EACzB;AACF;AAGO,IAAM,iBAAN,cAA6B,UAAU;AAAC;AAExC,IAAM,wBAAN,cAAoC,UAAU;AAAC;;;ACP/C,IAAM,qBAAN,MAAyB;AAAA,EACvB,QAAQ,WAA0C,QAAoC;AAC3F,UAAM,aAAa,OAAO,KAAK;AAC/B,QAAI,CAAC,WAAY,OAAM,IAAI,sBAAsB,iCAAiC;AAElF,UAAM,UAAU,UAAU,OAAO,cAAY,SAAS,GAAG,WAAW,UAAU,KAAK,SAAS,GAAG,SAAS,UAAU,CAAC;AACnH,QAAI,QAAQ,WAAW,EAAG,OAAM,IAAI,sBAAsB,wBAAwB,MAAM,IAAI;AAC5F,QAAI,QAAQ,SAAS,GAAG;AACtB,YAAM,IAAI,sBAAsB,0BAA0B,MAAM,MAAM,QAAQ,IAAI,WAAS,MAAM,EAAE,EAAE,KAAK,IAAI,CAAC,EAAE;AAAA,IACnH;AACA,WAAO,QAAQ,CAAC;AAAA,EAClB;AACF;;;ACfA,IAAAC,kBAAe;AACf,IAAAC,oBAAiB;;;ACDjB,qBAAe;AACf,uBAAiB;AAEjB,eAAsB,UAAU,KAA4B;AAC1D,QAAM,eAAAC,QAAG,SAAS,MAAM,KAAK,EAAE,WAAW,KAAK,CAAC;AAClD;AAEA,eAAsB,WAAW,UAAoC;AACnE,MAAI;AACF,UAAM,eAAAA,QAAG,SAAS,OAAO,QAAQ;AACjC,WAAO;AAAA,EACT,QAAQ;AACN,WAAO;AAAA,EACT;AACF;AAEA,eAAsB,gBAAgB,UAAkB,OAA+B;AACrF,QAAM,UAAU,iBAAAC,QAAK,QAAQ,QAAQ,CAAC;AACtC,QAAM,WAAW,GAAG,QAAQ,IAAI,QAAQ,GAAG,IAAI,KAAK,IAAI,CAAC;AACzD,QAAM,eAAAD,QAAG,SAAS,UAAU,UAAU,GAAG,KAAK,UAAU,OAAO,MAAM,CAAC,CAAC;AAAA,GAAM,MAAM;AACnF,QAAM,eAAAA,QAAG,SAAS,OAAO,UAAU,QAAQ;AAC7C;;;ACrBO,SAAS,SAAiB;AAC/B,UAAO,oBAAI,KAAK,GAAE,YAAY;AAChC;;;AFKO,IAAM,iBAAN,MAAqB;AAAA,EACnB,YACY,KACA,UACjB;AAFiB;AACA;AAAA,EAChB;AAAA,EAFgB;AAAA,EACA;AAAA,EAGnB,IAAW,YAAoB;AAC7B,WAAO,kBAAAE,QAAK,KAAK,KAAK,UAAU,YAAY;AAAA,EAC9C;AAAA,EAEA,MAAa,OAA+B;AAC1C,QAAI,CAAE,MAAM,WAAW,KAAK,SAAS,GAAI;AACvC,aAAO,KAAK,MAAM;AAAA,IACpB;AACA,QAAI;AACF,YAAM,OAAO,MAAM,gBAAAC,QAAG,SAAS,SAAS,KAAK,WAAW,MAAM;AAC9D,YAAM,SAAS,KAAK,WAAW,IAAI;AACnC,UAAI,OAAO,YAAY,EAAG,OAAM,IAAI,eAAe,mCAAmC,OAAO,OAAO,OAAO,CAAC,EAAE;AAC9G,aAAO;AAAA,IACT,SAAS,OAAO;AACd,UAAI,iBAAiB,aAAa;AAChC,cAAM,YAAY,MAAM,KAAK,sBAAsB;AACnD,YAAI,UAAW,QAAO;AAAA,MACxB;AACA,UAAI,iBAAiB,eAAgB,OAAM;AAC3C,YAAM,IAAI,eAAe,8BAA+B,MAAgB,OAAO,EAAE;AAAA,IACnF;AAAA,EACF;AAAA,EAEA,MAAa,MAAM,WAAyD;AAC1E,UAAM,UAAU,KAAK,QAAQ;AAC7B,UAAM,gBAAgB,KAAK,WAAW;AAAA,MACpC,SAAS;AAAA,MACT,KAAK,KAAK;AAAA,MACV,WAAW,OAAO;AAAA,MAClB;AAAA,IACF,CAAyB;AAAA,EAC3B;AAAA,EAEA,MAAa,OAAO,UAA6C;AAC/D,UAAM,QAAQ,MAAM,KAAK,KAAK;AAC9B,UAAM,SAAS,MAAM,UAAU,OAAO,UAAQ,KAAK,OAAO,SAAS,EAAE;AACrE,UAAM,KAAK,MAAM,CAAC,GAAG,QAAQ,QAAQ,CAAC;AAAA,EACxC;AAAA,EAEA,MAAa,OAAO,YAAoB,OAAiE;AACvG,UAAM,QAAQ,MAAM,KAAK,KAAK;AAC9B,UAAM,UAAU,MAAM,UAAU,KAAK,UAAQ,KAAK,OAAO,UAAU;AACnE,QAAI,CAAC,QAAS,OAAM,IAAI,eAAe,gCAAgC,UAAU,EAAE;AACnF,UAAM,OAAO,EAAE,GAAG,SAAS,GAAG,MAAM;AACpC,UAAM,KAAK,MAAM,MAAM,UAAU,IAAI,UAAQ,KAAK,OAAO,aAAa,OAAO,IAAI,CAAC;AAClF,WAAO;AAAA,EACT;AAAA,EAEA,MAAa,OAAO,aAA+C;AACjE,UAAM,MAAM,IAAI,IAAI,WAAW;AAC/B,UAAM,QAAQ,MAAM,KAAK,KAAK;AAC9B,UAAM,KAAK,MAAM,MAAM,UAAU,OAAO,cAAY,CAAC,IAAI,IAAI,SAAS,EAAE,CAAC,CAAC;AAAA,EAC5E;AAAA,EAEO,QAAuB;AAC5B,WAAO;AAAA,MACL,SAAS;AAAA,MACT,KAAK,KAAK;AAAA,MACV,WAAW,OAAO;AAAA,MAClB,WAAW,CAAC;AAAA,IACd;AAAA,EACF;AAAA,EAEQ,WAAW,MAA6B;AAC9C,WAAO,KAAK,MAAM,IAAI;AAAA,EACxB;AAAA,EAEA,MAAc,wBAAuD;AACnE,UAAM,OAAO,MAAM,gBAAAA,QAAG,SAAS,SAAS,KAAK,WAAW,MAAM;AAC9D,UAAM,SAAS,KAAK,sBAAsB,IAAI;AAC9C,QAAI,CAAC,OAAQ,QAAO;AAEpB,QAAI;AACF,YAAM,SAAS,KAAK,WAAW,MAAM;AACrC,UAAI,OAAO,YAAY,EAAG,OAAM,IAAI,eAAe,mCAAmC,OAAO,OAAO,OAAO,CAAC,EAAE;AAC9G,YAAM,gBAAgB,KAAK,WAAW,MAAM;AAC5C,aAAO;AAAA,IACT,QAAQ;AACN,aAAO;AAAA,IACT;AAAA,EACF;AAAA,EAEQ,sBAAsB,MAA6B;AACzD,UAAM,QAAQ,KAAK,OAAO,SAAS;AACnC,QAAI,QAAQ,EAAG,QAAO;AAEtB,QAAI,QAAQ;AACZ,QAAI,WAAW;AACf,QAAI,UAAU;AAEd,aAAS,QAAQ,OAAO,QAAQ,KAAK,QAAQ,SAAS,GAAG;AACvD,YAAM,OAAO,KAAK,KAAK;AAEvB,UAAI,UAAU;AACZ,YAAI,SAAS;AACX,oBAAU;AACV;AAAA,QACF;AACA,YAAI,SAAS,MAAM;AACjB,oBAAU;AACV;AAAA,QACF;AACA,YAAI,SAAS,IAAK,YAAW;AAC7B;AAAA,MACF;AAEA,UAAI,SAAS,KAAK;AAChB,mBAAW;AACX;AAAA,MACF;AAEA,UAAI,SAAS,OAAO,SAAS,KAAK;AAChC,iBAAS;AACT;AAAA,MACF;AAEA,UAAI,SAAS,OAAO,SAAS,KAAK;AAChC,iBAAS;AACT,YAAI,UAAU,GAAG;AACf,iBAAO,KAAK,MAAM,OAAO,QAAQ,CAAC;AAAA,QACpC;AAAA,MACF;AAAA,IACF;AAEA,WAAO;AAAA,EACT;AACF;;;AGzIO,IAAM,sBAAN,MAA0B;AAAA,EAC/B,OAAc,MAAM,UAA8B,OAAe,MAAM,KAAK,IAAI,GAAuB;AACrG,WAAO;AAAA,MACL,GAAG;AAAA,MACH,QAAQ,SAAS,WAAW,YAAY,YAAY,SAAS;AAAA,MAC7D,YAAY,IAAI,KAAK,GAAG,EAAE,YAAY;AAAA,MACtC,WAAW,IAAI,KAAK,MAAM,KAAK,EAAE,YAAY;AAAA,IAC/C;AAAA,EACF;AAAA,EAEA,OAAc,YAAY,UAA8B,MAAM,KAAK,IAAI,GAAuB;AAC5F,QAAI,CAAC,KAAK,UAAU,UAAU,GAAG,EAAG,QAAO;AAC3C,WAAO,EAAE,GAAG,UAAU,QAAQ,UAAgC;AAAA,EAChE;AAAA,EAEA,OAAc,UAAU,UAA8B,MAAM,KAAK,IAAI,GAAY;AAC/E,QAAI,CAAC,SAAS,UAAW,QAAO;AAChC,WAAO,IAAI,KAAK,SAAS,SAAS,EAAE,QAAQ,KAAK;AAAA,EACnD;AAAA,EAEA,OAAc,WAAW,UAA8B,MAAM,KAAK,IAAI,GAAY;AAChF,WAAO,SAAS,WAAW,aACtB,SAAS,QAAQ,QACjB,SAAS,gBAAgB,YACzB,SAAS,gBAAgB,YACzB,CAAC,KAAK,UAAU,UAAU,GAAG;AAAA,EACpC;AACF;;;ACxBO,IAAM,mBAAN,MAA+C;AAAA,EACpC,OAAO;AAAA,EACN;AAAA,EAEV,YAAY,KAAa,UAAkB;AAChD,SAAK,QAAQ,IAAI,eAAe,KAAK,QAAQ;AAAA,EAC/C;AAAA,EAEA,MAAa,SAAS,UAA8B,UAAuC,CAAC,GAAgC;AAC1H,UAAM,SAAS,QAAQ,QAAQ,oBAAoB,MAAM,UAAU,QAAQ,KAAK,IAAI;AACpF,UAAM,KAAK,MAAM,OAAO,MAAM;AAC9B,WAAO;AAAA,EACT;AAAA,EAEA,MAAa,UAAU,YAAoB,UAAwC,CAAC,GAAuC;AACzH,UAAM,UAAU,MAAM,KAAK,IAAI,UAAU;AACzC,QAAI,CAAC,QAAS,QAAO;AACrB,UAAM,UAAU,EAAE,GAAG,SAAS,GAAI,QAAQ,SAAS,CAAC,EAAG;AACvD,UAAM,OAAO,QAAQ,QAAQ,oBAAoB,MAAM,SAAS,QAAQ,KAAK,IAAI;AACjF,UAAM,KAAK,MAAM,OAAO,IAAI;AAC5B,WAAO;AAAA,EACT;AAAA,EAEA,MAAa,KAAK,UAAmC,CAAC,GAA2C;AAC/F,UAAM,QAAQ,MAAM,KAAK,MAAM,KAAK;AACpC,UAAM,YAAY,MAAM,UAAU,IAAI,cAAY,oBAAoB,YAAY,QAAQ,CAAC;AAC3F,QAAI,UAAU,KAAK,CAAC,UAAU,UAAU,aAAa,MAAM,UAAU,KAAK,CAAC,GAAG;AAC5E,YAAM,KAAK,MAAM,MAAM,SAAS;AAAA,IAClC;AACA,WAAO,UAAU,OAAO,cAAY;AAClC,UAAI,QAAQ,WAAW,SAAS,YAAY,QAAQ,QAAS,QAAO;AACpE,UAAI,CAAC,QAAQ,kBAAkB,SAAS,WAAW,UAAW,QAAO;AACrE,aAAO;AAAA,IACT,CAAC;AAAA,EACH;AAAA,EAEA,MAAa,IAAI,YAAwD;AACvE,UAAM,QAAQ,MAAM,KAAK,MAAM,KAAK;AACpC,WAAO,MAAM,UAAU,KAAK,cAAY,SAAS,OAAO,UAAU,KAAK;AAAA,EACzE;AAAA,EAEA,MAAa,aAAa,YAAwD;AAChF,UAAM,UAAU,MAAM,KAAK,IAAI,UAAU;AACzC,QAAI,CAAC,QAAS,QAAO;AACrB,UAAM,OAAO,EAAE,GAAG,SAAS,QAAQ,WAAoB;AACvD,UAAM,KAAK,MAAM,OAAO,IAAI;AAC5B,WAAO;AAAA,EACT;AAAA,EAEA,MAAa,WAAW,YAAmC;AACzD,UAAM,KAAK,MAAM,OAAO,CAAC,UAAU,CAAC;AAAA,EACtC;AACF;;;ACzDA,IAAAC,sBAAmB;AAaZ,IAAM,qBAAN,MAAyB;AAAA,EACvB,YACY,KACA,QACjB;AAFiB;AACA;AAAA,EAChB;AAAA,EAFgB;AAAA,EACA;AAAA,EAGZ,KAAK,UAA8B,YAAW,oBAAI,KAAK,GAAE,YAAY,GAAW;AACrF,WAAO,KAAK,KAAK,KAAK,QAAQ,UAAU,QAAQ,CAAC;AAAA,EACnD;AAAA,EAEO,OAAO,UAA8B,YAAW,oBAAI,KAAK,GAAE,YAAY,GAAuB;AACnG,UAAM,YAAY,KAAK,KAAK,UAAU,QAAQ;AAC9C,WAAO;AAAA,MACL,GAAG;AAAA,MACH,UAAU;AAAA,QACR,GAAI,SAAS,YAAY,CAAC;AAAA,QAC1B,cAAc;AAAA,UACZ,KAAK,KAAK;AAAA,UACV;AAAA,UACA;AAAA,QACF;AAAA,MACF;AAAA,IACF;AAAA,EACF;AAAA,EAEO,OAAO,UAAuC;AACnD,UAAM,eAAe,KAAK,aAAa,QAAQ;AAC/C,QAAI,CAAC,aAAc,QAAO;AAC1B,UAAM,WAAW,KAAK,KAAK,UAAU,aAAa,QAAQ;AAC1D,WAAO,KAAK,UAAU,UAAU,aAAa,SAAS;AAAA,EACxD;AAAA,EAEQ,QAAQ,UAA8B,UAAgD;AAC5F,WAAO;AAAA,MACL,KAAK,KAAK;AAAA,MACV,IAAI,SAAS;AAAA,MACb,SAAS,SAAS;AAAA,MAClB,aAAa,SAAS;AAAA,MACtB,KAAK,SAAS;AAAA,MACd,KAAK,SAAS;AAAA,MACd;AAAA,IACF;AAAA,EACF;AAAA,EAEQ,KAAK,SAA+C;AAC1D,WAAO,oBAAAC,QAAO,WAAW,UAAU,KAAK,MAAM,EAAE,OAAO,KAAK,UAAU,OAAO,CAAC,EAAE,OAAO,WAAW;AAAA,EACpG;AAAA,EAEQ,aAAa,UAA8E;AACjG,UAAM,QAAQ,SAAS,UAAU;AACjC,QAAI,CAAC,SAAS,OAAO,UAAU,SAAU,QAAO;AAChD,UAAM,SAAS;AACf,QAAI,OAAO,QAAQ,KAAK,OAAO,OAAO,OAAO,aAAa,YAAY,OAAO,OAAO,cAAc,SAAU,QAAO;AACnH,WAAO,EAAE,UAAU,OAAO,UAAU,WAAW,OAAO,UAAU;AAAA,EAClE;AAAA,EAEQ,UAAU,GAAW,GAAoB;AAC/C,UAAM,OAAO,OAAO,KAAK,CAAC;AAC1B,UAAM,QAAQ,OAAO,KAAK,CAAC;AAC3B,WAAO,KAAK,WAAW,MAAM,UAAU,oBAAAA,QAAO,gBAAgB,MAAM,KAAK;AAAA,EAC3E;AACF;;;AC7DO,IAAM,oBAAN,MAAgD;AAAA,EAO9C,YAA6B,SAAmC;AAAnC;AAClC,SAAK,SAAS,IAAI,kBAAkB,OAAO;AAC3C,SAAK,SAAS,QAAQ,aAAa,QAAQ,QAAQ,GAAG;AACtD,SAAK,SAAS,QAAQ,SAAS,IAAI,mBAAmB,QAAQ,KAAK,QAAQ,MAAM,IAAI;AACrF,SAAK,mBAAmB,QAAQ,oBAAoB,QAAQ,QAAQ,MAAM;AAAA,EAC5E;AAAA,EALoC;AAAA,EANpB,OAAO;AAAA,EACN;AAAA,EACA;AAAA,EACA;AAAA,EACA;AAAA,EASjB,MAAa,SAAS,UAA8B,UAAuC,CAAC,GAAgC;AAC1H,UAAM,QAAQ,QAAQ,SAAS;AAC/B,UAAM,UAAU,oBAAoB,MAAM,UAAU,KAAK;AACzD,UAAM,SAAS,KAAK,SAAS,KAAK,OAAO,OAAO,OAAO,IAAI;AAC3D,UAAM,KAAK,OAAO,QAAQ,CAAC,QAAQ,KAAK,SAAS,GAAG,OAAO,EAAE,CAAC;AAC9D,UAAM,KAAK,OAAO,QAAQ,CAAC,OAAO,KAAK,YAAY,OAAO,EAAE,GAAG,KAAK,UAAU,MAAM,GAAG,MAAM,KAAK,CAAC;AACnG,WAAO;AAAA,EACT;AAAA,EAEA,MAAa,UAAU,YAAoB,UAAwC,CAAC,GAAuC;AACzH,UAAM,UAAU,MAAM,KAAK,IAAI,UAAU;AACzC,QAAI,CAAC,QAAS,QAAO;AACrB,UAAM,QAAQ,QAAQ,SAAS,KAAK,aAAa,OAAO,KAAK;AAC7D,UAAM,UAAU,EAAE,GAAG,SAAS,GAAI,QAAQ,SAAS,CAAC,EAAG;AACvD,UAAM,UAAU,oBAAoB,MAAM,SAAS,KAAK;AACxD,UAAM,SAAS,KAAK,SAAS,KAAK,OAAO,OAAO,OAAO,IAAI;AAC3D,UAAM,KAAK,OAAO,QAAQ,CAAC,OAAO,KAAK,YAAY,UAAU,GAAG,KAAK,UAAU,MAAM,GAAG,MAAM,KAAK,CAAC;AACpG,WAAO;AAAA,EACT;AAAA,EAEA,MAAa,KAAK,UAAmC,CAAC,GAA2C;AAC/F,UAAM,MAAM,MAAM,KAAK,IAAI;AAC3B,UAAM,QAAQ,MAAM,QAAQ,IAAI,IAAI,IAAI,QAAM,KAAK,IAAI,EAAE,CAAC,CAAC;AAC3D,UAAM,MAAM,KAAK,IAAI;AACrB,UAAM,QAA8B,CAAC;AACrC,UAAM,WAAqB,CAAC;AAE5B,aAAS,QAAQ,GAAG,QAAQ,IAAI,QAAQ,SAAS,GAAG;AAClD,YAAM,KAAK,IAAI,KAAK;AACpB,YAAM,OAAO,MAAM,KAAK;AACxB,UAAI,CAAC,MAAM;AACT,iBAAS,KAAK,EAAE;AAChB;AAAA,MACF;AACA,YAAM,YAAY,oBAAoB,YAAY,MAAM,GAAG;AAC3D,UAAI,QAAQ,WAAW,UAAU,YAAY,QAAQ,QAAS;AAC9D,UAAI,CAAC,QAAQ,kBAAkB,UAAU,WAAW,UAAW;AAC/D,YAAM,KAAK,SAAS;AAAA,IACtB;AAEA,QAAI,SAAS,SAAS,EAAG,OAAM,KAAK,OAAO,QAAQ,CAAC,QAAQ,KAAK,SAAS,GAAG,GAAG,QAAQ,CAAC;AACzF,WAAO;AAAA,EACT;AAAA,EAEA,MAAa,IAAI,YAAwD;AACvE,UAAM,MAAM,MAAM,KAAK,OAAO,QAAQ,CAAC,OAAO,KAAK,YAAY,UAAU,CAAC,CAAC;AAC3E,QAAI,OAAO,QAAQ,SAAU,QAAO;AACpC,UAAM,SAAS,KAAK,MAAM,GAAG;AAC7B,QAAI,KAAK,qBAAqB,CAAC,KAAK,UAAU,CAAC,KAAK,OAAO,OAAO,MAAM,GAAI,QAAO;AACnF,WAAO;AAAA,EACT;AAAA,EAEA,MAAa,aAAa,YAAwD;AAChF,UAAM,UAAU,MAAM,KAAK,IAAI,UAAU;AACzC,QAAI,CAAC,QAAS,QAAO;AACrB,WAAO,KAAK,UAAU,YAAY,EAAE,OAAO,EAAE,QAAQ,WAAW,EAAE,CAAC;AAAA,EACrE;AAAA,EAEA,MAAa,WAAW,YAAmC;AACzD,UAAM,KAAK,OAAO,QAAQ,CAAC,OAAO,KAAK,YAAY,UAAU,CAAC,CAAC;AAC/D,UAAM,KAAK,OAAO,QAAQ,CAAC,QAAQ,KAAK,SAAS,GAAG,UAAU,CAAC;AAAA,EACjE;AAAA,EAEA,MAAc,MAAkC;AAC9C,UAAM,QAAQ,MAAM,KAAK,OAAO,QAAQ,CAAC,YAAY,KAAK,SAAS,CAAC,CAAC;AACrE,WAAO,MAAM,QAAQ,KAAK,IAAI,MAAM,OAAO,CAAC,SAAyB,OAAO,SAAS,QAAQ,IAAI,CAAC;AAAA,EACpG;AAAA,EAEQ,aAAa,UAA6C;AAChE,QAAI,CAAC,SAAS,UAAW,QAAO;AAChC,WAAO,KAAK,IAAI,KAAO,IAAI,KAAK,SAAS,SAAS,EAAE,QAAQ,IAAI,KAAK,IAAI,CAAC;AAAA,EAC5E;AAAA,EAEQ,WAAmB;AACzB,WAAO,GAAG,KAAK,MAAM;AAAA,EACvB;AAAA,EAEQ,YAAY,IAAoB;AACtC,WAAO,GAAG,KAAK,MAAM,aAAa,EAAE;AAAA,EACtC;AACF;;;ACtGO,IAAM,kBAAN,MAAsB;AAAA,EACpB,OAAO,QAA4C;AACxD,QAAI,OAAO,SAAS,SAAS,QAAQ;AACnC,aAAO,IAAI,iBAAiB,OAAO,KAAK,OAAO,QAAQ,QAAQ;AAAA,IACjE;AACA,WAAO,IAAI,kBAAkB;AAAA,MAC3B,KAAK,OAAO;AAAA,MACZ,KAAK,OAAO,SAAS;AAAA,MACrB,GAAI,OAAO,SAAS,cAAc,SAAY,EAAE,WAAW,OAAO,SAAS,UAAU,IAAI,CAAC;AAAA,MAC1F,GAAI,OAAO,SAAS,WAAW,SAAY,EAAE,QAAQ,OAAO,SAAS,OAAO,IAAI,CAAC;AAAA,MACjF,kBAAkB,OAAO,SAAS;AAAA,MAClC,kBAAkB,OAAO,SAAS;AAAA,IACpC,CAAC;AAAA,EACH;AACF;;;AVPO,IAAM,gBAAN,MAAoB;AAAA,EAClB,YAA6B,QAA8B;AAA9B;AAAA,EAA+B;AAAA,EAA/B;AAAA,EAEpC,MAAa,IAAI,UAAoC,CAAC,GAAkB;AACtE,UAAM,aAAa,IAAI,kBAAkB,EAAE,iBAAiB,KAAK,MAAM;AACvE,QAAI,CAAC,WAAY,OAAM,IAAI,MAAM,iEAAiE;AAClG,UAAM,UAAU,MAAM,KAAK,eAAe,OAAO;AACjD,UAAM,OAAO,MAAM,WAAW,UAAU,QAAQ,SAAS,CAAC,GAAG,WAAS;AACpE,UAAI,CAAC,KAAK,QAAQ,OAAO,OAAO,EAAG;AACnC,0BAAAC,QAAQ,OAAO,MAAM,KAAK,OAAO,OAAO,OAAO,CAAC;AAAA,IAClD,CAAC;AACD,UAAM,QAAQ,MAAY;AAAE,WAAK,QAAQ,QAAQ,KAAK,CAAC,EAAE,QAAQ,MAAM,oBAAAA,QAAQ,KAAK,CAAC,CAAC;AAAA,IAAE;AACxF,wBAAAA,QAAQ,KAAK,UAAU,KAAK;AAC5B,wBAAAA,QAAQ,KAAK,WAAW,KAAK;AAC7B,UAAM,IAAI,QAAc,MAAM,MAAS;AAAA,EACzC;AAAA,EAEA,MAAc,eAAe,SAAwE;AACnG,QAAI,CAAC,QAAQ,aAAa,QAAQ,UAAU,WAAW,EAAG,QAAO;AACjE,UAAM,WAAW,IAAI,gBAAgB,EAAE,OAAO,KAAK,MAAM;AACzD,UAAM,YAAY,MAAM,SAAS,KAAK,EAAE,gBAAgB,KAAK,CAAC;AAC9D,UAAM,WAAW,IAAI,mBAAmB;AACxC,WAAO;AAAA,MACL,GAAG;AAAA,MACH,WAAW,QAAQ,UAAU,IAAI,YAAU,SAAS,QAAQ,WAAW,MAAM,EAAE,EAAE;AAAA,IACnF;AAAA,EACF;AAAA,EAEQ,QAAQ,OAA2B,SAA8C;AACvF,QAAI,QAAQ,SAAS,QAAQ,MAAM,SAAS,KAAK,CAAC,QAAQ,MAAM,SAAS,MAAM,IAAI,EAAG,QAAO;AAC7F,QAAI,QAAQ,YAAY,QAAQ,SAAS,SAAS,MAAM,CAAC,MAAM,WAAW,CAAC,QAAQ,SAAS,SAAS,MAAM,OAAO,GAAI,QAAO;AAC7H,QAAI,QAAQ,aAAa,QAAQ,UAAU,SAAS,MAAM,CAAC,MAAM,cAAc,CAAC,QAAQ,UAAU,SAAS,MAAM,UAAU,GAAI,QAAO;AACtI,WAAO;AAAA,EACT;AAAA,EAEQ,OAAO,OAA2B,SAA2C;AACnF,QAAI,QAAQ,KAAM,QAAO,GAAG,KAAK,UAAU,KAAK,CAAC;AAAA;AACjD,QAAI,QAAQ,OAAO,MAAM,SAAS,MAAO,QAAQ,MAAM,QAAiC;AACxF,QAAI,MAAM,SAAS,OAAO;AACxB,YAAM,UAAU,MAAM;AACtB,YAAM,KAAK,MAAM,cAAc;AAC/B,aAAO,IAAI,EAAE,IAAI,QAAQ,MAAM,KAAK,QAAQ,KAAK;AAAA,IACnD;AACA,WAAO,IAAI,MAAM,IAAI,IAAI,MAAM,IAAI,KAAK,MAAM,WAAW,GAAG,IAAI,MAAM,cAAc,GAAG,IAAI,KAAK,UAAU,MAAM,OAAO,CAAC;AAAA;AAAA,EAC1H;AACF;","names":["tls","net","import_node_net","import_node_tls","tls","net","import_node_fs","import_node_path","fs","path","path","fs","import_node_crypto","crypto","process"]}