Rocky_Mountain_Vending/.pnpm-store/v10/files/c7/486261107507fcae3e050ebaa2781ef061d9e0a313a0c33c08efabb1da95ab7f05a20d6f4842da78b535143840d5c121b3a2fa92849afc36134a41ac7c489d

{"version":3,"sources":["../../../../src/server/lib/router-utils/instrumentation-node-extensions.ts"],"sourcesContent":["/**\n * This extension augments opentelemetry after registration if applicable.\n * This extension must only be loaded in Node environments.\n */\n\nimport type { Tracer } from '@opentelemetry/api'\nimport {\n  type WorkUnitStore,\n  workUnitAsyncStorage,\n} from '../../app-render/work-unit-async-storage.external'\nimport { InvariantError } from '../../../shared/lib/invariant-error'\nimport { isUseCacheFunction } from '../../../lib/client-and-server-references'\n\nexport function afterRegistration(): void {\n  if (process.env.NEXT_RUNTIME === 'edge') {\n    throw new InvariantError(\n      'Node.js instrumentation extensions should not be loaded in the Edge runtime.'\n    )\n  }\n\n  extendTracerProviderForCacheComponents()\n}\n\n// In theory we only want to enable this extension when cacheComponents is enabled\n// however there are certain servers that might load instrumentation before nextConfig is available\n// and so gating it on the config might lead to skipping this extension even when it is necessary.\n// When cacheComponents is disabled this extension should be a no-op so we enable it universally.\n// Additionally, soon, cacheComponents will be enabled always so this just pulls the extension forward in time\nfunction extendTracerProviderForCacheComponents(): void {\n  let api: typeof import('next/dist/compiled/@opentelemetry/api')\n\n  // we want to allow users to use their own version of @opentelemetry/api if they\n  // want to, so we try to require it first, and if it fails we fall back to the\n  // version that is bundled with Next.js\n  // this is because @opentelemetry/api has to be synced with the version of\n  // @opentelemetry/tracing that is used, and we don't want to force users to use\n  // the version that is bundled with Next.js.\n  // the API is ~stable, so this should be fine\n  try {\n    api = require('@opentelemetry/api') as typeof import('@opentelemetry/api')\n  } catch (err) {\n    api =\n      require('next/dist/compiled/@opentelemetry/api') as typeof import('next/dist/compiled/@opentelemetry/api')\n  }\n\n  const provider = api.trace.getTracerProvider()\n\n  // When Cache Components is enabled we need to instrument the tracer\n  // to exit the workUnitAsyncStorage context when generating spans.\n  const originalGetTracer = provider.getTracer.bind(provider)\n  provider.getTracer = (...args) => {\n    const tracer = originalGetTracer.apply(provider, args)\n    if (WeakTracers.has(tracer)) {\n      return tracer\n    }\n    const originalStartSpan = tracer.startSpan\n    tracer.startSpan = (...startSpanArgs) => {\n      return workUnitAsyncStorage.exit(() =>\n        originalStartSpan.apply(tracer, startSpanArgs)\n      )\n    }\n\n    const originalStartActiveSpan = tracer.startActiveSpan\n    // @ts-ignore TS doesn't recognize the overloads correctly\n    tracer.startActiveSpan = (...startActiveSpanArgs: any[]) => {\n      const workUnitStore = workUnitAsyncStorage.getStore()\n      if (!workUnitStore) {\n        // @ts-ignore TS doesn't recognize the overloads correctly\n        return originalStartActiveSpan.apply(tracer, startActiveSpanArgs)\n      }\n\n      let fnIdx: number = 0\n      if (\n        startActiveSpanArgs.length === 2 &&\n        typeof startActiveSpanArgs[1] === 'function'\n      ) {\n        fnIdx = 1\n      } else if (\n        startActiveSpanArgs.length === 3 &&\n        typeof startActiveSpanArgs[2] === 'function'\n      ) {\n        fnIdx = 2\n      } else if (\n        startActiveSpanArgs.length > 3 &&\n        typeof startActiveSpanArgs[3] === 'function'\n      ) {\n        fnIdx = 3\n      }\n\n      if (fnIdx) {\n        const originalFn = startActiveSpanArgs[fnIdx]\n        if (isUseCacheFunction(originalFn)) {\n          console.error(\n            'A Cache Function (`use cache`) was passed to startActiveSpan which means it will receive a Span argument with a possibly random ID on every invocation leading to cache misses. Provide a wrapping function around the Cache Function that does not forward the Span argument to avoid this issue.'\n          )\n        }\n        startActiveSpanArgs[fnIdx] = withWorkUnitContext(\n          workUnitStore,\n          originalFn\n        )\n      }\n\n      return workUnitAsyncStorage.exit(() => {\n        // @ts-ignore TS doesn't recognize the overloads correctly\n        return originalStartActiveSpan.apply(tracer, startActiveSpanArgs)\n      })\n    }\n\n    WeakTracers.add(tracer)\n    return tracer\n  }\n}\n\nconst WeakTracers = new WeakSet<Tracer>()\n\nfunction withWorkUnitContext(\n  workUnitStore: WorkUnitStore,\n  fn: (...args: any[]) => any\n) {\n  return (...args: any[]) =>\n    workUnitAsyncStorage.run(workUnitStore, fn, ...args)\n}\n"],"names":["workUnitAsyncStorage","InvariantError","isUseCacheFunction","afterRegistration","process","env","NEXT_RUNTIME","extendTracerProviderForCacheComponents","api","require","err","provider","trace","getTracerProvider","originalGetTracer","getTracer","bind","args","tracer","apply","WeakTracers","has","originalStartSpan","startSpan","startSpanArgs","exit","originalStartActiveSpan","startActiveSpan","startActiveSpanArgs","workUnitStore","getStore","fnIdx","length","originalFn","console","error","withWorkUnitContext","add","WeakSet","fn","run"],"mappings":"AAAA;;;CAGC,GAGD,SAEEA,oBAAoB,QACf,oDAAmD;AAC1D,SAASC,cAAc,QAAQ,sCAAqC;AACpE,SAASC,kBAAkB,QAAQ,4CAA2C;AAE9E,OAAO,SAASC;IACd,IAAIC,QAAQC,GAAG,CAACC,YAAY,KAAK,QAAQ;QACvC,MAAM,qBAEL,CAFK,IAAIL,eACR,iFADI,qBAAA;mBAAA;wBAAA;0BAAA;QAEN;IACF;IAEAM;AACF;AAEA,kFAAkF;AAClF,mGAAmG;AACnG,kGAAkG;AAClG,iGAAiG;AACjG,8GAA8G;AAC9G,SAASA;IACP,IAAIC;IAEJ,gFAAgF;IAChF,8EAA8E;IAC9E,uCAAuC;IACvC,0EAA0E;IAC1E,+EAA+E;IAC/E,4CAA4C;IAC5C,6CAA6C;IAC7C,IAAI;QACFA,MAAMC,QAAQ;IAChB,EAAE,OAAOC,KAAK;QACZF,MACEC,QAAQ;IACZ;IAEA,MAAME,WAAWH,IAAII,KAAK,CAACC,iBAAiB;IAE5C,oEAAoE;IACpE,kEAAkE;IAClE,MAAMC,oBAAoBH,SAASI,SAAS,CAACC,IAAI,CAACL;IAClDA,SAASI,SAAS,GAAG,CAAC,GAAGE;QACvB,MAAMC,SAASJ,kBAAkBK,KAAK,CAACR,UAAUM;QACjD,IAAIG,YAAYC,GAAG,CAACH,SAAS;YAC3B,OAAOA;QACT;QACA,MAAMI,oBAAoBJ,OAAOK,SAAS;QAC1CL,OAAOK,SAAS,GAAG,CAAC,GAAGC;YACrB,OAAOxB,qBAAqByB,IAAI,CAAC,IAC/BH,kBAAkBH,KAAK,CAACD,QAAQM;QAEpC;QAEA,MAAME,0BAA0BR,OAAOS,eAAe;QACtD,0DAA0D;QAC1DT,OAAOS,eAAe,GAAG,CAAC,GAAGC;YAC3B,MAAMC,gBAAgB7B,qBAAqB8B,QAAQ;YACnD,IAAI,CAACD,eAAe;gBAClB,0DAA0D;gBAC1D,OAAOH,wBAAwBP,KAAK,CAACD,QAAQU;YAC/C;YAEA,IAAIG,QAAgB;YACpB,IACEH,oBAAoBI,MAAM,KAAK,KAC/B,OAAOJ,mBAAmB,CAAC,EAAE,KAAK,YAClC;gBACAG,QAAQ;YACV,OAAO,IACLH,oBAAoBI,MAAM,KAAK,KAC/B,OAAOJ,mBAAmB,CAAC,EAAE,KAAK,YAClC;gBACAG,QAAQ;YACV,OAAO,IACLH,oBAAoBI,MAAM,GAAG,KAC7B,OAAOJ,mBAAmB,CAAC,EAAE,KAAK,YAClC;gBACAG,QAAQ;YACV;YAEA,IAAIA,OAAO;gBACT,MAAME,aAAaL,mBAAmB,CAACG,MAAM;gBAC7C,IAAI7B,mBAAmB+B,aAAa;oBAClCC,QAAQC,KAAK,CACX;gBAEJ;gBACAP,mBAAmB,CAACG,MAAM,GAAGK,oBAC3BP,eACAI;YAEJ;YAEA,OAAOjC,qBAAqByB,IAAI,CAAC;gBAC/B,0DAA0D;gBAC1D,OAAOC,wBAAwBP,KAAK,CAACD,QAAQU;YAC/C;QACF;QAEAR,YAAYiB,GAAG,CAACnB;QAChB,OAAOA;IACT;AACF;AAEA,MAAME,cAAc,IAAIkB;AAExB,SAASF,oBACPP,aAA4B,EAC5BU,EAA2B;IAE3B,OAAO,CAAC,GAAGtB,OACTjB,qBAAqBwC,GAAG,CAACX,eAAeU,OAAOtB;AACnD","ignoreList":[0]}