Rocky_Mountain_Vending/.pnpm-store/v10/files/8b/991207ed1fe97063241397ad36e63ad243c3720893b0579f2c08b0c1556ab132f21a78705b0e775c3ab8e7f7481a2421260258d7c5366c6718c2ce41dc1a5e

{"version":3,"sources":["../../../src/server/lib/dev-bundler-service.ts"],"sourcesContent":["import type { IncomingMessage } from 'http'\nimport type { DevBundler } from './router-utils/setup-dev-bundler'\nimport type { WorkerRequestHandler } from './types'\n\nimport { LRUCache } from './lru-cache'\nimport { createRequestResponseMocks } from './mock-request'\nimport { HMR_MESSAGE_SENT_TO_BROWSER } from '../dev/hot-reloader-types'\nimport type { ReactDebugChannelForBrowser } from '../dev/debug-channel'\nimport type { ServerCacheStatus } from '../../next-devtools/dev-overlay/cache-indicator'\n\n/**\n * The DevBundlerService provides an interface to perform tasks with the\n * bundler while in development.\n */\nexport class DevBundlerService {\n  public appIsrManifestInner: InstanceType<typeof LRUCache<boolean>>\n\n  constructor(\n    private readonly bundler: DevBundler,\n    private readonly handler: WorkerRequestHandler\n  ) {\n    this.appIsrManifestInner = new LRUCache(\n      8_000,\n\n      function length() {\n        return 16\n      }\n    )\n  }\n\n  public ensurePage: typeof this.bundler.hotReloader.ensurePage = async (\n    definition\n  ) => {\n    // TODO: remove after ensure is pulled out of server\n    return await this.bundler.hotReloader.ensurePage(definition)\n  }\n\n  public logErrorWithOriginalStack =\n    this.bundler.logErrorWithOriginalStack.bind(this.bundler)\n\n  public async getFallbackErrorComponents(url?: string) {\n    await this.bundler.hotReloader.buildFallbackError()\n    // Build the error page to ensure the fallback is built too.\n    // TODO: See if this can be moved into hotReloader or removed.\n    await this.bundler.hotReloader.ensurePage({\n      page: '/_error',\n      clientOnly: false,\n      definition: undefined,\n      url,\n    })\n  }\n\n  public async getCompilationError(page: string) {\n    const errors = await this.bundler.hotReloader.getCompilationErrors(page)\n    if (!errors) return\n\n    // Return the very first error we found.\n    return errors[0]\n  }\n\n  public async revalidate({\n    urlPath,\n    revalidateHeaders,\n    opts: revalidateOpts,\n  }: {\n    urlPath: string\n    revalidateHeaders: IncomingMessage['headers']\n    opts: any\n  }) {\n    const mocked = createRequestResponseMocks({\n      url: urlPath,\n      headers: revalidateHeaders,\n    })\n\n    await this.handler(mocked.req, mocked.res)\n    await mocked.res.hasStreamed\n\n    if (\n      mocked.res.getHeader('x-nextjs-cache') !== 'REVALIDATED' &&\n      mocked.res.statusCode !== 200 &&\n      !(mocked.res.statusCode === 404 && revalidateOpts.unstable_onlyGenerated)\n    ) {\n      throw new Error(`Invalid response ${mocked.res.statusCode}`)\n    }\n\n    return {}\n  }\n\n  public get appIsrManifest() {\n    const serializableManifest: Record<string, boolean> = {}\n\n    for (const [key, value] of this.appIsrManifestInner) {\n      serializableManifest[key] = value\n    }\n\n    return serializableManifest\n  }\n\n  public setCacheStatus(\n    status: ServerCacheStatus,\n    htmlRequestId: string,\n    requestId: string\n  ): void {\n    this.bundler.hotReloader.setCacheStatus(status, htmlRequestId, requestId)\n  }\n\n  public setIsrStatus(key: string, value: boolean | undefined) {\n    if (value === undefined) {\n      this.appIsrManifestInner.remove(key)\n    } else {\n      this.appIsrManifestInner.set(key, value)\n    }\n\n    // Only send the ISR manifest to legacy clients, i.e. Pages Router clients,\n    // or App Router clients that have Cache Components disabled. The ISR\n    // manifest is only used to inform the static indicator, which currently\n    // does not provide useful information if Cache Components is enabled due to\n    // its binary nature (i.e. it does not support showing info for partially\n    // static pages).\n    this.bundler?.hotReloader?.sendToLegacyClients({\n      type: HMR_MESSAGE_SENT_TO_BROWSER.ISR_MANIFEST,\n      data: this.appIsrManifest,\n    })\n  }\n\n  public setReactDebugChannel(\n    debugChannel: ReactDebugChannelForBrowser,\n    htmlRequestId: string,\n    requestId: string\n  ): void {\n    this.bundler.hotReloader.setReactDebugChannel(\n      debugChannel,\n      htmlRequestId,\n      requestId\n    )\n  }\n\n  public close() {\n    this.bundler.hotReloader.close()\n  }\n}\n"],"names":["LRUCache","createRequestResponseMocks","HMR_MESSAGE_SENT_TO_BROWSER","DevBundlerService","constructor","bundler","handler","ensurePage","definition","hotReloader","logErrorWithOriginalStack","bind","appIsrManifestInner","length","getFallbackErrorComponents","url","buildFallbackError","page","clientOnly","undefined","getCompilationError","errors","getCompilationErrors","revalidate","urlPath","revalidateHeaders","opts","revalidateOpts","mocked","headers","req","res","hasStreamed","getHeader","statusCode","unstable_onlyGenerated","Error","appIsrManifest","serializableManifest","key","value","setCacheStatus","status","htmlRequestId","requestId","setIsrStatus","remove","set","sendToLegacyClients","type","ISR_MANIFEST","data","setReactDebugChannel","debugChannel","close"],"mappings":"AAIA,SAASA,QAAQ,QAAQ,cAAa;AACtC,SAASC,0BAA0B,QAAQ,iBAAgB;AAC3D,SAASC,2BAA2B,QAAQ,4BAA2B;AAIvE;;;CAGC,GACD,OAAO,MAAMC;IAGXC,YACE,AAAiBC,OAAmB,EACpC,AAAiBC,OAA6B,CAC9C;aAFiBD,UAAAA;aACAC,UAAAA;aAWZC,aAAyD,OAC9DC;YAEA,oDAAoD;YACpD,OAAO,MAAM,IAAI,CAACH,OAAO,CAACI,WAAW,CAACF,UAAU,CAACC;QACnD;aAEOE,4BACL,IAAI,CAACL,OAAO,CAACK,yBAAyB,CAACC,IAAI,CAAC,IAAI,CAACN,OAAO;QAjBxD,IAAI,CAACO,mBAAmB,GAAG,IAAIZ,SAC7B,MAEA,SAASa;YACP,OAAO;QACT;IAEJ;IAYA,MAAaC,2BAA2BC,GAAY,EAAE;QACpD,MAAM,IAAI,CAACV,OAAO,CAACI,WAAW,CAACO,kBAAkB;QACjD,4DAA4D;QAC5D,8DAA8D;QAC9D,MAAM,IAAI,CAACX,OAAO,CAACI,WAAW,CAACF,UAAU,CAAC;YACxCU,MAAM;YACNC,YAAY;YACZV,YAAYW;YACZJ;QACF;IACF;IAEA,MAAaK,oBAAoBH,IAAY,EAAE;QAC7C,MAAMI,SAAS,MAAM,IAAI,CAAChB,OAAO,CAACI,WAAW,CAACa,oBAAoB,CAACL;QACnE,IAAI,CAACI,QAAQ;QAEb,wCAAwC;QACxC,OAAOA,MAAM,CAAC,EAAE;IAClB;IAEA,MAAaE,WAAW,EACtBC,OAAO,EACPC,iBAAiB,EACjBC,MAAMC,cAAc,EAKrB,EAAE;QACD,MAAMC,SAAS3B,2BAA2B;YACxCc,KAAKS;YACLK,SAASJ;QACX;QAEA,MAAM,IAAI,CAACnB,OAAO,CAACsB,OAAOE,GAAG,EAAEF,OAAOG,GAAG;QACzC,MAAMH,OAAOG,GAAG,CAACC,WAAW;QAE5B,IACEJ,OAAOG,GAAG,CAACE,SAAS,CAAC,sBAAsB,iBAC3CL,OAAOG,GAAG,CAACG,UAAU,KAAK,OAC1B,CAAEN,CAAAA,OAAOG,GAAG,CAACG,UAAU,KAAK,OAAOP,eAAeQ,sBAAsB,AAAD,GACvE;YACA,MAAM,qBAAsD,CAAtD,IAAIC,MAAM,CAAC,iBAAiB,EAAER,OAAOG,GAAG,CAACG,UAAU,EAAE,GAArD,qBAAA;uBAAA;4BAAA;8BAAA;YAAqD;QAC7D;QAEA,OAAO,CAAC;IACV;IAEA,IAAWG,iBAAiB;QAC1B,MAAMC,uBAAgD,CAAC;QAEvD,KAAK,MAAM,CAACC,KAAKC,MAAM,IAAI,IAAI,CAAC5B,mBAAmB,CAAE;YACnD0B,oBAAoB,CAACC,IAAI,GAAGC;QAC9B;QAEA,OAAOF;IACT;IAEOG,eACLC,MAAyB,EACzBC,aAAqB,EACrBC,SAAiB,EACX;QACN,IAAI,CAACvC,OAAO,CAACI,WAAW,CAACgC,cAAc,CAACC,QAAQC,eAAeC;IACjE;IAEOC,aAAaN,GAAW,EAAEC,KAA0B,EAAE;YAO3D,2EAA2E;QAC3E,qEAAqE;QACrE,wEAAwE;QACxE,4EAA4E;QAC5E,yEAAyE;QACzE,iBAAiB;QACjB,2BAAA;QAZA,IAAIA,UAAUrB,WAAW;YACvB,IAAI,CAACP,mBAAmB,CAACkC,MAAM,CAACP;QAClC,OAAO;YACL,IAAI,CAAC3B,mBAAmB,CAACmC,GAAG,CAACR,KAAKC;QACpC;SAQA,gBAAA,IAAI,CAACnC,OAAO,sBAAZ,4BAAA,cAAcI,WAAW,qBAAzB,0BAA2BuC,mBAAmB,CAAC;YAC7CC,MAAM/C,4BAA4BgD,YAAY;YAC9CC,MAAM,IAAI,CAACd,cAAc;QAC3B;IACF;IAEOe,qBACLC,YAAyC,EACzCV,aAAqB,EACrBC,SAAiB,EACX;QACN,IAAI,CAACvC,OAAO,CAACI,WAAW,CAAC2C,oBAAoB,CAC3CC,cACAV,eACAC;IAEJ;IAEOU,QAAQ;QACb,IAAI,CAACjD,OAAO,CAACI,WAAW,CAAC6C,KAAK;IAChC;AACF","ignoreList":[0]}