{"version":3,"file":"unified-request-context.js","names":[],"sources":["../../src/shims/unified-request-context.ts"],"sourcesContent":["/**\n * Unified per-request context backed by a single AsyncLocalStorage.\n *\n * Consolidates the 5–6 nested ALS scopes that previously wrapped every\n * App Router request (headers, navigation, cache-state, private-cache,\n * fetch-cache, execution-context) into one flat store.\n *\n * Each shim module checks `isInsideUnifiedScope()` and reads its sub-fields\n * from the unified store, falling back to its own standalone ALS when\n * outside (SSR environment, Pages Router, tests).\n */\n\nimport type { AsyncLocalStorage } from \"node:async_hooks\";\nimport { getOrCreateAls } from \"./internal/als-registry.js\";\nimport type {\n  CacheState,\n  ExecutionContextLike,\n  FetchCacheState,\n  HeadState,\n  I18nState,\n  NavigationState,\n  PrivateCacheState,\n  RouterState,\n  RootParamsState,\n  VinextHeadersShimState,\n} from \"./request-state-types.js\";\n\n// ---------------------------------------------------------------------------\n// Unified context shape\n// ---------------------------------------------------------------------------\n\n/**\n * Flat union of all per-request state previously spread across\n * VinextHeadersShimState, NavigationState, CacheState, PrivateCacheState,\n * FetchCacheState, and ExecutionContextLike.\n *\n * Each field group is documented with its source shim module.\n */\nexport type UnifiedRequestContext = {\n  // ── request-context.ts ─────────────────────────────────────────────\n  /** Cloudflare Workers ExecutionContext, or null on Node.js dev. */\n  executionContext: ExecutionContextLike | null;\n\n  // ── cache-for-request.ts ──────────────────────────────────────────\n  /** Per-request cache for cacheForRequest(). Keyed by factory function reference. */\n  // oxlint-disable-next-line @typescript-eslint/no-explicit-any\n  requestCache: WeakMap<(...args: any[]) => any, unknown>;\n} & VinextHeadersShimState &\n  I18nState &\n  NavigationState &\n  CacheState &\n  PrivateCacheState &\n  FetchCacheState &\n  RouterState &\n  HeadState &\n  RootParamsState;\n\n// ---------------------------------------------------------------------------\n// ALS setup — stored on globalThis via Symbol.for so all Vite environments\n// (RSC/SSR/client) share the same instance.\n// ---------------------------------------------------------------------------\n\nconst _REQUEST_CONTEXT_ALS_KEY = Symbol.for(\"vinext.requestContext.als\");\nconst _g = globalThis as unknown as Record<PropertyKey, unknown>;\nconst _als = getOrCreateAls<UnifiedRequestContext>(\"vinext.unifiedRequestContext.als\");\n\nfunction _getInheritedExecutionContext(): ExecutionContextLike | null {\n  const unifiedStore = _als.getStore();\n  if (unifiedStore) return unifiedStore.executionContext;\n\n  const executionContextAls = _g[_REQUEST_CONTEXT_ALS_KEY] as\n    | AsyncLocalStorage<ExecutionContextLike | null>\n    | undefined;\n  return executionContextAls?.getStore() ?? null;\n}\n\n// ---------------------------------------------------------------------------\n// Public API\n// ---------------------------------------------------------------------------\n\n/**\n * Create a fresh `UnifiedRequestContext` with defaults for all fields.\n * Pass partial overrides for the fields you need to pre-populate.\n */\nexport function createRequestContext(opts?: Partial<UnifiedRequestContext>): UnifiedRequestContext {\n  return {\n    headersContext: null,\n    actionRevalidationKind: 0,\n    dynamicUsageDetected: false,\n    invalidDynamicUsageError: null,\n    pendingSetCookies: [],\n    draftModeCookieHeader: null,\n    phase: \"render\",\n    i18nContext: null,\n    serverContext: null,\n    serverInsertedHTMLCallbacks: [],\n    requestScopedCacheLife: null,\n    unstableCacheRevalidation: \"foreground\",\n    _privateCache: null,\n    currentRequestTags: [],\n    currentFetchSoftTags: [],\n    currentFetchCacheMode: null,\n    isFetchDedupeActive: false,\n    currentFetchDedupeEntries: new Map(),\n    executionContext: _getInheritedExecutionContext(), // inherits from standalone ALS if present\n    requestCache: new WeakMap(),\n    ssrContext: null,\n    ssrHeadChildren: [],\n    rootParams: null,\n    ...opts,\n  };\n}\n\n/**\n * Run `fn` within a unified request context scope.\n * All shim modules will read/write their state from `ctx` for the\n * duration of the call, including async continuations.\n */\nexport function runWithRequestContext<T>(\n  ctx: UnifiedRequestContext,\n  fn: () => Promise<T>,\n): Promise<T>;\nexport function runWithRequestContext<T>(\n  ctx: UnifiedRequestContext,\n  fn: () => T | Promise<T>,\n): T | Promise<T>;\nexport function runWithRequestContext<T>(\n  ctx: UnifiedRequestContext,\n  fn: () => T | Promise<T>,\n): T | Promise<T> {\n  return _als.run(ctx, fn);\n}\n\n/**\n * Run `fn` in a nested unified scope derived from the current request context.\n * Used by legacy runWith* wrappers to reset or override one sub-state while\n * preserving proper async isolation for continuations created inside `fn`.\n * The child scope is a shallow clone of the parent store, so untouched fields\n * keep sharing their existing references while overridden slices can be reset.\n *\n * @internal\n */\nexport function runWithUnifiedStateMutation<T>(\n  mutate: (ctx: UnifiedRequestContext) => void,\n  fn: () => Promise<T>,\n): Promise<T>;\nexport function runWithUnifiedStateMutation<T>(\n  mutate: (ctx: UnifiedRequestContext) => void,\n  fn: () => T | Promise<T>,\n): T | Promise<T>;\nexport function runWithUnifiedStateMutation<T>(\n  mutate: (ctx: UnifiedRequestContext) => void,\n  fn: () => T | Promise<T>,\n): T | Promise<T> {\n  const parentCtx = _als.getStore();\n  if (!parentCtx) return fn();\n\n  const childCtx = { ...parentCtx };\n  // NOTE: This is a shallow clone. Array fields (pendingSetCookies,\n  // serverInsertedHTMLCallbacks, currentRequestTags, ssrHeadChildren), the\n  // _privateCache Map, requestCache WeakMap, and object fields (headersContext,\n  // i18nContext, serverContext, ssrContext, executionContext,\n  // requestScopedCacheLife) still share references with the parent until\n  // replaced. requestCache is intentionally shared — nested scopes within\n  // the same request should see the same cached values. The mutate\n  // callback must replace those reference-typed slices (for example\n  // `ctx.currentRequestTags = []`) rather than mutating them in-place (for\n  // example `ctx.currentRequestTags.push(...)`) or the parent scope will\n  // observe those changes too. Keep this enumeration in sync with\n  // UnifiedRequestContext: when adding a new reference-typed field, add it\n  // here too and verify callers still follow the replace-not-mutate rule.\n  mutate(childCtx);\n  return _als.run(childCtx, fn);\n}\n\n/**\n * Get the current unified request context.\n * Returns the ALS store when inside a `runWithRequestContext()` scope,\n * or a fresh detached context otherwise. Unlike the legacy per-shim fallback\n * singletons, this detached value is ephemeral — mutations do not persist\n * across calls. This is intentional to prevent state leakage outside request\n * scopes.\n *\n * Only direct callers observe this detached fallback. Shim `_getState()`\n * helpers should continue to gate on `isInsideUnifiedScope()` and fall back\n * to their standalone ALS/fallback singletons outside the unified scope.\n * If called inside a standalone `runWithExecutionContext()` scope, the\n * detached context still reflects that inherited `executionContext`.\n */\nexport function getRequestContext(): UnifiedRequestContext {\n  return _als.getStore() ?? createRequestContext();\n}\n\n/**\n * Check whether the current execution is inside a `runWithRequestContext()` scope.\n * Shim modules use this to decide whether to read from the unified store\n * or fall back to their own standalone ALS.\n */\nexport function isInsideUnifiedScope(): boolean {\n  return _als.getStore() != null;\n}\n"],"mappings":";;AA8DA,MAAM,2BAA2B,OAAO,IAAI,4BAA4B;AACxE,MAAM,KAAK;AACX,MAAM,OAAO,eAAsC,mCAAmC;AAEtF,SAAS,gCAA6D;CACpE,MAAM,eAAe,KAAK,UAAU;CACpC,IAAI,cAAc,OAAO,aAAa;CAKtC,OAH4B,GAAG,2BAGH,UAAU,IAAI;;;;;;AAW5C,SAAgB,qBAAqB,MAA8D;CACjG,OAAO;EACL,gBAAgB;EAChB,wBAAwB;EACxB,sBAAsB;EACtB,0BAA0B;EAC1B,mBAAmB,EAAE;EACrB,uBAAuB;EACvB,OAAO;EACP,aAAa;EACb,eAAe;EACf,6BAA6B,EAAE;EAC/B,wBAAwB;EACxB,2BAA2B;EAC3B,eAAe;EACf,oBAAoB,EAAE;EACtB,sBAAsB,EAAE;EACxB,uBAAuB;EACvB,qBAAqB;EACrB,2CAA2B,IAAI,KAAK;EACpC,kBAAkB,+BAA+B;EACjD,8BAAc,IAAI,SAAS;EAC3B,YAAY;EACZ,iBAAiB,EAAE;EACnB,YAAY;EACZ,GAAG;EACJ;;AAgBH,SAAgB,sBACd,KACA,IACgB;CAChB,OAAO,KAAK,IAAI,KAAK,GAAG;;AAoB1B,SAAgB,4BACd,QACA,IACgB;CAChB,MAAM,YAAY,KAAK,UAAU;CACjC,IAAI,CAAC,WAAW,OAAO,IAAI;CAE3B,MAAM,WAAW,EAAE,GAAG,WAAW;CAcjC,OAAO,SAAS;CAChB,OAAO,KAAK,IAAI,UAAU,GAAG;;;;;;;;;;;;;;;;AAiB/B,SAAgB,oBAA2C;CACzD,OAAO,KAAK,UAAU,IAAI,sBAAsB;;;;;;;AAQlD,SAAgB,uBAAgC;CAC9C,OAAO,KAAK,UAAU,IAAI"}