FM / router-utils

/opt/canhelp/node_modules/next/dist/esm/server/lib/router-utils/

/opt/canhelp/node_modules/next/dist/esm/server/lib/router-utils

Name	Size	Mode	Actions
block-cross-site.js	2990	0644	edit dl rm
block-cross-site.js.map	5236	0644	edit dl rm
build-data-route.js	1403	0644	edit dl rm
build-data-route.js.map	2712	0644	edit dl rm
build-prefetch-segment-data-route.js	2021	0644	edit dl rm
build-prefetch-segment-data-route.js.map	3690	0644	edit dl rm
decode-path-params.js	1112	0644	edit dl rm
decode-path-params.js.map	1589	0644	edit dl rm
filesystem.js	24149	0644	edit dl rm
filesystem.js.map	37721	0644	edit dl rm
instrumentation-globals.external.js	2682	0644	edit dl rm
instrumentation-globals.external.js.map	4763	0644	edit dl rm
instrumentation-node-extensions.js	4625	0644	edit dl rm
instrumentation-node-extensions.js.map	7205	0644	edit dl rm
is-postpone.js	234	0644	edit dl rm
is-postpone.js.map	579	0644	edit dl rm
proxy-request.js	3850	0644	edit dl rm
proxy-request.js.map	6603	0644	edit dl rm
resolve-routes.js	32252	0644	edit dl rm
resolve-routes.js.map	47115	0644	edit dl rm
route-types-utils.js	10509	0644	edit dl rm
route-types-utils.js.map	19197	0644	edit dl rm
router-server-context.js	180	0644	edit dl rm
router-server-context.js.map	2247	0644	edit dl rm
setup-dev-bundler.js	43758	0644	edit dl rm
setup-dev-bundler.js.map	68542	0644	edit dl rm
typegen.js	24092	0644	edit dl rm
typegen.js.map	34670	0644	edit dl rm
types.js	46	0644	edit dl rm
types.js.map	354	0644	edit dl rm

Edit: /opt/canhelp/node_modules/next/dist/esm/server/lib/router-utils/instrumentation-node-extensions.js (4625B)

/**
 * This extension augments opentelemetry after registration if applicable.
 * This extension must only be loaded in Node environments.
 */ import { workUnitAsyncStorage } from '../../app-render/work-unit-async-storage.external';
import { InvariantError } from '../../../shared/lib/invariant-error';
import { isUseCacheFunction } from '../../../lib/client-and-server-references';
export function afterRegistration() {
    if (process.env.NEXT_RUNTIME === 'edge') {
        throw Object.defineProperty(new InvariantError('Node.js instrumentation extensions should not be loaded in the Edge runtime.'), "__NEXT_ERROR_CODE", {
            value: "E775",
            enumerable: false,
            configurable: true
        });
    }
    extendTracerProviderForCacheComponents();
}
// In theory we only want to enable this extension when cacheComponents is enabled
// however there are certain servers that might load instrumentation before nextConfig is available
// and so gating it on the config might lead to skipping this extension even when it is necessary.
// When cacheComponents is disabled this extension should be a no-op so we enable it universally.
// Additionally, soon, cacheComponents will be enabled always so this just pulls the extension forward in time
function extendTracerProviderForCacheComponents() {
    let api;
    // we want to allow users to use their own version of @opentelemetry/api if they
    // want to, so we try to require it first, and if it fails we fall back to the
    // version that is bundled with Next.js
    // this is because @opentelemetry/api has to be synced with the version of
    // @opentelemetry/tracing that is used, and we don't want to force users to use
    // the version that is bundled with Next.js.
    // the API is ~stable, so this should be fine
    try {
        api = require('@opentelemetry/api');
    } catch (err) {
        api = require('next/dist/compiled/@opentelemetry/api');
    }
    const provider = api.trace.getTracerProvider();
    // When Cache Components is enabled we need to instrument the tracer
    // to exit the workUnitAsyncStorage context when generating spans.
    const originalGetTracer = provider.getTracer.bind(provider);
    provider.getTracer = (...args)=>{
        const tracer = originalGetTracer.apply(provider, args);
        if (WeakTracers.has(tracer)) {
            return tracer;
        }
        const originalStartSpan = tracer.startSpan;
        tracer.startSpan = (...startSpanArgs)=>{
            return workUnitAsyncStorage.exit(()=>originalStartSpan.apply(tracer, startSpanArgs));
        };
        const originalStartActiveSpan = tracer.startActiveSpan;
        // @ts-ignore TS doesn't recognize the overloads correctly
        tracer.startActiveSpan = (...startActiveSpanArgs)=>{
            const workUnitStore = workUnitAsyncStorage.getStore();
            if (!workUnitStore) {
                // @ts-ignore TS doesn't recognize the overloads correctly
                return originalStartActiveSpan.apply(tracer, startActiveSpanArgs);
            }
            let fnIdx = 0;
            if (startActiveSpanArgs.length === 2 && typeof startActiveSpanArgs[1] === 'function') {
                fnIdx = 1;
            } else if (startActiveSpanArgs.length === 3 && typeof startActiveSpanArgs[2] === 'function') {
                fnIdx = 2;
            } else if (startActiveSpanArgs.length > 3 && typeof startActiveSpanArgs[3] === 'function') {
                fnIdx = 3;
            }
            if (fnIdx) {
                const originalFn = startActiveSpanArgs[fnIdx];
                if (isUseCacheFunction(originalFn)) {
                    console.error('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.');
                }
                startActiveSpanArgs[fnIdx] = withWorkUnitContext(workUnitStore, originalFn);
            }
            return workUnitAsyncStorage.exit(()=>{
                // @ts-ignore TS doesn't recognize the overloads correctly
                return originalStartActiveSpan.apply(tracer, startActiveSpanArgs);
            });
        };
        WeakTracers.add(tracer);
        return tracer;
    };
}
const WeakTracers = new WeakSet();
function withWorkUnitContext(workUnitStore, fn) {
    return (...args)=>workUnitAsyncStorage.run(workUnitStore, fn, ...args);
}

//# sourceMappingURL=instrumentation-node-extensions.js.map

cmd: