{"version":3,"sources":["../../../../src/server/dev/hot-reloader-turbopack.ts"],"sourcesContent":["import type { Socket } from 'net'\nimport { mkdir, writeFile } from 'fs/promises'\nimport * as inspector from 'inspector'\nimport { join, extname, relative } from 'path'\nimport { pathToFileURL } from 'url'\n\nimport ws from 'next/dist/compiled/ws'\n\nimport type { OutputState } from '../../build/output/store'\nimport { store as consoleStore } from '../../build/output/store'\nimport type {\n CompilationError,\n HmrMessageSentToBrowser,\n NextJsHotReloaderInterface,\n ReloadPageMessage,\n SyncMessage,\n TurbopackConnectedMessage,\n} from './hot-reloader-types'\nimport { HMR_MESSAGE_SENT_TO_BROWSER } from './hot-reloader-types'\nimport type {\n Update as TurbopackUpdate,\n Endpoint,\n WrittenEndpoint,\n TurbopackResult,\n Project,\n Entrypoints,\n NodeJsHmrUpdate,\n NodeJsPartialHmrUpdate,\n} from '../../build/swc/types'\nimport { createDefineEnv, getBindingsSync, HmrTarget } from '../../build/swc'\nimport * as Log from '../../build/output/log'\nimport { BLOCKED_PAGES } from '../../shared/lib/constants'\nimport {\n getOverlayMiddleware,\n getSourceMapMiddleware,\n getOriginalStackFrames,\n} from './middleware-turbopack'\nimport { PageNotFoundError } from '../../shared/lib/utils'\nimport { debounce } from '../utils'\nimport { deleteCache } from './require-cache'\nimport {\n clearAllModuleContexts,\n clearModuleContext,\n} from '../lib/render-server'\nimport { denormalizePagePath } from '../../shared/lib/page-path/denormalize-page-path'\nimport { trace } from '../../trace'\nimport {\n AssetMapper,\n type ChangeSubscriptions,\n type ClientState,\n handleEntrypoints,\n handlePagesErrorRoute,\n handleRouteType,\n hasEntrypointForKey,\n msToNs,\n type ReadyIds,\n type SendHmr,\n type StartBuilding,\n processTopLevelIssues,\n printNonFatalIssue,\n normalizedPageToTurbopackStructureRoute,\n} from './turbopack-utils'\nimport {\n propagateServerField,\n type ServerFields,\n type SetupOpts,\n} from '../lib/router-utils/setup-dev-bundler'\nimport { TurbopackManifestLoader } from '../../shared/lib/turbopack/manifest-loader'\nimport { findPagePathData } from './on-demand-entry-handler'\nimport type { RouteDefinition } from '../route-definitions/route-definition'\nimport {\n type EntryKey,\n getEntryKey,\n splitEntryKey,\n} from '../../shared/lib/turbopack/entry-key'\nimport {\n createBinaryHmrMessageData,\n FAST_REFRESH_RUNTIME_RELOAD,\n} from './messages'\nimport { generateEncryptionKeyBase64 } from '../app-render/encryption-utils-server'\nimport { isAppPageRouteDefinition } from '../route-definitions/app-page-route-definition'\nimport { normalizeAppPath } from '../../shared/lib/router/utils/app-paths'\nimport type { ModernSourceMapPayload } from '../lib/source-maps'\nimport { isDeferredEntry } from '../../build/entries'\nimport {\n isMetadataRoute,\n isMetadataRouteFile,\n} from '../../lib/metadata/is-metadata-route'\nimport { setBundlerFindSourceMapImplementation } from '../patch-error-inspect'\nimport { getNextErrorFeedbackMiddleware } from '../../next-devtools/server/get-next-error-feedback-middleware'\nimport {\n formatIssue,\n isFileSystemCacheEnabledForDev,\n isWellKnownError,\n processIssues,\n renderStyledStringToErrorAnsi,\n type EntryIssuesMap,\n type IssuesMap,\n type TopLevelIssuesMap,\n} from '../../shared/lib/turbopack/utils'\nimport { getDevOverlayFontMiddleware } from '../../next-devtools/server/font/get-dev-overlay-font-middleware'\nimport { devIndicatorServerState } from './dev-indicator-server-state'\nimport { getDisableDevIndicatorMiddleware } from '../../next-devtools/server/dev-indicator-middleware'\nimport { getRestartDevServerMiddleware } from '../../next-devtools/server/restart-dev-server-middleware'\nimport { backgroundLogCompilationEvents } from '../../shared/lib/turbopack/compilation-events'\nimport { getSupportedBrowsers } from '../../build/get-supported-browsers'\nimport { printBuildErrors } from '../../build/print-build-errors'\nimport {\n receiveBrowserLogsTurbopack,\n handleClientFileLogs,\n} from './browser-logs/receive-logs'\nimport { normalizePath } from '../../lib/normalize-path'\nimport {\n devToolsConfigMiddleware,\n getDevToolsConfig,\n} from '../../next-devtools/server/devtools-config-middleware'\nimport { getAttachNodejsDebuggerMiddleware } from '../../next-devtools/server/attach-nodejs-debugger-middleware'\nimport {\n connectReactDebugChannel,\n connectReactDebugChannelForHtmlRequest,\n deleteReactDebugChannelForHtmlRequest,\n setReactDebugChannelForHtmlRequest,\n} from './debug-channel'\nimport {\n getVersionInfo,\n matchNextPageBundleRequest,\n} from './hot-reloader-shared-utils'\nimport { getMcpMiddleware } from '../mcp/get-mcp-middleware'\nimport { handleErrorStateResponse } from '../mcp/tools/get-errors'\nimport { handlePageMetadataResponse } from '../mcp/tools/get-page-metadata'\nimport { setStackFrameResolver } from '../mcp/tools/utils/format-errors'\nimport { recordMcpTelemetry } from '../mcp/mcp-telemetry-tracker'\nimport { getFileLogger } from './browser-logs/file-logger'\nimport type { ServerCacheStatus } from '../../next-devtools/dev-overlay/cache-indicator'\nimport type { Lockfile } from '../../build/lockfile'\nimport {\n sendSerializedErrorsToClient,\n sendSerializedErrorsToClientForHtmlRequest,\n setErrorsRscStreamForHtmlRequest,\n} from './serialized-errors'\n\nconst wsServer = new ws.Server({ noServer: true })\nconst isTestMode = !!(\n process.env.NEXT_TEST_MODE ||\n process.env.__NEXT_TEST_MODE ||\n process.env.DEBUG\n)\n\nconst sessionId = Math.floor(Number.MAX_SAFE_INTEGER * Math.random())\n\ndeclare const __next__clear_chunk_cache__: (() => void) | null | undefined\n\ndeclare const __turbopack_server_hmr_apply__:\n | ((update: NodeJsPartialHmrUpdate) => boolean)\n | undefined\n\ntype ServerHmrSubscriptions = Map<\n string,\n AsyncIterableIterator>\n>\n\nfunction setupServerHmr(\n project: Project,\n {\n clear,\n }: {\n clear: () => void | Promise\n }\n) {\n const serverHmrSubscriptions: ServerHmrSubscriptions = new Map()\n\n /**\n * Subscribe to HMR updates for a server chunk.\n * @param chunkPath - Server chunk output path (e.g., \"server/chunks/ssr/..._.js\")\n */\n function subscribeToServerHmr(chunkPath: string) {\n if (serverHmrSubscriptions.has(chunkPath)) {\n return\n }\n\n const subscription = project.hmrEvents(chunkPath, HmrTarget.Server)\n serverHmrSubscriptions.set(chunkPath, subscription)\n\n // Start listening for changes in background\n ;(async () => {\n // Skip initial state\n await subscription.next()\n\n for await (const result of subscription) {\n const update = result as NodeJsHmrUpdate\n\n // Fully re-evaluate all chunks from disk. Clears the module cache and\n // notifies browsers to refetch RSC.\n if (update.type === 'restart') {\n await clear()\n continue\n }\n\n if (update.type !== 'partial') {\n continue\n }\n\n const instruction = update.instruction\n if (!instruction || instruction.type !== 'EcmascriptMergedUpdate') {\n continue\n }\n\n if (typeof __turbopack_server_hmr_apply__ === 'function') {\n const applied = __turbopack_server_hmr_apply__(update)\n if (!applied) {\n await clear()\n }\n }\n }\n })().catch(async (err) => {\n console.error('[Server HMR] Subscription error:', err)\n serverHmrSubscriptions.delete(chunkPath)\n await clear()\n })\n }\n\n // Listen to the Rust bindings update us on changing server HMR chunk paths\n ;(async () => {\n try {\n const serverHmrChunkPaths = project.hmrChunkNamesSubscribe(\n HmrTarget.Server\n )\n\n // Process chunk paths (both initial and subsequent updates)\n for await (const data of serverHmrChunkPaths) {\n const currentChunkPaths = new Set(\n data.chunkNames.filter((path) => path.endsWith('.js'))\n )\n\n // Clean up subscriptions for removed chunk paths (like when pages are deleted)\n const chunkPathsToRemove: string[] = []\n for (const chunkPath of serverHmrSubscriptions.keys()) {\n if (!currentChunkPaths.has(chunkPath)) {\n chunkPathsToRemove.push(chunkPath)\n }\n }\n\n for (const chunkPath of chunkPathsToRemove) {\n const subscription = serverHmrSubscriptions.get(chunkPath)\n subscription?.return?.()\n serverHmrSubscriptions.delete(chunkPath)\n }\n\n // Subscribe to HMR events for new server chunks\n for (const chunkPath of currentChunkPaths) {\n if (!serverHmrSubscriptions.has(chunkPath)) {\n subscribeToServerHmr(chunkPath)\n }\n }\n }\n } catch (err) {\n console.error('[Server HMR Setup] Error in chunk path subscription:', err)\n }\n })()\n\n return serverHmrSubscriptions\n}\n\n/**\n * Replaces turbopack:///[project] with the specified project in the `source` field.\n */\nfunction rewriteTurbopackSources(\n projectRoot: string,\n sourceMap: ModernSourceMapPayload\n): void {\n if ('sections' in sourceMap) {\n for (const section of sourceMap.sections) {\n rewriteTurbopackSources(projectRoot, section.map)\n }\n } else {\n for (let i = 0; i < sourceMap.sources.length; i++) {\n sourceMap.sources[i] = pathToFileURL(\n join(\n projectRoot,\n sourceMap.sources[i].replace(/turbopack:\\/\\/\\/\\[project\\]/, '')\n )\n ).toString()\n }\n }\n}\n\nfunction getSourceMapFromTurbopack(\n project: Project,\n projectRoot: string,\n sourceURL: string\n): ModernSourceMapPayload | undefined {\n let sourceMapJson: string | null = null\n\n try {\n sourceMapJson = project.getSourceMapSync(sourceURL)\n } catch (err) {}\n\n if (sourceMapJson === null) {\n return undefined\n } else {\n const payload: ModernSourceMapPayload = JSON.parse(sourceMapJson)\n // The sourcemap from Turbopack is not yet written to disk so its `sources`\n // are not absolute paths yet. We need to rewrite them to be absolute paths.\n rewriteTurbopackSources(projectRoot, payload)\n return payload\n }\n}\n\nexport async function createHotReloaderTurbopack(\n opts: SetupOpts & { isSrcDir: boolean },\n serverFields: ServerFields,\n distDir: string,\n resetFetch: () => void,\n lockfile: Lockfile | undefined,\n serverFastRefresh?: boolean\n): Promise {\n const dev = true\n const buildId = 'development'\n const { nextConfig, dir: projectPath } = opts\n\n const bindings = getBindingsSync()\n\n // Turbopack requires native bindings and cannot run with WASM bindings.\n // Detect this early and give a clear, actionable error message.\n if (bindings.isWasm) {\n throw new Error(\n `Turbopack is not supported on this platform (${process.platform}/${process.arch}) because native bindings are not available. ` +\n `Only WebAssembly (WASM) bindings were loaded, and Turbopack requires native bindings.\\n\\n` +\n `To use Next.js on this platform, use Webpack instead:\\n` +\n ` next dev --webpack\\n\\n` +\n `For more information, see: https://nextjs.org/docs/app/api-reference/turbopack#supported-platforms`\n )\n }\n\n // For the debugging purpose, check if createNext or equivalent next instance setup in test cases\n // works correctly. Normally `run-test` hides output so only will be visible when `--debug` flag is used.\n if (isTestMode) {\n ;(require('console') as typeof import('console')).log(\n 'Creating turbopack project',\n {\n dir: projectPath,\n testMode: isTestMode,\n }\n )\n }\n\n const hasRewrites =\n opts.fsChecker.rewrites.afterFiles.length > 0 ||\n opts.fsChecker.rewrites.beforeFiles.length > 0 ||\n opts.fsChecker.rewrites.fallback.length > 0\n\n const hotReloaderSpan = trace('hot-reloader', undefined, {\n version: process.env.__NEXT_VERSION as string,\n })\n // Ensure the hotReloaderSpan is flushed immediately as it's the parentSpan for all processing\n // of the current `next dev` invocation.\n hotReloaderSpan.stop()\n\n // Initialize log monitor for file logging\n // Enable logging by default in development mode\n const mcpServerEnabled = !!nextConfig.experimental.mcpServer\n const fileLogger = getFileLogger()\n fileLogger.initialize(distDir, mcpServerEnabled)\n\n const encryptionKey = await generateEncryptionKeyBase64({\n isBuild: false,\n distDir,\n })\n\n // TODO: Implement\n let clientRouterFilters: any\n if (nextConfig.experimental.clientRouterFilter) {\n // TODO this need to be set correctly for filesystem cache to work\n }\n\n const supportedBrowsers = getSupportedBrowsers(projectPath, dev)\n const currentNodeJsVersion = process.versions.node\n\n const rootPath =\n opts.nextConfig.turbopack?.root ||\n opts.nextConfig.outputFileTracingRoot ||\n projectPath\n const project = await bindings.turbo.createProject(\n {\n rootPath,\n projectPath: normalizePath(relative(rootPath, projectPath) || '.'),\n distDir,\n nextConfig: opts.nextConfig,\n watch: {\n enable: dev,\n pollIntervalMs: nextConfig.watchOptions?.pollIntervalMs,\n },\n dev,\n env: process.env as Record,\n defineEnv: createDefineEnv({\n isTurbopack: true,\n clientRouterFilters,\n config: nextConfig,\n dev,\n distDir,\n projectPath,\n fetchCacheKeyPrefix: opts.nextConfig.experimental.fetchCacheKeyPrefix,\n hasRewrites,\n // TODO: Implement\n middlewareMatchers: undefined,\n rewrites: opts.fsChecker.rewrites,\n }),\n buildId,\n encryptionKey,\n previewProps: opts.fsChecker.previewProps,\n browserslistQuery: supportedBrowsers.join(', '),\n noMangling: false,\n writeRoutesHashesManifest: false,\n currentNodeJsVersion,\n isPersistentCachingEnabled: isFileSystemCacheEnabledForDev(\n opts.nextConfig\n ),\n nextVersion: process.env.__NEXT_VERSION as string,\n serverHmr: serverFastRefresh,\n },\n {\n memoryLimit: opts.nextConfig.experimental?.turbopackMemoryLimit,\n isShortSession: false,\n }\n )\n backgroundLogCompilationEvents(project, {\n eventTypes: [\n 'StartupCacheInvalidationEvent',\n 'TimingEvent',\n 'SlowFilesystemEvent',\n 'TraceEvent',\n ],\n parentSpan: hotReloaderSpan,\n })\n setBundlerFindSourceMapImplementation(\n getSourceMapFromTurbopack.bind(null, project, projectPath)\n )\n\n // Set up code frame renderer using native bindings\n const { installCodeFrameSupport } =\n require('../lib/install-code-frame') as typeof import('../lib/install-code-frame')\n installCodeFrameSupport()\n\n opts.onDevServerCleanup?.(async () => {\n setBundlerFindSourceMapImplementation(() => undefined)\n await project.onExit()\n await lockfile?.unlock()\n })\n const entrypointsSubscription = project.entrypointsSubscribe()\n\n const currentWrittenEntrypoints: Map = new Map()\n const currentEntrypoints: Entrypoints = {\n global: {\n app: undefined,\n document: undefined,\n error: undefined,\n\n middleware: undefined,\n instrumentation: undefined,\n },\n\n page: new Map(),\n app: new Map(),\n }\n\n const currentTopLevelIssues: TopLevelIssuesMap = new Map()\n const currentEntryIssues: EntryIssuesMap = new Map()\n\n const manifestLoader = new TurbopackManifestLoader({\n buildId,\n distDir,\n encryptionKey,\n dev: true,\n sriEnabled: false,\n })\n\n // Dev specific\n const changeSubscriptions: ChangeSubscriptions = new Map()\n const serverPathState = new Map()\n const readyIds: ReadyIds = new Set()\n let currentEntriesHandlingResolve: ((value?: unknown) => void) | undefined\n let currentEntriesHandling = new Promise(\n (resolve) => (currentEntriesHandlingResolve = resolve)\n )\n\n const assetMapper = new AssetMapper()\n\n // Deferred entries state management\n const deferredEntriesConfig = nextConfig.experimental.deferredEntries\n const hasDeferredEntriesConfig =\n deferredEntriesConfig && deferredEntriesConfig.length > 0\n let onBeforeDeferredEntriesCalled = false\n let onBeforeDeferredEntriesPromise: Promise | null = null\n // Track non-deferred entries that are currently being built\n const nonDeferredBuildingEntries: Set = new Set()\n\n // Function to wait for all non-deferred entries to be built\n async function waitForNonDeferredEntries(): Promise {\n return new Promise((resolve) => {\n const checkEntries = () => {\n // Check if there are any non-deferred entries that are still building\n if (nonDeferredBuildingEntries.size === 0) {\n resolve()\n } else {\n // Check again after a short delay\n setTimeout(checkEntries, 100)\n }\n }\n checkEntries()\n })\n }\n\n // Function to handle deferred entry processing\n async function processDeferredEntry(): Promise {\n if (!hasDeferredEntriesConfig) return\n\n // Wait for all non-deferred entries to be built\n await waitForNonDeferredEntries()\n\n // Call the onBeforeDeferredEntries callback once\n if (!onBeforeDeferredEntriesCalled) {\n onBeforeDeferredEntriesCalled = true\n\n if (nextConfig.experimental.onBeforeDeferredEntries) {\n if (!onBeforeDeferredEntriesPromise) {\n onBeforeDeferredEntriesPromise =\n nextConfig.experimental.onBeforeDeferredEntries()\n }\n await onBeforeDeferredEntriesPromise\n }\n } else if (onBeforeDeferredEntriesPromise) {\n // Wait for any in-progress callback\n await onBeforeDeferredEntriesPromise\n }\n }\n\n // Track whether HMR is pending - used to call callback once after HMR settles\n let hmrPendingDeferredCallback = false\n\n // Debounced function to call onBeforeDeferredEntries after HMR\n // This prevents rapid-fire calls when turbopack fires many update events\n // Use 500ms debounce to ensure all rapid updates are batched together\n const callOnBeforeDeferredEntriesAfterHMR = debounce(() => {\n // Only call if HMR triggered a need for the callback\n if (hasDeferredEntriesConfig && hmrPendingDeferredCallback) {\n hmrPendingDeferredCallback = false\n onBeforeDeferredEntriesCalled = true\n if (nextConfig.experimental.onBeforeDeferredEntries) {\n onBeforeDeferredEntriesPromise =\n nextConfig.experimental.onBeforeDeferredEntries()\n }\n }\n }, 500)\n\n function clearRequireCache(\n key: EntryKey,\n writtenEndpoint: WrittenEndpoint,\n {\n force,\n }: {\n // Always clear the cache, don't check if files have changed\n force?: boolean\n } = {}\n ): boolean {\n if (force) {\n for (const { path, contentHash } of writtenEndpoint.serverPaths) {\n // We ignore source maps\n if (path.endsWith('.map')) continue\n const localKey = `${key}:${path}`\n serverPathState.set(localKey, contentHash)\n serverPathState.set(path, contentHash)\n }\n } else {\n // Figure out if the server files have changed\n let hasChange = false\n for (const { path, contentHash } of writtenEndpoint.serverPaths) {\n // We ignore source maps\n if (path.endsWith('.map')) continue\n const localKey = `${key}:${path}`\n const localHash = serverPathState.get(localKey)\n const globalHash = serverPathState.get(path)\n if (\n (localHash && localHash !== contentHash) ||\n (globalHash && globalHash !== contentHash)\n ) {\n hasChange = true\n serverPathState.set(localKey, contentHash)\n serverPathState.set(path, contentHash)\n } else {\n if (!localHash) {\n serverPathState.set(localKey, contentHash)\n }\n if (!globalHash) {\n serverPathState.set(path, contentHash)\n }\n }\n }\n\n if (!hasChange) {\n return false\n }\n }\n\n const serverPaths = writtenEndpoint.serverPaths.map(({ path: p }) =>\n join(distDir, p)\n )\n\n const { type: entryType, page: entryPage } = splitEntryKey(key)\n\n // Server HMR applies to App Router entries built with the Turbopack Node.js\n // runtime: app pages and regular route handlers. Edge routes, Pages Router\n // pages, middleware/instrumentation, and metadata routes (manifest.ts,\n // robots.ts, sitemap.ts, icon.tsx, etc.) are excluded. Metadata routes are\n // excluded because they serve HTTP responses directly and must re-execute\n // on every request to pick up file changes; the in-place module update\n // model of Server HMR does not apply to them.\n const usesServerHmr =\n serverFastRefresh &&\n entryType === 'app' &&\n writtenEndpoint.type !== 'edge' &&\n !isMetadataRoute(entryPage)\n\n const filesToDelete: string[] = []\n for (const file of serverPaths) {\n clearModuleContext(file)\n\n const relativePath = relative(distDir, file)\n if (\n // For Pages Router, edge routes, middleware, and manifest files:\n // clear the sharedCache in evalManifest(), Node.js require.cache,\n // and edge runtime module contexts.\n force ||\n !usesServerHmr ||\n !serverHmrSubscriptions?.has(relativePath)\n ) {\n filesToDelete.push(file)\n }\n }\n deleteCache(filesToDelete)\n\n // Reset the fetch patch so patchFetch() can re-wrap on the next request.\n if (serverPaths.length > 0) {\n resetFetch()\n }\n\n // Clear Turbopack's chunk-loading cache so chunks are re-required from disk on\n // the next request.\n //\n // For App Router with server HMR, this is normally skipped as server HMR\n // manages module updates in-place. However, it *is* required when force is `true`\n // (like for .env file or tsconfig changes).\n if (\n (!usesServerHmr || force) &&\n typeof __next__clear_chunk_cache__ === 'function'\n ) {\n __next__clear_chunk_cache__()\n }\n\n return true\n }\n\n const buildingIds = new Set()\n\n const startBuilding: StartBuilding = (id, requestUrl, forceRebuild) => {\n if (!forceRebuild && readyIds.has(id)) {\n return () => {}\n }\n if (buildingIds.size === 0) {\n consoleStore.setState(\n {\n loading: true,\n trigger: id,\n url: requestUrl,\n } as OutputState,\n true\n )\n }\n buildingIds.add(id)\n return function finishBuilding() {\n if (buildingIds.size === 0) {\n return\n }\n readyIds.add(id)\n buildingIds.delete(id)\n if (buildingIds.size === 0) {\n hmrEventHappened = false\n consoleStore.setState(\n {\n loading: false,\n } as OutputState,\n true\n )\n }\n }\n }\n\n let serverHmrSubscriptions: ServerHmrSubscriptions | undefined\n\n let hmrEventHappened = false\n let hmrHash = 0\n\n const clientsWithoutHtmlRequestId = new Set()\n const clientsByHtmlRequestId = new Map()\n const cacheStatusesByHtmlRequestId = new Map()\n const clientStates = new WeakMap()\n\n function sendToClient(client: ws, message: HmrMessageSentToBrowser) {\n const data =\n typeof message.type === 'number'\n ? createBinaryHmrMessageData(message)\n : JSON.stringify(message)\n\n client.send(data)\n }\n\n function sendEnqueuedMessages() {\n for (const [, issueMap] of currentEntryIssues) {\n if (\n [...issueMap.values()].filter((i) => i.severity !== 'warning').length >\n 0\n ) {\n // During compilation errors we want to delay the HMR events until errors are fixed\n return\n }\n }\n\n for (const client of [\n ...clientsWithoutHtmlRequestId,\n ...clientsByHtmlRequestId.values(),\n ]) {\n const state = clientStates.get(client)\n if (!state) {\n continue\n }\n\n for (const [, issueMap] of state.clientIssues) {\n if (\n [...issueMap.values()].filter((i) => i.severity !== 'warning')\n .length > 0\n ) {\n // During compilation errors we want to delay the HMR events until errors are fixed\n return\n }\n }\n\n for (const message of state.messages.values()) {\n sendToClient(client, message)\n }\n state.messages.clear()\n\n if (state.turbopackUpdates.length > 0) {\n sendToClient(client, {\n type: HMR_MESSAGE_SENT_TO_BROWSER.TURBOPACK_MESSAGE,\n data: state.turbopackUpdates,\n })\n state.turbopackUpdates.length = 0\n }\n }\n }\n const sendEnqueuedMessagesDebounce = debounce(sendEnqueuedMessages, 2)\n\n const sendHmr: SendHmr = (id: string, message: HmrMessageSentToBrowser) => {\n for (const client of [\n ...clientsWithoutHtmlRequestId,\n ...clientsByHtmlRequestId.values(),\n ]) {\n clientStates.get(client)?.messages.set(id, message)\n }\n\n hmrEventHappened = true\n sendEnqueuedMessagesDebounce()\n }\n\n function sendTurbopackMessage(payload: TurbopackUpdate) {\n // TODO(PACK-2049): For some reason we end up emitting hundreds of issues messages on bigger apps,\n // a lot of which are duplicates.\n // They are currently not handled on the client at all, so might as well not send them for now.\n payload.diagnostics = []\n payload.issues = []\n\n for (const client of [\n ...clientsWithoutHtmlRequestId,\n ...clientsByHtmlRequestId.values(),\n ]) {\n clientStates.get(client)?.turbopackUpdates.push(payload)\n }\n\n hmrEventHappened = true\n sendEnqueuedMessagesDebounce()\n }\n\n async function subscribeToClientChanges(\n key: EntryKey,\n includeIssues: boolean,\n endpoint: Endpoint,\n createMessage: (\n change: TurbopackResult,\n hash: string\n ) => Promise | HmrMessageSentToBrowser | void,\n onError?: (\n error: Error\n ) => Promise | HmrMessageSentToBrowser | void\n ) {\n if (changeSubscriptions.has(key)) {\n return\n }\n\n const { side } = splitEntryKey(key)\n\n const changedPromise = endpoint[`${side}Changed`](includeIssues)\n changeSubscriptions.set(key, changedPromise)\n try {\n const changed = await changedPromise\n\n for await (const change of changed) {\n processIssues(currentEntryIssues, key, change, false, true)\n // TODO: Get an actual content hash from Turbopack.\n const message = await createMessage(change, String(++hmrHash))\n if (message) {\n sendHmr(key, message)\n }\n }\n } catch (e) {\n changeSubscriptions.delete(key)\n const payload = await onError?.(e as Error)\n if (payload) {\n sendHmr(key, payload)\n }\n return\n }\n changeSubscriptions.delete(key)\n }\n\n async function unsubscribeFromClientChanges(key: EntryKey) {\n const subscription = await changeSubscriptions.get(key)\n if (subscription) {\n await subscription.return?.()\n changeSubscriptions.delete(key)\n }\n currentEntryIssues.delete(key)\n }\n\n async function subscribeToClientHmrEvents(client: ws, id: string) {\n const key = getEntryKey('assets', 'client', id)\n if (!hasEntrypointForKey(currentEntrypoints, key, assetMapper)) {\n // maybe throw an error / force the client to reload?\n return\n }\n\n const state = clientStates.get(client)\n if (!state || state.subscriptions.has(id)) {\n return\n }\n\n const subscription = project!.hmrEvents(id, HmrTarget.Client)\n state.subscriptions.set(id, subscription)\n\n // The subscription will always emit once, which is the initial\n // computation. This is not a change, so swallow it.\n try {\n await subscription.next()\n\n for await (const data of subscription) {\n processIssues(state.clientIssues, key, data, false, true)\n if (data.type !== 'issues') {\n sendTurbopackMessage(data as TurbopackUpdate)\n }\n }\n } catch (e) {\n // The client might be using an HMR session from a previous server, tell them\n // to fully reload the page to resolve the issue. We can't use\n // `hotReloader.send` since that would force every connected client to\n // reload, only this client is out of date.\n const reloadMessage: ReloadPageMessage = {\n type: HMR_MESSAGE_SENT_TO_BROWSER.RELOAD_PAGE,\n data: `error in HMR event subscription for ${id}: ${e}`,\n }\n sendToClient(client, reloadMessage)\n client.close()\n return\n }\n }\n\n function unsubscribeFromClientHmrEvents(client: ws, id: string) {\n const state = clientStates.get(client)\n if (!state) {\n return\n }\n\n const subscription = state.subscriptions.get(id)\n subscription?.return!()\n\n const key = getEntryKey('assets', 'client', id)\n state.clientIssues.delete(key)\n }\n\n async function handleEntrypointsSubscription() {\n for await (const entrypoints of entrypointsSubscription) {\n if (!currentEntriesHandlingResolve) {\n currentEntriesHandling = new Promise(\n // eslint-disable-next-line no-loop-func\n (resolve) => (currentEntriesHandlingResolve = resolve)\n )\n }\n\n // Always process issues/diagnostics, even if there are no entrypoints yet\n processTopLevelIssues(currentTopLevelIssues, entrypoints)\n\n // Certain crtical issues prevent any entrypoints from being constructed so return early\n if (!('routes' in entrypoints)) {\n printBuildErrors(entrypoints, true)\n\n currentEntriesHandlingResolve!()\n currentEntriesHandlingResolve = undefined\n continue\n }\n\n const routes = entrypoints.routes\n const existingRoutes = [\n ...currentEntrypoints.app.keys(),\n ...currentEntrypoints.page.keys(),\n ]\n const newRoutes = [...routes.keys()]\n\n const addedRoutes = newRoutes.filter(\n (route) =>\n !currentEntrypoints.app.has(route) &&\n !currentEntrypoints.page.has(route)\n )\n const removedRoutes = existingRoutes.filter((route) => !routes.has(route))\n\n await handleEntrypoints({\n entrypoints: entrypoints as any,\n\n currentEntrypoints,\n\n currentEntryIssues,\n manifestLoader,\n devRewrites: opts.fsChecker.rewrites,\n productionRewrites: undefined,\n logErrors: true,\n\n dev: {\n assetMapper,\n changeSubscriptions,\n clients: [\n ...clientsWithoutHtmlRequestId,\n ...clientsByHtmlRequestId.values(),\n ],\n clientStates,\n serverFields,\n\n hooks: {\n handleWrittenEndpoint: (id, result, forceDeleteCache) => {\n currentWrittenEntrypoints.set(id, result)\n return clearRequireCache(id, result, { force: forceDeleteCache })\n },\n propagateServerField: propagateServerField.bind(null, opts),\n sendHmr,\n startBuilding,\n subscribeToChanges: subscribeToClientChanges,\n unsubscribeFromChanges: unsubscribeFromClientChanges,\n unsubscribeFromHmrEvents: unsubscribeFromClientHmrEvents,\n },\n },\n })\n\n // Reload matchers when the files have been compiled\n await propagateServerField(opts, 'reloadMatchers', undefined)\n\n if (addedRoutes.length > 0 || removedRoutes.length > 0) {\n // When the list of routes changes a new manifest should be fetched for Pages Router.\n hotReloader.send({\n type: HMR_MESSAGE_SENT_TO_BROWSER.DEV_PAGES_MANIFEST_UPDATE,\n data: [\n {\n devPagesManifest: true,\n },\n ],\n })\n }\n\n for (const route of addedRoutes) {\n hotReloader.send({\n type: HMR_MESSAGE_SENT_TO_BROWSER.ADDED_PAGE,\n data: [route],\n })\n }\n\n for (const route of removedRoutes) {\n hotReloader.send({\n type: HMR_MESSAGE_SENT_TO_BROWSER.REMOVED_PAGE,\n data: [route],\n })\n }\n\n currentEntriesHandlingResolve!()\n currentEntriesHandlingResolve = undefined\n }\n }\n\n await mkdir(join(distDir, 'server'), { recursive: true })\n await mkdir(join(distDir, 'static', buildId), { recursive: true })\n await writeFile(\n join(distDir, 'package.json'),\n JSON.stringify(\n {\n type: 'commonjs',\n },\n null,\n 2\n )\n )\n\n const middlewares = [\n getOverlayMiddleware({\n project,\n projectPath,\n isSrcDir: opts.isSrcDir,\n }),\n getSourceMapMiddleware(project),\n getNextErrorFeedbackMiddleware(opts.telemetry),\n getDevOverlayFontMiddleware(),\n getDisableDevIndicatorMiddleware(),\n getRestartDevServerMiddleware({\n telemetry: opts.telemetry,\n turbopackProject: project,\n }),\n devToolsConfigMiddleware({\n distDir,\n sendUpdateSignal: (data) => {\n hotReloader.send({\n type: HMR_MESSAGE_SENT_TO_BROWSER.DEVTOOLS_CONFIG,\n data,\n })\n },\n }),\n getAttachNodejsDebuggerMiddleware(),\n ...(nextConfig.experimental.mcpServer\n ? [\n getMcpMiddleware({\n projectPath,\n distDir,\n nextConfig,\n pagesDir: opts.pagesDir,\n appDir: opts.appDir,\n sendHmrMessage: (message) => hotReloader.send(message),\n getActiveConnectionCount: () =>\n clientsWithoutHtmlRequestId.size + clientsByHtmlRequestId.size,\n getDevServerUrl: () => process.env.__NEXT_PRIVATE_ORIGIN,\n }),\n ]\n : []),\n ]\n\n setStackFrameResolver(async (request) => {\n return getOriginalStackFrames({\n project,\n projectPath,\n isServer: request.isServer,\n isEdgeServer: request.isEdgeServer,\n isAppDirectory: request.isAppDirectory,\n frames: request.frames,\n })\n })\n\n let versionInfoCached: ReturnType | undefined\n // This fetch, even though not awaited, is not kicked off eagerly because the first `fetch()` in\n // Node.js adds roughly 20ms main-thread blocking to load the SSL certificate cache\n // We don't want that blocking time to be in the hot path for the `ready in` logging.\n // Instead, the fetch is kicked off lazily when the first `getVersionInfoCached()` is called.\n const getVersionInfoCached = (): ReturnType => {\n if (!versionInfoCached) {\n versionInfoCached = getVersionInfo()\n }\n return versionInfoCached\n }\n\n let devtoolsFrontendUrl: string | undefined\n const inspectorURLRaw = inspector.url()\n if (inspectorURLRaw !== undefined) {\n const inspectorURL = new URL(inspectorURLRaw)\n\n let debugInfo\n try {\n const debugInfoList = await fetch(\n `http://${inspectorURL.host}/json/list`\n ).then((res) => res.json())\n debugInfo = debugInfoList[0]\n } catch {}\n if (debugInfo) {\n devtoolsFrontendUrl = debugInfo.devtoolsFrontendUrl\n }\n }\n\n const hotReloader: NextJsHotReloaderInterface = {\n turbopackProject: project,\n activeWebpackConfigs: undefined,\n serverStats: null,\n edgeServerStats: null,\n async run(req, res, _parsedUrl) {\n // intercept page chunks request and ensure them with turbopack\n if (req.url?.startsWith('/_next/static/chunks/pages/')) {\n const params = matchNextPageBundleRequest(req.url)\n\n if (params) {\n const decodedPagePath = `/${params.path\n .map((param: string) => decodeURIComponent(param))\n .join('/')}`\n\n const denormalizedPagePath = denormalizePagePath(decodedPagePath)\n\n await hotReloader\n .ensurePage({\n page: denormalizedPagePath,\n clientOnly: false,\n definition: undefined,\n url: req.url,\n })\n .catch(console.error)\n }\n }\n\n for (const middleware of middlewares) {\n let calledNext = false\n\n await middleware(req, res, () => {\n calledNext = true\n })\n\n if (!calledNext) {\n return { finished: true }\n }\n }\n\n // Request was not finished.\n return { finished: undefined }\n },\n\n // TODO: Figure out if socket type can match the NextJsHotReloaderInterface\n onHMR(req, socket: Socket, head, onUpgrade) {\n wsServer.handleUpgrade(req, socket, head, (client) => {\n const clientIssues: EntryIssuesMap = new Map()\n const subscriptions: Map> = new Map()\n\n const htmlRequestId = req.url\n ? new URL(req.url, 'http://n').searchParams.get('id')\n : null\n\n // Clients with a request ID are inferred App Router clients. If Cache\n // Components is not enabled, we consider those legacy clients. Pages\n // Router clients are also considered legacy clients. TODO: Maybe mark\n // clients as App Router / Pages Router clients explicitly, instead of\n // inferring it from the presence of a request ID.\n if (htmlRequestId) {\n clientsByHtmlRequestId.set(htmlRequestId, client)\n const enableCacheComponents = nextConfig.cacheComponents\n if (enableCacheComponents) {\n onUpgrade(client, { isLegacyClient: false })\n const cacheStatus = cacheStatusesByHtmlRequestId.get(htmlRequestId)\n if (cacheStatus !== undefined) {\n sendToClient(client, {\n type: HMR_MESSAGE_SENT_TO_BROWSER.CACHE_INDICATOR,\n state: cacheStatus,\n })\n cacheStatusesByHtmlRequestId.delete(htmlRequestId)\n }\n } else {\n onUpgrade(client, { isLegacyClient: true })\n }\n\n connectReactDebugChannelForHtmlRequest(\n htmlRequestId,\n sendToClient.bind(null, client)\n )\n\n sendSerializedErrorsToClientForHtmlRequest(\n htmlRequestId,\n sendToClient.bind(null, client)\n )\n } else {\n clientsWithoutHtmlRequestId.add(client)\n onUpgrade(client, { isLegacyClient: true })\n }\n\n clientStates.set(client, {\n clientIssues,\n messages: new Map(),\n turbopackUpdates: [],\n subscriptions,\n })\n\n client.on('close', () => {\n // Remove active subscriptions\n for (const subscription of subscriptions.values()) {\n subscription.return?.()\n }\n clientStates.delete(client)\n\n if (htmlRequestId) {\n clientsByHtmlRequestId.delete(htmlRequestId)\n deleteReactDebugChannelForHtmlRequest(htmlRequestId)\n } else {\n clientsWithoutHtmlRequestId.delete(client)\n }\n })\n\n client.addEventListener('message', async ({ data }) => {\n const parsedData = JSON.parse(\n typeof data !== 'string' ? data.toString() : data\n )\n\n // Next.js messages\n switch (parsedData.event) {\n case 'span-end': {\n hotReloaderSpan.manualTraceChild(\n parsedData.spanName,\n msToNs(parsedData.startTime),\n msToNs(parsedData.endTime),\n parsedData.attributes\n )\n break\n }\n case 'client-hmr-latency': // { id, startTime, endTime, page, updatedModules, isPageHidden }\n hotReloaderSpan.manualTraceChild(\n parsedData.event,\n msToNs(parsedData.startTime),\n msToNs(parsedData.endTime),\n {\n updatedModules: parsedData.updatedModules,\n page: parsedData.page,\n isPageHidden: parsedData.isPageHidden,\n }\n )\n break\n\n case 'client-error': // { errorCount, clientId }\n case 'client-warning': // { warningCount, clientId }\n case 'client-success': // { clientId }\n case 'server-component-reload-page': // { clientId }\n case 'client-reload-page': // { clientId }\n case 'client-removed-page': // { page }\n case 'client-full-reload': // { stackTrace, hadRuntimeError }\n const { hadRuntimeError, dependencyChain } = parsedData\n if (hadRuntimeError) {\n Log.warn(FAST_REFRESH_RUNTIME_RELOAD)\n }\n if (\n Array.isArray(dependencyChain) &&\n typeof dependencyChain[0] === 'string'\n ) {\n const cleanedModulePath = dependencyChain[0]\n .replace(/^\\[project\\]/, '.')\n .replace(/ \\[.*\\] \\(.*\\)$/, '')\n Log.warn(\n `Fast Refresh had to perform a full reload when ${cleanedModulePath} changed. Read more: https://nextjs.org/docs/messages/fast-refresh-reload`\n )\n }\n break\n case 'client-added-page':\n // TODO\n break\n case 'browser-logs': {\n const browserToTerminalConfig =\n nextConfig.logging && nextConfig.logging.browserToTerminal\n if (browserToTerminalConfig) {\n await receiveBrowserLogsTurbopack({\n entries: parsedData.entries,\n router: parsedData.router,\n sourceType: parsedData.sourceType,\n project,\n projectPath,\n distDir,\n config: browserToTerminalConfig,\n })\n }\n break\n }\n case 'client-file-logs': {\n // Always log to file regardless of terminal flag\n await handleClientFileLogs(parsedData.logs)\n break\n }\n case 'ping': {\n // Handle ping events to keep WebSocket connections alive\n // No-op - just acknowledge the ping\n break\n }\n\n case 'mcp-error-state-response': {\n handleErrorStateResponse(\n parsedData.requestId,\n parsedData.errorState,\n parsedData.url\n )\n break\n }\n\n case 'mcp-page-metadata-response': {\n handlePageMetadataResponse(\n parsedData.requestId,\n parsedData.segmentTrieData,\n parsedData.url\n )\n break\n }\n\n default:\n // Might be a Turbopack message...\n if (!parsedData.type) {\n throw new Error(`unrecognized HMR message \"${data}\"`)\n }\n }\n\n // Turbopack messages\n switch (parsedData.type) {\n case 'turbopack-subscribe':\n subscribeToClientHmrEvents(client, parsedData.path)\n break\n\n case 'turbopack-unsubscribe':\n unsubscribeFromClientHmrEvents(client, parsedData.path)\n break\n\n default:\n if (!parsedData.event) {\n throw new Error(`unrecognized Turbopack HMR message \"${data}\"`)\n }\n }\n })\n\n const turbopackConnectedMessage: TurbopackConnectedMessage = {\n type: HMR_MESSAGE_SENT_TO_BROWSER.TURBOPACK_CONNECTED,\n data: { sessionId },\n }\n sendToClient(client, turbopackConnectedMessage)\n\n const errors: CompilationError[] = []\n\n for (const entryIssues of currentEntryIssues.values()) {\n for (const issue of entryIssues.values()) {\n if (issue.severity !== 'warning') {\n errors.push({\n message: formatIssue(issue),\n })\n } else {\n printNonFatalIssue(issue)\n }\n }\n }\n\n if (devIndicatorServerState.disabledUntil < Date.now()) {\n devIndicatorServerState.disabledUntil = 0\n }\n\n ;(async function () {\n const versionInfo = await getVersionInfoCached()\n const devToolsConfig = await getDevToolsConfig(distDir)\n\n const syncMessage: SyncMessage = {\n type: HMR_MESSAGE_SENT_TO_BROWSER.SYNC,\n errors,\n warnings: [],\n hash: '',\n versionInfo,\n debug: {\n devtoolsFrontendUrl,\n },\n devIndicator: devIndicatorServerState,\n devToolsConfig,\n }\n\n sendToClient(client, syncMessage)\n })()\n })\n },\n\n send(action) {\n const payload = JSON.stringify(action)\n\n for (const client of [\n ...clientsWithoutHtmlRequestId,\n ...clientsByHtmlRequestId.values(),\n ]) {\n client.send(payload)\n }\n },\n\n sendToLegacyClients(action) {\n const payload = JSON.stringify(action)\n\n // Clients with a request ID are inferred App Router clients. If Cache\n // Components is not enabled, we consider those legacy clients. Pages\n // Router clients are also considered legacy clients. TODO: Maybe mark\n // clients as App Router / Pages Router clients explicitly, instead of\n // inferring it from the presence of a request ID.\n\n if (!nextConfig.cacheComponents) {\n for (const client of clientsByHtmlRequestId.values()) {\n client.send(payload)\n }\n }\n\n for (const client of clientsWithoutHtmlRequestId) {\n client.send(payload)\n }\n },\n\n setCacheStatus(status: ServerCacheStatus, htmlRequestId: string): void {\n // Legacy clients don't have Cache Components.\n const client = clientsByHtmlRequestId.get(htmlRequestId)\n if (client !== undefined) {\n sendToClient(client, {\n type: HMR_MESSAGE_SENT_TO_BROWSER.CACHE_INDICATOR,\n state: status,\n })\n } else {\n // If the client is not connected, store the status so that we can send it\n // when the client connects.\n cacheStatusesByHtmlRequestId.set(htmlRequestId, status)\n }\n },\n\n setReactDebugChannel(debugChannel, htmlRequestId, requestId) {\n const client = clientsByHtmlRequestId.get(htmlRequestId)\n\n if (htmlRequestId === requestId) {\n // The debug channel is for the HTML request.\n if (client) {\n // If the client is connected, we can connect the debug channel for\n // the HTML request immediately.\n connectReactDebugChannel(\n htmlRequestId,\n debugChannel,\n sendToClient.bind(null, client)\n )\n } else {\n // Otherwise, we'll do that when the client connects and just store\n // the debug channel.\n setReactDebugChannelForHtmlRequest(htmlRequestId, debugChannel)\n }\n } else if (client) {\n // The debug channel is for a subsequent request (e.g. client-side\n // navigation for server function call). If the client is not connected\n // anymore, we don't need to connect the debug channel.\n connectReactDebugChannel(\n requestId,\n debugChannel,\n sendToClient.bind(null, client)\n )\n }\n },\n\n sendErrorsToBrowser(errorsRscStream, htmlRequestId) {\n const client = clientsByHtmlRequestId.get(htmlRequestId)\n\n if (client) {\n // If the client is connected, we can send the errors immediately.\n sendSerializedErrorsToClient(\n errorsRscStream,\n sendToClient.bind(null, client)\n )\n } else {\n // Otherwise, store the errors stream so that we can send it when the\n // client connects.\n setErrorsRscStreamForHtmlRequest(htmlRequestId, errorsRscStream)\n }\n },\n\n setHmrServerError(_error) {\n // Not implemented yet.\n },\n clearHmrServerError() {\n // Not implemented yet.\n },\n async start() {},\n async getCompilationErrors(page) {\n const appEntryKey = getEntryKey('app', 'server', page)\n const pagesEntryKey = getEntryKey('pages', 'server', page)\n\n const topLevelIssues = currentTopLevelIssues.values()\n\n const thisEntryIssues =\n currentEntryIssues.get(appEntryKey) ??\n currentEntryIssues.get(pagesEntryKey)\n\n if (thisEntryIssues !== undefined && thisEntryIssues.size > 0) {\n // If there is an error related to the requesting page we display it instead of the first error\n return [...topLevelIssues, ...thisEntryIssues.values()]\n .map((issue) => {\n const formattedIssue = formatIssue(issue)\n if (issue.severity === 'warning') {\n printNonFatalIssue(issue)\n return null\n } else if (isWellKnownError(issue)) {\n Log.error(formattedIssue)\n }\n\n return new Error(formattedIssue)\n })\n .filter((error) => error !== null)\n }\n\n // Otherwise, return all errors across pages\n const errors = []\n for (const issue of topLevelIssues) {\n if (issue.severity !== 'warning') {\n errors.push(new Error(formatIssue(issue)))\n }\n }\n for (const entryIssues of currentEntryIssues.values()) {\n for (const issue of entryIssues.values()) {\n if (issue.severity !== 'warning') {\n const message = formatIssue(issue)\n errors.push(new Error(message))\n } else {\n printNonFatalIssue(issue)\n }\n }\n }\n return errors\n },\n async invalidate({\n // .env files or tsconfig/jsconfig change\n reloadAfterInvalidation,\n }) {\n if (reloadAfterInvalidation) {\n for (const [key, entrypoint] of currentWrittenEntrypoints) {\n clearRequireCache(key, entrypoint, { force: true })\n }\n\n await clearAllModuleContexts()\n this.send({\n type: HMR_MESSAGE_SENT_TO_BROWSER.SERVER_COMPONENT_CHANGES,\n hash: String(++hmrHash),\n })\n }\n },\n async buildFallbackError() {\n // Not implemented yet.\n },\n async ensurePage({\n page: inputPage,\n // Unused parameters\n // clientOnly,\n appPaths,\n definition,\n isApp,\n url: requestUrl,\n }) {\n // When there is no route definition this is an internal file not a route the user added.\n // Middleware and instrumentation are handled in turbpack-utils.ts handleEntrypoints instead.\n if (!definition) {\n if (inputPage === '/middleware') return\n if (inputPage === '/src/middleware') return\n if (inputPage === '/instrumentation') return\n if (inputPage === '/src/instrumentation') return\n }\n\n return hotReloaderSpan\n .traceChild('ensure-page', {\n inputPage,\n })\n .traceAsyncFn(async () => {\n if (BLOCKED_PAGES.includes(inputPage) && inputPage !== '/_error') {\n return\n }\n\n await currentEntriesHandling\n\n // TODO We shouldn't look into the filesystem again. This should use the information from entrypoints\n let routeDef: Pick<\n RouteDefinition,\n 'filename' | 'bundlePath' | 'page'\n > =\n definition ??\n (await findPagePathData(\n projectPath,\n inputPage,\n nextConfig.pageExtensions,\n opts.pagesDir,\n opts.appDir,\n !!nextConfig.experimental.globalNotFound\n ))\n\n // If the route is actually an app page route, then we should have access\n // to the app route definition, and therefore, the appPaths from it.\n if (!appPaths && definition && isAppPageRouteDefinition(definition)) {\n appPaths = definition.appPaths\n }\n\n // Check if this is a deferred entry and wait for non-deferred entries first\n if (hasDeferredEntriesConfig) {\n const isDeferred = isDeferredEntry(\n routeDef.page,\n deferredEntriesConfig\n )\n if (isDeferred) {\n await processDeferredEntry()\n } else {\n // Track non-deferred entry as building\n nonDeferredBuildingEntries.add(routeDef.page)\n }\n }\n\n let page = routeDef.page\n if (appPaths) {\n const normalizedPage = normalizeAppPath(page)\n\n // filter out paths that are not exact matches (e.g. catchall)\n const matchingAppPaths = appPaths.filter(\n (path) => normalizeAppPath(path) === normalizedPage\n )\n\n // the last item in the array is the root page, if there are parallel routes\n page = matchingAppPaths[matchingAppPaths.length - 1]\n }\n\n const pathname = definition?.pathname ?? inputPage\n\n if (page === '/_error') {\n let finishBuilding = startBuilding(pathname, requestUrl, false)\n try {\n await handlePagesErrorRoute({\n currentEntryIssues,\n entrypoints: currentEntrypoints,\n manifestLoader,\n devRewrites: opts.fsChecker.rewrites,\n productionRewrites: undefined,\n logErrors: true,\n hooks: {\n subscribeToChanges: subscribeToClientChanges,\n handleWrittenEndpoint: (id, result, forceDeleteCache) => {\n currentWrittenEntrypoints.set(id, result)\n assetMapper.setPathsForKey(id, result.clientPaths)\n return clearRequireCache(id, result, {\n force: forceDeleteCache,\n })\n },\n },\n })\n } finally {\n finishBuilding()\n }\n return\n }\n\n const isInsideAppDir = routeDef.bundlePath.startsWith('app/')\n const isEntryMetadataRouteFile = isMetadataRouteFile(\n routeDef.filename.replace(opts.appDir || '', ''),\n nextConfig.pageExtensions,\n true\n )\n const normalizedAppPage = isEntryMetadataRouteFile\n ? normalizedPageToTurbopackStructureRoute(\n page,\n extname(routeDef.filename)\n )\n : page\n\n const route = isInsideAppDir\n ? currentEntrypoints.app.get(normalizedAppPage)\n : currentEntrypoints.page.get(page)\n\n if (!route) {\n // TODO: why is this entry missing in turbopack?\n if (page === '/middleware') return\n if (page === '/src/middleware') return\n if (page === '/proxy') return\n if (page === '/src/proxy') return\n if (page === '/instrumentation') return\n if (page === '/src/instrumentation') return\n\n throw new PageNotFoundError(`route not found ${page}`)\n }\n\n // We don't throw on ensureOpts.isApp === true for page-api\n // since this can happen when app pages make\n // api requests to page API routes.\n if (isApp && route.type === 'page') {\n throw new Error(`mis-matched route type: isApp && page for ${page}`)\n }\n\n const finishBuilding = startBuilding(pathname, requestUrl, false)\n try {\n await handleRouteType({\n dev,\n page,\n pathname,\n route,\n currentEntryIssues,\n entrypoints: currentEntrypoints,\n manifestLoader,\n readyIds,\n devRewrites: opts.fsChecker.rewrites,\n productionRewrites: undefined,\n logErrors: true,\n\n hooks: {\n subscribeToChanges: subscribeToClientChanges,\n handleWrittenEndpoint: (id, result, forceDeleteCache) => {\n currentWrittenEntrypoints.set(id, result)\n assetMapper.setPathsForKey(id, result.clientPaths)\n return clearRequireCache(id, result, {\n force: forceDeleteCache,\n })\n },\n },\n })\n } finally {\n finishBuilding()\n // Remove non-deferred entry from building set\n if (hasDeferredEntriesConfig) {\n nonDeferredBuildingEntries.delete(routeDef.page)\n }\n }\n })\n },\n close() {\n // Report MCP telemetry if MCP server is enabled\n recordMcpTelemetry(opts.telemetry)\n\n for (const wsClient of [\n ...clientsWithoutHtmlRequestId,\n ...clientsByHtmlRequestId.values(),\n ]) {\n // it's okay to not cleanly close these websocket connections, this is dev\n wsClient.terminate()\n }\n clientsWithoutHtmlRequestId.clear()\n clientsByHtmlRequestId.clear()\n },\n }\n\n handleEntrypointsSubscription().catch((err) => {\n console.error(err)\n process.exit(1)\n })\n\n // Write empty manifests\n await currentEntriesHandling\n await manifestLoader.writeManifests({\n devRewrites: opts.fsChecker.rewrites,\n productionRewrites: undefined,\n entrypoints: currentEntrypoints,\n })\n\n async function handleProjectUpdates() {\n for await (const updateMessage of project.updateInfoSubscribe(30)) {\n switch (updateMessage.updateType) {\n case 'start': {\n hotReloader.send({ type: HMR_MESSAGE_SENT_TO_BROWSER.BUILDING })\n // Mark that HMR has started and we need to call the callback after it settles\n // This ensures onBeforeDeferredEntries will be called again during HMR\n if (hasDeferredEntriesConfig) {\n hmrPendingDeferredCallback = true\n onBeforeDeferredEntriesCalled = false\n onBeforeDeferredEntriesPromise = null\n }\n break\n }\n case 'end': {\n sendEnqueuedMessages()\n\n function addToErrorsMap(\n errorsMap: Map,\n issueMap: IssuesMap\n ) {\n for (const [key, issue] of issueMap) {\n if (issue.severity === 'warning') continue\n if (errorsMap.has(key)) continue\n\n const message = formatIssue(issue)\n\n errorsMap.set(key, {\n message,\n details: issue.detail\n ? renderStyledStringToErrorAnsi(issue.detail)\n : undefined,\n })\n }\n }\n\n function addErrors(\n errorsMap: Map,\n issues: EntryIssuesMap\n ) {\n for (const issueMap of issues.values()) {\n addToErrorsMap(errorsMap, issueMap)\n }\n }\n\n const errors = new Map()\n addToErrorsMap(errors, currentTopLevelIssues)\n addErrors(errors, currentEntryIssues)\n\n for (const client of [\n ...clientsWithoutHtmlRequestId,\n ...clientsByHtmlRequestId.values(),\n ]) {\n const state = clientStates.get(client)\n if (!state) {\n continue\n }\n\n const clientErrors = new Map(errors)\n addErrors(clientErrors, state.clientIssues)\n\n sendToClient(client, {\n type: HMR_MESSAGE_SENT_TO_BROWSER.BUILT,\n hash: String(++hmrHash),\n errors: [...clientErrors.values()],\n warnings: [],\n })\n }\n\n if (hmrEventHappened) {\n const time = updateMessage.value.duration\n const timeMessage =\n time > 2000 ? `${Math.round(time / 100) / 10}s` : `${time}ms`\n Log.event(`Compiled in ${timeMessage}`)\n hmrEventHappened = false\n }\n\n // Call onBeforeDeferredEntries after compilation completes during HMR\n // This ensures the callback is invoked even when non-deferred entries change\n // Use debounced function to prevent rapid-fire calls from turbopack updates\n if (hasDeferredEntriesConfig) {\n callOnBeforeDeferredEntriesAfterHMR()\n }\n break\n }\n default:\n }\n }\n }\n\n handleProjectUpdates().catch((err) => {\n console.error(err)\n process.exit(1)\n })\n\n if (serverFastRefresh) {\n serverHmrSubscriptions = setupServerHmr(project, {\n clear: async () => {\n // Clear Node's require cache of all Turbopack-built modules\n const chunkPaths = [...(serverHmrSubscriptions?.keys() ?? [])].map(\n (chunkPath) => join(distDir, chunkPath)\n )\n deleteCache(chunkPaths)\n\n // Clear Turbopack's runtime caches\n if (typeof __next__clear_chunk_cache__ === 'function') {\n __next__clear_chunk_cache__()\n }\n\n // Reset the server HMR handler registry. All server runtime chunks are\n // cleared from require.cache above; when they're next required they'll\n // re-register into this Map and reinstall the routing dispatcher.\n ;(globalThis as any).__turbopack_server_hmr_handlers__ = new Map()\n\n // Clear all edge contexts\n await clearAllModuleContexts()\n\n resetFetch()\n\n // Tell browsers to refetch RSC (soft refresh, not full page reload)\n hotReloader.send({\n type: HMR_MESSAGE_SENT_TO_BROWSER.SERVER_COMPONENT_CHANGES,\n hash: String(++hmrHash),\n })\n },\n })\n }\n\n return hotReloader\n}\n"],"names":["mkdir","writeFile","inspector","join","extname","relative","pathToFileURL","ws","store","consoleStore","HMR_MESSAGE_SENT_TO_BROWSER","createDefineEnv","getBindingsSync","HmrTarget","Log","BLOCKED_PAGES","getOverlayMiddleware","getSourceMapMiddleware","getOriginalStackFrames","PageNotFoundError","debounce","deleteCache","clearAllModuleContexts","clearModuleContext","denormalizePagePath","trace","AssetMapper","handleEntrypoints","handlePagesErrorRoute","handleRouteType","hasEntrypointForKey","msToNs","processTopLevelIssues","printNonFatalIssue","normalizedPageToTurbopackStructureRoute","propagateServerField","TurbopackManifestLoader","findPagePathData","getEntryKey","splitEntryKey","createBinaryHmrMessageData","FAST_REFRESH_RUNTIME_RELOAD","generateEncryptionKeyBase64","isAppPageRouteDefinition","normalizeAppPath","isDeferredEntry","isMetadataRoute","isMetadataRouteFile","setBundlerFindSourceMapImplementation","getNextErrorFeedbackMiddleware","formatIssue","isFileSystemCacheEnabledForDev","isWellKnownError","processIssues","renderStyledStringToErrorAnsi","getDevOverlayFontMiddleware","devIndicatorServerState","getDisableDevIndicatorMiddleware","getRestartDevServerMiddleware","backgroundLogCompilationEvents","getSupportedBrowsers","printBuildErrors","receiveBrowserLogsTurbopack","handleClientFileLogs","normalizePath","devToolsConfigMiddleware","getDevToolsConfig","getAttachNodejsDebuggerMiddleware","connectReactDebugChannel","connectReactDebugChannelForHtmlRequest","deleteReactDebugChannelForHtmlRequest","setReactDebugChannelForHtmlRequest","getVersionInfo","matchNextPageBundleRequest","getMcpMiddleware","handleErrorStateResponse","handlePageMetadataResponse","setStackFrameResolver","recordMcpTelemetry","getFileLogger","sendSerializedErrorsToClient","sendSerializedErrorsToClientForHtmlRequest","setErrorsRscStreamForHtmlRequest","wsServer","Server","noServer","isTestMode","process","env","NEXT_TEST_MODE","__NEXT_TEST_MODE","DEBUG","sessionId","Math","floor","Number","MAX_SAFE_INTEGER","random","setupServerHmr","project","clear","serverHmrSubscriptions","Map","subscribeToServerHmr","chunkPath","has","subscription","hmrEvents","set","next","result","update","type","instruction","__turbopack_server_hmr_apply__","applied","catch","err","console","error","delete","serverHmrChunkPaths","hmrChunkNamesSubscribe","data","currentChunkPaths","Set","chunkNames","filter","path","endsWith","chunkPathsToRemove","keys","push","get","return","rewriteTurbopackSources","projectRoot","sourceMap","section","sections","map","i","sources","length","replace","toString","getSourceMapFromTurbopack","sourceURL","sourceMapJson","getSourceMapSync","undefined","payload","JSON","parse","createHotReloaderTurbopack","opts","serverFields","distDir","resetFetch","lockfile","serverFastRefresh","nextConfig","dev","buildId","dir","projectPath","bindings","isWasm","Error","platform","arch","require","log","testMode","hasRewrites","fsChecker","rewrites","afterFiles","beforeFiles","fallback","hotReloaderSpan","version","__NEXT_VERSION","stop","mcpServerEnabled","experimental","mcpServer","fileLogger","initialize","encryptionKey","isBuild","clientRouterFilters","clientRouterFilter","supportedBrowsers","currentNodeJsVersion","versions","node","rootPath","turbopack","root","outputFileTracingRoot","turbo","createProject","watch","enable","pollIntervalMs","watchOptions","defineEnv","isTurbopack","config","fetchCacheKeyPrefix","middlewareMatchers","previewProps","browserslistQuery","noMangling","writeRoutesHashesManifest","isPersistentCachingEnabled","nextVersion","serverHmr","memoryLimit","turbopackMemoryLimit","isShortSession","eventTypes","parentSpan","bind","installCodeFrameSupport","onDevServerCleanup","onExit","unlock","entrypointsSubscription","entrypointsSubscribe","currentWrittenEntrypoints","currentEntrypoints","global","app","document","middleware","instrumentation","page","currentTopLevelIssues","currentEntryIssues","manifestLoader","sriEnabled","changeSubscriptions","serverPathState","readyIds","currentEntriesHandlingResolve","currentEntriesHandling","Promise","resolve","assetMapper","deferredEntriesConfig","deferredEntries","hasDeferredEntriesConfig","onBeforeDeferredEntriesCalled","onBeforeDeferredEntriesPromise","nonDeferredBuildingEntries","waitForNonDeferredEntries","checkEntries","size","setTimeout","processDeferredEntry","onBeforeDeferredEntries","hmrPendingDeferredCallback","callOnBeforeDeferredEntriesAfterHMR","clearRequireCache","key","writtenEndpoint","force","contentHash","serverPaths","localKey","hasChange","localHash","globalHash","p","entryType","entryPage","usesServerHmr","filesToDelete","file","relativePath","__next__clear_chunk_cache__","buildingIds","startBuilding","id","requestUrl","forceRebuild","setState","loading","trigger","url","add","finishBuilding","hmrEventHappened","hmrHash","clientsWithoutHtmlRequestId","clientsByHtmlRequestId","cacheStatusesByHtmlRequestId","clientStates","WeakMap","sendToClient","client","message","stringify","send","sendEnqueuedMessages","issueMap","values","severity","state","clientIssues","messages","turbopackUpdates","TURBOPACK_MESSAGE","sendEnqueuedMessagesDebounce","sendHmr","sendTurbopackMessage","diagnostics","issues","subscribeToClientChanges","includeIssues","endpoint","createMessage","onError","side","changedPromise","changed","change","String","e","unsubscribeFromClientChanges","subscribeToClientHmrEvents","subscriptions","Client","reloadMessage","RELOAD_PAGE","close","unsubscribeFromClientHmrEvents","handleEntrypointsSubscription","entrypoints","routes","existingRoutes","newRoutes","addedRoutes","route","removedRoutes","devRewrites","productionRewrites","logErrors","clients","hooks","handleWrittenEndpoint","forceDeleteCache","subscribeToChanges","unsubscribeFromChanges","unsubscribeFromHmrEvents","hotReloader","DEV_PAGES_MANIFEST_UPDATE","devPagesManifest","ADDED_PAGE","REMOVED_PAGE","recursive","middlewares","isSrcDir","telemetry","turbopackProject","sendUpdateSignal","DEVTOOLS_CONFIG","pagesDir","appDir","sendHmrMessage","getActiveConnectionCount","getDevServerUrl","__NEXT_PRIVATE_ORIGIN","request","isServer","isEdgeServer","isAppDirectory","frames","versionInfoCached","getVersionInfoCached","devtoolsFrontendUrl","inspectorURLRaw","inspectorURL","URL","debugInfo","debugInfoList","fetch","host","then","res","json","activeWebpackConfigs","serverStats","edgeServerStats","run","req","_parsedUrl","startsWith","params","decodedPagePath","param","decodeURIComponent","denormalizedPagePath","ensurePage","clientOnly","definition","calledNext","finished","onHMR","socket","head","onUpgrade","handleUpgrade","htmlRequestId","searchParams","enableCacheComponents","cacheComponents","isLegacyClient","cacheStatus","CACHE_INDICATOR","on","addEventListener","parsedData","event","manualTraceChild","spanName","startTime","endTime","attributes","updatedModules","isPageHidden","hadRuntimeError","dependencyChain","warn","Array","isArray","cleanedModulePath","browserToTerminalConfig","logging","browserToTerminal","entries","router","sourceType","logs","requestId","errorState","segmentTrieData","turbopackConnectedMessage","TURBOPACK_CONNECTED","errors","entryIssues","issue","disabledUntil","Date","now","versionInfo","devToolsConfig","syncMessage","SYNC","warnings","hash","debug","devIndicator","action","sendToLegacyClients","setCacheStatus","status","setReactDebugChannel","debugChannel","sendErrorsToBrowser","errorsRscStream","setHmrServerError","_error","clearHmrServerError","start","getCompilationErrors","appEntryKey","pagesEntryKey","topLevelIssues","thisEntryIssues","formattedIssue","invalidate","reloadAfterInvalidation","entrypoint","SERVER_COMPONENT_CHANGES","buildFallbackError","inputPage","appPaths","isApp","traceChild","traceAsyncFn","includes","routeDef","pageExtensions","globalNotFound","isDeferred","normalizedPage","matchingAppPaths","pathname","setPathsForKey","clientPaths","isInsideAppDir","bundlePath","isEntryMetadataRouteFile","filename","normalizedAppPage","wsClient","terminate","exit","writeManifests","handleProjectUpdates","updateMessage","updateInfoSubscribe","updateType","BUILDING","addToErrorsMap","errorsMap","details","detail","addErrors","clientErrors","BUILT","time","value","duration","timeMessage","round","chunkPaths","globalThis","__turbopack_server_hmr_handlers__"],"mappings":"AACA,SAASA,KAAK,EAAEC,SAAS,QAAQ,cAAa;AAC9C,YAAYC,eAAe,YAAW;AACtC,SAASC,IAAI,EAAEC,OAAO,EAAEC,QAAQ,QAAQ,OAAM;AAC9C,SAASC,aAAa,QAAQ,MAAK;AAEnC,OAAOC,QAAQ,wBAAuB;AAGtC,SAASC,SAASC,YAAY,QAAQ,2BAA0B;AAShE,SAASC,2BAA2B,QAAQ,uBAAsB;AAWlE,SAASC,eAAe,EAAEC,eAAe,EAAEC,SAAS,QAAQ,kBAAiB;AAC7E,YAAYC,SAAS,yBAAwB;AAC7C,SAASC,aAAa,QAAQ,6BAA4B;AAC1D,SACEC,oBAAoB,EACpBC,sBAAsB,EACtBC,sBAAsB,QACjB,yBAAwB;AAC/B,SAASC,iBAAiB,QAAQ,yBAAwB;AAC1D,SAASC,QAAQ,QAAQ,WAAU;AACnC,SAASC,WAAW,QAAQ,kBAAiB;AAC7C,SACEC,sBAAsB,EACtBC,kBAAkB,QACb,uBAAsB;AAC7B,SAASC,mBAAmB,QAAQ,mDAAkD;AACtF,SAASC,KAAK,QAAQ,cAAa;AACnC,SACEC,WAAW,EAGXC,iBAAiB,EACjBC,qBAAqB,EACrBC,eAAe,EACfC,mBAAmB,EACnBC,MAAM,EAINC,qBAAqB,EACrBC,kBAAkB,EAClBC,uCAAuC,QAClC,oBAAmB;AAC1B,SACEC,oBAAoB,QAGf,wCAAuC;AAC9C,SAASC,uBAAuB,QAAQ,6CAA4C;AACpF,SAASC,gBAAgB,QAAQ,4BAA2B;AAE5D,SAEEC,WAAW,EACXC,aAAa,QACR,uCAAsC;AAC7C,SACEC,0BAA0B,EAC1BC,2BAA2B,QACtB,aAAY;AACnB,SAASC,2BAA2B,QAAQ,wCAAuC;AACnF,SAASC,wBAAwB,QAAQ,iDAAgD;AACzF,SAASC,gBAAgB,QAAQ,0CAAyC;AAE1E,SAASC,eAAe,QAAQ,sBAAqB;AACrD,SACEC,eAAe,EACfC,mBAAmB,QACd,uCAAsC;AAC7C,SAASC,qCAAqC,QAAQ,yBAAwB;AAC9E,SAASC,8BAA8B,QAAQ,gEAA+D;AAC9G,SACEC,WAAW,EACXC,8BAA8B,EAC9BC,gBAAgB,EAChBC,aAAa,EACbC,6BAA6B,QAIxB,mCAAkC;AACzC,SAASC,2BAA2B,QAAQ,kEAAiE;AAC7G,SAASC,uBAAuB,QAAQ,+BAA8B;AACtE,SAASC,gCAAgC,QAAQ,sDAAqD;AACtG,SAASC,6BAA6B,QAAQ,2DAA0D;AACxG,SAASC,8BAA8B,QAAQ,gDAA+C;AAC9F,SAASC,oBAAoB,QAAQ,qCAAoC;AACzE,SAASC,gBAAgB,QAAQ,iCAAgC;AACjE,SACEC,2BAA2B,EAC3BC,oBAAoB,QACf,8BAA6B;AACpC,SAASC,aAAa,QAAQ,2BAA0B;AACxD,SACEC,wBAAwB,EACxBC,iBAAiB,QACZ,wDAAuD;AAC9D,SAASC,iCAAiC,QAAQ,+DAA8D;AAChH,SACEC,wBAAwB,EACxBC,sCAAsC,EACtCC,qCAAqC,EACrCC,kCAAkC,QAC7B,kBAAiB;AACxB,SACEC,cAAc,EACdC,0BAA0B,QACrB,8BAA6B;AACpC,SAASC,gBAAgB,QAAQ,4BAA2B;AAC5D,SAASC,wBAAwB,QAAQ,0BAAyB;AAClE,SAASC,0BAA0B,QAAQ,iCAAgC;AAC3E,SAASC,qBAAqB,QAAQ,mCAAkC;AACxE,SAASC,kBAAkB,QAAQ,+BAA8B;AACjE,SAASC,aAAa,QAAQ,6BAA4B;AAG1D,SACEC,4BAA4B,EAC5BC,0CAA0C,EAC1CC,gCAAgC,QAC3B,sBAAqB;AAE5B,MAAMC,WAAW,IAAI5E,GAAG6E,MAAM,CAAC;IAAEC,UAAU;AAAK;AAChD,MAAMC,aAAa,CAAC,CAClBC,CAAAA,QAAQC,GAAG,CAACC,cAAc,IAC1BF,QAAQC,GAAG,CAACE,gBAAgB,IAC5BH,QAAQC,GAAG,CAACG,KAAK,AAAD;AAGlB,MAAMC,YAAYC,KAAKC,KAAK,CAACC,OAAOC,gBAAgB,GAAGH,KAAKI,MAAM;AAalE,SAASC,eACPC,OAAgB,EAChB,EACEC,KAAK,EAGN;IAED,MAAMC,yBAAiD,IAAIC;IAE3D;;;GAGC,GACD,SAASC,qBAAqBC,SAAiB;QAC7C,IAAIH,uBAAuBI,GAAG,CAACD,YAAY;YACzC;QACF;QAEA,MAAME,eAAeP,QAAQQ,SAAS,CAACH,WAAW3F,UAAUuE,MAAM;QAClEiB,uBAAuBO,GAAG,CAACJ,WAAWE;QAGpC,CAAA;YACA,qBAAqB;YACrB,MAAMA,aAAaG,IAAI;YAEvB,WAAW,MAAMC,UAAUJ,aAAc;gBACvC,MAAMK,SAASD;gBAEf,sEAAsE;gBACtE,oCAAoC;gBACpC,IAAIC,OAAOC,IAAI,KAAK,WAAW;oBAC7B,MAAMZ;oBACN;gBACF;gBAEA,IAAIW,OAAOC,IAAI,KAAK,WAAW;oBAC7B;gBACF;gBAEA,MAAMC,cAAcF,OAAOE,WAAW;gBACtC,IAAI,CAACA,eAAeA,YAAYD,IAAI,KAAK,0BAA0B;oBACjE;gBACF;gBAEA,IAAI,OAAOE,mCAAmC,YAAY;oBACxD,MAAMC,UAAUD,+BAA+BH;oBAC/C,IAAI,CAACI,SAAS;wBACZ,MAAMf;oBACR;gBACF;YACF;QACF,CAAA,IAAKgB,KAAK,CAAC,OAAOC;YAChBC,QAAQC,KAAK,CAAC,oCAAoCF;YAClDhB,uBAAuBmB,MAAM,CAAChB;YAC9B,MAAMJ;QACR;IACF;IAEA,2EAA2E;;IACzE,CAAA;QACA,IAAI;YACF,MAAMqB,sBAAsBtB,QAAQuB,sBAAsB,CACxD7G,UAAUuE,MAAM;YAGlB,4DAA4D;YAC5D,WAAW,MAAMuC,QAAQF,oBAAqB;gBAC5C,MAAMG,oBAAoB,IAAIC,IAC5BF,KAAKG,UAAU,CAACC,MAAM,CAAC,CAACC,OAASA,KAAKC,QAAQ,CAAC;gBAGjD,+EAA+E;gBAC/E,MAAMC,qBAA+B,EAAE;gBACvC,KAAK,MAAM1B,aAAaH,uBAAuB8B,IAAI,GAAI;oBACrD,IAAI,CAACP,kBAAkBnB,GAAG,CAACD,YAAY;wBACrC0B,mBAAmBE,IAAI,CAAC5B;oBAC1B;gBACF;gBAEA,KAAK,MAAMA,aAAa0B,mBAAoB;wBAE1CxB;oBADA,MAAMA,eAAeL,uBAAuBgC,GAAG,CAAC7B;oBAChDE,iCAAAA,uBAAAA,aAAc4B,MAAM,qBAApB5B,0BAAAA;oBACAL,uBAAuBmB,MAAM,CAAChB;gBAChC;gBAEA,gDAAgD;gBAChD,KAAK,MAAMA,aAAaoB,kBAAmB;oBACzC,IAAI,CAACvB,uBAAuBI,GAAG,CAACD,YAAY;wBAC1CD,qBAAqBC;oBACvB;gBACF;YACF;QACF,EAAE,OAAOa,KAAK;YACZC,QAAQC,KAAK,CAAC,wDAAwDF;QACxE;IACF,CAAA;IAEA,OAAOhB;AACT;AAEA;;CAEC,GACD,SAASkC,wBACPC,WAAmB,EACnBC,SAAiC;IAEjC,IAAI,cAAcA,WAAW;QAC3B,KAAK,MAAMC,WAAWD,UAAUE,QAAQ,CAAE;YACxCJ,wBAAwBC,aAAaE,QAAQE,GAAG;QAClD;IACF,OAAO;QACL,IAAK,IAAIC,IAAI,GAAGA,IAAIJ,UAAUK,OAAO,CAACC,MAAM,EAAEF,IAAK;YACjDJ,UAAUK,OAAO,CAACD,EAAE,GAAGvI,cACrBH,KACEqI,aACAC,UAAUK,OAAO,CAACD,EAAE,CAACG,OAAO,CAAC,+BAA+B,MAE9DC,QAAQ;QACZ;IACF;AACF;AAEA,SAASC,0BACP/C,OAAgB,EAChBqC,WAAmB,EACnBW,SAAiB;IAEjB,IAAIC,gBAA+B;IAEnC,IAAI;QACFA,gBAAgBjD,QAAQkD,gBAAgB,CAACF;IAC3C,EAAE,OAAO9B,KAAK,CAAC;IAEf,IAAI+B,kBAAkB,MAAM;QAC1B,OAAOE;IACT,OAAO;QACL,MAAMC,UAAkCC,KAAKC,KAAK,CAACL;QACnD,2EAA2E;QAC3E,4EAA4E;QAC5Eb,wBAAwBC,aAAae;QACrC,OAAOA;IACT;AACF;AAEA,OAAO,eAAeG,2BACpBC,IAAuC,EACvCC,YAA0B,EAC1BC,OAAe,EACfC,UAAsB,EACtBC,QAA8B,EAC9BC,iBAA2B;QAiEzBL,4BAWoBM,0BA+BLN;IAzGjB,MAAMO,MAAM;IACZ,MAAMC,UAAU;IAChB,MAAM,EAAEF,UAAU,EAAEG,KAAKC,WAAW,EAAE,GAAGV;IAEzC,MAAMW,WAAW1J;IAEjB,wEAAwE;IACxE,gEAAgE;IAChE,IAAI0J,SAASC,MAAM,EAAE;QACnB,MAAM,qBAML,CANK,IAAIC,MACR,CAAC,6CAA6C,EAAEjF,QAAQkF,QAAQ,CAAC,CAAC,EAAElF,QAAQmF,IAAI,CAAC,6CAA6C,CAAC,GAC7H,CAAC,yFAAyF,CAAC,GAC3F,CAAC,uDAAuD,CAAC,GACzD,CAAC,wBAAwB,CAAC,GAC1B,CAAC,kGAAkG,CAAC,GALlG,qBAAA;mBAAA;wBAAA;0BAAA;QAMN;IACF;IAEA,iGAAiG;IACjG,yGAAyG;IACzG,IAAIpF,YAAY;;QACZqF,QAAQ,WAAwCC,GAAG,CACnD,8BACA;YACER,KAAKC;YACLQ,UAAUvF;QACZ;IAEJ;IAEA,MAAMwF,cACJnB,KAAKoB,SAAS,CAACC,QAAQ,CAACC,UAAU,CAAClC,MAAM,GAAG,KAC5CY,KAAKoB,SAAS,CAACC,QAAQ,CAACE,WAAW,CAACnC,MAAM,GAAG,KAC7CY,KAAKoB,SAAS,CAACC,QAAQ,CAACG,QAAQ,CAACpC,MAAM,GAAG;IAE5C,MAAMqC,kBAAkB3J,MAAM,gBAAgB6H,WAAW;QACvD+B,SAAS9F,QAAQC,GAAG,CAAC8F,cAAc;IACrC;IACA,8FAA8F;IAC9F,wCAAwC;IACxCF,gBAAgBG,IAAI;IAEpB,0CAA0C;IAC1C,gDAAgD;IAChD,MAAMC,mBAAmB,CAAC,CAACvB,WAAWwB,YAAY,CAACC,SAAS;IAC5D,MAAMC,aAAa5G;IACnB4G,WAAWC,UAAU,CAAC/B,SAAS2B;IAE/B,MAAMK,gBAAgB,MAAMnJ,4BAA4B;QACtDoJ,SAAS;QACTjC;IACF;IAEA,kBAAkB;IAClB,IAAIkC;IACJ,IAAI9B,WAAWwB,YAAY,CAACO,kBAAkB,EAAE;IAC9C,kEAAkE;IACpE;IAEA,MAAMC,oBAAoBrI,qBAAqByG,aAAaH;IAC5D,MAAMgC,uBAAuB3G,QAAQ4G,QAAQ,CAACC,IAAI;IAElD,MAAMC,WACJ1C,EAAAA,6BAAAA,KAAKM,UAAU,CAACqC,SAAS,qBAAzB3C,2BAA2B4C,IAAI,KAC/B5C,KAAKM,UAAU,CAACuC,qBAAqB,IACrCnC;IACF,MAAMlE,UAAU,MAAMmE,SAASmC,KAAK,CAACC,aAAa,CAChD;QACEL;QACAhC,aAAarG,cAAc3D,SAASgM,UAAUhC,gBAAgB;QAC9DR;QACAI,YAAYN,KAAKM,UAAU;QAC3B0C,OAAO;YACLC,QAAQ1C;YACR2C,cAAc,GAAE5C,2BAAAA,WAAW6C,YAAY,qBAAvB7C,yBAAyB4C,cAAc;QACzD;QACA3C;QACA1E,KAAKD,QAAQC,GAAG;QAChBuH,WAAWpM,gBAAgB;YACzBqM,aAAa;YACbjB;YACAkB,QAAQhD;YACRC;YACAL;YACAQ;YACA6C,qBAAqBvD,KAAKM,UAAU,CAACwB,YAAY,CAACyB,mBAAmB;YACrEpC;YACA,kBAAkB;YAClBqC,oBAAoB7D;YACpB0B,UAAUrB,KAAKoB,SAAS,CAACC,QAAQ;QACnC;QACAb;QACA0B;QACAuB,cAAczD,KAAKoB,SAAS,CAACqC,YAAY;QACzCC,mBAAmBpB,kBAAkB9L,IAAI,CAAC;QAC1CmN,YAAY;QACZC,2BAA2B;QAC3BrB;QACAsB,4BAA4BrK,+BAC1BwG,KAAKM,UAAU;QAEjBwD,aAAalI,QAAQC,GAAG,CAAC8F,cAAc;QACvCoC,WAAW1D;IACb,GACA;QACE2D,WAAW,GAAEhE,gCAAAA,KAAKM,UAAU,CAACwB,YAAY,qBAA5B9B,8BAA8BiE,oBAAoB;QAC/DC,gBAAgB;IAClB;IAEFlK,+BAA+BwC,SAAS;QACtC2H,YAAY;YACV;YACA;YACA;YACA;SACD;QACDC,YAAY3C;IACd;IACApI,sCACEkG,0BAA0B8E,IAAI,CAAC,MAAM7H,SAASkE;IAGhD,mDAAmD;IACnD,MAAM,EAAE4D,uBAAuB,EAAE,GAC/BtD,QAAQ;IACVsD;IAEAtE,KAAKuE,kBAAkB,oBAAvBvE,KAAKuE,kBAAkB,MAAvBvE,MAA0B;QACxB3G,sCAAsC,IAAMsG;QAC5C,MAAMnD,QAAQgI,MAAM;QACpB,OAAMpE,4BAAAA,SAAUqE,MAAM;IACxB;IACA,MAAMC,0BAA0BlI,QAAQmI,oBAAoB;IAE5D,MAAMC,4BAA4D,IAAIjI;IACtE,MAAMkI,qBAAkC;QACtCC,QAAQ;YACNC,KAAKpF;YACLqF,UAAUrF;YACV/B,OAAO+B;YAEPsF,YAAYtF;YACZuF,iBAAiBvF;QACnB;QAEAwF,MAAM,IAAIxI;QACVoI,KAAK,IAAIpI;IACX;IAEA,MAAMyI,wBAA2C,IAAIzI;IACrD,MAAM0I,qBAAqC,IAAI1I;IAE/C,MAAM2I,iBAAiB,IAAI7M,wBAAwB;QACjD+H;QACAN;QACAgC;QACA3B,KAAK;QACLgF,YAAY;IACd;IAEA,eAAe;IACf,MAAMC,sBAA2C,IAAI7I;IACrD,MAAM8I,kBAAkB,IAAI9I;IAC5B,MAAM+I,WAAqB,IAAIxH;IAC/B,IAAIyH;IACJ,IAAIC,yBAAyB,IAAIC,QAC/B,CAACC,UAAaH,gCAAgCG;IAGhD,MAAMC,cAAc,IAAIhO;IAExB,oCAAoC;IACpC,MAAMiO,wBAAwB1F,WAAWwB,YAAY,CAACmE,eAAe;IACrE,MAAMC,2BACJF,yBAAyBA,sBAAsB5G,MAAM,GAAG;IAC1D,IAAI+G,gCAAgC;IACpC,IAAIC,iCAAuD;IAC3D,4DAA4D;IAC5D,MAAMC,6BAA0C,IAAInI;IAEpD,4DAA4D;IAC5D,eAAeoI;QACb,OAAO,IAAIT,QAAc,CAACC;YACxB,MAAMS,eAAe;gBACnB,sEAAsE;gBACtE,IAAIF,2BAA2BG,IAAI,KAAK,GAAG;oBACzCV;gBACF,OAAO;oBACL,kCAAkC;oBAClCW,WAAWF,cAAc;gBAC3B;YACF;YACAA;QACF;IACF;IAEA,+CAA+C;IAC/C,eAAeG;QACb,IAAI,CAACR,0BAA0B;QAE/B,gDAAgD;QAChD,MAAMI;QAEN,iDAAiD;QACjD,IAAI,CAACH,+BAA+B;YAClCA,gCAAgC;YAEhC,IAAI7F,WAAWwB,YAAY,CAAC6E,uBAAuB,EAAE;gBACnD,IAAI,CAACP,gCAAgC;oBACnCA,iCACE9F,WAAWwB,YAAY,CAAC6E,uBAAuB;gBACnD;gBACA,MAAMP;YACR;QACF,OAAO,IAAIA,gCAAgC;YACzC,oCAAoC;YACpC,MAAMA;QACR;IACF;IAEA,8EAA8E;IAC9E,IAAIQ,6BAA6B;IAEjC,+DAA+D;IAC/D,yEAAyE;IACzE,sEAAsE;IACtE,MAAMC,sCAAsCpP,SAAS;QACnD,qDAAqD;QACrD,IAAIyO,4BAA4BU,4BAA4B;YAC1DA,6BAA6B;YAC7BT,gCAAgC;YAChC,IAAI7F,WAAWwB,YAAY,CAAC6E,uBAAuB,EAAE;gBACnDP,iCACE9F,WAAWwB,YAAY,CAAC6E,uBAAuB;YACnD;QACF;IACF,GAAG;IAEH,SAASG,kBACPC,GAAa,EACbC,eAAgC,EAChC,EACEC,KAAK,EAIN,GAAG,CAAC,CAAC;QAEN,IAAIA,OAAO;YACT,KAAK,MAAM,EAAE5I,IAAI,EAAE6I,WAAW,EAAE,IAAIF,gBAAgBG,WAAW,CAAE;gBAC/D,wBAAwB;gBACxB,IAAI9I,KAAKC,QAAQ,CAAC,SAAS;gBAC3B,MAAM8I,WAAW,GAAGL,IAAI,CAAC,EAAE1I,MAAM;gBACjCoH,gBAAgBxI,GAAG,CAACmK,UAAUF;gBAC9BzB,gBAAgBxI,GAAG,CAACoB,MAAM6I;YAC5B;QACF,OAAO;YACL,8CAA8C;YAC9C,IAAIG,YAAY;YAChB,KAAK,MAAM,EAAEhJ,IAAI,EAAE6I,WAAW,EAAE,IAAIF,gBAAgBG,WAAW,CAAE;gBAC/D,wBAAwB;gBACxB,IAAI9I,KAAKC,QAAQ,CAAC,SAAS;gBAC3B,MAAM8I,WAAW,GAAGL,IAAI,CAAC,EAAE1I,MAAM;gBACjC,MAAMiJ,YAAY7B,gBAAgB/G,GAAG,CAAC0I;gBACtC,MAAMG,aAAa9B,gBAAgB/G,GAAG,CAACL;gBACvC,IACE,AAACiJ,aAAaA,cAAcJ,eAC3BK,cAAcA,eAAeL,aAC9B;oBACAG,YAAY;oBACZ5B,gBAAgBxI,GAAG,CAACmK,UAAUF;oBAC9BzB,gBAAgBxI,GAAG,CAACoB,MAAM6I;gBAC5B,OAAO;oBACL,IAAI,CAACI,WAAW;wBACd7B,gBAAgBxI,GAAG,CAACmK,UAAUF;oBAChC;oBACA,IAAI,CAACK,YAAY;wBACf9B,gBAAgBxI,GAAG,CAACoB,MAAM6I;oBAC5B;gBACF;YACF;YAEA,IAAI,CAACG,WAAW;gBACd,OAAO;YACT;QACF;QAEA,MAAMF,cAAcH,gBAAgBG,WAAW,CAAClI,GAAG,CAAC,CAAC,EAAEZ,MAAMmJ,CAAC,EAAE,GAC9DhR,KAAK0J,SAASsH;QAGhB,MAAM,EAAEnK,MAAMoK,SAAS,EAAEtC,MAAMuC,SAAS,EAAE,GAAG9O,cAAcmO;QAE3D,4EAA4E;QAC5E,2EAA2E;QAC3E,uEAAuE;QACvE,2EAA2E;QAC3E,0EAA0E;QAC1E,uEAAuE;QACvE,8CAA8C;QAC9C,MAAMY,gBACJtH,qBACAoH,cAAc,SACdT,gBAAgB3J,IAAI,KAAK,UACzB,CAAClE,gBAAgBuO;QAEnB,MAAME,gBAA0B,EAAE;QAClC,KAAK,MAAMC,QAAQV,YAAa;YAC9BvP,mBAAmBiQ;YAEnB,MAAMC,eAAepR,SAASwJ,SAAS2H;YACvC,IACE,iEAAiE;YACjE,kEAAkE;YAClE,oCAAoC;YACpCZ,SACA,CAACU,iBACD,EAACjL,0CAAAA,uBAAwBI,GAAG,CAACgL,gBAC7B;gBACAF,cAAcnJ,IAAI,CAACoJ;YACrB;QACF;QACAnQ,YAAYkQ;QAEZ,yEAAyE;QACzE,IAAIT,YAAY/H,MAAM,GAAG,GAAG;YAC1Be;QACF;QAEA,+EAA+E;QAC/E,oBAAoB;QACpB,EAAE;QACF,yEAAyE;QACzE,kFAAkF;QAClF,4CAA4C;QAC5C,IACE,AAAC,CAAA,CAACwH,iBAAiBV,KAAI,KACvB,OAAOc,gCAAgC,YACvC;YACAA;QACF;QAEA,OAAO;IACT;IAEA,MAAMC,cAAc,IAAI9J;IAExB,MAAM+J,gBAA+B,CAACC,IAAIC,YAAYC;QACpD,IAAI,CAACA,gBAAgB1C,SAAS5I,GAAG,CAACoL,KAAK;YACrC,OAAO,KAAO;QAChB;QACA,IAAIF,YAAYxB,IAAI,KAAK,GAAG;YAC1B1P,aAAauR,QAAQ,CACnB;gBACEC,SAAS;gBACTC,SAASL;gBACTM,KAAKL;YACP,GACA;QAEJ;QACAH,YAAYS,GAAG,CAACP;QAChB,OAAO,SAASQ;YACd,IAAIV,YAAYxB,IAAI,KAAK,GAAG;gBAC1B;YACF;YACAd,SAAS+C,GAAG,CAACP;YACbF,YAAYnK,MAAM,CAACqK;YACnB,IAAIF,YAAYxB,IAAI,KAAK,GAAG;gBAC1BmC,mBAAmB;gBACnB7R,aAAauR,QAAQ,CACnB;oBACEC,SAAS;gBACX,GACA;YAEJ;QACF;IACF;IAEA,IAAI5L;IAEJ,IAAIiM,mBAAmB;IACvB,IAAIC,UAAU;IAEd,MAAMC,8BAA8B,IAAI3K;IACxC,MAAM4K,yBAAyB,IAAInM;IACnC,MAAMoM,+BAA+B,IAAIpM;IACzC,MAAMqM,eAAe,IAAIC;IAEzB,SAASC,aAAaC,MAAU,EAAEC,OAAgC;QAChE,MAAMpL,OACJ,OAAOoL,QAAQ/L,IAAI,KAAK,WACpBxE,2BAA2BuQ,WAC3BvJ,KAAKwJ,SAAS,CAACD;QAErBD,OAAOG,IAAI,CAACtL;IACd;IAEA,SAASuL;QACP,KAAK,MAAM,GAAGC,SAAS,IAAInE,mBAAoB;YAC7C,IACE;mBAAImE,SAASC,MAAM;aAAG,CAACrL,MAAM,CAAC,CAACc,IAAMA,EAAEwK,QAAQ,KAAK,WAAWtK,MAAM,GACrE,GACA;gBACA,mFAAmF;gBACnF;YACF;QACF;QAEA,KAAK,MAAM+J,UAAU;eAChBN;eACAC,uBAAuBW,MAAM;SACjC,CAAE;YACD,MAAME,QAAQX,aAAatK,GAAG,CAACyK;YAC/B,IAAI,CAACQ,OAAO;gBACV;YACF;YAEA,KAAK,MAAM,GAAGH,SAAS,IAAIG,MAAMC,YAAY,CAAE;gBAC7C,IACE;uBAAIJ,SAASC,MAAM;iBAAG,CAACrL,MAAM,CAAC,CAACc,IAAMA,EAAEwK,QAAQ,KAAK,WACjDtK,MAAM,GAAG,GACZ;oBACA,mFAAmF;oBACnF;gBACF;YACF;YAEA,KAAK,MAAMgK,WAAWO,MAAME,QAAQ,CAACJ,MAAM,GAAI;gBAC7CP,aAAaC,QAAQC;YACvB;YACAO,MAAME,QAAQ,CAACpN,KAAK;YAEpB,IAAIkN,MAAMG,gBAAgB,CAAC1K,MAAM,GAAG,GAAG;gBACrC8J,aAAaC,QAAQ;oBACnB9L,MAAMtG,4BAA4BgT,iBAAiB;oBACnD/L,MAAM2L,MAAMG,gBAAgB;gBAC9B;gBACAH,MAAMG,gBAAgB,CAAC1K,MAAM,GAAG;YAClC;QACF;IACF;IACA,MAAM4K,+BAA+BvS,SAAS8R,sBAAsB;IAEpE,MAAMU,UAAmB,CAAC/B,IAAYkB;QACpC,KAAK,MAAMD,UAAU;eAChBN;eACAC,uBAAuBW,MAAM;SACjC,CAAE;gBACDT;aAAAA,oBAAAA,aAAatK,GAAG,CAACyK,4BAAjBH,kBAA0Ba,QAAQ,CAAC5M,GAAG,CAACiL,IAAIkB;QAC7C;QAEAT,mBAAmB;QACnBqB;IACF;IAEA,SAASE,qBAAqBtK,OAAwB;QACpD,kGAAkG;QAClG,mCAAmC;QACnC,iGAAiG;QACjGA,QAAQuK,WAAW,GAAG,EAAE;QACxBvK,QAAQwK,MAAM,GAAG,EAAE;QAEnB,KAAK,MAAMjB,UAAU;eAChBN;eACAC,uBAAuBW,MAAM;SACjC,CAAE;gBACDT;aAAAA,oBAAAA,aAAatK,GAAG,CAACyK,4BAAjBH,kBAA0Bc,gBAAgB,CAACrL,IAAI,CAACmB;QAClD;QAEA+I,mBAAmB;QACnBqB;IACF;IAEA,eAAeK,yBACbtD,GAAa,EACbuD,aAAsB,EACtBC,QAAkB,EAClBC,aAGsE,EACtEC,OAEsE;QAEtE,IAAIjF,oBAAoB1I,GAAG,CAACiK,MAAM;YAChC;QACF;QAEA,MAAM,EAAE2D,IAAI,EAAE,GAAG9R,cAAcmO;QAE/B,MAAM4D,iBAAiBJ,QAAQ,CAAC,GAAGG,KAAK,OAAO,CAAC,CAAC,CAACJ;QAClD9E,oBAAoBvI,GAAG,CAAC8J,KAAK4D;QAC7B,IAAI;YACF,MAAMC,UAAU,MAAMD;YAEtB,WAAW,MAAME,UAAUD,QAAS;gBAClClR,cAAc2L,oBAAoB0B,KAAK8D,QAAQ,OAAO;gBACtD,mDAAmD;gBACnD,MAAMzB,UAAU,MAAMoB,cAAcK,QAAQC,OAAO,EAAElC;gBACrD,IAAIQ,SAAS;oBACXa,QAAQlD,KAAKqC;gBACf;YACF;QACF,EAAE,OAAO2B,GAAG;YACVvF,oBAAoB3H,MAAM,CAACkJ;YAC3B,MAAMnH,UAAU,OAAM6K,2BAAAA,QAAUM;YAChC,IAAInL,SAAS;gBACXqK,QAAQlD,KAAKnH;YACf;YACA;QACF;QACA4F,oBAAoB3H,MAAM,CAACkJ;IAC7B;IAEA,eAAeiE,6BAA6BjE,GAAa;QACvD,MAAMhK,eAAe,MAAMyI,oBAAoB9G,GAAG,CAACqI;QACnD,IAAIhK,cAAc;YAChB,OAAMA,aAAa4B,MAAM,oBAAnB5B,aAAa4B,MAAM,MAAnB5B;YACNyI,oBAAoB3H,MAAM,CAACkJ;QAC7B;QACA1B,mBAAmBxH,MAAM,CAACkJ;IAC5B;IAEA,eAAekE,2BAA2B9B,MAAU,EAAEjB,EAAU;QAC9D,MAAMnB,MAAMpO,YAAY,UAAU,UAAUuP;QAC5C,IAAI,CAAC/P,oBAAoB0M,oBAAoBkC,KAAKhB,cAAc;YAC9D,qDAAqD;YACrD;QACF;QAEA,MAAM4D,QAAQX,aAAatK,GAAG,CAACyK;QAC/B,IAAI,CAACQ,SAASA,MAAMuB,aAAa,CAACpO,GAAG,CAACoL,KAAK;YACzC;QACF;QAEA,MAAMnL,eAAeP,QAASQ,SAAS,CAACkL,IAAIhR,UAAUiU,MAAM;QAC5DxB,MAAMuB,aAAa,CAACjO,GAAG,CAACiL,IAAInL;QAE5B,+DAA+D;QAC/D,oDAAoD;QACpD,IAAI;YACF,MAAMA,aAAaG,IAAI;YAEvB,WAAW,MAAMc,QAAQjB,aAAc;gBACrCrD,cAAciQ,MAAMC,YAAY,EAAE7C,KAAK/I,MAAM,OAAO;gBACpD,IAAIA,KAAKX,IAAI,KAAK,UAAU;oBAC1B6M,qBAAqBlM;gBACvB;YACF;QACF,EAAE,OAAO+M,GAAG;YACV,6EAA6E;YAC7E,8DAA8D;YAC9D,sEAAsE;YACtE,2CAA2C;YAC3C,MAAMK,gBAAmC;gBACvC/N,MAAMtG,4BAA4BsU,WAAW;gBAC7CrN,MAAM,CAAC,oCAAoC,EAAEkK,GAAG,EAAE,EAAE6C,GAAG;YACzD;YACA7B,aAAaC,QAAQiC;YACrBjC,OAAOmC,KAAK;YACZ;QACF;IACF;IAEA,SAASC,+BAA+BpC,MAAU,EAAEjB,EAAU;QAC5D,MAAMyB,QAAQX,aAAatK,GAAG,CAACyK;QAC/B,IAAI,CAACQ,OAAO;YACV;QACF;QAEA,MAAM5M,eAAe4M,MAAMuB,aAAa,CAACxM,GAAG,CAACwJ;QAC7CnL,gCAAAA,aAAc4B,MAAM;QAEpB,MAAMoI,MAAMpO,YAAY,UAAU,UAAUuP;QAC5CyB,MAAMC,YAAY,CAAC/L,MAAM,CAACkJ;IAC5B;IAEA,eAAeyE;QACb,WAAW,MAAMC,eAAe/G,wBAAyB;YACvD,IAAI,CAACiB,+BAA+B;gBAClCC,yBAAyB,IAAIC,QAC3B,wCAAwC;gBACxC,CAACC,UAAaH,gCAAgCG;YAElD;YAEA,0EAA0E;YAC1EzN,sBAAsB+M,uBAAuBqG;YAE7C,wFAAwF;YACxF,IAAI,CAAE,CAAA,YAAYA,WAAU,GAAI;gBAC9BvR,iBAAiBuR,aAAa;gBAE9B9F;gBACAA,gCAAgChG;gBAChC;YACF;YAEA,MAAM+L,SAASD,YAAYC,MAAM;YACjC,MAAMC,iBAAiB;mBAClB9G,mBAAmBE,GAAG,CAACvG,IAAI;mBAC3BqG,mBAAmBM,IAAI,CAAC3G,IAAI;aAChC;YACD,MAAMoN,YAAY;mBAAIF,OAAOlN,IAAI;aAAG;YAEpC,MAAMqN,cAAcD,UAAUxN,MAAM,CAClC,CAAC0N,QACC,CAACjH,mBAAmBE,GAAG,CAACjI,GAAG,CAACgP,UAC5B,CAACjH,mBAAmBM,IAAI,CAACrI,GAAG,CAACgP;YAEjC,MAAMC,gBAAgBJ,eAAevN,MAAM,CAAC,CAAC0N,QAAU,CAACJ,OAAO5O,GAAG,CAACgP;YAEnE,MAAM9T,kBAAkB;gBACtByT,aAAaA;gBAEb5G;gBAEAQ;gBACAC;gBACA0G,aAAahM,KAAKoB,SAAS,CAACC,QAAQ;gBACpC4K,oBAAoBtM;gBACpBuM,WAAW;gBAEX3L,KAAK;oBACHwF;oBACAP;oBACA2G,SAAS;2BACJtD;2BACAC,uBAAuBW,MAAM;qBACjC;oBACDT;oBACA/I;oBAEAmM,OAAO;wBACLC,uBAAuB,CAACnE,IAAI/K,QAAQmP;4BAClC1H,0BAA0B3H,GAAG,CAACiL,IAAI/K;4BAClC,OAAO2J,kBAAkBoB,IAAI/K,QAAQ;gCAAE8J,OAAOqF;4BAAiB;wBACjE;wBACA9T,sBAAsBA,qBAAqB6L,IAAI,CAAC,MAAMrE;wBACtDiK;wBACAhC;wBACAsE,oBAAoBlC;wBACpBmC,wBAAwBxB;wBACxByB,0BAA0BlB;oBAC5B;gBACF;YACF;YAEA,oDAAoD;YACpD,MAAM/S,qBAAqBwH,MAAM,kBAAkBL;YAEnD,IAAIkM,YAAYzM,MAAM,GAAG,KAAK2M,cAAc3M,MAAM,GAAG,GAAG;gBACtD,qFAAqF;gBACrFsN,YAAYpD,IAAI,CAAC;oBACfjM,MAAMtG,4BAA4B4V,yBAAyB;oBAC3D3O,MAAM;wBACJ;4BACE4O,kBAAkB;wBACpB;qBACD;gBACH;YACF;YAEA,KAAK,MAAMd,SAASD,YAAa;gBAC/Ba,YAAYpD,IAAI,CAAC;oBACfjM,MAAMtG,4BAA4B8V,UAAU;oBAC5C7O,MAAM;wBAAC8N;qBAAM;gBACf;YACF;YAEA,KAAK,MAAMA,SAASC,cAAe;gBACjCW,YAAYpD,IAAI,CAAC;oBACfjM,MAAMtG,4BAA4B+V,YAAY;oBAC9C9O,MAAM;wBAAC8N;qBAAM;gBACf;YACF;YAEAnG;YACAA,gCAAgChG;QAClC;IACF;IAEA,MAAMtJ,MAAMG,KAAK0J,SAAS,WAAW;QAAE6M,WAAW;IAAK;IACvD,MAAM1W,MAAMG,KAAK0J,SAAS,UAAUM,UAAU;QAAEuM,WAAW;IAAK;IAChE,MAAMzW,UACJE,KAAK0J,SAAS,iBACdL,KAAKwJ,SAAS,CACZ;QACEhM,MAAM;IACR,GACA,MACA;IAIJ,MAAM2P,cAAc;QAClB3V,qBAAqB;YACnBmF;YACAkE;YACAuM,UAAUjN,KAAKiN,QAAQ;QACzB;QACA3V,uBAAuBkF;QACvBlD,+BAA+B0G,KAAKkN,SAAS;QAC7CtT;QACAE;QACAC,8BAA8B;YAC5BmT,WAAWlN,KAAKkN,SAAS;YACzBC,kBAAkB3Q;QACpB;QACAlC,yBAAyB;YACvB4F;YACAkN,kBAAkB,CAACpP;gBACjB0O,YAAYpD,IAAI,CAAC;oBACfjM,MAAMtG,4BAA4BsW,eAAe;oBACjDrP;gBACF;YACF;QACF;QACAxD;WACI8F,WAAWwB,YAAY,CAACC,SAAS,GACjC;YACEhH,iBAAiB;gBACf2F;gBACAR;gBACAI;gBACAgN,UAAUtN,KAAKsN,QAAQ;gBACvBC,QAAQvN,KAAKuN,MAAM;gBACnBC,gBAAgB,CAACpE,UAAYsD,YAAYpD,IAAI,CAACF;gBAC9CqE,0BAA0B,IACxB5E,4BAA4BrC,IAAI,GAAGsC,uBAAuBtC,IAAI;gBAChEkH,iBAAiB,IAAM9R,QAAQC,GAAG,CAAC8R,qBAAqB;YAC1D;SACD,GACD,EAAE;KACP;IAEDzS,sBAAsB,OAAO0S;QAC3B,OAAOrW,uBAAuB;YAC5BiF;YACAkE;YACAmN,UAAUD,QAAQC,QAAQ;YAC1BC,cAAcF,QAAQE,YAAY;YAClCC,gBAAgBH,QAAQG,cAAc;YACtCC,QAAQJ,QAAQI,MAAM;QACxB;IACF;IAEA,IAAIC;IACJ,gGAAgG;IAChG,mFAAmF;IACnF,qFAAqF;IACrF,6FAA6F;IAC7F,MAAMC,uBAAuB;QAC3B,IAAI,CAACD,mBAAmB;YACtBA,oBAAoBpT;QACtB;QACA,OAAOoT;IACT;IAEA,IAAIE;IACJ,MAAMC,kBAAkB7X,UAAUiS,GAAG;IACrC,IAAI4F,oBAAoBzO,WAAW;QACjC,MAAM0O,eAAe,IAAIC,IAAIF;QAE7B,IAAIG;QACJ,IAAI;YACF,MAAMC,gBAAgB,MAAMC,MAC1B,CAAC,OAAO,EAAEJ,aAAaK,IAAI,CAAC,UAAU,CAAC,EACvCC,IAAI,CAAC,CAACC,MAAQA,IAAIC,IAAI;YACxBN,YAAYC,aAAa,CAAC,EAAE;QAC9B,EAAE,OAAM,CAAC;QACT,IAAID,WAAW;YACbJ,sBAAsBI,UAAUJ,mBAAmB;QACrD;IACF;IAEA,MAAMzB,cAA0C;QAC9CS,kBAAkB3Q;QAClBsS,sBAAsBnP;QACtBoP,aAAa;QACbC,iBAAiB;QACjB,MAAMC,KAAIC,GAAG,EAAEN,GAAG,EAAEO,UAAU;gBAExBD;YADJ,+DAA+D;YAC/D,KAAIA,WAAAA,IAAI1G,GAAG,qBAAP0G,SAASE,UAAU,CAAC,gCAAgC;gBACtD,MAAMC,SAASvU,2BAA2BoU,IAAI1G,GAAG;gBAEjD,IAAI6G,QAAQ;oBACV,MAAMC,kBAAkB,CAAC,CAAC,EAAED,OAAOhR,IAAI,CACpCY,GAAG,CAAC,CAACsQ,QAAkBC,mBAAmBD,QAC1C/Y,IAAI,CAAC,MAAM;oBAEd,MAAMiZ,uBAAuB5X,oBAAoByX;oBAEjD,MAAM5C,YACHgD,UAAU,CAAC;wBACVvK,MAAMsK;wBACNE,YAAY;wBACZC,YAAYjQ;wBACZ6I,KAAK0G,IAAI1G,GAAG;oBACd,GACC/K,KAAK,CAACE,QAAQC,KAAK;gBACxB;YACF;YAEA,KAAK,MAAMqH,cAAc+H,YAAa;gBACpC,IAAI6C,aAAa;gBAEjB,MAAM5K,WAAWiK,KAAKN,KAAK;oBACzBiB,aAAa;gBACf;gBAEA,IAAI,CAACA,YAAY;oBACf,OAAO;wBAAEC,UAAU;oBAAK;gBAC1B;YACF;YAEA,4BAA4B;YAC5B,OAAO;gBAAEA,UAAUnQ;YAAU;QAC/B;QAEA,2EAA2E;QAC3EoQ,OAAMb,GAAG,EAAEc,MAAc,EAAEC,IAAI,EAAEC,SAAS;YACxC1U,SAAS2U,aAAa,CAACjB,KAAKc,QAAQC,MAAM,CAAC9G;gBACzC,MAAMS,eAA+B,IAAIjN;gBACzC,MAAMuO,gBAAiD,IAAIvO;gBAE3D,MAAMyT,gBAAgBlB,IAAI1G,GAAG,GACzB,IAAI8F,IAAIY,IAAI1G,GAAG,EAAE,YAAY6H,YAAY,CAAC3R,GAAG,CAAC,QAC9C;gBAEJ,sEAAsE;gBACtE,qEAAqE;gBACrE,sEAAsE;gBACtE,sEAAsE;gBACtE,kDAAkD;gBAClD,IAAI0R,eAAe;oBACjBtH,uBAAuB7L,GAAG,CAACmT,eAAejH;oBAC1C,MAAMmH,wBAAwBhQ,WAAWiQ,eAAe;oBACxD,IAAID,uBAAuB;wBACzBJ,UAAU/G,QAAQ;4BAAEqH,gBAAgB;wBAAM;wBAC1C,MAAMC,cAAc1H,6BAA6BrK,GAAG,CAAC0R;wBACrD,IAAIK,gBAAgB9Q,WAAW;4BAC7BuJ,aAAaC,QAAQ;gCACnB9L,MAAMtG,4BAA4B2Z,eAAe;gCACjD/G,OAAO8G;4BACT;4BACA1H,6BAA6BlL,MAAM,CAACuS;wBACtC;oBACF,OAAO;wBACLF,UAAU/G,QAAQ;4BAAEqH,gBAAgB;wBAAK;oBAC3C;oBAEA9V,uCACE0V,eACAlH,aAAa7E,IAAI,CAAC,MAAM8E;oBAG1B7N,2CACE8U,eACAlH,aAAa7E,IAAI,CAAC,MAAM8E;gBAE5B,OAAO;oBACLN,4BAA4BJ,GAAG,CAACU;oBAChC+G,UAAU/G,QAAQ;wBAAEqH,gBAAgB;oBAAK;gBAC3C;gBAEAxH,aAAa/L,GAAG,CAACkM,QAAQ;oBACvBS;oBACAC,UAAU,IAAIlN;oBACdmN,kBAAkB,EAAE;oBACpBoB;gBACF;gBAEA/B,OAAOwH,EAAE,CAAC,SAAS;oBACjB,8BAA8B;oBAC9B,KAAK,MAAM5T,gBAAgBmO,cAAczB,MAAM,GAAI;wBACjD1M,aAAa4B,MAAM,oBAAnB5B,aAAa4B,MAAM,MAAnB5B;oBACF;oBACAiM,aAAanL,MAAM,CAACsL;oBAEpB,IAAIiH,eAAe;wBACjBtH,uBAAuBjL,MAAM,CAACuS;wBAC9BzV,sCAAsCyV;oBACxC,OAAO;wBACLvH,4BAA4BhL,MAAM,CAACsL;oBACrC;gBACF;gBAEAA,OAAOyH,gBAAgB,CAAC,WAAW,OAAO,EAAE5S,IAAI,EAAE;oBAChD,MAAM6S,aAAahR,KAAKC,KAAK,CAC3B,OAAO9B,SAAS,WAAWA,KAAKsB,QAAQ,KAAKtB;oBAG/C,mBAAmB;oBACnB,OAAQ6S,WAAWC,KAAK;wBACtB,KAAK;4BAAY;gCACfrP,gBAAgBsP,gBAAgB,CAC9BF,WAAWG,QAAQ,EACnB5Y,OAAOyY,WAAWI,SAAS,GAC3B7Y,OAAOyY,WAAWK,OAAO,GACzBL,WAAWM,UAAU;gCAEvB;4BACF;wBACA,KAAK;4BACH1P,gBAAgBsP,gBAAgB,CAC9BF,WAAWC,KAAK,EAChB1Y,OAAOyY,WAAWI,SAAS,GAC3B7Y,OAAOyY,WAAWK,OAAO,GACzB;gCACEE,gBAAgBP,WAAWO,cAAc;gCACzCjM,MAAM0L,WAAW1L,IAAI;gCACrBkM,cAAcR,WAAWQ,YAAY;4BACvC;4BAEF;wBAEF,KAAK;wBACL,KAAK;wBACL,KAAK;wBACL,KAAK;wBACL,KAAK;wBACL,KAAK;wBACL,KAAK;4BACH,MAAM,EAAEC,eAAe,EAAEC,eAAe,EAAE,GAAGV;4BAC7C,IAAIS,iBAAiB;gCACnBna,IAAIqa,IAAI,CAAC1Y;4BACX;4BACA,IACE2Y,MAAMC,OAAO,CAACH,oBACd,OAAOA,eAAe,CAAC,EAAE,KAAK,UAC9B;gCACA,MAAMI,oBAAoBJ,eAAe,CAAC,EAAE,CACzClS,OAAO,CAAC,gBAAgB,KACxBA,OAAO,CAAC,mBAAmB;gCAC9BlI,IAAIqa,IAAI,CACN,CAAC,+CAA+C,EAAEG,kBAAkB,yEAAyE,CAAC;4BAElJ;4BACA;wBACF,KAAK;4BAEH;wBACF,KAAK;4BAAgB;gCACnB,MAAMC,0BACJtR,WAAWuR,OAAO,IAAIvR,WAAWuR,OAAO,CAACC,iBAAiB;gCAC5D,IAAIF,yBAAyB;oCAC3B,MAAMzX,4BAA4B;wCAChC4X,SAASlB,WAAWkB,OAAO;wCAC3BC,QAAQnB,WAAWmB,MAAM;wCACzBC,YAAYpB,WAAWoB,UAAU;wCACjCzV;wCACAkE;wCACAR;wCACAoD,QAAQsO;oCACV;gCACF;gCACA;4BACF;wBACA,KAAK;4BAAoB;gCACvB,iDAAiD;gCACjD,MAAMxX,qBAAqByW,WAAWqB,IAAI;gCAC1C;4BACF;wBACA,KAAK;4BAAQ;gCAGX;4BACF;wBAEA,KAAK;4BAA4B;gCAC/BlX,yBACE6V,WAAWsB,SAAS,EACpBtB,WAAWuB,UAAU,EACrBvB,WAAWrI,GAAG;gCAEhB;4BACF;wBAEA,KAAK;4BAA8B;gCACjCvN,2BACE4V,WAAWsB,SAAS,EACpBtB,WAAWwB,eAAe,EAC1BxB,WAAWrI,GAAG;gCAEhB;4BACF;wBAEA;4BACE,kCAAkC;4BAClC,IAAI,CAACqI,WAAWxT,IAAI,EAAE;gCACpB,MAAM,qBAA+C,CAA/C,IAAIwD,MAAM,CAAC,0BAA0B,EAAE7C,KAAK,CAAC,CAAC,GAA9C,qBAAA;2CAAA;gDAAA;kDAAA;gCAA8C;4BACtD;oBACJ;oBAEA,qBAAqB;oBACrB,OAAQ6S,WAAWxT,IAAI;wBACrB,KAAK;4BACH4N,2BAA2B9B,QAAQ0H,WAAWxS,IAAI;4BAClD;wBAEF,KAAK;4BACHkN,+BAA+BpC,QAAQ0H,WAAWxS,IAAI;4BACtD;wBAEF;4BACE,IAAI,CAACwS,WAAWC,KAAK,EAAE;gCACrB,MAAM,qBAAyD,CAAzD,IAAIjQ,MAAM,CAAC,oCAAoC,EAAE7C,KAAK,CAAC,CAAC,GAAxD,qBAAA;2CAAA;gDAAA;kDAAA;gCAAwD;4BAChE;oBACJ;gBACF;gBAEA,MAAMsU,4BAAuD;oBAC3DjV,MAAMtG,4BAA4Bwb,mBAAmB;oBACrDvU,MAAM;wBAAE/B;oBAAU;gBACpB;gBACAiN,aAAaC,QAAQmJ;gBAErB,MAAME,SAA6B,EAAE;gBAErC,KAAK,MAAMC,eAAepN,mBAAmBoE,MAAM,GAAI;oBACrD,KAAK,MAAMiJ,SAASD,YAAYhJ,MAAM,GAAI;wBACxC,IAAIiJ,MAAMhJ,QAAQ,KAAK,WAAW;4BAChC8I,OAAO/T,IAAI,CAAC;gCACV2K,SAAS7P,YAAYmZ;4BACvB;wBACF,OAAO;4BACLpa,mBAAmBoa;wBACrB;oBACF;gBACF;gBAEA,IAAI7Y,wBAAwB8Y,aAAa,GAAGC,KAAKC,GAAG,IAAI;oBACtDhZ,wBAAwB8Y,aAAa,GAAG;gBAC1C;;gBAEE,CAAA;oBACA,MAAMG,cAAc,MAAM5E;oBAC1B,MAAM6E,iBAAiB,MAAMxY,kBAAkB2F;oBAE/C,MAAM8S,cAA2B;wBAC/B3V,MAAMtG,4BAA4Bkc,IAAI;wBACtCT;wBACAU,UAAU,EAAE;wBACZC,MAAM;wBACNL;wBACAM,OAAO;4BACLjF;wBACF;wBACAkF,cAAcxZ;wBACdkZ;oBACF;oBAEA7J,aAAaC,QAAQ6J;gBACvB,CAAA;YACF;QACF;QAEA1J,MAAKgK,MAAM;YACT,MAAM1T,UAAUC,KAAKwJ,SAAS,CAACiK;YAE/B,KAAK,MAAMnK,UAAU;mBAChBN;mBACAC,uBAAuBW,MAAM;aACjC,CAAE;gBACDN,OAAOG,IAAI,CAAC1J;YACd;QACF;QAEA2T,qBAAoBD,MAAM;YACxB,MAAM1T,UAAUC,KAAKwJ,SAAS,CAACiK;YAE/B,sEAAsE;YACtE,qEAAqE;YACrE,sEAAsE;YACtE,sEAAsE;YACtE,kDAAkD;YAElD,IAAI,CAAChT,WAAWiQ,eAAe,EAAE;gBAC/B,KAAK,MAAMpH,UAAUL,uBAAuBW,MAAM,GAAI;oBACpDN,OAAOG,IAAI,CAAC1J;gBACd;YACF;YAEA,KAAK,MAAMuJ,UAAUN,4BAA6B;gBAChDM,OAAOG,IAAI,CAAC1J;YACd;QACF;QAEA4T,gBAAeC,MAAyB,EAAErD,aAAqB;YAC7D,8CAA8C;YAC9C,MAAMjH,SAASL,uBAAuBpK,GAAG,CAAC0R;YAC1C,IAAIjH,WAAWxJ,WAAW;gBACxBuJ,aAAaC,QAAQ;oBACnB9L,MAAMtG,4BAA4B2Z,eAAe;oBACjD/G,OAAO8J;gBACT;YACF,OAAO;gBACL,0EAA0E;gBAC1E,4BAA4B;gBAC5B1K,6BAA6B9L,GAAG,CAACmT,eAAeqD;YAClD;QACF;QAEAC,sBAAqBC,YAAY,EAAEvD,aAAa,EAAE+B,SAAS;YACzD,MAAMhJ,SAASL,uBAAuBpK,GAAG,CAAC0R;YAE1C,IAAIA,kBAAkB+B,WAAW;gBAC/B,6CAA6C;gBAC7C,IAAIhJ,QAAQ;oBACV,mEAAmE;oBACnE,gCAAgC;oBAChC1O,yBACE2V,eACAuD,cACAzK,aAAa7E,IAAI,CAAC,MAAM8E;gBAE5B,OAAO;oBACL,mEAAmE;oBACnE,qBAAqB;oBACrBvO,mCAAmCwV,eAAeuD;gBACpD;YACF,OAAO,IAAIxK,QAAQ;gBACjB,kEAAkE;gBAClE,uEAAuE;gBACvE,uDAAuD;gBACvD1O,yBACE0X,WACAwB,cACAzK,aAAa7E,IAAI,CAAC,MAAM8E;YAE5B;QACF;QAEAyK,qBAAoBC,eAAe,EAAEzD,aAAa;YAChD,MAAMjH,SAASL,uBAAuBpK,GAAG,CAAC0R;YAE1C,IAAIjH,QAAQ;gBACV,kEAAkE;gBAClE9N,6BACEwY,iBACA3K,aAAa7E,IAAI,CAAC,MAAM8E;YAE5B,OAAO;gBACL,qEAAqE;gBACrE,mBAAmB;gBACnB5N,iCAAiC6U,eAAeyD;YAClD;QACF;QAEAC,mBAAkBC,MAAM;QACtB,uBAAuB;QACzB;QACAC;QACE,uBAAuB;QACzB;QACA,MAAMC,UAAS;QACf,MAAMC,sBAAqB/O,IAAI;YAC7B,MAAMgP,cAAcxb,YAAY,OAAO,UAAUwM;YACjD,MAAMiP,gBAAgBzb,YAAY,SAAS,UAAUwM;YAErD,MAAMkP,iBAAiBjP,sBAAsBqE,MAAM;YAEnD,MAAM6K,kBACJjP,mBAAmB3G,GAAG,CAACyV,gBACvB9O,mBAAmB3G,GAAG,CAAC0V;YAEzB,IAAIE,oBAAoB3U,aAAa2U,gBAAgB9N,IAAI,GAAG,GAAG;gBAC7D,+FAA+F;gBAC/F,OAAO;uBAAI6N;uBAAmBC,gBAAgB7K,MAAM;iBAAG,CACpDxK,GAAG,CAAC,CAACyT;oBACJ,MAAM6B,iBAAiBhb,YAAYmZ;oBACnC,IAAIA,MAAMhJ,QAAQ,KAAK,WAAW;wBAChCpR,mBAAmBoa;wBACnB,OAAO;oBACT,OAAO,IAAIjZ,iBAAiBiZ,QAAQ;wBAClCvb,IAAIyG,KAAK,CAAC2W;oBACZ;oBAEA,OAAO,qBAAyB,CAAzB,IAAI1T,MAAM0T,iBAAV,qBAAA;+BAAA;oCAAA;sCAAA;oBAAwB;gBACjC,GACCnW,MAAM,CAAC,CAACR,QAAUA,UAAU;YACjC;YAEA,4CAA4C;YAC5C,MAAM4U,SAAS,EAAE;YACjB,KAAK,MAAME,SAAS2B,eAAgB;gBAClC,IAAI3B,MAAMhJ,QAAQ,KAAK,WAAW;oBAChC8I,OAAO/T,IAAI,CAAC,qBAA6B,CAA7B,IAAIoC,MAAMtH,YAAYmZ,SAAtB,qBAAA;+BAAA;oCAAA;sCAAA;oBAA4B;gBAC1C;YACF;YACA,KAAK,MAAMD,eAAepN,mBAAmBoE,MAAM,GAAI;gBACrD,KAAK,MAAMiJ,SAASD,YAAYhJ,MAAM,GAAI;oBACxC,IAAIiJ,MAAMhJ,QAAQ,KAAK,WAAW;wBAChC,MAAMN,UAAU7P,YAAYmZ;wBAC5BF,OAAO/T,IAAI,CAAC,qBAAkB,CAAlB,IAAIoC,MAAMuI,UAAV,qBAAA;mCAAA;wCAAA;0CAAA;wBAAiB;oBAC/B,OAAO;wBACL9Q,mBAAmBoa;oBACrB;gBACF;YACF;YACA,OAAOF;QACT;QACA,MAAMgC,YAAW,EACf,yCAAyC;QACzCC,uBAAuB,EACxB;YACC,IAAIA,yBAAyB;gBAC3B,KAAK,MAAM,CAAC1N,KAAK2N,WAAW,IAAI9P,0BAA2B;oBACzDkC,kBAAkBC,KAAK2N,YAAY;wBAAEzN,OAAO;oBAAK;gBACnD;gBAEA,MAAMtP;gBACN,IAAI,CAAC2R,IAAI,CAAC;oBACRjM,MAAMtG,4BAA4B4d,wBAAwB;oBAC1DxB,MAAMrI,OAAO,EAAElC;gBACjB;YACF;QACF;QACA,MAAMgM;QACJ,uBAAuB;QACzB;QACA,MAAMlF,YAAW,EACfvK,MAAM0P,SAAS,EACf,oBAAoB;QACpB,cAAc;QACdC,QAAQ,EACRlF,UAAU,EACVmF,KAAK,EACLvM,KAAKL,UAAU,EAChB;YACC,yFAAyF;YACzF,6FAA6F;YAC7F,IAAI,CAACyH,YAAY;gBACf,IAAIiF,cAAc,eAAe;gBACjC,IAAIA,cAAc,mBAAmB;gBACrC,IAAIA,cAAc,oBAAoB;gBACtC,IAAIA,cAAc,wBAAwB;YAC5C;YAEA,OAAOpT,gBACJuT,UAAU,CAAC,eAAe;gBACzBH;YACF,GACCI,YAAY,CAAC;gBACZ,IAAI7d,cAAc8d,QAAQ,CAACL,cAAcA,cAAc,WAAW;oBAChE;gBACF;gBAEA,MAAMjP;gBAEN,qGAAqG;gBACrG,IAAIuP,WAIFvF,cACC,MAAMlX,iBACLgI,aACAmU,WACAvU,WAAW8U,cAAc,EACzBpV,KAAKsN,QAAQ,EACbtN,KAAKuN,MAAM,EACX,CAAC,CAACjN,WAAWwB,YAAY,CAACuT,cAAc;gBAG5C,yEAAyE;gBACzE,oEAAoE;gBACpE,IAAI,CAACP,YAAYlF,cAAc5W,yBAAyB4W,aAAa;oBACnEkF,WAAWlF,WAAWkF,QAAQ;gBAChC;gBAEA,4EAA4E;gBAC5E,IAAI5O,0BAA0B;oBAC5B,MAAMoP,aAAapc,gBACjBic,SAAShQ,IAAI,EACba;oBAEF,IAAIsP,YAAY;wBACd,MAAM5O;oBACR,OAAO;wBACL,uCAAuC;wBACvCL,2BAA2BoC,GAAG,CAAC0M,SAAShQ,IAAI;oBAC9C;gBACF;gBAEA,IAAIA,OAAOgQ,SAAShQ,IAAI;gBACxB,IAAI2P,UAAU;oBACZ,MAAMS,iBAAiBtc,iBAAiBkM;oBAExC,8DAA8D;oBAC9D,MAAMqQ,mBAAmBV,SAAS1W,MAAM,CACtC,CAACC,OAASpF,iBAAiBoF,UAAUkX;oBAGvC,4EAA4E;oBAC5EpQ,OAAOqQ,gBAAgB,CAACA,iBAAiBpW,MAAM,GAAG,EAAE;gBACtD;gBAEA,MAAMqW,WAAW7F,CAAAA,8BAAAA,WAAY6F,QAAQ,KAAIZ;gBAEzC,IAAI1P,SAAS,WAAW;oBACtB,IAAIuD,iBAAiBT,cAAcwN,UAAUtN,YAAY;oBACzD,IAAI;wBACF,MAAMlQ,sBAAsB;4BAC1BoN;4BACAoG,aAAa5G;4BACbS;4BACA0G,aAAahM,KAAKoB,SAAS,CAACC,QAAQ;4BACpC4K,oBAAoBtM;4BACpBuM,WAAW;4BACXE,OAAO;gCACLG,oBAAoBlC;gCACpBgC,uBAAuB,CAACnE,IAAI/K,QAAQmP;oCAClC1H,0BAA0B3H,GAAG,CAACiL,IAAI/K;oCAClC4I,YAAY2P,cAAc,CAACxN,IAAI/K,OAAOwY,WAAW;oCACjD,OAAO7O,kBAAkBoB,IAAI/K,QAAQ;wCACnC8J,OAAOqF;oCACT;gCACF;4BACF;wBACF;oBACF,SAAU;wBACR5D;oBACF;oBACA;gBACF;gBAEA,MAAMkN,iBAAiBT,SAASU,UAAU,CAACzG,UAAU,CAAC;gBACtD,MAAM0G,2BAA2B1c,oBAC/B+b,SAASY,QAAQ,CAAC1W,OAAO,CAACW,KAAKuN,MAAM,IAAI,IAAI,KAC7CjN,WAAW8U,cAAc,EACzB;gBAEF,MAAMY,oBAAoBF,2BACtBvd,wCACE4M,MACA1O,QAAQ0e,SAASY,QAAQ,KAE3B5Q;gBAEJ,MAAM2G,QAAQ8J,iBACV/Q,mBAAmBE,GAAG,CAACrG,GAAG,CAACsX,qBAC3BnR,mBAAmBM,IAAI,CAACzG,GAAG,CAACyG;gBAEhC,IAAI,CAAC2G,OAAO;oBACV,gDAAgD;oBAChD,IAAI3G,SAAS,eAAe;oBAC5B,IAAIA,SAAS,mBAAmB;oBAChC,IAAIA,SAAS,UAAU;oBACvB,IAAIA,SAAS,cAAc;oBAC3B,IAAIA,SAAS,oBAAoB;oBACjC,IAAIA,SAAS,wBAAwB;oBAErC,MAAM,IAAI3N,kBAAkB,CAAC,gBAAgB,EAAE2N,MAAM;gBACvD;gBAEA,2DAA2D;gBAC3D,4CAA4C;gBAC5C,mCAAmC;gBACnC,IAAI4P,SAASjJ,MAAMzO,IAAI,KAAK,QAAQ;oBAClC,MAAM,qBAA8D,CAA9D,IAAIwD,MAAM,CAAC,0CAA0C,EAAEsE,MAAM,GAA7D,qBAAA;+BAAA;oCAAA;sCAAA;oBAA6D;gBACrE;gBAEA,MAAMuD,iBAAiBT,cAAcwN,UAAUtN,YAAY;gBAC3D,IAAI;oBACF,MAAMjQ,gBAAgB;wBACpBqI;wBACA4E;wBACAsQ;wBACA3J;wBACAzG;wBACAoG,aAAa5G;wBACbS;wBACAI;wBACAsG,aAAahM,KAAKoB,SAAS,CAACC,QAAQ;wBACpC4K,oBAAoBtM;wBACpBuM,WAAW;wBAEXE,OAAO;4BACLG,oBAAoBlC;4BACpBgC,uBAAuB,CAACnE,IAAI/K,QAAQmP;gCAClC1H,0BAA0B3H,GAAG,CAACiL,IAAI/K;gCAClC4I,YAAY2P,cAAc,CAACxN,IAAI/K,OAAOwY,WAAW;gCACjD,OAAO7O,kBAAkBoB,IAAI/K,QAAQ;oCACnC8J,OAAOqF;gCACT;4BACF;wBACF;oBACF;gBACF,SAAU;oBACR5D;oBACA,8CAA8C;oBAC9C,IAAIxC,0BAA0B;wBAC5BG,2BAA2BxI,MAAM,CAACsX,SAAShQ,IAAI;oBACjD;gBACF;YACF;QACJ;QACAmG;YACE,gDAAgD;YAChDnQ,mBAAmB6E,KAAKkN,SAAS;YAEjC,KAAK,MAAM+I,YAAY;mBAClBpN;mBACAC,uBAAuBW,MAAM;aACjC,CAAE;gBACD,0EAA0E;gBAC1EwM,SAASC,SAAS;YACpB;YACArN,4BAA4BpM,KAAK;YACjCqM,uBAAuBrM,KAAK;QAC9B;IACF;IAEA+O,gCAAgC/N,KAAK,CAAC,CAACC;QACrCC,QAAQC,KAAK,CAACF;QACd9B,QAAQua,IAAI,CAAC;IACf;IAEA,wBAAwB;IACxB,MAAMvQ;IACN,MAAMN,eAAe8Q,cAAc,CAAC;QAClCpK,aAAahM,KAAKoB,SAAS,CAACC,QAAQ;QACpC4K,oBAAoBtM;QACpB8L,aAAa5G;IACf;IAEA,eAAewR;QACb,WAAW,MAAMC,iBAAiB9Z,QAAQ+Z,mBAAmB,CAAC,IAAK;YACjE,OAAQD,cAAcE,UAAU;gBAC9B,KAAK;oBAAS;wBACZ9J,YAAYpD,IAAI,CAAC;4BAAEjM,MAAMtG,4BAA4B0f,QAAQ;wBAAC;wBAC9D,8EAA8E;wBAC9E,uEAAuE;wBACvE,IAAIvQ,0BAA0B;4BAC5BU,6BAA6B;4BAC7BT,gCAAgC;4BAChCC,iCAAiC;wBACnC;wBACA;oBACF;gBACA,KAAK;oBAAO;wBACVmD;wBAEA,SAASmN,eACPC,SAAwC,EACxCnN,QAAmB;4BAEnB,KAAK,MAAM,CAACzC,KAAK2L,MAAM,IAAIlJ,SAAU;gCACnC,IAAIkJ,MAAMhJ,QAAQ,KAAK,WAAW;gCAClC,IAAIiN,UAAU7Z,GAAG,CAACiK,MAAM;gCAExB,MAAMqC,UAAU7P,YAAYmZ;gCAE5BiE,UAAU1Z,GAAG,CAAC8J,KAAK;oCACjBqC;oCACAwN,SAASlE,MAAMmE,MAAM,GACjBld,8BAA8B+Y,MAAMmE,MAAM,IAC1ClX;gCACN;4BACF;wBACF;wBAEA,SAASmX,UACPH,SAAwC,EACxCvM,MAAsB;4BAEtB,KAAK,MAAMZ,YAAYY,OAAOX,MAAM,GAAI;gCACtCiN,eAAeC,WAAWnN;4BAC5B;wBACF;wBAEA,MAAMgJ,SAAS,IAAI7V;wBACnB+Z,eAAelE,QAAQpN;wBACvB0R,UAAUtE,QAAQnN;wBAElB,KAAK,MAAM8D,UAAU;+BAChBN;+BACAC,uBAAuBW,MAAM;yBACjC,CAAE;4BACD,MAAME,QAAQX,aAAatK,GAAG,CAACyK;4BAC/B,IAAI,CAACQ,OAAO;gCACV;4BACF;4BAEA,MAAMoN,eAAe,IAAIpa,IAAI6V;4BAC7BsE,UAAUC,cAAcpN,MAAMC,YAAY;4BAE1CV,aAAaC,QAAQ;gCACnB9L,MAAMtG,4BAA4BigB,KAAK;gCACvC7D,MAAMrI,OAAO,EAAElC;gCACf4J,QAAQ;uCAAIuE,aAAatN,MAAM;iCAAG;gCAClCyJ,UAAU,EAAE;4BACd;wBACF;wBAEA,IAAIvK,kBAAkB;4BACpB,MAAMsO,OAAOX,cAAcY,KAAK,CAACC,QAAQ;4BACzC,MAAMC,cACJH,OAAO,OAAO,GAAG/a,KAAKmb,KAAK,CAACJ,OAAO,OAAO,GAAG,CAAC,CAAC,GAAG,GAAGA,KAAK,EAAE,CAAC;4BAC/D9f,IAAI2Z,KAAK,CAAC,CAAC,YAAY,EAAEsG,aAAa;4BACtCzO,mBAAmB;wBACrB;wBAEA,sEAAsE;wBACtE,6EAA6E;wBAC7E,4EAA4E;wBAC5E,IAAIzC,0BAA0B;4BAC5BW;wBACF;wBACA;oBACF;gBACA;YACF;QACF;IACF;IAEAwP,uBAAuB5Y,KAAK,CAAC,CAACC;QAC5BC,QAAQC,KAAK,CAACF;QACd9B,QAAQua,IAAI,CAAC;IACf;IAEA,IAAI9V,mBAAmB;QACrB3D,yBAAyBH,eAAeC,SAAS;YAC/CC,OAAO;gBACL,4DAA4D;gBAC5D,MAAM6a,aAAa;uBAAK5a,CAAAA,0CAAAA,uBAAwB8B,IAAI,OAAM,EAAE;iBAAE,CAACS,GAAG,CAChE,CAACpC,YAAcrG,KAAK0J,SAASrD;gBAE/BnF,YAAY4f;gBAEZ,mCAAmC;gBACnC,IAAI,OAAOvP,gCAAgC,YAAY;oBACrDA;gBACF;gBAEA,uEAAuE;gBACvE,uEAAuE;gBACvE,kEAAkE;;gBAChEwP,WAAmBC,iCAAiC,GAAG,IAAI7a;gBAE7D,0BAA0B;gBAC1B,MAAMhF;gBAENwI;gBAEA,oEAAoE;gBACpEuM,YAAYpD,IAAI,CAAC;oBACfjM,MAAMtG,4BAA4B4d,wBAAwB;oBAC1DxB,MAAMrI,OAAO,EAAElC;gBACjB;YACF;QACF;IACF;IAEA,OAAO8D;AACT","ignoreList":[0]}