{"version":3,"sources":["../../../src/server/lib/start-server.ts"],"sourcesContent":["// Start CPU profile if it wasn't already started.\nimport './cpu-profile'\nimport { getNetworkHost } from '../../lib/get-network-host'\n\nif (performance.getEntriesByName('next-start').length === 0) {\n  performance.mark('next-start')\n}\nimport '../next'\nimport '../require-hook'\n\nimport type { IncomingMessage, ServerResponse } from 'http'\nimport type { SelfSignedCertificate } from '../../lib/mkcert'\nimport type { WorkerRequestHandler, WorkerUpgradeHandler } from './types'\n\nimport fs from 'fs'\nimport v8 from 'v8'\nimport path from 'path'\nimport http from 'http'\nimport https from 'https'\nimport os from 'os'\nimport { exec } from 'child_process'\nimport Watchpack from 'next/dist/compiled/watchpack'\nimport * as Log from '../../build/output/log'\nimport setupDebug from 'next/dist/compiled/debug'\nimport { RESTART_EXIT_CODE } from './utils'\nimport { formatHostname } from './format-hostname'\nimport { initialize } from './router-server'\nimport {\n  CONFIG_FILES,\n  PHASE_DEVELOPMENT_SERVER,\n} from '../../shared/lib/constants'\nimport { getStartServerInfo, logStartInfo } from './app-info-log'\nimport { validateTurboNextConfig } from '../../lib/turbopack-warning'\nimport { type Span, trace, flushAllTraces } from '../../trace'\nimport { isIPv6 } from './is-ipv6'\nimport { AsyncCallbackSet } from './async-callback-set'\nimport type { NextServer } from '../next'\nimport type { ConfiguredExperimentalFeature } from '../config'\n\nconst debug = setupDebug('next:start-server')\nlet startServerSpan: Span | undefined\n\n/**\n * Get the process ID (PID) of the process using the specified port\n */\nasync function getProcessIdUsingPort(port: number): Promise<string | null> {\n  const timeoutMs = 250\n  const processLookupController = new AbortController()\n\n  const pidPromise = new Promise<string | null>((resolve) => {\n    const handleError = (error: Error) => {\n      debug('Failed to get process ID for port', port, error)\n      resolve(null)\n    }\n\n    try {\n      // Use lsof on Unix-like systems (macOS, Linux)\n      if (process.platform !== 'win32') {\n        exec(\n          `lsof -ti:${port} -sTCP:LISTEN`,\n          { signal: processLookupController.signal },\n          (error, stdout) => {\n            if (error) {\n              handleError(error)\n              return\n            }\n            // `-sTCP` will ensure there's only one port, clean up output\n            const pid = stdout.trim()\n            resolve(pid || null)\n          }\n        )\n      } else {\n        // Use netstat on Windows\n        exec(\n          `netstat -ano | findstr /C:\":${port} \" | findstr LISTENING`,\n          { signal: processLookupController.signal },\n          (error, stdout) => {\n            if (error) {\n              handleError(error)\n              return\n            }\n            // Clean up output and extract PID\n            const cleanOutput = stdout.replace(/\\s+/g, ' ').trim()\n            if (cleanOutput) {\n              const lines = cleanOutput.split('\\n')\n              const firstLine = lines[0].trim()\n              if (firstLine) {\n                const parts = firstLine.split(' ')\n                const pid = parts[parts.length - 1]\n                resolve(pid || null)\n              } else {\n                resolve(null)\n              }\n            } else {\n              resolve(null)\n            }\n          }\n        )\n      }\n    } catch (cause) {\n      handleError(\n        new Error('Unexpected error during process lookup', { cause })\n      )\n    }\n  })\n\n  const timeoutId = setTimeout(() => {\n    processLookupController.abort(\n      `PID detection timed out after ${timeoutMs}ms for port ${port}.`\n    )\n  }, timeoutMs)\n\n  pidPromise.finally(() => clearTimeout(timeoutId))\n\n  return pidPromise\n}\n\nexport interface StartServerOptions {\n  dir: string\n  port: number\n  isDev: boolean\n  hostname?: string\n  allowRetry?: boolean\n  customServer?: boolean\n  minimalMode?: boolean\n  keepAliveTimeout?: number\n  // this is dev-server only\n  selfSignedCertificate?: SelfSignedCertificate\n}\n\nexport async function getRequestHandlers({\n  dir,\n  port,\n  isDev,\n  onDevServerCleanup,\n  server,\n  hostname,\n  minimalMode,\n  keepAliveTimeout,\n  experimentalHttpsServer,\n  quiet,\n}: {\n  dir: string\n  port: number\n  isDev: boolean\n  onDevServerCleanup: ((listener: () => Promise<void>) => void) | undefined\n  server?: import('http').Server\n  hostname?: string\n  minimalMode?: boolean\n  keepAliveTimeout?: number\n  experimentalHttpsServer?: boolean\n  quiet?: boolean\n}): ReturnType<typeof initialize> {\n  return initialize({\n    dir,\n    port,\n    hostname,\n    onDevServerCleanup,\n    dev: isDev,\n    minimalMode,\n    server,\n    keepAliveTimeout,\n    experimentalHttpsServer,\n    startServerSpan,\n    quiet,\n  })\n}\n\nexport async function startServer(\n  serverOptions: StartServerOptions\n): Promise<void> {\n  const {\n    dir,\n    isDev,\n    hostname,\n    minimalMode,\n    allowRetry,\n    keepAliveTimeout,\n    selfSignedCertificate,\n  } = serverOptions\n  let { port } = serverOptions\n\n  process.title = `next-server (v${process.env.__NEXT_VERSION})`\n  let handlersReady = () => {}\n  let handlersError = () => {}\n\n  let handlersPromise: Promise<void> | undefined = new Promise<void>(\n    (resolve, reject) => {\n      handlersReady = resolve\n      handlersError = reject\n    }\n  )\n  let requestHandler: WorkerRequestHandler = async (\n    req: IncomingMessage,\n    res: ServerResponse\n  ): Promise<void> => {\n    if (handlersPromise) {\n      await handlersPromise\n      return requestHandler(req, res)\n    }\n    throw new Error('Invariant request handler was not setup')\n  }\n  let upgradeHandler: WorkerUpgradeHandler = async (\n    req,\n    socket,\n    head\n  ): Promise<void> => {\n    if (handlersPromise) {\n      await handlersPromise\n      return upgradeHandler(req, socket, head)\n    }\n    throw new Error('Invariant upgrade handler was not setup')\n  }\n\n  let nextServer: NextServer | undefined\n\n  // setup server listener as fast as possible\n  if (selfSignedCertificate && !isDev) {\n    throw new Error(\n      'Using a self signed certificate is only supported with `next dev`.'\n    )\n  }\n\n  async function requestListener(req: IncomingMessage, res: ServerResponse) {\n    try {\n      if (handlersPromise) {\n        await handlersPromise\n        handlersPromise = undefined\n      }\n      await requestHandler(req, res)\n    } catch (err) {\n      res.statusCode = 500\n      res.end('Internal Server Error')\n      Log.error(`Failed to handle request for ${req.url}`)\n      console.error(err)\n    } finally {\n      if (isDev) {\n        if (\n          v8.getHeapStatistics().used_heap_size >\n          0.8 * v8.getHeapStatistics().heap_size_limit\n        ) {\n          Log.warn(\n            `Server is approaching the used memory threshold, restarting...`\n          )\n          trace('server-restart-close-to-memory-threshold', undefined, {\n            'memory.heapSizeLimit': String(\n              v8.getHeapStatistics().heap_size_limit\n            ),\n            'memory.heapUsed': String(v8.getHeapStatistics().used_heap_size),\n          }).stop()\n          await flushAllTraces()\n          process.exit(RESTART_EXIT_CODE)\n        }\n      }\n    }\n  }\n\n  const server = selfSignedCertificate\n    ? https.createServer(\n        {\n          key: fs.readFileSync(selfSignedCertificate.key),\n          cert: fs.readFileSync(selfSignedCertificate.cert),\n        },\n        requestListener\n      )\n    : http.createServer(requestListener)\n\n  if (keepAliveTimeout) {\n    server.keepAliveTimeout = keepAliveTimeout\n  }\n  server.on('upgrade', async (req, socket, head) => {\n    try {\n      await upgradeHandler(req, socket, head)\n    } catch (err) {\n      socket.destroy()\n      Log.error(`Failed to handle request for ${req.url}`)\n      console.error(err)\n    }\n  })\n\n  let portRetryCount = 0\n  const originalPort = port\n\n  server.on('error', (err: NodeJS.ErrnoException) => {\n    if (\n      allowRetry &&\n      port &&\n      isDev &&\n      err.code === 'EADDRINUSE' &&\n      portRetryCount < 10\n    ) {\n      port += 1\n      portRetryCount += 1\n      server.listen(port, hostname)\n    } else {\n      Log.error(`Failed to start server`)\n      console.error(err)\n      process.exit(1)\n    }\n  })\n\n  let cleanupListeners = isDev ? new AsyncCallbackSet() : undefined\n\n  await new Promise<void>((resolve) => {\n    server.on('listening', async () => {\n      const addr = server.address()\n      const actualHostname = formatHostname(\n        typeof addr === 'object'\n          ? addr?.address || hostname || 'localhost'\n          : addr\n      )\n      const formattedHostname =\n        !hostname || actualHostname === '0.0.0.0'\n          ? 'localhost'\n          : actualHostname === '[::]'\n            ? '[::1]'\n            : formatHostname(hostname)\n\n      port = typeof addr === 'object' ? addr?.port || port : port\n\n      if (portRetryCount) {\n        const pid = await getProcessIdUsingPort(originalPort)\n        if (pid) {\n          Log.warn(\n            `Port ${originalPort} is in use by process ${pid}, using available port ${port} instead.`\n          )\n        } else {\n          Log.warn(\n            `Port ${originalPort} is in use by an unknown process, using available port ${port} instead.`\n          )\n        }\n      }\n\n      const networkHostname =\n        hostname ?? getNetworkHost(isIPv6(actualHostname) ? 'IPv6' : 'IPv4')\n\n      const protocol = selfSignedCertificate ? 'https' : 'http'\n\n      const networkUrl = networkHostname\n        ? `${protocol}://${formatHostname(networkHostname)}:${port}`\n        : null\n\n      const appUrl = `${protocol}://${formattedHostname}:${port}`\n\n      // Store the selected port to:\n      // - expose it to render workers\n      // - re-use it for automatic dev server restarts with a randomly selected port\n      process.env.PORT = port + ''\n\n      process.env.__NEXT_PRIVATE_ORIGIN = appUrl\n\n      // Set experimental HTTPS flag for metadata resolution\n      if (selfSignedCertificate) {\n        process.env.__NEXT_EXPERIMENTAL_HTTPS = '1'\n      }\n\n      // Only load env and config in dev to for logging purposes\n      let envInfo: string[] | undefined\n      let experimentalFeatures: ConfiguredExperimentalFeature[] | undefined\n      let cacheComponents: boolean | undefined\n      try {\n        if (isDev) {\n          const startServerInfo = await getStartServerInfo({ dir, dev: isDev })\n          envInfo = startServerInfo.envInfo\n          cacheComponents = startServerInfo.cacheComponents\n          experimentalFeatures = startServerInfo.experimentalFeatures\n        }\n        logStartInfo({\n          networkUrl,\n          appUrl,\n          envInfo,\n          experimentalFeatures,\n          cacheComponents,\n          logBundler: isDev,\n        })\n\n        Log.event(`Starting...`)\n\n        let cleanupStarted = false\n        let closeUpgraded: (() => void) | null = null\n        const cleanup = () => {\n          if (cleanupStarted) {\n            // We can get duplicate signals, e.g. when `ctrl+c` is used in an\n            // interactive shell (i.e. bash, zsh), the shell will recursively\n            // send SIGINT to children. The parent `next-dev` process will also\n            // send us SIGINT.\n            return\n          }\n          cleanupStarted = true\n          ;(async () => {\n            debug('start-server process cleanup')\n\n            // first, stop accepting new connections and finish pending requests,\n            // because they might affect `nextServer.close()` (e.g. by scheduling an `after`)\n            await new Promise<void>((res) => {\n              server.close((err) => {\n                if (err) console.error(err)\n                res()\n              })\n              if (isDev) {\n                server.closeAllConnections()\n                closeUpgraded?.()\n              }\n            })\n\n            // now that no new requests can come in, clean up the rest\n            await Promise.all([\n              nextServer?.close().catch(console.error),\n              cleanupListeners?.runAll().catch(console.error),\n            ])\n\n            // Flush telemetry if this is a dev server\n            if (isDev) {\n              try {\n                const { traceGlobals } =\n                  require('../../trace/shared') as typeof import('../../trace/shared')\n                const telemetry = traceGlobals.get('telemetry') as\n                  | InstanceType<\n                      typeof import('../../telemetry/storage').Telemetry\n                    >\n                  | undefined\n                if (telemetry) {\n                  // Use flushDetached to avoid blocking process exit\n                  // Each process writes to a unique file (_events_${pid}.json)\n                  // to avoid race conditions with the parent process\n                  telemetry.flushDetached('dev', dir)\n                }\n              } catch (_) {\n                // Ignore telemetry errors during cleanup\n              }\n            }\n\n            debug('start-server process cleanup finished')\n            process.exit(0)\n          })()\n        }\n\n        // Make sure commands gracefully respect termination signals (e.g. from Docker)\n        // Allow the graceful termination to be manually configurable\n        if (!process.env.NEXT_MANUAL_SIG_HANDLE) {\n          process.on('SIGINT', cleanup)\n          process.on('SIGTERM', cleanup)\n        }\n\n        const initResult = await getRequestHandlers({\n          dir,\n          port,\n          isDev,\n          onDevServerCleanup: cleanupListeners\n            ? cleanupListeners.add.bind(cleanupListeners)\n            : undefined,\n          server,\n          hostname,\n          minimalMode,\n          keepAliveTimeout,\n          experimentalHttpsServer: !!selfSignedCertificate,\n        })\n        requestHandler = initResult.requestHandler\n        upgradeHandler = initResult.upgradeHandler\n        nextServer = initResult.server\n        closeUpgraded = initResult.closeUpgraded\n\n        const startServerProcessDuration =\n          performance.mark('next-start-end') &&\n          performance.measure(\n            'next-start-duration',\n            'next-start',\n            'next-start-end'\n          ).duration\n\n        handlersReady()\n        const formatDurationText =\n          startServerProcessDuration > 2000\n            ? `${Math.round(startServerProcessDuration / 100) / 10}s`\n            : `${Math.round(startServerProcessDuration)}ms`\n\n        Log.event(`Ready in ${formatDurationText}`)\n\n        if (process.env.TURBOPACK && isDev) {\n          await validateTurboNextConfig({\n            dir: serverOptions.dir,\n            configPhase: PHASE_DEVELOPMENT_SERVER,\n          })\n        }\n      } catch (err) {\n        // fatal error if we can't setup\n        handlersError()\n        console.error(err)\n        process.exit(1)\n      }\n\n      resolve()\n    })\n    server.listen(port, hostname)\n  })\n\n  if (isDev) {\n    function watchConfigFiles(\n      dirToWatch: string,\n      onChange: (filename: string) => void\n    ) {\n      const wp = new Watchpack()\n      wp.watch({\n        files: CONFIG_FILES.map((file) => path.join(dirToWatch, file)),\n      })\n      wp.on('change', onChange)\n    }\n    watchConfigFiles(dir, async (filename) => {\n      if (process.env.__NEXT_DISABLE_MEMORY_WATCHER) {\n        Log.info(\n          `Detected change, manual restart required due to '__NEXT_DISABLE_MEMORY_WATCHER' usage`\n        )\n        return\n      }\n\n      Log.warn(\n        `Found a change in ${path.basename(\n          filename\n        )}. Restarting the server to apply the changes...`\n      )\n      process.exit(RESTART_EXIT_CODE)\n    })\n  }\n}\n\nif (process.env.NEXT_PRIVATE_WORKER && process.send) {\n  process.addListener('message', async (msg: any) => {\n    if (\n      msg &&\n      typeof msg === 'object' &&\n      msg.nextWorkerOptions &&\n      process.send\n    ) {\n      startServerSpan = trace('start-dev-server', undefined, {\n        cpus: String(os.cpus().length),\n        platform: os.platform(),\n        'memory.freeMem': String(os.freemem()),\n        'memory.totalMem': String(os.totalmem()),\n        'memory.heapSizeLimit': String(v8.getHeapStatistics().heap_size_limit),\n      })\n      await startServerSpan.traceAsyncFn(() =>\n        startServer(msg.nextWorkerOptions)\n      )\n      const memoryUsage = process.memoryUsage()\n      startServerSpan.setAttribute('memory.rss', String(memoryUsage.rss))\n      startServerSpan.setAttribute(\n        'memory.heapTotal',\n        String(memoryUsage.heapTotal)\n      )\n      startServerSpan.setAttribute(\n        'memory.heapUsed',\n        String(memoryUsage.heapUsed)\n      )\n      process.send({ nextServerReady: true, port: process.env.PORT })\n    }\n  })\n  process.send({ nextWorkerReady: true })\n}\n"],"names":["getRequestHandlers","startServer","performance","getEntriesByName","length","mark","debug","setupDebug","startServerSpan","getProcessIdUsingPort","port","timeoutMs","processLookupController","AbortController","pidPromise","Promise","resolve","handleError","error","process","platform","exec","signal","stdout","pid","trim","cleanOutput","replace","lines","split","firstLine","parts","cause","Error","timeoutId","setTimeout","abort","finally","clearTimeout","dir","isDev","onDevServerCleanup","server","hostname","minimalMode","keepAliveTimeout","experimentalHttpsServer","quiet","initialize","dev","serverOptions","allowRetry","selfSignedCertificate","title","env","__NEXT_VERSION","handlersReady","handlersError","handlersPromise","reject","requestHandler","req","res","upgradeHandler","socket","head","nextServer","requestListener","undefined","err","statusCode","end","Log","url","console","v8","getHeapStatistics","used_heap_size","heap_size_limit","warn","trace","String","stop","flushAllTraces","exit","RESTART_EXIT_CODE","https","createServer","key","fs","readFileSync","cert","http","on","destroy","portRetryCount","originalPort","code","listen","cleanupListeners","AsyncCallbackSet","addr","address","actualHostname","formatHostname","formattedHostname","networkHostname","getNetworkHost","isIPv6","protocol","networkUrl","appUrl","PORT","__NEXT_PRIVATE_ORIGIN","__NEXT_EXPERIMENTAL_HTTPS","envInfo","experimentalFeatures","cacheComponents","startServerInfo","getStartServerInfo","logStartInfo","logBundler","event","cleanupStarted","closeUpgraded","cleanup","close","closeAllConnections","all","catch","runAll","traceGlobals","require","telemetry","get","flushDetached","_","NEXT_MANUAL_SIG_HANDLE","initResult","add","bind","startServerProcessDuration","measure","duration","formatDurationText","Math","round","TURBOPACK","validateTurboNextConfig","configPhase","PHASE_DEVELOPMENT_SERVER","watchConfigFiles","dirToWatch","onChange","wp","Watchpack","watch","files","CONFIG_FILES","map","file","path","join","filename","__NEXT_DISABLE_MEMORY_WATCHER","info","basename","NEXT_PRIVATE_WORKER","send","addListener","msg","nextWorkerOptions","cpus","os","freemem","totalmem","traceAsyncFn","memoryUsage","setAttribute","rss","heapTotal","heapUsed","nextServerReady","nextWorkerReady"],"mappings":"AAAA,kDAAkD;;;;;;;;;;;;;;;;IAkI5BA,kBAAkB;eAAlBA;;IAsCAC,WAAW;eAAXA;;;QAvKf;gCACwB;QAKxB;QACA;2DAMQ;2DACA;6DACE;6DACA;8DACC;2DACH;+BACM;kEACC;6DACD;8DACE;uBACW;gCACH;8BACJ;2BAIpB;4BAC0C;kCACT;uBACS;wBAC1B;kCACU;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;AA/BjC,IAAIC,YAAYC,gBAAgB,CAAC,cAAcC,MAAM,KAAK,GAAG;IAC3DF,YAAYG,IAAI,CAAC;AACnB;AAiCA,MAAMC,QAAQC,IAAAA,cAAU,EAAC;AACzB,IAAIC;AAEJ;;CAEC,GACD,eAAeC,sBAAsBC,IAAY;IAC/C,MAAMC,YAAY;IAClB,MAAMC,0BAA0B,IAAIC;IAEpC,MAAMC,aAAa,IAAIC,QAAuB,CAACC;QAC7C,MAAMC,cAAc,CAACC;YACnBZ,MAAM,qCAAqCI,MAAMQ;YACjDF,QAAQ;QACV;QAEA,IAAI;YACF,+CAA+C;YAC/C,IAAIG,QAAQC,QAAQ,KAAK,SAAS;gBAChCC,IAAAA,mBAAI,EACF,CAAC,SAAS,EAAEX,KAAK,aAAa,CAAC,EAC/B;oBAAEY,QAAQV,wBAAwBU,MAAM;gBAAC,GACzC,CAACJ,OAAOK;oBACN,IAAIL,OAAO;wBACTD,YAAYC;wBACZ;oBACF;oBACA,6DAA6D;oBAC7D,MAAMM,MAAMD,OAAOE,IAAI;oBACvBT,QAAQQ,OAAO;gBACjB;YAEJ,OAAO;gBACL,yBAAyB;gBACzBH,IAAAA,mBAAI,EACF,CAAC,4BAA4B,EAAEX,KAAK,sBAAsB,CAAC,EAC3D;oBAAEY,QAAQV,wBAAwBU,MAAM;gBAAC,GACzC,CAACJ,OAAOK;oBACN,IAAIL,OAAO;wBACTD,YAAYC;wBACZ;oBACF;oBACA,kCAAkC;oBAClC,MAAMQ,cAAcH,OAAOI,OAAO,CAAC,QAAQ,KAAKF,IAAI;oBACpD,IAAIC,aAAa;wBACf,MAAME,QAAQF,YAAYG,KAAK,CAAC;wBAChC,MAAMC,YAAYF,KAAK,CAAC,EAAE,CAACH,IAAI;wBAC/B,IAAIK,WAAW;4BACb,MAAMC,QAAQD,UAAUD,KAAK,CAAC;4BAC9B,MAAML,MAAMO,KAAK,CAACA,MAAM3B,MAAM,GAAG,EAAE;4BACnCY,QAAQQ,OAAO;wBACjB,OAAO;4BACLR,QAAQ;wBACV;oBACF,OAAO;wBACLA,QAAQ;oBACV;gBACF;YAEJ;QACF,EAAE,OAAOgB,OAAO;YACdf,YACE,qBAA8D,CAA9D,IAAIgB,MAAM,0CAA0C;gBAAED;YAAM,IAA5D,qBAAA;uBAAA;4BAAA;8BAAA;YAA6D;QAEjE;IACF;IAEA,MAAME,YAAYC,WAAW;QAC3BvB,wBAAwBwB,KAAK,CAC3B,CAAC,8BAA8B,EAAEzB,UAAU,YAAY,EAAED,KAAK,CAAC,CAAC;IAEpE,GAAGC;IAEHG,WAAWuB,OAAO,CAAC,IAAMC,aAAaJ;IAEtC,OAAOpB;AACT;AAeO,eAAed,mBAAmB,EACvCuC,GAAG,EACH7B,IAAI,EACJ8B,KAAK,EACLC,kBAAkB,EAClBC,MAAM,EACNC,QAAQ,EACRC,WAAW,EACXC,gBAAgB,EAChBC,uBAAuB,EACvBC,KAAK,EAYN;IACC,OAAOC,IAAAA,wBAAU,EAAC;QAChBT;QACA7B;QACAiC;QACAF;QACAQ,KAAKT;QACLI;QACAF;QACAG;QACAC;QACAtC;QACAuC;IACF;AACF;AAEO,eAAe9C,YACpBiD,aAAiC;IAEjC,MAAM,EACJX,GAAG,EACHC,KAAK,EACLG,QAAQ,EACRC,WAAW,EACXO,UAAU,EACVN,gBAAgB,EAChBO,qBAAqB,EACtB,GAAGF;IACJ,IAAI,EAAExC,IAAI,EAAE,GAAGwC;IAEf/B,QAAQkC,KAAK,GAAG,CAAC,cAAc,EAAElC,QAAQmC,GAAG,CAACC,cAAc,CAAC,CAAC,CAAC;IAC9D,IAAIC,gBAAgB,KAAO;IAC3B,IAAIC,gBAAgB,KAAO;IAE3B,IAAIC,kBAA6C,IAAI3C,QACnD,CAACC,SAAS2C;QACRH,gBAAgBxC;QAChByC,gBAAgBE;IAClB;IAEF,IAAIC,iBAAuC,OACzCC,KACAC;QAEA,IAAIJ,iBAAiB;YACnB,MAAMA;YACN,OAAOE,eAAeC,KAAKC;QAC7B;QACA,MAAM,qBAAoD,CAApD,IAAI7B,MAAM,4CAAV,qBAAA;mBAAA;wBAAA;0BAAA;QAAmD;IAC3D;IACA,IAAI8B,iBAAuC,OACzCF,KACAG,QACAC;QAEA,IAAIP,iBAAiB;YACnB,MAAMA;YACN,OAAOK,eAAeF,KAAKG,QAAQC;QACrC;QACA,MAAM,qBAAoD,CAApD,IAAIhC,MAAM,4CAAV,qBAAA;mBAAA;wBAAA;0BAAA;QAAmD;IAC3D;IAEA,IAAIiC;IAEJ,4CAA4C;IAC5C,IAAId,yBAAyB,CAACZ,OAAO;QACnC,MAAM,qBAEL,CAFK,IAAIP,MACR,uEADI,qBAAA;mBAAA;wBAAA;0BAAA;QAEN;IACF;IAEA,eAAekC,gBAAgBN,GAAoB,EAAEC,GAAmB;QACtE,IAAI;YACF,IAAIJ,iBAAiB;gBACnB,MAAMA;gBACNA,kBAAkBU;YACpB;YACA,MAAMR,eAAeC,KAAKC;QAC5B,EAAE,OAAOO,KAAK;YACZP,IAAIQ,UAAU,GAAG;YACjBR,IAAIS,GAAG,CAAC;YACRC,KAAItD,KAAK,CAAC,CAAC,6BAA6B,EAAE2C,IAAIY,GAAG,EAAE;YACnDC,QAAQxD,KAAK,CAACmD;QAChB,SAAU;YACR,IAAI7B,OAAO;gBACT,IACEmC,WAAE,CAACC,iBAAiB,GAAGC,cAAc,GACrC,MAAMF,WAAE,CAACC,iBAAiB,GAAGE,eAAe,EAC5C;oBACAN,KAAIO,IAAI,CACN,CAAC,8DAA8D,CAAC;oBAElEC,IAAAA,YAAK,EAAC,4CAA4CZ,WAAW;wBAC3D,wBAAwBa,OACtBN,WAAE,CAACC,iBAAiB,GAAGE,eAAe;wBAExC,mBAAmBG,OAAON,WAAE,CAACC,iBAAiB,GAAGC,cAAc;oBACjE,GAAGK,IAAI;oBACP,MAAMC,IAAAA,qBAAc;oBACpBhE,QAAQiE,IAAI,CAACC,wBAAiB;gBAChC;YACF;QACF;IACF;IAEA,MAAM3C,SAASU,wBACXkC,cAAK,CAACC,YAAY,CAChB;QACEC,KAAKC,WAAE,CAACC,YAAY,CAACtC,sBAAsBoC,GAAG;QAC9CG,MAAMF,WAAE,CAACC,YAAY,CAACtC,sBAAsBuC,IAAI;IAClD,GACAxB,mBAEFyB,aAAI,CAACL,YAAY,CAACpB;IAEtB,IAAItB,kBAAkB;QACpBH,OAAOG,gBAAgB,GAAGA;IAC5B;IACAH,OAAOmD,EAAE,CAAC,WAAW,OAAOhC,KAAKG,QAAQC;QACvC,IAAI;YACF,MAAMF,eAAeF,KAAKG,QAAQC;QACpC,EAAE,OAAOI,KAAK;YACZL,OAAO8B,OAAO;YACdtB,KAAItD,KAAK,CAAC,CAAC,6BAA6B,EAAE2C,IAAIY,GAAG,EAAE;YACnDC,QAAQxD,KAAK,CAACmD;QAChB;IACF;IAEA,IAAI0B,iBAAiB;IACrB,MAAMC,eAAetF;IAErBgC,OAAOmD,EAAE,CAAC,SAAS,CAACxB;QAClB,IACElB,cACAzC,QACA8B,SACA6B,IAAI4B,IAAI,KAAK,gBACbF,iBAAiB,IACjB;YACArF,QAAQ;YACRqF,kBAAkB;YAClBrD,OAAOwD,MAAM,CAACxF,MAAMiC;QACtB,OAAO;YACL6B,KAAItD,KAAK,CAAC,CAAC,sBAAsB,CAAC;YAClCwD,QAAQxD,KAAK,CAACmD;YACdlD,QAAQiE,IAAI,CAAC;QACf;IACF;IAEA,IAAIe,mBAAmB3D,QAAQ,IAAI4D,kCAAgB,KAAKhC;IAExD,MAAM,IAAIrD,QAAc,CAACC;QACvB0B,OAAOmD,EAAE,CAAC,aAAa;YACrB,MAAMQ,OAAO3D,OAAO4D,OAAO;YAC3B,MAAMC,iBAAiBC,IAAAA,8BAAc,EACnC,OAAOH,SAAS,WACZA,CAAAA,wBAAAA,KAAMC,OAAO,KAAI3D,YAAY,cAC7B0D;YAEN,MAAMI,oBACJ,CAAC9D,YAAY4D,mBAAmB,YAC5B,cACAA,mBAAmB,SACjB,UACAC,IAAAA,8BAAc,EAAC7D;YAEvBjC,OAAO,OAAO2F,SAAS,WAAWA,CAAAA,wBAAAA,KAAM3F,IAAI,KAAIA,OAAOA;YAEvD,IAAIqF,gBAAgB;gBAClB,MAAMvE,MAAM,MAAMf,sBAAsBuF;gBACxC,IAAIxE,KAAK;oBACPgD,KAAIO,IAAI,CACN,CAAC,KAAK,EAAEiB,aAAa,sBAAsB,EAAExE,IAAI,uBAAuB,EAAEd,KAAK,SAAS,CAAC;gBAE7F,OAAO;oBACL8D,KAAIO,IAAI,CACN,CAAC,KAAK,EAAEiB,aAAa,uDAAuD,EAAEtF,KAAK,SAAS,CAAC;gBAEjG;YACF;YAEA,MAAMgG,kBACJ/D,YAAYgE,IAAAA,8BAAc,EAACC,IAAAA,cAAM,EAACL,kBAAkB,SAAS;YAE/D,MAAMM,WAAWzD,wBAAwB,UAAU;YAEnD,MAAM0D,aAAaJ,kBACf,GAAGG,SAAS,GAAG,EAAEL,IAAAA,8BAAc,EAACE,iBAAiB,CAAC,EAAEhG,MAAM,GAC1D;YAEJ,MAAMqG,SAAS,GAAGF,SAAS,GAAG,EAAEJ,kBAAkB,CAAC,EAAE/F,MAAM;YAE3D,8BAA8B;YAC9B,gCAAgC;YAChC,8EAA8E;YAC9ES,QAAQmC,GAAG,CAAC0D,IAAI,GAAGtG,OAAO;YAE1BS,QAAQmC,GAAG,CAAC2D,qBAAqB,GAAGF;YAEpC,sDAAsD;YACtD,IAAI3D,uBAAuB;gBACzBjC,QAAQmC,GAAG,CAAC4D,yBAAyB,GAAG;YAC1C;YAEA,0DAA0D;YAC1D,IAAIC;YACJ,IAAIC;YACJ,IAAIC;YACJ,IAAI;gBACF,IAAI7E,OAAO;oBACT,MAAM8E,kBAAkB,MAAMC,IAAAA,8BAAkB,EAAC;wBAAEhF;wBAAKU,KAAKT;oBAAM;oBACnE2E,UAAUG,gBAAgBH,OAAO;oBACjCE,kBAAkBC,gBAAgBD,eAAe;oBACjDD,uBAAuBE,gBAAgBF,oBAAoB;gBAC7D;gBACAI,IAAAA,wBAAY,EAAC;oBACXV;oBACAC;oBACAI;oBACAC;oBACAC;oBACAI,YAAYjF;gBACd;gBAEAgC,KAAIkD,KAAK,CAAC,CAAC,WAAW,CAAC;gBAEvB,IAAIC,iBAAiB;gBACrB,IAAIC,gBAAqC;gBACzC,MAAMC,UAAU;oBACd,IAAIF,gBAAgB;wBAClB,iEAAiE;wBACjE,iEAAiE;wBACjE,mEAAmE;wBACnE,kBAAkB;wBAClB;oBACF;oBACAA,iBAAiB;oBACf,CAAA;wBACArH,MAAM;wBAEN,qEAAqE;wBACrE,iFAAiF;wBACjF,MAAM,IAAIS,QAAc,CAAC+C;4BACvBpB,OAAOoF,KAAK,CAAC,CAACzD;gCACZ,IAAIA,KAAKK,QAAQxD,KAAK,CAACmD;gCACvBP;4BACF;4BACA,IAAItB,OAAO;gCACTE,OAAOqF,mBAAmB;gCAC1BH,iCAAAA;4BACF;wBACF;wBAEA,0DAA0D;wBAC1D,MAAM7G,QAAQiH,GAAG,CAAC;4BAChB9D,8BAAAA,WAAY4D,KAAK,GAAGG,KAAK,CAACvD,QAAQxD,KAAK;4BACvCiF,oCAAAA,iBAAkB+B,MAAM,GAAGD,KAAK,CAACvD,QAAQxD,KAAK;yBAC/C;wBAED,0CAA0C;wBAC1C,IAAIsB,OAAO;4BACT,IAAI;gCACF,MAAM,EAAE2F,YAAY,EAAE,GACpBC,QAAQ;gCACV,MAAMC,YAAYF,aAAaG,GAAG,CAAC;gCAKnC,IAAID,WAAW;oCACb,mDAAmD;oCACnD,6DAA6D;oCAC7D,mDAAmD;oCACnDA,UAAUE,aAAa,CAAC,OAAOhG;gCACjC;4BACF,EAAE,OAAOiG,GAAG;4BACV,yCAAyC;4BAC3C;wBACF;wBAEAlI,MAAM;wBACNa,QAAQiE,IAAI,CAAC;oBACf,CAAA;gBACF;gBAEA,+EAA+E;gBAC/E,6DAA6D;gBAC7D,IAAI,CAACjE,QAAQmC,GAAG,CAACmF,sBAAsB,EAAE;oBACvCtH,QAAQ0E,EAAE,CAAC,UAAUgC;oBACrB1G,QAAQ0E,EAAE,CAAC,WAAWgC;gBACxB;gBAEA,MAAMa,aAAa,MAAM1I,mBAAmB;oBAC1CuC;oBACA7B;oBACA8B;oBACAC,oBAAoB0D,mBAChBA,iBAAiBwC,GAAG,CAACC,IAAI,CAACzC,oBAC1B/B;oBACJ1B;oBACAC;oBACAC;oBACAC;oBACAC,yBAAyB,CAAC,CAACM;gBAC7B;gBACAQ,iBAAiB8E,WAAW9E,cAAc;gBAC1CG,iBAAiB2E,WAAW3E,cAAc;gBAC1CG,aAAawE,WAAWhG,MAAM;gBAC9BkF,gBAAgBc,WAAWd,aAAa;gBAExC,MAAMiB,6BACJ3I,YAAYG,IAAI,CAAC,qBACjBH,YAAY4I,OAAO,CACjB,uBACA,cACA,kBACAC,QAAQ;gBAEZvF;gBACA,MAAMwF,qBACJH,6BAA6B,OACzB,GAAGI,KAAKC,KAAK,CAACL,6BAA6B,OAAO,GAAG,CAAC,CAAC,GACvD,GAAGI,KAAKC,KAAK,CAACL,4BAA4B,EAAE,CAAC;gBAEnDrE,KAAIkD,KAAK,CAAC,CAAC,SAAS,EAAEsB,oBAAoB;gBAE1C,IAAI7H,QAAQmC,GAAG,CAAC6F,SAAS,IAAI3G,OAAO;oBAClC,MAAM4G,IAAAA,yCAAuB,EAAC;wBAC5B7G,KAAKW,cAAcX,GAAG;wBACtB8G,aAAaC,mCAAwB;oBACvC;gBACF;YACF,EAAE,OAAOjF,KAAK;gBACZ,gCAAgC;gBAChCZ;gBACAiB,QAAQxD,KAAK,CAACmD;gBACdlD,QAAQiE,IAAI,CAAC;YACf;YAEApE;QACF;QACA0B,OAAOwD,MAAM,CAACxF,MAAMiC;IACtB;IAEA,IAAIH,OAAO;QACT,SAAS+G,iBACPC,UAAkB,EAClBC,QAAoC;YAEpC,MAAMC,KAAK,IAAIC,kBAAS;YACxBD,GAAGE,KAAK,CAAC;gBACPC,OAAOC,uBAAY,CAACC,GAAG,CAAC,CAACC,OAASC,aAAI,CAACC,IAAI,CAACV,YAAYQ;YAC1D;YACAN,GAAG7D,EAAE,CAAC,UAAU4D;QAClB;QACAF,iBAAiBhH,KAAK,OAAO4H;YAC3B,IAAIhJ,QAAQmC,GAAG,CAAC8G,6BAA6B,EAAE;gBAC7C5F,KAAI6F,IAAI,CACN,CAAC,qFAAqF,CAAC;gBAEzF;YACF;YAEA7F,KAAIO,IAAI,CACN,CAAC,kBAAkB,EAAEkF,aAAI,CAACK,QAAQ,CAChCH,UACA,+CAA+C,CAAC;YAEpDhJ,QAAQiE,IAAI,CAACC,wBAAiB;QAChC;IACF;AACF;AAEA,IAAIlE,QAAQmC,GAAG,CAACiH,mBAAmB,IAAIpJ,QAAQqJ,IAAI,EAAE;IACnDrJ,QAAQsJ,WAAW,CAAC,WAAW,OAAOC;QACpC,IACEA,OACA,OAAOA,QAAQ,YACfA,IAAIC,iBAAiB,IACrBxJ,QAAQqJ,IAAI,EACZ;YACAhK,kBAAkBwE,IAAAA,YAAK,EAAC,oBAAoBZ,WAAW;gBACrDwG,MAAM3F,OAAO4F,WAAE,CAACD,IAAI,GAAGxK,MAAM;gBAC7BgB,UAAUyJ,WAAE,CAACzJ,QAAQ;gBACrB,kBAAkB6D,OAAO4F,WAAE,CAACC,OAAO;gBACnC,mBAAmB7F,OAAO4F,WAAE,CAACE,QAAQ;gBACrC,wBAAwB9F,OAAON,WAAE,CAACC,iBAAiB,GAAGE,eAAe;YACvE;YACA,MAAMtE,gBAAgBwK,YAAY,CAAC,IACjC/K,YAAYyK,IAAIC,iBAAiB;YAEnC,MAAMM,cAAc9J,QAAQ8J,WAAW;YACvCzK,gBAAgB0K,YAAY,CAAC,cAAcjG,OAAOgG,YAAYE,GAAG;YACjE3K,gBAAgB0K,YAAY,CAC1B,oBACAjG,OAAOgG,YAAYG,SAAS;YAE9B5K,gBAAgB0K,YAAY,CAC1B,mBACAjG,OAAOgG,YAAYI,QAAQ;YAE7BlK,QAAQqJ,IAAI,CAAC;gBAAEc,iBAAiB;gBAAM5K,MAAMS,QAAQmC,GAAG,CAAC0D,IAAI;YAAC;QAC/D;IACF;IACA7F,QAAQqJ,IAAI,CAAC;QAAEe,iBAAiB;IAAK;AACvC","ignoreList":[0]}