Big News: Socket raises $60M Series C at a $1B valuation to secure software supply chains for AI-driven development.Announcement
Sign In

@tanstack/start-server-core

Package Overview
Dependencies
Maintainers
5
Versions
436
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

@tanstack/start-server-core - npm Package Compare versions

Comparing version
1.168.0
to
1.168.1
+42
dist/esm/finalManifest.d.ts
import { Manifest } from '@tanstack/router-core';
import { HandlerInlineCssOption } from './inlineCss.js';
import { StartManifestWithClientEntry, TransformAssets } from './transformAssetUrls.js';
export type { HandlerInlineCssOption, StartManifestWithClientEntry, TransformAssets, };
export interface FinalManifestOptions {
/**
* Controls whether Start inlines build-collected CSS by default at runtime.
*
* This only has an effect when the build was created with
* `server.build.inlineCss` enabled. Pass a callback to decide per request.
* `handler(request, { inlineCss })` overrides this value for that request.
*
* @default true
*/
inlineCss?: HandlerInlineCssOption;
/**
* Transform manifest-managed asset URLs and attributes at runtime, e.g. to
* prepend a CDN prefix.
*
* This covers JS preloads, CSS links, the client entry script, and URLs
* inside build-collected inline CSS. Asset imports used directly in
* components should be handled by the bundler instead.
*/
transformAssets?: TransformAssets;
}
export type GetBaseManifest = () => Promise<StartManifestWithClientEntry>;
export interface FinalManifestRequestOptions {
request: Request;
requestInlineCss: boolean | undefined;
getBaseManifest: GetBaseManifest;
}
export interface FinalManifestResolver {
warmup: (opts: {
getBaseManifest: GetBaseManifest;
}) => Promise<Manifest> | undefined;
resolveCached: (opts: FinalManifestRequestOptions) => Promise<Manifest>;
resolveUncached: (opts: FinalManifestRequestOptions) => Promise<Manifest>;
}
export declare function createCachedBaseManifestLoader(loadBaseManifest: GetBaseManifest): GetBaseManifest;
export declare function createFinalManifestResolver(opts: FinalManifestOptions & {
cacheCreateTransform: boolean;
}): FinalManifestResolver;
import { buildManifestWithClientEntry, resolveTransformAssetsConfig, transformManifestAssets } from "./transformAssetUrls.js";
import { getStaticHandlerInlineCssDefault, resolveInlineCssForRequest } from "./inlineCss.js";
//#region src/finalManifest.ts
function createCachedBaseManifestLoader(loadBaseManifest) {
let baseManifestPromise;
return () => {
if (!baseManifestPromise) baseManifestPromise = loadBaseManifest().catch((error) => {
baseManifestPromise = void 0;
throw error;
});
return baseManifestPromise;
};
}
function createFinalManifestTransformResolver(transformAssets, opts) {
const transformConfig = transformAssets !== void 0 ? resolveTransformAssetsConfig(transformAssets) : void 0;
const cache = transformConfig ? transformConfig.cache : true;
const warmup = !!transformAssets && typeof transformAssets === "object" && "warmup" in transformAssets && transformAssets.warmup === true;
let cachedCreateTransformPromise;
const clearCachedCreateTransform = () => {
cachedCreateTransformPromise = void 0;
};
return {
cache,
warmup,
clearCachedCreateTransform,
getTransformFn: async (ctx) => {
if (!transformConfig) return void 0;
if (transformConfig.type !== "createTransform") return transformConfig.transformFn;
if (!cache || !opts.cacheCreateTransform) return transformConfig.createTransform(ctx);
if (!cachedCreateTransformPromise) cachedCreateTransformPromise = Promise.resolve(transformConfig.createTransform(ctx)).catch((error) => {
clearCachedCreateTransform();
throw error;
});
return cachedCreateTransformPromise;
}
};
}
function createFinalManifestResolver(opts) {
const finalManifestCache = /* @__PURE__ */ new Map();
const transformResolver = createFinalManifestTransformResolver(opts.transformAssets, { cacheCreateTransform: opts.cacheCreateTransform });
const handlerDefaultInlineCss = getStaticHandlerInlineCssDefault(opts.inlineCss);
const getRequestManifestOptions = async (requestOpts) => {
const transformFn = await transformResolver.getTransformFn({
warmup: false,
request: requestOpts.request
});
const inlineCss = await resolveInlineCssForRequest({
request: requestOpts.request,
handlerInlineCss: opts.inlineCss,
requestInlineCss: requestOpts.requestInlineCss
});
return {
getBaseManifest: requestOpts.getBaseManifest,
transformFn,
cache: transformResolver.cache,
inlineCss
};
};
const resolveRequest = async (requestOpts, cache) => {
return resolveFinalManifest({
...await getRequestManifestOptions(requestOpts),
finalManifestCache: cache
});
};
return {
warmup: ({ getBaseManifest }) => warmupFinalManifest({
enabled: transformResolver.warmup,
handlerDefaultInlineCss,
cache: transformResolver.cache,
finalManifestCache,
getBaseManifest,
getTransformFn: () => transformResolver.getTransformFn({ warmup: true }),
onError: transformResolver.clearCachedCreateTransform
}),
resolveCached: (requestOpts) => resolveRequest(requestOpts, finalManifestCache),
resolveUncached: (requestOpts) => resolveRequest(requestOpts, void 0)
};
}
function getFinalManifestCacheKey(inlineCss) {
return inlineCss ? "inline-css" : "linked-css";
}
function cacheFinalManifestPromise(cachedFinalManifestPromises, cacheKey, promise) {
const cachedFinalManifestPromise = promise.catch((error) => {
if (cachedFinalManifestPromises.get(cacheKey) === cachedFinalManifestPromise) cachedFinalManifestPromises.delete(cacheKey);
throw error;
});
cachedFinalManifestPromises.set(cacheKey, cachedFinalManifestPromise);
return cachedFinalManifestPromise;
}
function getOrCreateCachedFinalManifestPromise(cachedFinalManifestPromises, cacheKey, computeFinalManifest) {
const cachedFinalManifestPromise = cachedFinalManifestPromises.get(cacheKey);
if (cachedFinalManifestPromise) return cachedFinalManifestPromise;
return cacheFinalManifestPromise(cachedFinalManifestPromises, cacheKey, Promise.resolve().then(computeFinalManifest));
}
async function buildFinalManifest(opts) {
return opts.transformFn ? await transformManifestAssets(opts.base, opts.transformFn, { inlineCss: opts.inlineCss }) : buildManifestWithClientEntry(opts.base, { inlineCss: opts.inlineCss });
}
async function resolveFinalManifest(opts) {
const computeFinalManifest = async () => {
return buildFinalManifest({
base: await opts.getBaseManifest(),
transformFn: opts.transformFn,
inlineCss: opts.inlineCss
});
};
if (opts.finalManifestCache && (!opts.transformFn || opts.cache)) return getOrCreateCachedFinalManifestPromise(opts.finalManifestCache, getFinalManifestCacheKey(opts.inlineCss), computeFinalManifest);
return computeFinalManifest();
}
function warmupFinalManifest(opts) {
if (!opts.enabled || opts.handlerDefaultInlineCss === void 0 || !opts.cache) return;
const inlineCss = opts.handlerDefaultInlineCss;
const warmupPromise = getOrCreateCachedFinalManifestPromise(opts.finalManifestCache, getFinalManifestCacheKey(inlineCss), async () => {
const [base, transformFn] = await Promise.all([opts.getBaseManifest(), opts.getTransformFn()]);
return buildFinalManifest({
base,
transformFn,
inlineCss
});
});
if (opts.onError) warmupPromise.catch(opts.onError);
return warmupPromise;
}
//#endregion
export { createCachedBaseManifestLoader, createFinalManifestResolver };
//# sourceMappingURL=finalManifest.js.map
{"version":3,"file":"finalManifest.js","names":[],"sources":["../../src/finalManifest.ts"],"sourcesContent":["import {\n buildManifestWithClientEntry,\n resolveTransformAssetsConfig,\n transformManifestAssets,\n} from './transformAssetUrls'\nimport {\n getStaticHandlerInlineCssDefault,\n resolveInlineCssForRequest,\n} from './inlineCss'\nimport type { Manifest } from '@tanstack/router-core'\nimport type { HandlerInlineCssOption } from './inlineCss'\nimport type {\n CreateTransformAssetsContext,\n StartManifestWithClientEntry,\n TransformAssets,\n TransformAssetsFn,\n} from './transformAssetUrls'\n\nexport type {\n HandlerInlineCssOption,\n StartManifestWithClientEntry,\n TransformAssets,\n}\n\nexport interface FinalManifestOptions {\n /**\n * Controls whether Start inlines build-collected CSS by default at runtime.\n *\n * This only has an effect when the build was created with\n * `server.build.inlineCss` enabled. Pass a callback to decide per request.\n * `handler(request, { inlineCss })` overrides this value for that request.\n *\n * @default true\n */\n inlineCss?: HandlerInlineCssOption\n /**\n * Transform manifest-managed asset URLs and attributes at runtime, e.g. to\n * prepend a CDN prefix.\n *\n * This covers JS preloads, CSS links, the client entry script, and URLs\n * inside build-collected inline CSS. Asset imports used directly in\n * components should be handled by the bundler instead.\n */\n transformAssets?: TransformAssets\n}\n\ntype FinalManifestCacheKey = 'inline-css' | 'linked-css'\ntype FinalManifestCache = Map<FinalManifestCacheKey, Promise<Manifest>>\nexport type GetBaseManifest = () => Promise<StartManifestWithClientEntry>\n\nexport interface FinalManifestRequestOptions {\n request: Request\n requestInlineCss: boolean | undefined\n getBaseManifest: GetBaseManifest\n}\n\ninterface FinalManifestTransformResolver {\n cache: boolean\n warmup: boolean\n getTransformFn: (\n ctx: CreateTransformAssetsContext,\n ) => Promise<TransformAssetsFn | undefined>\n clearCachedCreateTransform: () => void\n}\n\nexport interface FinalManifestResolver {\n warmup: (opts: {\n getBaseManifest: GetBaseManifest\n }) => Promise<Manifest> | undefined\n resolveCached: (opts: FinalManifestRequestOptions) => Promise<Manifest>\n resolveUncached: (opts: FinalManifestRequestOptions) => Promise<Manifest>\n}\n\nexport function createCachedBaseManifestLoader(\n loadBaseManifest: GetBaseManifest,\n): GetBaseManifest {\n let baseManifestPromise: Promise<StartManifestWithClientEntry> | undefined\n\n return () => {\n if (!baseManifestPromise) {\n baseManifestPromise = loadBaseManifest().catch((error) => {\n baseManifestPromise = undefined\n throw error\n })\n }\n\n return baseManifestPromise\n }\n}\n\nfunction createFinalManifestTransformResolver(\n transformAssets: TransformAssets | undefined,\n opts: { cacheCreateTransform: boolean },\n): FinalManifestTransformResolver {\n const transformConfig =\n transformAssets !== undefined\n ? resolveTransformAssetsConfig(transformAssets)\n : undefined\n const cache = transformConfig ? transformConfig.cache : true\n const warmup =\n !!transformAssets &&\n typeof transformAssets === 'object' &&\n 'warmup' in transformAssets &&\n transformAssets.warmup === true\n\n let cachedCreateTransformPromise: Promise<TransformAssetsFn> | undefined\n\n const clearCachedCreateTransform = () => {\n cachedCreateTransformPromise = undefined\n }\n\n return {\n cache,\n warmup,\n clearCachedCreateTransform,\n getTransformFn: async (ctx) => {\n if (!transformConfig) return undefined\n\n if (transformConfig.type !== 'createTransform') {\n return transformConfig.transformFn\n }\n\n if (!cache || !opts.cacheCreateTransform) {\n return transformConfig.createTransform(ctx)\n }\n\n if (!cachedCreateTransformPromise) {\n cachedCreateTransformPromise = Promise.resolve(\n transformConfig.createTransform(ctx),\n ).catch((error) => {\n clearCachedCreateTransform()\n throw error\n })\n }\n\n return cachedCreateTransformPromise\n },\n }\n}\n\nexport function createFinalManifestResolver(\n opts: FinalManifestOptions & { cacheCreateTransform: boolean },\n): FinalManifestResolver {\n const finalManifestCache: FinalManifestCache = new Map()\n const transformResolver = createFinalManifestTransformResolver(\n opts.transformAssets,\n { cacheCreateTransform: opts.cacheCreateTransform },\n )\n const handlerDefaultInlineCss = getStaticHandlerInlineCssDefault(\n opts.inlineCss,\n )\n\n const getRequestManifestOptions = async (\n requestOpts: FinalManifestRequestOptions,\n ) => {\n const transformFn = await transformResolver.getTransformFn({\n warmup: false,\n request: requestOpts.request,\n })\n const inlineCss = await resolveInlineCssForRequest({\n request: requestOpts.request,\n handlerInlineCss: opts.inlineCss,\n requestInlineCss: requestOpts.requestInlineCss,\n })\n\n return {\n getBaseManifest: requestOpts.getBaseManifest,\n transformFn,\n cache: transformResolver.cache,\n inlineCss,\n }\n }\n\n const resolveRequest = async (\n requestOpts: FinalManifestRequestOptions,\n cache: FinalManifestCache | undefined,\n ) => {\n return resolveFinalManifest({\n ...(await getRequestManifestOptions(requestOpts)),\n finalManifestCache: cache,\n })\n }\n\n return {\n warmup: ({ getBaseManifest }) =>\n warmupFinalManifest({\n enabled: transformResolver.warmup,\n handlerDefaultInlineCss,\n cache: transformResolver.cache,\n finalManifestCache,\n getBaseManifest,\n getTransformFn: () =>\n transformResolver.getTransformFn({ warmup: true }),\n onError: transformResolver.clearCachedCreateTransform,\n }),\n resolveCached: (requestOpts) =>\n resolveRequest(requestOpts, finalManifestCache),\n resolveUncached: (requestOpts) => resolveRequest(requestOpts, undefined),\n }\n}\n\nfunction getFinalManifestCacheKey(inlineCss: boolean): FinalManifestCacheKey {\n return inlineCss ? 'inline-css' : 'linked-css'\n}\n\nfunction cacheFinalManifestPromise(\n cachedFinalManifestPromises: FinalManifestCache,\n cacheKey: FinalManifestCacheKey,\n promise: Promise<Manifest>,\n): Promise<Manifest> {\n const cachedFinalManifestPromise = promise.catch((error) => {\n if (\n cachedFinalManifestPromises.get(cacheKey) === cachedFinalManifestPromise\n ) {\n cachedFinalManifestPromises.delete(cacheKey)\n }\n throw error\n })\n\n cachedFinalManifestPromises.set(cacheKey, cachedFinalManifestPromise)\n return cachedFinalManifestPromise\n}\n\nfunction getOrCreateCachedFinalManifestPromise(\n cachedFinalManifestPromises: FinalManifestCache,\n cacheKey: FinalManifestCacheKey,\n computeFinalManifest: () => Promise<Manifest>,\n): Promise<Manifest> {\n const cachedFinalManifestPromise = cachedFinalManifestPromises.get(cacheKey)\n if (cachedFinalManifestPromise) {\n return cachedFinalManifestPromise\n }\n\n return cacheFinalManifestPromise(\n cachedFinalManifestPromises,\n cacheKey,\n Promise.resolve().then(computeFinalManifest),\n )\n}\n\nasync function buildFinalManifest(opts: {\n base: StartManifestWithClientEntry\n transformFn: TransformAssetsFn | undefined\n inlineCss: boolean\n}): Promise<Manifest> {\n return opts.transformFn\n ? await transformManifestAssets(opts.base, opts.transformFn, {\n inlineCss: opts.inlineCss,\n })\n : buildManifestWithClientEntry(opts.base, { inlineCss: opts.inlineCss })\n}\n\nasync function resolveFinalManifest(opts: {\n getBaseManifest: () => Promise<StartManifestWithClientEntry>\n transformFn: TransformAssetsFn | undefined\n cache: boolean\n inlineCss: boolean\n finalManifestCache?: FinalManifestCache\n}): Promise<Manifest> {\n const computeFinalManifest = async () => {\n return buildFinalManifest({\n base: await opts.getBaseManifest(),\n transformFn: opts.transformFn,\n inlineCss: opts.inlineCss,\n })\n }\n\n if (opts.finalManifestCache && (!opts.transformFn || opts.cache)) {\n return getOrCreateCachedFinalManifestPromise(\n opts.finalManifestCache,\n getFinalManifestCacheKey(opts.inlineCss),\n computeFinalManifest,\n )\n }\n\n return computeFinalManifest()\n}\n\nfunction warmupFinalManifest(opts: {\n enabled: boolean\n handlerDefaultInlineCss: boolean | undefined\n cache: boolean\n finalManifestCache: FinalManifestCache\n getBaseManifest: () => Promise<StartManifestWithClientEntry>\n getTransformFn: () => Promise<TransformAssetsFn | undefined>\n onError?: () => void\n}): Promise<Manifest> | undefined {\n if (\n !opts.enabled ||\n opts.handlerDefaultInlineCss === undefined ||\n !opts.cache\n ) {\n return undefined\n }\n\n const inlineCss = opts.handlerDefaultInlineCss\n const warmupPromise = getOrCreateCachedFinalManifestPromise(\n opts.finalManifestCache,\n getFinalManifestCacheKey(inlineCss),\n async () => {\n const [base, transformFn] = await Promise.all([\n opts.getBaseManifest(),\n opts.getTransformFn(),\n ])\n\n return buildFinalManifest({\n base,\n transformFn,\n inlineCss,\n })\n },\n )\n\n if (opts.onError) {\n void warmupPromise.catch(opts.onError)\n }\n\n return warmupPromise\n}\n"],"mappings":";;;AAyEA,SAAgB,+BACd,kBACiB;CACjB,IAAI;AAEJ,cAAa;AACX,MAAI,CAAC,oBACH,uBAAsB,kBAAkB,CAAC,OAAO,UAAU;AACxD,yBAAsB,KAAA;AACtB,SAAM;IACN;AAGJ,SAAO;;;AAIX,SAAS,qCACP,iBACA,MACgC;CAChC,MAAM,kBACJ,oBAAoB,KAAA,IAChB,6BAA6B,gBAAgB,GAC7C,KAAA;CACN,MAAM,QAAQ,kBAAkB,gBAAgB,QAAQ;CACxD,MAAM,SACJ,CAAC,CAAC,mBACF,OAAO,oBAAoB,YAC3B,YAAY,mBACZ,gBAAgB,WAAW;CAE7B,IAAI;CAEJ,MAAM,mCAAmC;AACvC,iCAA+B,KAAA;;AAGjC,QAAO;EACL;EACA;EACA;EACA,gBAAgB,OAAO,QAAQ;AAC7B,OAAI,CAAC,gBAAiB,QAAO,KAAA;AAE7B,OAAI,gBAAgB,SAAS,kBAC3B,QAAO,gBAAgB;AAGzB,OAAI,CAAC,SAAS,CAAC,KAAK,qBAClB,QAAO,gBAAgB,gBAAgB,IAAI;AAG7C,OAAI,CAAC,6BACH,gCAA+B,QAAQ,QACrC,gBAAgB,gBAAgB,IAAI,CACrC,CAAC,OAAO,UAAU;AACjB,gCAA4B;AAC5B,UAAM;KACN;AAGJ,UAAO;;EAEV;;AAGH,SAAgB,4BACd,MACuB;CACvB,MAAM,qCAAyC,IAAI,KAAK;CACxD,MAAM,oBAAoB,qCACxB,KAAK,iBACL,EAAE,sBAAsB,KAAK,sBAAsB,CACpD;CACD,MAAM,0BAA0B,iCAC9B,KAAK,UACN;CAED,MAAM,4BAA4B,OAChC,gBACG;EACH,MAAM,cAAc,MAAM,kBAAkB,eAAe;GACzD,QAAQ;GACR,SAAS,YAAY;GACtB,CAAC;EACF,MAAM,YAAY,MAAM,2BAA2B;GACjD,SAAS,YAAY;GACrB,kBAAkB,KAAK;GACvB,kBAAkB,YAAY;GAC/B,CAAC;AAEF,SAAO;GACL,iBAAiB,YAAY;GAC7B;GACA,OAAO,kBAAkB;GACzB;GACD;;CAGH,MAAM,iBAAiB,OACrB,aACA,UACG;AACH,SAAO,qBAAqB;GAC1B,GAAI,MAAM,0BAA0B,YAAY;GAChD,oBAAoB;GACrB,CAAC;;AAGJ,QAAO;EACL,SAAS,EAAE,sBACT,oBAAoB;GAClB,SAAS,kBAAkB;GAC3B;GACA,OAAO,kBAAkB;GACzB;GACA;GACA,sBACE,kBAAkB,eAAe,EAAE,QAAQ,MAAM,CAAC;GACpD,SAAS,kBAAkB;GAC5B,CAAC;EACJ,gBAAgB,gBACd,eAAe,aAAa,mBAAmB;EACjD,kBAAkB,gBAAgB,eAAe,aAAa,KAAA,EAAU;EACzE;;AAGH,SAAS,yBAAyB,WAA2C;AAC3E,QAAO,YAAY,eAAe;;AAGpC,SAAS,0BACP,6BACA,UACA,SACmB;CACnB,MAAM,6BAA6B,QAAQ,OAAO,UAAU;AAC1D,MACE,4BAA4B,IAAI,SAAS,KAAK,2BAE9C,6BAA4B,OAAO,SAAS;AAE9C,QAAM;GACN;AAEF,6BAA4B,IAAI,UAAU,2BAA2B;AACrE,QAAO;;AAGT,SAAS,sCACP,6BACA,UACA,sBACmB;CACnB,MAAM,6BAA6B,4BAA4B,IAAI,SAAS;AAC5E,KAAI,2BACF,QAAO;AAGT,QAAO,0BACL,6BACA,UACA,QAAQ,SAAS,CAAC,KAAK,qBAAqB,CAC7C;;AAGH,eAAe,mBAAmB,MAIZ;AACpB,QAAO,KAAK,cACR,MAAM,wBAAwB,KAAK,MAAM,KAAK,aAAa,EACzD,WAAW,KAAK,WACjB,CAAC,GACF,6BAA6B,KAAK,MAAM,EAAE,WAAW,KAAK,WAAW,CAAC;;AAG5E,eAAe,qBAAqB,MAMd;CACpB,MAAM,uBAAuB,YAAY;AACvC,SAAO,mBAAmB;GACxB,MAAM,MAAM,KAAK,iBAAiB;GAClC,aAAa,KAAK;GAClB,WAAW,KAAK;GACjB,CAAC;;AAGJ,KAAI,KAAK,uBAAuB,CAAC,KAAK,eAAe,KAAK,OACxD,QAAO,sCACL,KAAK,oBACL,yBAAyB,KAAK,UAAU,EACxC,qBACD;AAGH,QAAO,sBAAsB;;AAG/B,SAAS,oBAAoB,MAQK;AAChC,KACE,CAAC,KAAK,WACN,KAAK,4BAA4B,KAAA,KACjC,CAAC,KAAK,MAEN;CAGF,MAAM,YAAY,KAAK;CACvB,MAAM,gBAAgB,sCACpB,KAAK,oBACL,yBAAyB,UAAU,EACnC,YAAY;EACV,MAAM,CAAC,MAAM,eAAe,MAAM,QAAQ,IAAI,CAC5C,KAAK,iBAAiB,EACtB,KAAK,gBAAgB,CACtB,CAAC;AAEF,SAAO,mBAAmB;GACxB;GACA;GACA;GACD,CAAC;GAEL;AAED,KAAI,KAAK,QACF,eAAc,MAAM,KAAK,QAAQ;AAGxC,QAAO"}
import { Awaitable } from '@tanstack/router-core';
export type HandlerInlineCssOption = boolean | ((ctx: {
request: Request;
}) => Awaitable<boolean>);
export declare function getStaticHandlerInlineCssDefault(handlerInlineCss: HandlerInlineCssOption | undefined): boolean | undefined;
export declare function resolveInlineCssForRequest(opts: {
request: Request;
handlerInlineCss: HandlerInlineCssOption | undefined;
requestInlineCss: boolean | undefined;
}): Promise<boolean>;
//#region src/inlineCss.ts
function getStaticHandlerInlineCssDefault(handlerInlineCss) {
if (typeof handlerInlineCss === "function") return;
return handlerInlineCss ?? true;
}
async function resolveInlineCssForRequest(opts) {
if (opts.requestInlineCss !== void 0) return opts.requestInlineCss;
if (typeof opts.handlerInlineCss === "function") return await opts.handlerInlineCss({ request: opts.request });
return opts.handlerInlineCss ?? true;
}
//#endregion
export { getStaticHandlerInlineCssDefault, resolveInlineCssForRequest };
//# sourceMappingURL=inlineCss.js.map
{"version":3,"file":"inlineCss.js","names":[],"sources":["../../src/inlineCss.ts"],"sourcesContent":["import type { Awaitable } from '@tanstack/router-core'\n\nexport type HandlerInlineCssOption =\n | boolean\n | ((ctx: { request: Request }) => Awaitable<boolean>)\n\nexport function getStaticHandlerInlineCssDefault(\n handlerInlineCss: HandlerInlineCssOption | undefined,\n) {\n if (typeof handlerInlineCss === 'function') {\n return undefined\n }\n\n return handlerInlineCss ?? true\n}\n\nexport async function resolveInlineCssForRequest(opts: {\n request: Request\n handlerInlineCss: HandlerInlineCssOption | undefined\n requestInlineCss: boolean | undefined\n}) {\n if (opts.requestInlineCss !== undefined) {\n return opts.requestInlineCss\n }\n\n if (typeof opts.handlerInlineCss === 'function') {\n return await opts.handlerInlineCss({ request: opts.request })\n }\n\n return opts.handlerInlineCss ?? true\n}\n"],"mappings":";AAMA,SAAgB,iCACd,kBACA;AACA,KAAI,OAAO,qBAAqB,WAC9B;AAGF,QAAO,oBAAoB;;AAG7B,eAAsB,2BAA2B,MAI9C;AACD,KAAI,KAAK,qBAAqB,KAAA,EAC5B,QAAO,KAAK;AAGd,KAAI,OAAO,KAAK,qBAAqB,WACnC,QAAO,MAAM,KAAK,iBAAiB,EAAE,SAAS,KAAK,SAAS,CAAC;AAG/D,QAAO,KAAK,oBAAoB"}
import {
buildManifestWithClientEntry,
resolveTransformAssetsConfig,
transformManifestAssets,
} from './transformAssetUrls'
import {
getStaticHandlerInlineCssDefault,
resolveInlineCssForRequest,
} from './inlineCss'
import type { Manifest } from '@tanstack/router-core'
import type { HandlerInlineCssOption } from './inlineCss'
import type {
CreateTransformAssetsContext,
StartManifestWithClientEntry,
TransformAssets,
TransformAssetsFn,
} from './transformAssetUrls'
export type {
HandlerInlineCssOption,
StartManifestWithClientEntry,
TransformAssets,
}
export interface FinalManifestOptions {
/**
* Controls whether Start inlines build-collected CSS by default at runtime.
*
* This only has an effect when the build was created with
* `server.build.inlineCss` enabled. Pass a callback to decide per request.
* `handler(request, { inlineCss })` overrides this value for that request.
*
* @default true
*/
inlineCss?: HandlerInlineCssOption
/**
* Transform manifest-managed asset URLs and attributes at runtime, e.g. to
* prepend a CDN prefix.
*
* This covers JS preloads, CSS links, the client entry script, and URLs
* inside build-collected inline CSS. Asset imports used directly in
* components should be handled by the bundler instead.
*/
transformAssets?: TransformAssets
}
type FinalManifestCacheKey = 'inline-css' | 'linked-css'
type FinalManifestCache = Map<FinalManifestCacheKey, Promise<Manifest>>
export type GetBaseManifest = () => Promise<StartManifestWithClientEntry>
export interface FinalManifestRequestOptions {
request: Request
requestInlineCss: boolean | undefined
getBaseManifest: GetBaseManifest
}
interface FinalManifestTransformResolver {
cache: boolean
warmup: boolean
getTransformFn: (
ctx: CreateTransformAssetsContext,
) => Promise<TransformAssetsFn | undefined>
clearCachedCreateTransform: () => void
}
export interface FinalManifestResolver {
warmup: (opts: {
getBaseManifest: GetBaseManifest
}) => Promise<Manifest> | undefined
resolveCached: (opts: FinalManifestRequestOptions) => Promise<Manifest>
resolveUncached: (opts: FinalManifestRequestOptions) => Promise<Manifest>
}
export function createCachedBaseManifestLoader(
loadBaseManifest: GetBaseManifest,
): GetBaseManifest {
let baseManifestPromise: Promise<StartManifestWithClientEntry> | undefined
return () => {
if (!baseManifestPromise) {
baseManifestPromise = loadBaseManifest().catch((error) => {
baseManifestPromise = undefined
throw error
})
}
return baseManifestPromise
}
}
function createFinalManifestTransformResolver(
transformAssets: TransformAssets | undefined,
opts: { cacheCreateTransform: boolean },
): FinalManifestTransformResolver {
const transformConfig =
transformAssets !== undefined
? resolveTransformAssetsConfig(transformAssets)
: undefined
const cache = transformConfig ? transformConfig.cache : true
const warmup =
!!transformAssets &&
typeof transformAssets === 'object' &&
'warmup' in transformAssets &&
transformAssets.warmup === true
let cachedCreateTransformPromise: Promise<TransformAssetsFn> | undefined
const clearCachedCreateTransform = () => {
cachedCreateTransformPromise = undefined
}
return {
cache,
warmup,
clearCachedCreateTransform,
getTransformFn: async (ctx) => {
if (!transformConfig) return undefined
if (transformConfig.type !== 'createTransform') {
return transformConfig.transformFn
}
if (!cache || !opts.cacheCreateTransform) {
return transformConfig.createTransform(ctx)
}
if (!cachedCreateTransformPromise) {
cachedCreateTransformPromise = Promise.resolve(
transformConfig.createTransform(ctx),
).catch((error) => {
clearCachedCreateTransform()
throw error
})
}
return cachedCreateTransformPromise
},
}
}
export function createFinalManifestResolver(
opts: FinalManifestOptions & { cacheCreateTransform: boolean },
): FinalManifestResolver {
const finalManifestCache: FinalManifestCache = new Map()
const transformResolver = createFinalManifestTransformResolver(
opts.transformAssets,
{ cacheCreateTransform: opts.cacheCreateTransform },
)
const handlerDefaultInlineCss = getStaticHandlerInlineCssDefault(
opts.inlineCss,
)
const getRequestManifestOptions = async (
requestOpts: FinalManifestRequestOptions,
) => {
const transformFn = await transformResolver.getTransformFn({
warmup: false,
request: requestOpts.request,
})
const inlineCss = await resolveInlineCssForRequest({
request: requestOpts.request,
handlerInlineCss: opts.inlineCss,
requestInlineCss: requestOpts.requestInlineCss,
})
return {
getBaseManifest: requestOpts.getBaseManifest,
transformFn,
cache: transformResolver.cache,
inlineCss,
}
}
const resolveRequest = async (
requestOpts: FinalManifestRequestOptions,
cache: FinalManifestCache | undefined,
) => {
return resolveFinalManifest({
...(await getRequestManifestOptions(requestOpts)),
finalManifestCache: cache,
})
}
return {
warmup: ({ getBaseManifest }) =>
warmupFinalManifest({
enabled: transformResolver.warmup,
handlerDefaultInlineCss,
cache: transformResolver.cache,
finalManifestCache,
getBaseManifest,
getTransformFn: () =>
transformResolver.getTransformFn({ warmup: true }),
onError: transformResolver.clearCachedCreateTransform,
}),
resolveCached: (requestOpts) =>
resolveRequest(requestOpts, finalManifestCache),
resolveUncached: (requestOpts) => resolveRequest(requestOpts, undefined),
}
}
function getFinalManifestCacheKey(inlineCss: boolean): FinalManifestCacheKey {
return inlineCss ? 'inline-css' : 'linked-css'
}
function cacheFinalManifestPromise(
cachedFinalManifestPromises: FinalManifestCache,
cacheKey: FinalManifestCacheKey,
promise: Promise<Manifest>,
): Promise<Manifest> {
const cachedFinalManifestPromise = promise.catch((error) => {
if (
cachedFinalManifestPromises.get(cacheKey) === cachedFinalManifestPromise
) {
cachedFinalManifestPromises.delete(cacheKey)
}
throw error
})
cachedFinalManifestPromises.set(cacheKey, cachedFinalManifestPromise)
return cachedFinalManifestPromise
}
function getOrCreateCachedFinalManifestPromise(
cachedFinalManifestPromises: FinalManifestCache,
cacheKey: FinalManifestCacheKey,
computeFinalManifest: () => Promise<Manifest>,
): Promise<Manifest> {
const cachedFinalManifestPromise = cachedFinalManifestPromises.get(cacheKey)
if (cachedFinalManifestPromise) {
return cachedFinalManifestPromise
}
return cacheFinalManifestPromise(
cachedFinalManifestPromises,
cacheKey,
Promise.resolve().then(computeFinalManifest),
)
}
async function buildFinalManifest(opts: {
base: StartManifestWithClientEntry
transformFn: TransformAssetsFn | undefined
inlineCss: boolean
}): Promise<Manifest> {
return opts.transformFn
? await transformManifestAssets(opts.base, opts.transformFn, {
inlineCss: opts.inlineCss,
})
: buildManifestWithClientEntry(opts.base, { inlineCss: opts.inlineCss })
}
async function resolveFinalManifest(opts: {
getBaseManifest: () => Promise<StartManifestWithClientEntry>
transformFn: TransformAssetsFn | undefined
cache: boolean
inlineCss: boolean
finalManifestCache?: FinalManifestCache
}): Promise<Manifest> {
const computeFinalManifest = async () => {
return buildFinalManifest({
base: await opts.getBaseManifest(),
transformFn: opts.transformFn,
inlineCss: opts.inlineCss,
})
}
if (opts.finalManifestCache && (!opts.transformFn || opts.cache)) {
return getOrCreateCachedFinalManifestPromise(
opts.finalManifestCache,
getFinalManifestCacheKey(opts.inlineCss),
computeFinalManifest,
)
}
return computeFinalManifest()
}
function warmupFinalManifest(opts: {
enabled: boolean
handlerDefaultInlineCss: boolean | undefined
cache: boolean
finalManifestCache: FinalManifestCache
getBaseManifest: () => Promise<StartManifestWithClientEntry>
getTransformFn: () => Promise<TransformAssetsFn | undefined>
onError?: () => void
}): Promise<Manifest> | undefined {
if (
!opts.enabled ||
opts.handlerDefaultInlineCss === undefined ||
!opts.cache
) {
return undefined
}
const inlineCss = opts.handlerDefaultInlineCss
const warmupPromise = getOrCreateCachedFinalManifestPromise(
opts.finalManifestCache,
getFinalManifestCacheKey(inlineCss),
async () => {
const [base, transformFn] = await Promise.all([
opts.getBaseManifest(),
opts.getTransformFn(),
])
return buildFinalManifest({
base,
transformFn,
inlineCss,
})
},
)
if (opts.onError) {
void warmupPromise.catch(opts.onError)
}
return warmupPromise
}
import type { Awaitable } from '@tanstack/router-core'
export type HandlerInlineCssOption =
| boolean
| ((ctx: { request: Request }) => Awaitable<boolean>)
export function getStaticHandlerInlineCssDefault(
handlerInlineCss: HandlerInlineCssOption | undefined,
) {
if (typeof handlerInlineCss === 'function') {
return undefined
}
return handlerInlineCss ?? true
}
export async function resolveInlineCssForRequest(opts: {
request: Request
handlerInlineCss: HandlerInlineCssOption | undefined
requestInlineCss: boolean | undefined
}) {
if (opts.requestInlineCss !== undefined) {
return opts.requestInlineCss
}
if (typeof opts.handlerInlineCss === 'function') {
return await opts.handlerInlineCss({ request: opts.request })
}
return opts.handlerInlineCss ?? true
}
+2
-133
import { RequestHandler } from './request-handler.js';
import { AnyRouter, Register } from '@tanstack/router-core';
import { HandlerCallback } from '@tanstack/router-core/ssr/server';
import { TransformAssetUrls, TransformAssets } from './transformAssetUrls.js';
export interface CreateStartHandlerOptions {
import { FinalManifestOptions } from './finalManifest.js';
export interface CreateStartHandlerOptions extends FinalManifestOptions {
handler: HandlerCallback<AnyRouter>;
/**
* Transform asset URLs and attributes at runtime, e.g. to prepend a CDN prefix.
*
* **String** — a URL prefix prepended to every asset URL (cached by default):
* ```ts
* createStartHandler({
* handler: defaultStreamHandler,
* transformAssets: 'https://cdn.example.com',
* })
* ```
*
* **Object shorthand** — a URL prefix with optional `crossOrigin`:
* ```ts
* createStartHandler({
* handler: defaultStreamHandler,
* transformAssets: {
* prefix: 'https://cdn.example.com',
* crossOrigin: 'anonymous',
* },
* })
* ```
*
* `crossOrigin` accepts a single value or a per-kind record:
* ```ts
* transformAssets: {
* prefix: 'https://cdn.example.com',
* crossOrigin: {
* modulepreload: 'anonymous',
* stylesheet: 'use-credentials',
* },
* }
* ```
*
* **Callback** — receives `{ kind, url }` and returns either a string URL or
* `{ href, crossOrigin? }` (cached by default — runs once on first request):
* ```ts
* createStartHandler({
* handler: defaultStreamHandler,
* transformAssets: ({ kind, url }) => {
* const href = `https://cdn.example.com${url}`
*
* if (kind === 'modulepreload') {
* return { href, crossOrigin: 'anonymous' }
* }
*
* return { href }
* },
* })
* ```
*
* **Object** — for explicit cache control:
* ```ts
* createStartHandler({
* handler: defaultStreamHandler,
* transformAssets: {
* transform: ({ url }) => {
* const region = getRequest().headers.get('x-region') || 'us'
* return { href: `https://cdn-${region}.example.com${url}` }
* },
* cache: false,
* },
* })
* ```
*
* `kind` is one of `'modulepreload' | 'stylesheet' | 'clientEntry'`.
* `crossOrigin` applies to manifest-managed `<link>` assets.
*
* By default, the transformed manifest is cached after the first request
* (`cache: true`). Set `cache: false` for per-request transforms.
*
* If you're using a cached transform, you can optionally set `warmup: true`
* (object form only) to compute the transformed manifest in the background at
* server startup.
*
* Note: This only transforms URLs managed by TanStack Start's manifest
* (JS preloads, CSS links, and the client entry script). For asset imports
* used directly in components (e.g. `import logo from './logo.svg'`),
* configure Vite's `experimental.renderBuiltUrl` in your vite.config.ts.
*/
transformAssets?: TransformAssets;
/**
* @deprecated Use `transformAssets` instead.
*
* **String** — a URL prefix prepended to every asset URL (cached by default):
* ```ts
* createStartHandler({
* handler: defaultStreamHandler,
* transformAssetUrls: 'https://cdn.example.com',
* })
* ```
*
* **Callback** — receives `{ url, type }` and returns a new URL
* (cached by default — runs once on first request):
* ```ts
* createStartHandler({
* handler: defaultStreamHandler,
* transformAssetUrls: ({ url, type }) => {
* return `https://cdn.example.com${url}`
* },
* })
* ```
*
* **Object** — for explicit cache control:
* ```ts
* createStartHandler({
* handler: defaultStreamHandler,
* transformAssetUrls: {
* transform: ({ url }) => {
* const region = getRequest().headers.get('x-region') || 'us'
* return `https://cdn-${region}.example.com${url}`
* },
* cache: false, // transform per-request
* },
* })
* ```
*
* `type` is one of `'modulepreload' | 'stylesheet' | 'clientEntry'`.
*
* By default, the transformed manifest is cached after the first request
* (`cache: true`). Set `cache: false` for per-request transforms.
*
* If you're using a cached transform, you can optionally set `warmup: true`
* (object form only) to compute the transformed manifest in the background at
* server startup.
*
* Note: This only transforms URLs managed by TanStack Start's manifest
* (JS preloads, CSS links, and the client entry script). For asset imports
* used directly in components (e.g. `import logo from './logo.svg'`),
* configure Vite's `experimental.renderBuiltUrl` in your vite.config.ts.
*/
transformAssetUrls?: TransformAssetUrls;
}

@@ -139,0 +8,0 @@ /**

import { requestHandler } from "./request-response.js";
import { getStartManifest } from "./router-manifest.js";
import { handleServerAction } from "./server-functions-handler.js";
import { adaptTransformAssetUrlsConfigToTransformAssets, buildManifestWithClientEntry, resolveTransformAssetsConfig, transformManifestAssets } from "./transformAssetUrls.js";
import { collectDynamicHintsFromMatches, collectStaticHintsFromManifest, createEarlyHintsEvent, createResponseLinkHeaderEntries, getResponseLinkHeaderEntries } from "./early-hints.js";
import { createEarlyHintsCollector } from "./early-hints.js";
import { createCachedBaseManifestLoader, createFinalManifestResolver } from "./finalManifest.js";
import { HEADERS } from "./constants.js";

@@ -19,64 +19,9 @@ import { ServerFunctionSerializationAdapter } from "./serializer/ServerFunctionSerializationAdapter.js";

}
function notifyEarlyHints(phase, event, onEarlyHints) {
try {
const result = onEarlyHints(event);
if (result) Promise.resolve(result).catch((err) => {
console.error(`Error sending ${phase} early hints:`, err);
});
} catch (err) {
console.error(`Error sending ${phase} early hints:`, err);
}
}
function getResponseLinkHeaderFilter(responseLinkHeader) {
if (typeof responseLinkHeader !== "object") return;
return responseLinkHeader.filter;
}
function appendResponseLinkHeaders(opts) {
if (!opts.filter) {
for (const entry of opts.entries) opts.responseHeaders.append("Link", entry.link);
return;
}
const links = getResponseLinkHeaderEntries(opts);
for (const link of links) opts.responseHeaders.append("Link", link);
}
function collectResponseLinkHeaderEntries(opts) {
for (let index = 0; index < opts.event.hints.length; index++) opts.entries.push({
phase: opts.phase,
hint: opts.event.hints[index],
link: opts.event.links[index]
});
}
function handleCollectedEarlyHints(opts) {
const event = opts.onEarlyHints ? createEarlyHintsEvent({
phase: opts.phase,
hints: opts.hints,
sentLinks: opts.sentLinks,
sentHints: opts.sentHints
}) : void 0;
if (event) notifyEarlyHints(opts.phase, event, opts.onEarlyHints);
if (!opts.responseLinkHeaderEntries) return;
if (event) {
collectResponseLinkHeaderEntries({
phase: opts.phase,
event,
entries: opts.responseLinkHeaderEntries
});
return;
}
createResponseLinkHeaderEntries({
phase: opts.phase,
hints: opts.hints,
sentLinks: opts.sentLinks,
entries: opts.responseLinkHeaderEntries
});
}
var entriesPromise;
var baseManifestPromise;
var hasWarnedMissingCsrfMiddleware = false;
var defaultCsrfMiddleware = createCsrfMiddleware({ filter: (ctx) => ctx.handlerType === "serverFn" });
/**
* Cached final manifest (with client entry script tag). In production,
* this is computed once and reused for every request when caching is enabled.
*/
var cachedFinalManifestPromise;
var getCachedBaseManifest = createCachedBaseManifestLoader(() => getStartManifest());
var getProdBaseManifest = () => getCachedBaseManifest();
var getBaseManifest = process.env.TSS_DEV_SERVER === "true" ? getStartManifest : getProdBaseManifest;
var createEarlyHintsForRequest = process.env.TSS_DEV_SERVER === "true" ? () => void 0 : createEarlyHintsCollector;
async function loadEntries() {

@@ -126,30 +71,2 @@ const [routerEntry, startEntry, pluginAdapters] = await Promise.all([

}
/**
* Returns the raw manifest data (without client entry script tag baked in).
* In dev mode, always returns fresh data. In prod, cached.
*/
function getBaseManifest(matchedRoutes) {
if (process.env.TSS_DEV_SERVER === "true") return getStartManifest(matchedRoutes);
if (!baseManifestPromise) baseManifestPromise = getStartManifest();
return baseManifestPromise;
}
/**
* Resolves a final Manifest for a given request.
*
* - No transform: builds client entry script tag and returns (cached in prod).
* - Cached transform: transforms all URLs + builds script tag, caches result.
* - Per-request transform: deep-clones base manifest, transforms per-request.
*/
async function resolveManifest(matchedRoutes, transformFn, cache) {
const base = await getBaseManifest(matchedRoutes);
const computeFinalManifest = async () => {
return transformFn ? await transformManifestAssets(base, transformFn, { clone: !cache }) : buildManifestWithClientEntry(base);
};
if (process.env.TSS_DEV_SERVER === "true") return computeFinalManifest();
if (!transformFn || cache) {
if (!cachedFinalManifestPromise) cachedFinalManifestPromise = computeFinalManifest();
return cachedFinalManifestPromise;
}
return computeFinalManifest();
}
var ROUTER_BASEPATH = process.env.TSS_ROUTER_BASEPATH || "/";

@@ -261,37 +178,10 @@ var SERVER_FN_BASE = process.env.TSS_SERVER_FN_BASE;

function createStartHandler(cbOrOptions) {
const handlerOptions = typeof cbOrOptions === "function" ? {} : cbOrOptions;
const cb = typeof cbOrOptions === "function" ? cbOrOptions : cbOrOptions.handler;
const transformAssetsOption = typeof cbOrOptions === "function" ? void 0 : cbOrOptions.transformAssets;
const transformAssetUrlsOption = typeof cbOrOptions === "function" ? void 0 : cbOrOptions.transformAssetUrls;
const transformOption = transformAssetsOption !== void 0 ? resolveTransformAssetsConfig(transformAssetsOption) : transformAssetUrlsOption !== void 0 ? resolveTransformAssetsConfig(adaptTransformAssetUrlsConfigToTransformAssets(transformAssetUrlsOption)) : void 0;
const warmupTransformManifest = !!transformAssetsOption && typeof transformAssetsOption === "object" && "warmup" in transformAssetsOption && transformAssetsOption.warmup === true || !!transformAssetUrlsOption && typeof transformAssetUrlsOption === "object" && transformAssetUrlsOption.warmup === true;
const resolvedTransformConfig = transformOption;
const cache = resolvedTransformConfig ? resolvedTransformConfig.cache : true;
const shouldCacheCreateTransform = cache && process.env.TSS_DEV_SERVER !== "true";
let cachedCreateTransformPromise;
const getTransformFn = async (opts) => {
if (!resolvedTransformConfig) return void 0;
if (resolvedTransformConfig.type === "createTransform") {
if (shouldCacheCreateTransform) {
if (!cachedCreateTransformPromise) cachedCreateTransformPromise = Promise.resolve(resolvedTransformConfig.createTransform(opts)).catch((error) => {
cachedCreateTransformPromise = void 0;
throw error;
});
return cachedCreateTransformPromise;
}
return resolvedTransformConfig.createTransform(opts);
}
return resolvedTransformConfig.transformFn;
};
if (warmupTransformManifest && cache && process.env.TSS_DEV_SERVER !== "true" && !cachedFinalManifestPromise) {
const warmupPromise = (async () => {
const base = await getBaseManifest(void 0);
const transformFn = await getTransformFn({ warmup: true });
return transformFn ? await transformManifestAssets(base, transformFn, { clone: false }) : buildManifestWithClientEntry(base);
})();
cachedFinalManifestPromise = warmupPromise;
warmupPromise.catch(() => {
if (cachedFinalManifestPromise === warmupPromise) cachedFinalManifestPromise = void 0;
cachedCreateTransformPromise = void 0;
});
}
const finalManifestResolver = createFinalManifestResolver({
...handlerOptions,
cacheCreateTransform: process.env.TSS_DEV_SERVER !== "true"
});
const resolveManifestForRequest = process.env.TSS_DEV_SERVER === "true" ? finalManifestResolver.resolveUncached : finalManifestResolver.resolveCached;
if (process.env.TSS_DEV_SERVER !== "true") finalManifestResolver.warmup({ getBaseManifest: () => getBaseManifest(void 0) });
const startRequestResolver = async (request, requestOpts) => {

@@ -366,21 +256,15 @@ let router = null;

if (!["*/*", "text/html"].some((mimeType) => acceptParts.some((part) => part.trim().startsWith(mimeType)))) return Response.json({ error: "Only HTML requests are supported here" }, { status: 500 });
const manifest = await resolveManifest(matchedRoutes, await getTransformFn({
warmup: false,
request
}), cache);
const onEarlyHints = requestOpts?.onEarlyHints;
const responseLinkHeader = requestOpts?.responseLinkHeader;
const shouldCollectEarlyHints = process.env.TSS_DEV_SERVER !== "true" && (!!onEarlyHints || !!responseLinkHeader);
const sentEarlyHintLinks = shouldCollectEarlyHints ? /* @__PURE__ */ new Set() : void 0;
const sentEarlyHints = onEarlyHints ? new Array() : void 0;
const responseLinkHeaderEntries = shouldCollectEarlyHints && responseLinkHeader ? new Array() : void 0;
const responseLinkHeaderFilter = shouldCollectEarlyHints ? getResponseLinkHeaderFilter(responseLinkHeader) : void 0;
if (shouldCollectEarlyHints && sentEarlyHintLinks && matchedRoutes?.length) handleCollectedEarlyHints({
phase: "static",
hints: collectStaticHintsFromManifest(manifest, matchedRoutes),
sentLinks: sentEarlyHintLinks,
sentHints: sentEarlyHints,
onEarlyHints,
responseLinkHeaderEntries
const manifest = await resolveManifestForRequest({
request,
requestInlineCss: requestOpts?.inlineCss,
getBaseManifest: () => getBaseManifest(matchedRoutes)
});
const earlyHints = createEarlyHintsForRequest({
onEarlyHints: requestOpts?.onEarlyHints,
responseLinkHeader: requestOpts?.responseLinkHeader
});
earlyHints?.collectStatic({
manifest,
matchedRoutes
});
const routerInstance = await getRouter();

@@ -396,18 +280,7 @@ attachRouterServerSsrUtils({

if (routerInstance.state.redirect) return routerInstance.state.redirect;
if (shouldCollectEarlyHints && sentEarlyHintLinks) handleCollectedEarlyHints({
phase: "dynamic",
hints: collectDynamicHintsFromMatches(routerInstance.stores.matches.get()),
sentLinks: sentEarlyHintLinks,
sentHints: sentEarlyHints,
onEarlyHints,
responseLinkHeaderEntries
});
earlyHints?.collectDynamic(routerInstance.stores.matches.get());
const ctx = getStartContext({ throwIfNotFound: false });
await routerInstance.serverSsr.dehydrate({ requestAssets: ctx?.requestAssets });
const responseHeaders = getStartResponseHeaders({ router: routerInstance });
if (responseLinkHeaderEntries?.length) appendResponseLinkHeaders({
responseHeaders,
entries: responseLinkHeaderEntries,
filter: responseLinkHeaderFilter
});
earlyHints?.appendResponseHeaders(responseHeaders);
cbWillCleanup = true;

@@ -414,0 +287,0 @@ return cb({

@@ -1,1 +0,1 @@

{"version":3,"file":"createStartHandler.js","names":[],"sources":["../../src/createStartHandler.ts"],"sourcesContent":["import { createMemoryHistory } from '@tanstack/history'\nimport {\n createCsrfMiddleware,\n createNullProtoObject,\n csrfSymbol,\n flattenMiddlewares,\n mergeHeaders,\n safeObjectMerge,\n} from '@tanstack/start-client-core'\nimport {\n executeRewriteInput,\n isRedirect,\n isResolvedRedirect,\n} from '@tanstack/router-core'\nimport {\n attachRouterServerSsrUtils,\n getNormalizedURL,\n getOrigin,\n} from '@tanstack/router-core/ssr/server'\nimport {\n getStartContext,\n runWithStartContext,\n} from '@tanstack/start-storage-context'\nimport { requestHandler } from './request-response'\nimport { getStartManifest } from './router-manifest'\nimport { handleServerAction } from './server-functions-handler'\nimport {\n adaptTransformAssetUrlsConfigToTransformAssets,\n buildManifestWithClientEntry,\n resolveTransformAssetsConfig,\n transformManifestAssets,\n} from './transformAssetUrls'\nimport {\n collectDynamicHintsFromMatches,\n collectStaticHintsFromManifest,\n createEarlyHintsEvent,\n createResponseLinkHeaderEntries,\n getResponseLinkHeaderEntries,\n} from './early-hints'\n\nimport { HEADERS } from './constants'\nimport { ServerFunctionSerializationAdapter } from './serializer/ServerFunctionSerializationAdapter'\nimport type {\n AnyFunctionMiddleware,\n AnyRequestMiddleware,\n AnyStartInstanceOptions,\n RouteMethod,\n RouteMethodHandlerFn,\n RouterEntry,\n StartEntry,\n} from '@tanstack/start-client-core'\nimport type { RequestHandler } from './request-handler'\nimport type {\n EarlyHint,\n EarlyHintsEvent,\n EarlyHintsPhase,\n OnEarlyHints,\n ResponseLinkHeaderEntry,\n ResponseLinkHeaderFilter,\n ResponseLinkHeaderOptions,\n} from './early-hints'\nimport type {\n AnyRoute,\n AnyRouter,\n AnySerializationAdapter,\n Manifest,\n Register,\n} from '@tanstack/router-core'\nimport type { HandlerCallback } from '@tanstack/router-core/ssr/server'\nimport type {\n StartManifestWithClientEntry,\n TransformAssetUrls,\n TransformAssets,\n TransformAssetsFn,\n} from './transformAssetUrls'\n\ntype TODO = any\n\ntype AnyMiddlewareServerFn =\n | AnyRequestMiddleware['options']['server']\n | AnyFunctionMiddleware['options']['server']\n\nexport interface CreateStartHandlerOptions {\n handler: HandlerCallback<AnyRouter>\n /**\n * Transform asset URLs and attributes at runtime, e.g. to prepend a CDN prefix.\n *\n * **String** — a URL prefix prepended to every asset URL (cached by default):\n * ```ts\n * createStartHandler({\n * handler: defaultStreamHandler,\n * transformAssets: 'https://cdn.example.com',\n * })\n * ```\n *\n * **Object shorthand** — a URL prefix with optional `crossOrigin`:\n * ```ts\n * createStartHandler({\n * handler: defaultStreamHandler,\n * transformAssets: {\n * prefix: 'https://cdn.example.com',\n * crossOrigin: 'anonymous',\n * },\n * })\n * ```\n *\n * `crossOrigin` accepts a single value or a per-kind record:\n * ```ts\n * transformAssets: {\n * prefix: 'https://cdn.example.com',\n * crossOrigin: {\n * modulepreload: 'anonymous',\n * stylesheet: 'use-credentials',\n * },\n * }\n * ```\n *\n * **Callback** — receives `{ kind, url }` and returns either a string URL or\n * `{ href, crossOrigin? }` (cached by default — runs once on first request):\n * ```ts\n * createStartHandler({\n * handler: defaultStreamHandler,\n * transformAssets: ({ kind, url }) => {\n * const href = `https://cdn.example.com${url}`\n *\n * if (kind === 'modulepreload') {\n * return { href, crossOrigin: 'anonymous' }\n * }\n *\n * return { href }\n * },\n * })\n * ```\n *\n * **Object** — for explicit cache control:\n * ```ts\n * createStartHandler({\n * handler: defaultStreamHandler,\n * transformAssets: {\n * transform: ({ url }) => {\n * const region = getRequest().headers.get('x-region') || 'us'\n * return { href: `https://cdn-${region}.example.com${url}` }\n * },\n * cache: false,\n * },\n * })\n * ```\n *\n * `kind` is one of `'modulepreload' | 'stylesheet' | 'clientEntry'`.\n * `crossOrigin` applies to manifest-managed `<link>` assets.\n *\n * By default, the transformed manifest is cached after the first request\n * (`cache: true`). Set `cache: false` for per-request transforms.\n *\n * If you're using a cached transform, you can optionally set `warmup: true`\n * (object form only) to compute the transformed manifest in the background at\n * server startup.\n *\n * Note: This only transforms URLs managed by TanStack Start's manifest\n * (JS preloads, CSS links, and the client entry script). For asset imports\n * used directly in components (e.g. `import logo from './logo.svg'`),\n * configure Vite's `experimental.renderBuiltUrl` in your vite.config.ts.\n */\n transformAssets?: TransformAssets\n /**\n * @deprecated Use `transformAssets` instead.\n *\n * **String** — a URL prefix prepended to every asset URL (cached by default):\n * ```ts\n * createStartHandler({\n * handler: defaultStreamHandler,\n * transformAssetUrls: 'https://cdn.example.com',\n * })\n * ```\n *\n * **Callback** — receives `{ url, type }` and returns a new URL\n * (cached by default — runs once on first request):\n * ```ts\n * createStartHandler({\n * handler: defaultStreamHandler,\n * transformAssetUrls: ({ url, type }) => {\n * return `https://cdn.example.com${url}`\n * },\n * })\n * ```\n *\n * **Object** — for explicit cache control:\n * ```ts\n * createStartHandler({\n * handler: defaultStreamHandler,\n * transformAssetUrls: {\n * transform: ({ url }) => {\n * const region = getRequest().headers.get('x-region') || 'us'\n * return `https://cdn-${region}.example.com${url}`\n * },\n * cache: false, // transform per-request\n * },\n * })\n * ```\n *\n * `type` is one of `'modulepreload' | 'stylesheet' | 'clientEntry'`.\n *\n * By default, the transformed manifest is cached after the first request\n * (`cache: true`). Set `cache: false` for per-request transforms.\n *\n * If you're using a cached transform, you can optionally set `warmup: true`\n * (object form only) to compute the transformed manifest in the background at\n * server startup.\n *\n * Note: This only transforms URLs managed by TanStack Start's manifest\n * (JS preloads, CSS links, and the client entry script). For asset imports\n * used directly in components (e.g. `import logo from './logo.svg'`),\n * configure Vite's `experimental.renderBuiltUrl` in your vite.config.ts.\n */\n transformAssetUrls?: TransformAssetUrls\n}\n\nfunction getStartResponseHeaders(opts: { router: AnyRouter }) {\n const headers = mergeHeaders(\n {\n 'Content-Type': 'text/html; charset=utf-8',\n },\n ...opts.router.stores.matches.get().map((match) => {\n return match.headers\n }),\n )\n return headers\n}\n\nfunction notifyEarlyHints(\n phase: EarlyHintsPhase,\n event: EarlyHintsEvent,\n onEarlyHints: OnEarlyHints,\n) {\n try {\n const result = onEarlyHints(event)\n if (result) {\n void Promise.resolve(result).catch((err) => {\n console.error(`Error sending ${phase} early hints:`, err)\n })\n }\n } catch (err) {\n console.error(`Error sending ${phase} early hints:`, err)\n }\n}\n\nfunction getResponseLinkHeaderFilter(\n responseLinkHeader: boolean | ResponseLinkHeaderOptions | undefined,\n): ResponseLinkHeaderFilter | undefined {\n if (typeof responseLinkHeader !== 'object') {\n return undefined\n }\n\n return responseLinkHeader.filter\n}\n\nfunction appendResponseLinkHeaders(opts: {\n responseHeaders: Headers\n entries: ReadonlyArray<ResponseLinkHeaderEntry>\n filter?: ResponseLinkHeaderFilter\n}) {\n if (!opts.filter) {\n for (const entry of opts.entries) {\n opts.responseHeaders.append('Link', entry.link)\n }\n return\n }\n\n const links = getResponseLinkHeaderEntries(opts)\n\n for (const link of links) {\n opts.responseHeaders.append('Link', link)\n }\n}\n\nfunction collectResponseLinkHeaderEntries(opts: {\n phase: EarlyHintsPhase\n event: EarlyHintsEvent\n entries: Array<ResponseLinkHeaderEntry>\n}) {\n for (let index = 0; index < opts.event.hints.length; index++) {\n opts.entries.push({\n phase: opts.phase,\n hint: opts.event.hints[index]!,\n link: opts.event.links[index]!,\n })\n }\n}\n\nfunction handleCollectedEarlyHints(opts: {\n phase: EarlyHintsPhase\n hints: ReadonlyArray<EarlyHint>\n sentLinks: Set<string>\n sentHints?: Array<EarlyHint>\n onEarlyHints?: OnEarlyHints\n responseLinkHeaderEntries?: Array<ResponseLinkHeaderEntry>\n}) {\n const event = opts.onEarlyHints\n ? createEarlyHintsEvent({\n phase: opts.phase,\n hints: opts.hints,\n sentLinks: opts.sentLinks,\n sentHints: opts.sentHints!,\n })\n : undefined\n\n if (event) {\n notifyEarlyHints(opts.phase, event, opts.onEarlyHints!)\n }\n\n if (!opts.responseLinkHeaderEntries) return\n\n if (event) {\n collectResponseLinkHeaderEntries({\n phase: opts.phase,\n event,\n entries: opts.responseLinkHeaderEntries,\n })\n return\n }\n\n createResponseLinkHeaderEntries({\n phase: opts.phase,\n hints: opts.hints,\n sentLinks: opts.sentLinks,\n entries: opts.responseLinkHeaderEntries,\n })\n}\n\ninterface PluginAdaptersEntry {\n hasPluginAdapters: boolean\n pluginSerializationAdapters: Array<AnySerializationAdapter>\n}\n\ninterface Entries {\n startEntry: StartEntry\n routerEntry: RouterEntry\n pluginAdapters: PluginAdaptersEntry\n}\n\n// Cached entries - promises stored immediately to prevent concurrent imports\n// that can cause race conditions during module initialization\nlet entriesPromise: Promise<Entries> | undefined\nlet baseManifestPromise: Promise<StartManifestWithClientEntry> | undefined\nlet hasWarnedMissingCsrfMiddleware = false\nconst defaultCsrfMiddleware = createCsrfMiddleware({\n filter: (ctx) => ctx.handlerType === 'serverFn',\n})\n\n/**\n * Cached final manifest (with client entry script tag). In production,\n * this is computed once and reused for every request when caching is enabled.\n */\nlet cachedFinalManifestPromise: Promise<Manifest> | undefined\n\nasync function loadEntries(): Promise<Entries> {\n const [routerEntry, startEntry, pluginAdapters] = await Promise.all([\n // @ts-ignore When building, we currently don't respect tsconfig.ts' `include` so we are not picking up the .d.ts from start-client-core\n import('#tanstack-router-entry'),\n // @ts-ignore When building, we currently don't respect tsconfig.ts' `include` so we are not picking up the .d.ts from start-client-core\n import('#tanstack-start-entry'),\n // @ts-ignore When building, we currently don't respect tsconfig.ts' `include` so we are not picking up the .d.ts from start-client-core\n import('#tanstack-start-plugin-adapters'),\n ])\n return {\n routerEntry: routerEntry as unknown as RouterEntry,\n startEntry: startEntry as unknown as StartEntry,\n pluginAdapters: pluginAdapters as unknown as PluginAdaptersEntry,\n }\n}\n\nfunction getEntries() {\n if (!entriesPromise) {\n entriesPromise = loadEntries()\n }\n return entriesPromise\n}\n\nfunction hasCsrfMiddleware(\n middlewares: Array<AnyRequestMiddleware | AnyFunctionMiddleware>,\n): boolean {\n return middlewares.some((middleware) => csrfSymbol in middleware)\n}\n\nfunction warnMissingCsrfMiddlewareOnce() {\n if (hasWarnedMissingCsrfMiddleware) return\n hasWarnedMissingCsrfMiddleware = true\n\n console.warn(`TanStack Start server functions are not protected by the CSRF middleware.\n\nServer functions are same-origin RPC endpoints and should be protected from cross-site requests.\n\nAdd the CSRF middleware in src/start.ts:\n\n const csrfMiddleware = createCsrfMiddleware({\n filter: (ctx) => ctx.handlerType === 'serverFn',\n })\n\n export const startInstance = createStart(() => ({\n requestMiddleware: [csrfMiddleware],\n }))\n\nIf you intentionally handle CSRF another way, disable this warning:\n\n tanstackStart({\n serverFns: {\n disableCsrfMiddlewareWarning: true,\n },\n })`)\n}\n\n/**\n * Returns the raw manifest data (without client entry script tag baked in).\n * In dev mode, always returns fresh data. In prod, cached.\n */\nfunction getBaseManifest(\n matchedRoutes?: ReadonlyArray<AnyRoute>,\n): Promise<StartManifestWithClientEntry> {\n // In dev mode, always get fresh manifest (no caching) to include route-specific dev styles\n if (process.env.TSS_DEV_SERVER === 'true') {\n return getStartManifest(matchedRoutes)\n }\n // In prod, cache the base manifest\n if (!baseManifestPromise) {\n baseManifestPromise = getStartManifest()\n }\n return baseManifestPromise\n}\n\n/**\n * Resolves a final Manifest for a given request.\n *\n * - No transform: builds client entry script tag and returns (cached in prod).\n * - Cached transform: transforms all URLs + builds script tag, caches result.\n * - Per-request transform: deep-clones base manifest, transforms per-request.\n */\nasync function resolveManifest(\n matchedRoutes: ReadonlyArray<AnyRoute> | undefined,\n transformFn: TransformAssetsFn | undefined,\n cache: boolean,\n): Promise<Manifest> {\n const base = await getBaseManifest(matchedRoutes)\n\n const computeFinalManifest = async () => {\n return transformFn\n ? await transformManifestAssets(base, transformFn, { clone: !cache })\n : buildManifestWithClientEntry(base)\n }\n\n // In dev, always compute fresh to include route-specific dev styles.\n if (process.env.TSS_DEV_SERVER === 'true') {\n return computeFinalManifest()\n }\n\n // In prod, cache unless we're explicitly doing per-request transforms.\n if (!transformFn || cache) {\n if (!cachedFinalManifestPromise) {\n cachedFinalManifestPromise = computeFinalManifest()\n }\n return cachedFinalManifestPromise\n }\n\n // Per-request transform — deep-clone and transform every time.\n return computeFinalManifest()\n}\n\n// Pre-computed constants\nconst ROUTER_BASEPATH = process.env.TSS_ROUTER_BASEPATH || '/'\nconst SERVER_FN_BASE = process.env.TSS_SERVER_FN_BASE\nconst IS_PRERENDERING = process.env.TSS_PRERENDERING === 'true'\nconst IS_SHELL_ENV = process.env.TSS_SHELL === 'true'\nconst IS_DEV = process.env.NODE_ENV === 'development'\n\n// Reusable error messages\nconst ERR_NO_RESPONSE = IS_DEV\n ? `It looks like you forgot to return a response from your server route handler. If you want to defer to the app router, make sure to have a component set in this route.`\n : 'Internal Server Error'\n\nconst ERR_NO_DEFER = IS_DEV\n ? `You cannot defer to the app router if there is no component defined on this route.`\n : 'Internal Server Error'\n\nfunction throwRouteHandlerError(): never {\n throw new Error(ERR_NO_RESPONSE)\n}\n\nfunction throwIfMayNotDefer(): never {\n throw new Error(ERR_NO_DEFER)\n}\n\n/**\n * Check if a value is a special response (Response or Redirect)\n */\nfunction isSpecialResponse(value: unknown): value is Response {\n return value instanceof Response || isRedirect(value)\n}\n\n/**\n * Normalize middleware result to context shape\n */\nfunction handleCtxResult(result: TODO) {\n if (isSpecialResponse(result)) {\n return { response: result }\n }\n return result\n}\n\n/**\n * Execute a middleware chain\n */\nfunction executeMiddleware(middlewares: Array<TODO>, ctx: TODO): Promise<TODO> {\n let index = -1\n\n const next = async (nextCtx?: TODO): Promise<TODO> => {\n // Merge context if provided using safeObjectMerge for prototype pollution prevention\n if (nextCtx) {\n if (nextCtx.context) {\n ctx.context = safeObjectMerge(ctx.context, nextCtx.context)\n }\n // Copy own properties except context (Object.keys returns only own enumerable properties)\n for (const key of Object.keys(nextCtx)) {\n if (key !== 'context') {\n ctx[key] = nextCtx[key]\n }\n }\n }\n\n index++\n const middleware = middlewares[index]\n if (!middleware) return ctx\n\n let result: TODO\n try {\n result = await middleware({ ...ctx, next })\n } catch (err) {\n if (isSpecialResponse(err)) {\n ctx.response = err\n return ctx\n }\n throw err\n }\n\n const normalized = handleCtxResult(result)\n if (normalized) {\n if (normalized.response !== undefined) {\n ctx.response = normalized.response\n }\n if (normalized.context) {\n ctx.context = safeObjectMerge(ctx.context, normalized.context)\n }\n }\n\n return ctx\n }\n\n return next()\n}\n\n/**\n * Wrap a route handler as middleware\n */\nfunction handlerToMiddleware(\n handler: RouteMethodHandlerFn<any, AnyRoute, any, any, any, any, any>,\n mayDefer: boolean = false,\n): TODO {\n if (mayDefer) {\n return handler\n }\n return async (ctx: TODO) => {\n const response = await handler({ ...ctx, next: throwIfMayNotDefer })\n if (!response) {\n throwRouteHandlerError()\n }\n return response\n }\n}\n\n/**\n * Creates the TanStack Start request handler.\n *\n * @example Backwards-compatible usage (handler callback only):\n * ```ts\n * export default createStartHandler(defaultStreamHandler)\n * ```\n *\n * @example With CDN URL rewriting:\n * ```ts\n * export default createStartHandler({\n * handler: defaultStreamHandler,\n * transformAssets: 'https://cdn.example.com',\n * })\n * ```\n *\n * @example With per-request URL rewriting:\n * ```ts\n * export default createStartHandler({\n * handler: defaultStreamHandler,\n * transformAssets: {\n * transform: ({ url }) => {\n * const cdnBase = getRequest().headers.get('x-cdn-base') || ''\n * return { href: `${cdnBase}${url}` }\n * },\n * cache: false,\n * },\n * })\n * ```\n */\nexport function createStartHandler<TRegister = Register>(\n cbOrOptions: HandlerCallback<AnyRouter> | CreateStartHandlerOptions,\n): RequestHandler<TRegister> {\n // Normalize the overloaded argument\n const cb: HandlerCallback<AnyRouter> =\n typeof cbOrOptions === 'function' ? cbOrOptions : cbOrOptions.handler\n const transformAssetsOption: TransformAssets | undefined =\n typeof cbOrOptions === 'function' ? undefined : cbOrOptions.transformAssets\n const transformAssetUrlsOption: TransformAssetUrls | undefined =\n typeof cbOrOptions === 'function'\n ? undefined\n : cbOrOptions.transformAssetUrls\n\n const transformOption =\n transformAssetsOption !== undefined\n ? resolveTransformAssetsConfig(transformAssetsOption)\n : transformAssetUrlsOption !== undefined\n ? resolveTransformAssetsConfig(\n adaptTransformAssetUrlsConfigToTransformAssets(\n transformAssetUrlsOption,\n ),\n )\n : undefined\n\n const warmupTransformManifest =\n (!!transformAssetsOption &&\n typeof transformAssetsOption === 'object' &&\n 'warmup' in transformAssetsOption &&\n transformAssetsOption.warmup === true) ||\n (!!transformAssetUrlsOption &&\n typeof transformAssetUrlsOption === 'object' &&\n transformAssetUrlsOption.warmup === true)\n\n // Pre-resolve the transform function and cache flag\n const resolvedTransformConfig = transformOption\n const cache = resolvedTransformConfig ? resolvedTransformConfig.cache : true\n const shouldCacheCreateTransform =\n cache && process.env.TSS_DEV_SERVER !== 'true'\n\n // Memoize a single createTransform() result when caching is enabled outside\n // of the dev server.\n let cachedCreateTransformPromise: Promise<TransformAssetsFn> | undefined\n\n const getTransformFn = async (\n opts: { warmup: true } | { warmup: false; request: Request },\n ): Promise<TransformAssetsFn | undefined> => {\n if (!resolvedTransformConfig) return undefined\n\n if (resolvedTransformConfig.type === 'createTransform') {\n if (shouldCacheCreateTransform) {\n if (!cachedCreateTransformPromise) {\n cachedCreateTransformPromise = Promise.resolve(\n resolvedTransformConfig.createTransform(opts),\n ).catch((error) => {\n cachedCreateTransformPromise = undefined\n throw error\n })\n }\n\n return cachedCreateTransformPromise\n }\n\n return resolvedTransformConfig.createTransform(opts)\n }\n\n return resolvedTransformConfig.transformFn\n }\n\n // Background warmup for cached transforms (production only)\n if (\n warmupTransformManifest &&\n cache &&\n process.env.TSS_DEV_SERVER !== 'true' &&\n !cachedFinalManifestPromise\n ) {\n // NOTE: Do not call resolveManifest() here.\n // resolveManifest() reads from cachedFinalManifestPromise, and since we set\n // cachedFinalManifestPromise to this warmup promise, that would create a\n // self-referential promise and hang forever.\n const warmupPromise = (async () => {\n const base = await getBaseManifest(undefined)\n const transformFn = await getTransformFn({ warmup: true })\n return transformFn\n ? await transformManifestAssets(base, transformFn, { clone: false })\n : buildManifestWithClientEntry(base)\n })()\n cachedFinalManifestPromise = warmupPromise\n warmupPromise.catch(() => {\n // If warmup fails, allow the next request to retry.\n if (cachedFinalManifestPromise === warmupPromise) {\n cachedFinalManifestPromise = undefined\n }\n cachedCreateTransformPromise = undefined\n })\n }\n\n const startRequestResolver: RequestHandler<Register> = async (\n request,\n requestOpts,\n ) => {\n let router: AnyRouter | null = null as AnyRouter | null\n let cbWillCleanup = false as boolean\n\n try {\n // normalizing and sanitizing the pathname here for server, so we always deal with the same format during SSR.\n // during normalization paths like '//posts' are flattened to '/posts'.\n // in these cases we would prefer to redirect to the new path\n const { url, handledProtocolRelativeURL } = getNormalizedURL(request.url)\n const href = url.pathname + url.search + url.hash\n const origin = getOrigin(request)\n\n if (handledProtocolRelativeURL) {\n return Response.redirect(url, 308)\n }\n\n const entries = await getEntries()\n const hasStartInstance = !!entries.startEntry.startInstance\n const startOptions: AnyStartInstanceOptions =\n (await entries.startEntry.startInstance?.getOptions()) ||\n ({} as AnyStartInstanceOptions)\n\n const { hasPluginAdapters, pluginSerializationAdapters } =\n entries.pluginAdapters\n\n const serializationAdapters = [\n ...(startOptions.serializationAdapters || []),\n ...(hasPluginAdapters ? pluginSerializationAdapters : []),\n ServerFunctionSerializationAdapter,\n ]\n\n const requestStartOptions = {\n ...startOptions,\n requestMiddleware: hasStartInstance\n ? startOptions.requestMiddleware\n : [defaultCsrfMiddleware],\n serializationAdapters,\n }\n\n // Flatten request middlewares once\n const flattenedRequestMiddlewares = requestStartOptions.requestMiddleware\n ? flattenMiddlewares(requestStartOptions.requestMiddleware)\n : []\n\n // Create set for deduplication\n const executedRequestMiddlewares = new Set<TODO>(\n flattenedRequestMiddlewares,\n )\n\n // Memoized router getter\n const getRouter = async (): Promise<AnyRouter> => {\n if (router) return router\n\n router = await entries.routerEntry.getRouter()\n\n let isShell = IS_SHELL_ENV\n if (IS_PRERENDERING && !isShell) {\n isShell = request.headers.get(HEADERS.TSS_SHELL) === 'true'\n }\n\n const history = createMemoryHistory({\n initialEntries: [href],\n })\n\n router.update({\n history,\n isShell,\n isPrerendering: IS_PRERENDERING,\n origin: router.options.origin ?? origin,\n ...{\n defaultSsr: requestStartOptions.defaultSsr,\n serializationAdapters: [\n ...requestStartOptions.serializationAdapters,\n ...(router.options.serializationAdapters || []),\n ],\n },\n basepath: ROUTER_BASEPATH,\n })\n\n return router\n }\n\n // Check for server function requests first (early exit)\n if (SERVER_FN_BASE && url.pathname.startsWith(SERVER_FN_BASE)) {\n if (\n process.env.NODE_ENV !== 'production' &&\n process.env.TSS_DISABLE_CSRF_MIDDLEWARE_WARNING !== 'true' &&\n !hasCsrfMiddleware(flattenedRequestMiddlewares)\n ) {\n warnMissingCsrfMiddlewareOnce()\n }\n\n const serverFnId = url.pathname\n .slice(SERVER_FN_BASE.length)\n .split('/')[0]\n\n if (!serverFnId) {\n throw new Error('Invalid server action param for serverFnId')\n }\n\n const serverFnHandler = async ({ context }: TODO) => {\n return runWithStartContext(\n {\n getRouter,\n startOptions: requestStartOptions,\n contextAfterGlobalMiddlewares: context,\n request,\n executedRequestMiddlewares,\n handlerType: 'serverFn',\n },\n () =>\n handleServerAction({\n request,\n context: requestOpts?.context,\n serverFnId,\n }),\n )\n }\n\n const middlewares = flattenedRequestMiddlewares.map(\n (d) => d.options.server,\n )\n const ctx = await executeMiddleware([...middlewares, serverFnHandler], {\n request,\n pathname: url.pathname,\n handlerType: 'serverFn',\n context: createNullProtoObject(requestOpts?.context),\n })\n\n return handleRedirectResponse(ctx.response, request, getRouter)\n }\n\n // Router execution function\n const executeRouter = async (\n serverContext: TODO,\n matchedRoutes?: ReadonlyArray<AnyRoute>,\n ): Promise<Response> => {\n const acceptHeader = request.headers.get('Accept') || '*/*'\n const acceptParts = acceptHeader.split(',')\n const supportedMimeTypes = ['*/*', 'text/html']\n\n const isSupported = supportedMimeTypes.some((mimeType) =>\n acceptParts.some((part) => part.trim().startsWith(mimeType)),\n )\n\n if (!isSupported) {\n return Response.json(\n { error: 'Only HTML requests are supported here' },\n { status: 500 },\n )\n }\n\n const manifest = await resolveManifest(\n matchedRoutes,\n await getTransformFn({ warmup: false, request }),\n cache,\n )\n\n const onEarlyHints = requestOpts?.onEarlyHints\n const responseLinkHeader = requestOpts?.responseLinkHeader\n const shouldCollectEarlyHints =\n process.env.TSS_DEV_SERVER !== 'true' &&\n (!!onEarlyHints || !!responseLinkHeader)\n const sentEarlyHintLinks = shouldCollectEarlyHints\n ? new Set<string>()\n : undefined\n const sentEarlyHints = onEarlyHints ? new Array<EarlyHint>() : undefined\n const responseLinkHeaderEntries =\n shouldCollectEarlyHints && responseLinkHeader\n ? new Array<ResponseLinkHeaderEntry>()\n : undefined\n const responseLinkHeaderFilter = shouldCollectEarlyHints\n ? getResponseLinkHeaderFilter(responseLinkHeader)\n : undefined\n\n if (\n shouldCollectEarlyHints &&\n sentEarlyHintLinks &&\n matchedRoutes?.length\n ) {\n const hints = collectStaticHintsFromManifest(manifest, matchedRoutes)\n handleCollectedEarlyHints({\n phase: 'static',\n hints,\n sentLinks: sentEarlyHintLinks,\n sentHints: sentEarlyHints,\n onEarlyHints,\n responseLinkHeaderEntries,\n })\n }\n\n const routerInstance = await getRouter()\n\n attachRouterServerSsrUtils({\n router: routerInstance,\n manifest,\n getRequestAssets: () =>\n getStartContext({ throwIfNotFound: false })?.requestAssets,\n includeUnmatchedRouteAssets: false,\n })\n\n routerInstance.update({ additionalContext: { serverContext } })\n await routerInstance.load()\n\n if (routerInstance.state.redirect) {\n return routerInstance.state.redirect\n }\n\n if (shouldCollectEarlyHints && sentEarlyHintLinks) {\n const loadedMatches = routerInstance.stores.matches.get()\n const hints = collectDynamicHintsFromMatches(loadedMatches)\n handleCollectedEarlyHints({\n phase: 'dynamic',\n hints,\n sentLinks: sentEarlyHintLinks,\n sentHints: sentEarlyHints,\n onEarlyHints,\n responseLinkHeaderEntries,\n })\n }\n\n // Pass request-scoped assets to dehydrate for manifest injection\n const ctx = getStartContext({ throwIfNotFound: false })\n await routerInstance.serverSsr!.dehydrate({\n requestAssets: ctx?.requestAssets,\n })\n\n const responseHeaders = getStartResponseHeaders({\n router: routerInstance,\n })\n if (responseLinkHeaderEntries?.length) {\n appendResponseLinkHeaders({\n responseHeaders,\n entries: responseLinkHeaderEntries,\n filter: responseLinkHeaderFilter,\n })\n }\n cbWillCleanup = true\n\n return cb({\n request,\n router: routerInstance,\n responseHeaders,\n })\n }\n\n // Main request handler\n const requestHandlerMiddleware = async ({ context }: TODO) => {\n return runWithStartContext(\n {\n getRouter,\n startOptions: requestStartOptions,\n contextAfterGlobalMiddlewares: context,\n request,\n executedRequestMiddlewares,\n handlerType: 'router',\n },\n async () => {\n try {\n return await handleServerRoutes({\n getRouter,\n request,\n url,\n executeRouter,\n context,\n executedRequestMiddlewares,\n })\n } catch (err) {\n if (err instanceof Response) {\n return err\n }\n throw err\n }\n },\n )\n }\n\n const middlewares = flattenedRequestMiddlewares.map(\n (d) => d.options.server,\n )\n const ctx = await executeMiddleware(\n [...middlewares, requestHandlerMiddleware],\n {\n request,\n pathname: url.pathname,\n handlerType: 'router',\n context: createNullProtoObject(requestOpts?.context),\n },\n )\n\n return handleRedirectResponse(ctx.response, request, getRouter)\n } finally {\n if (router && !cbWillCleanup) {\n // Clean up router SSR state if it was set up but won't be cleaned up by the callback\n // (e.g., in redirect cases or early returns before the callback is invoked).\n // When the callback runs, it handles cleanup (either via transformStreamWithRouter\n // for streaming, or directly in renderRouterToString for non-streaming).\n router.serverSsr?.cleanup()\n }\n router = null\n }\n }\n\n return requestHandler(startRequestResolver)\n}\n\nasync function handleRedirectResponse(\n response: Response,\n request: Request,\n getRouter: () => Promise<AnyRouter>,\n): Promise<Response> {\n if (!isRedirect(response)) {\n return response\n }\n\n if (isResolvedRedirect(response)) {\n if (request.headers.get('x-tsr-serverFn') === 'true') {\n return Response.json(\n { ...response.options, isSerializedRedirect: true },\n { headers: response.headers },\n )\n }\n return response\n }\n\n const opts = response.options\n if (opts.to && typeof opts.to === 'string' && !opts.to.startsWith('/')) {\n throw new Error(\n `Server side redirects must use absolute paths via the 'href' or 'to' options. The redirect() method's \"to\" property accepts an internal path only. Use the \"href\" property to provide an external URL. Received: ${JSON.stringify(opts)}`,\n )\n }\n\n if (\n ['params', 'search', 'hash'].some(\n (d) => typeof (opts as TODO)[d] === 'function',\n )\n ) {\n throw new Error(\n `Server side redirects must use static search, params, and hash values and do not support functional values. Received functional values for: ${Object.keys(\n opts,\n )\n .filter((d) => typeof (opts as TODO)[d] === 'function')\n .map((d) => `\"${d}\"`)\n .join(', ')}`,\n )\n }\n\n const router = await getRouter()\n const redirect = router.resolveRedirect(response)\n\n if (request.headers.get('x-tsr-serverFn') === 'true') {\n return Response.json(\n { ...response.options, isSerializedRedirect: true },\n { headers: response.headers },\n )\n }\n\n return redirect\n}\n\nasync function handleServerRoutes({\n getRouter,\n request,\n url,\n executeRouter,\n context,\n executedRequestMiddlewares,\n}: {\n getRouter: () => Promise<AnyRouter>\n request: Request\n url: URL\n executeRouter: (\n serverContext: any,\n matchedRoutes?: ReadonlyArray<AnyRoute>,\n ) => Promise<Response>\n context: any\n executedRequestMiddlewares: Set<AnyRequestMiddleware>\n}): Promise<Response> {\n const router = await getRouter()\n const rewrittenUrl = executeRewriteInput(router.rewrite, url)\n const pathname = rewrittenUrl.pathname\n // this will perform a fuzzy match, however for server routes we need an exact match\n // if the route is not an exact match, executeRouter will handle rendering the app router\n // the match will be cached internally, so no extra work is done during the app router render\n const { matchedRoutes, foundRoute, routeParams } =\n router.getMatchedRoutes(pathname)\n\n const isExactMatch = foundRoute && routeParams['**'] === undefined\n\n // Collect and dedupe route middlewares\n const routeMiddlewares: Array<AnyMiddlewareServerFn> = []\n\n // Collect middleware from matched routes, filtering out those already executed\n // in the request phase\n for (const route of matchedRoutes) {\n const serverMiddleware = route.options.server?.middleware as\n | Array<AnyRequestMiddleware>\n | undefined\n if (serverMiddleware) {\n const flattened = flattenMiddlewares(serverMiddleware)\n for (const m of flattened) {\n if (!executedRequestMiddlewares.has(m)) {\n routeMiddlewares.push(m.options.server)\n }\n }\n }\n }\n\n // Add handler middleware if exact match\n const server = foundRoute?.options.server\n let isHeadFallback = false\n if (server?.handlers && isExactMatch) {\n const handlers =\n typeof server.handlers === 'function'\n ? server.handlers({ createHandlers: (d: any) => d })\n : server.handlers\n\n const requestMethod = request.method.toUpperCase() as RouteMethod\n // Per RFC 9110 §9.3.2, HEAD must return the same header fields as GET.\n // Priority for HEAD: explicit HEAD handler → GET → ANY (last resort).\n const handler =\n requestMethod === 'HEAD'\n ? (handlers['HEAD'] ?? handlers['GET'] ?? handlers['ANY'])\n : (handlers[requestMethod] ?? handlers['ANY'])\n isHeadFallback =\n requestMethod === 'HEAD' && handler !== undefined && !handlers['HEAD']\n\n if (handler) {\n const mayDefer = !!foundRoute.options.component\n\n if (typeof handler === 'function') {\n routeMiddlewares.push(handlerToMiddleware(handler, mayDefer))\n } else {\n if (handler.middleware?.length) {\n const handlerMiddlewares = flattenMiddlewares(handler.middleware)\n for (const m of handlerMiddlewares) {\n routeMiddlewares.push(m.options.server)\n }\n }\n if (handler.handler) {\n routeMiddlewares.push(handlerToMiddleware(handler.handler, mayDefer))\n }\n }\n }\n }\n\n // Final middleware: execute router with matched routes for dev styles\n routeMiddlewares.push((ctx: TODO) =>\n executeRouter(ctx.context, matchedRoutes),\n )\n\n const ctx = await executeMiddleware(routeMiddlewares, {\n request,\n context,\n params: routeParams,\n pathname,\n handlerType: 'router',\n })\n\n // RFC 9110 §9.3.2: HEAD must carry the same header fields as GET but no body.\n // Resolve any redirect before stripping so the Location header survives.\n if (isHeadFallback) {\n if (!ctx.response) {\n throwRouteHandlerError()\n }\n\n const resolved = await handleRedirectResponse(\n ctx.response,\n request,\n getRouter,\n )\n return new Response(null, resolved)\n }\n\n return ctx.response\n}\n"],"mappings":";;;;;;;;;;;;;AAyNA,SAAS,wBAAwB,MAA6B;AAS5D,QARgB,aACd,EACE,gBAAgB,4BACjB,EACD,GAAG,KAAK,OAAO,OAAO,QAAQ,KAAK,CAAC,KAAK,UAAU;AACjD,SAAO,MAAM;GACb,CACH;;AAIH,SAAS,iBACP,OACA,OACA,cACA;AACA,KAAI;EACF,MAAM,SAAS,aAAa,MAAM;AAClC,MAAI,OACG,SAAQ,QAAQ,OAAO,CAAC,OAAO,QAAQ;AAC1C,WAAQ,MAAM,iBAAiB,MAAM,gBAAgB,IAAI;IACzD;UAEG,KAAK;AACZ,UAAQ,MAAM,iBAAiB,MAAM,gBAAgB,IAAI;;;AAI7D,SAAS,4BACP,oBACsC;AACtC,KAAI,OAAO,uBAAuB,SAChC;AAGF,QAAO,mBAAmB;;AAG5B,SAAS,0BAA0B,MAIhC;AACD,KAAI,CAAC,KAAK,QAAQ;AAChB,OAAK,MAAM,SAAS,KAAK,QACvB,MAAK,gBAAgB,OAAO,QAAQ,MAAM,KAAK;AAEjD;;CAGF,MAAM,QAAQ,6BAA6B,KAAK;AAEhD,MAAK,MAAM,QAAQ,MACjB,MAAK,gBAAgB,OAAO,QAAQ,KAAK;;AAI7C,SAAS,iCAAiC,MAIvC;AACD,MAAK,IAAI,QAAQ,GAAG,QAAQ,KAAK,MAAM,MAAM,QAAQ,QACnD,MAAK,QAAQ,KAAK;EAChB,OAAO,KAAK;EACZ,MAAM,KAAK,MAAM,MAAM;EACvB,MAAM,KAAK,MAAM,MAAM;EACxB,CAAC;;AAIN,SAAS,0BAA0B,MAOhC;CACD,MAAM,QAAQ,KAAK,eACf,sBAAsB;EACpB,OAAO,KAAK;EACZ,OAAO,KAAK;EACZ,WAAW,KAAK;EAChB,WAAW,KAAK;EACjB,CAAC,GACF,KAAA;AAEJ,KAAI,MACF,kBAAiB,KAAK,OAAO,OAAO,KAAK,aAAc;AAGzD,KAAI,CAAC,KAAK,0BAA2B;AAErC,KAAI,OAAO;AACT,mCAAiC;GAC/B,OAAO,KAAK;GACZ;GACA,SAAS,KAAK;GACf,CAAC;AACF;;AAGF,iCAAgC;EAC9B,OAAO,KAAK;EACZ,OAAO,KAAK;EACZ,WAAW,KAAK;EAChB,SAAS,KAAK;EACf,CAAC;;AAgBJ,IAAI;AACJ,IAAI;AACJ,IAAI,iCAAiC;AACrC,IAAM,wBAAwB,qBAAqB,EACjD,SAAS,QAAQ,IAAI,gBAAgB,YACtC,CAAC;;;;;AAMF,IAAI;AAEJ,eAAe,cAAgC;CAC7C,MAAM,CAAC,aAAa,YAAY,kBAAkB,MAAM,QAAQ,IAAI;EAElE,OAAO;EAEP,OAAO;EAEP,OAAO;EACR,CAAC;AACF,QAAO;EACQ;EACD;EACI;EACjB;;AAGH,SAAS,aAAa;AACpB,KAAI,CAAC,eACH,kBAAiB,aAAa;AAEhC,QAAO;;AAGT,SAAS,kBACP,aACS;AACT,QAAO,YAAY,MAAM,eAAe,cAAc,WAAW;;AAGnE,SAAS,gCAAgC;AACvC,KAAI,+BAAgC;AACpC,kCAAiC;AAEjC,SAAQ,KAAK;;;;;;;;;;;;;;;;;;;;MAoBT;;;;;;AAON,SAAS,gBACP,eACuC;AAEvC,KAAI,QAAQ,IAAI,mBAAmB,OACjC,QAAO,iBAAiB,cAAc;AAGxC,KAAI,CAAC,oBACH,uBAAsB,kBAAkB;AAE1C,QAAO;;;;;;;;;AAUT,eAAe,gBACb,eACA,aACA,OACmB;CACnB,MAAM,OAAO,MAAM,gBAAgB,cAAc;CAEjD,MAAM,uBAAuB,YAAY;AACvC,SAAO,cACH,MAAM,wBAAwB,MAAM,aAAa,EAAE,OAAO,CAAC,OAAO,CAAC,GACnE,6BAA6B,KAAK;;AAIxC,KAAI,QAAQ,IAAI,mBAAmB,OACjC,QAAO,sBAAsB;AAI/B,KAAI,CAAC,eAAe,OAAO;AACzB,MAAI,CAAC,2BACH,8BAA6B,sBAAsB;AAErD,SAAO;;AAIT,QAAO,sBAAsB;;AAI/B,IAAM,kBAAkB,QAAQ,IAAI,uBAAuB;AAC3D,IAAM,iBAAiB,QAAQ,IAAI;AACnC,IAAM,kBAAkB,QAAQ,IAAI,qBAAqB;AACzD,IAAM,eAAe,QAAQ,IAAI,cAAc;AAC/C,IAAM,SAAA,QAAA,IAAA,aAAkC;AAGxC,IAAM,kBAAkB,SACpB,2KACA;AAEJ,IAAM,eAAe,SACjB,uFACA;AAEJ,SAAS,yBAAgC;AACvC,OAAM,IAAI,MAAM,gBAAgB;;AAGlC,SAAS,qBAA4B;AACnC,OAAM,IAAI,MAAM,aAAa;;;;;AAM/B,SAAS,kBAAkB,OAAmC;AAC5D,QAAO,iBAAiB,YAAY,WAAW,MAAM;;;;;AAMvD,SAAS,gBAAgB,QAAc;AACrC,KAAI,kBAAkB,OAAO,CAC3B,QAAO,EAAE,UAAU,QAAQ;AAE7B,QAAO;;;;;AAMT,SAAS,kBAAkB,aAA0B,KAA0B;CAC7E,IAAI,QAAQ;CAEZ,MAAM,OAAO,OAAO,YAAkC;AAEpD,MAAI,SAAS;AACX,OAAI,QAAQ,QACV,KAAI,UAAU,gBAAgB,IAAI,SAAS,QAAQ,QAAQ;AAG7D,QAAK,MAAM,OAAO,OAAO,KAAK,QAAQ,CACpC,KAAI,QAAQ,UACV,KAAI,OAAO,QAAQ;;AAKzB;EACA,MAAM,aAAa,YAAY;AAC/B,MAAI,CAAC,WAAY,QAAO;EAExB,IAAI;AACJ,MAAI;AACF,YAAS,MAAM,WAAW;IAAE,GAAG;IAAK;IAAM,CAAC;WACpC,KAAK;AACZ,OAAI,kBAAkB,IAAI,EAAE;AAC1B,QAAI,WAAW;AACf,WAAO;;AAET,SAAM;;EAGR,MAAM,aAAa,gBAAgB,OAAO;AAC1C,MAAI,YAAY;AACd,OAAI,WAAW,aAAa,KAAA,EAC1B,KAAI,WAAW,WAAW;AAE5B,OAAI,WAAW,QACb,KAAI,UAAU,gBAAgB,IAAI,SAAS,WAAW,QAAQ;;AAIlE,SAAO;;AAGT,QAAO,MAAM;;;;;AAMf,SAAS,oBACP,SACA,WAAoB,OACd;AACN,KAAI,SACF,QAAO;AAET,QAAO,OAAO,QAAc;EAC1B,MAAM,WAAW,MAAM,QAAQ;GAAE,GAAG;GAAK,MAAM;GAAoB,CAAC;AACpE,MAAI,CAAC,SACH,yBAAwB;AAE1B,SAAO;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;AAkCX,SAAgB,mBACd,aAC2B;CAE3B,MAAM,KACJ,OAAO,gBAAgB,aAAa,cAAc,YAAY;CAChE,MAAM,wBACJ,OAAO,gBAAgB,aAAa,KAAA,IAAY,YAAY;CAC9D,MAAM,2BACJ,OAAO,gBAAgB,aACnB,KAAA,IACA,YAAY;CAElB,MAAM,kBACJ,0BAA0B,KAAA,IACtB,6BAA6B,sBAAsB,GACnD,6BAA6B,KAAA,IAC3B,6BACE,+CACE,yBACD,CACF,GACD,KAAA;CAER,MAAM,0BACH,CAAC,CAAC,yBACD,OAAO,0BAA0B,YACjC,YAAY,yBACZ,sBAAsB,WAAW,QAClC,CAAC,CAAC,4BACD,OAAO,6BAA6B,YACpC,yBAAyB,WAAW;CAGxC,MAAM,0BAA0B;CAChC,MAAM,QAAQ,0BAA0B,wBAAwB,QAAQ;CACxE,MAAM,6BACJ,SAAS,QAAQ,IAAI,mBAAmB;CAI1C,IAAI;CAEJ,MAAM,iBAAiB,OACrB,SAC2C;AAC3C,MAAI,CAAC,wBAAyB,QAAO,KAAA;AAErC,MAAI,wBAAwB,SAAS,mBAAmB;AACtD,OAAI,4BAA4B;AAC9B,QAAI,CAAC,6BACH,gCAA+B,QAAQ,QACrC,wBAAwB,gBAAgB,KAAK,CAC9C,CAAC,OAAO,UAAU;AACjB,oCAA+B,KAAA;AAC/B,WAAM;MACN;AAGJ,WAAO;;AAGT,UAAO,wBAAwB,gBAAgB,KAAK;;AAGtD,SAAO,wBAAwB;;AAIjC,KACE,2BACA,SACA,QAAQ,IAAI,mBAAmB,UAC/B,CAAC,4BACD;EAKA,MAAM,iBAAiB,YAAY;GACjC,MAAM,OAAO,MAAM,gBAAgB,KAAA,EAAU;GAC7C,MAAM,cAAc,MAAM,eAAe,EAAE,QAAQ,MAAM,CAAC;AAC1D,UAAO,cACH,MAAM,wBAAwB,MAAM,aAAa,EAAE,OAAO,OAAO,CAAC,GAClE,6BAA6B,KAAK;MACpC;AACJ,+BAA6B;AAC7B,gBAAc,YAAY;AAExB,OAAI,+BAA+B,cACjC,8BAA6B,KAAA;AAE/B,kCAA+B,KAAA;IAC/B;;CAGJ,MAAM,uBAAiD,OACrD,SACA,gBACG;EACH,IAAI,SAA2B;EAC/B,IAAI,gBAAgB;AAEpB,MAAI;GAIF,MAAM,EAAE,KAAK,+BAA+B,iBAAiB,QAAQ,IAAI;GACzE,MAAM,OAAO,IAAI,WAAW,IAAI,SAAS,IAAI;GAC7C,MAAM,SAAS,UAAU,QAAQ;AAEjC,OAAI,2BACF,QAAO,SAAS,SAAS,KAAK,IAAI;GAGpC,MAAM,UAAU,MAAM,YAAY;GAClC,MAAM,mBAAmB,CAAC,CAAC,QAAQ,WAAW;GAC9C,MAAM,eACH,MAAM,QAAQ,WAAW,eAAe,YAAY,IACpD,EAAE;GAEL,MAAM,EAAE,mBAAmB,gCACzB,QAAQ;GAEV,MAAM,wBAAwB;IAC5B,GAAI,aAAa,yBAAyB,EAAE;IAC5C,GAAI,oBAAoB,8BAA8B,EAAE;IACxD;IACD;GAED,MAAM,sBAAsB;IAC1B,GAAG;IACH,mBAAmB,mBACf,aAAa,oBACb,CAAC,sBAAsB;IAC3B;IACD;GAGD,MAAM,8BAA8B,oBAAoB,oBACpD,mBAAmB,oBAAoB,kBAAkB,GACzD,EAAE;GAGN,MAAM,6BAA6B,IAAI,IACrC,4BACD;GAGD,MAAM,YAAY,YAAgC;AAChD,QAAI,OAAQ,QAAO;AAEnB,aAAS,MAAM,QAAQ,YAAY,WAAW;IAE9C,IAAI,UAAU;AACd,QAAI,mBAAmB,CAAC,QACtB,WAAU,QAAQ,QAAQ,IAAI,QAAQ,UAAU,KAAK;IAGvD,MAAM,UAAU,oBAAoB,EAClC,gBAAgB,CAAC,KAAK,EACvB,CAAC;AAEF,WAAO,OAAO;KACZ;KACA;KACA,gBAAgB;KAChB,QAAQ,OAAO,QAAQ,UAAU;KAE/B,YAAY,oBAAoB;KAChC,uBAAuB,CACrB,GAAG,oBAAoB,uBACvB,GAAI,OAAO,QAAQ,yBAAyB,EAAE,CAC/C;KAEH,UAAU;KACX,CAAC;AAEF,WAAO;;AAIT,OAAI,kBAAkB,IAAI,SAAS,WAAW,eAAe,EAAE;AAC7D,QAAA,QAAA,IAAA,aAC2B,gBACzB,QAAQ,IAAI,wCAAwC,UACpD,CAAC,kBAAkB,4BAA4B,CAE/C,gCAA+B;IAGjC,MAAM,aAAa,IAAI,SACpB,MAAM,eAAe,OAAO,CAC5B,MAAM,IAAI,CAAC;AAEd,QAAI,CAAC,WACH,OAAM,IAAI,MAAM,6CAA6C;IAG/D,MAAM,kBAAkB,OAAO,EAAE,cAAoB;AACnD,YAAO,oBACL;MACE;MACA,cAAc;MACd,+BAA+B;MAC/B;MACA;MACA,aAAa;MACd,QAEC,mBAAmB;MACjB;MACA,SAAS,aAAa;MACtB;MACD,CAAC,CACL;;AAaH,WAAO,wBAPK,MAAM,kBAAkB,CAAC,GAHjB,4BAA4B,KAC7C,MAAM,EAAE,QAAQ,OAClB,EACoD,gBAAgB,EAAE;KACrE;KACA,UAAU,IAAI;KACd,aAAa;KACb,SAAS,sBAAsB,aAAa,QAAQ;KACrD,CAAC,EAEgC,UAAU,SAAS,UAAU;;GAIjE,MAAM,gBAAgB,OACpB,eACA,kBACsB;IAEtB,MAAM,eADe,QAAQ,QAAQ,IAAI,SAAS,IAAI,OACrB,MAAM,IAAI;AAO3C,QAAI,CANuB,CAAC,OAAO,YAAY,CAER,MAAM,aAC3C,YAAY,MAAM,SAAS,KAAK,MAAM,CAAC,WAAW,SAAS,CAAC,CAC7D,CAGC,QAAO,SAAS,KACd,EAAE,OAAO,yCAAyC,EAClD,EAAE,QAAQ,KAAK,CAChB;IAGH,MAAM,WAAW,MAAM,gBACrB,eACA,MAAM,eAAe;KAAE,QAAQ;KAAO;KAAS,CAAC,EAChD,MACD;IAED,MAAM,eAAe,aAAa;IAClC,MAAM,qBAAqB,aAAa;IACxC,MAAM,0BACJ,QAAQ,IAAI,mBAAmB,WAC9B,CAAC,CAAC,gBAAgB,CAAC,CAAC;IACvB,MAAM,qBAAqB,0CACvB,IAAI,KAAa,GACjB,KAAA;IACJ,MAAM,iBAAiB,eAAe,IAAI,OAAkB,GAAG,KAAA;IAC/D,MAAM,4BACJ,2BAA2B,qBACvB,IAAI,OAAgC,GACpC,KAAA;IACN,MAAM,2BAA2B,0BAC7B,4BAA4B,mBAAmB,GAC/C,KAAA;AAEJ,QACE,2BACA,sBACA,eAAe,OAGf,2BAA0B;KACxB,OAAO;KACP,OAHY,+BAA+B,UAAU,cAAc;KAInE,WAAW;KACX,WAAW;KACX;KACA;KACD,CAAC;IAGJ,MAAM,iBAAiB,MAAM,WAAW;AAExC,+BAA2B;KACzB,QAAQ;KACR;KACA,wBACE,gBAAgB,EAAE,iBAAiB,OAAO,CAAC,EAAE;KAC/C,6BAA6B;KAC9B,CAAC;AAEF,mBAAe,OAAO,EAAE,mBAAmB,EAAE,eAAe,EAAE,CAAC;AAC/D,UAAM,eAAe,MAAM;AAE3B,QAAI,eAAe,MAAM,SACvB,QAAO,eAAe,MAAM;AAG9B,QAAI,2BAA2B,mBAG7B,2BAA0B;KACxB,OAAO;KACP,OAHY,+BADQ,eAAe,OAAO,QAAQ,KAAK,CACE;KAIzD,WAAW;KACX,WAAW;KACX;KACA;KACD,CAAC;IAIJ,MAAM,MAAM,gBAAgB,EAAE,iBAAiB,OAAO,CAAC;AACvD,UAAM,eAAe,UAAW,UAAU,EACxC,eAAe,KAAK,eACrB,CAAC;IAEF,MAAM,kBAAkB,wBAAwB,EAC9C,QAAQ,gBACT,CAAC;AACF,QAAI,2BAA2B,OAC7B,2BAA0B;KACxB;KACA,SAAS;KACT,QAAQ;KACT,CAAC;AAEJ,oBAAgB;AAEhB,WAAO,GAAG;KACR;KACA,QAAQ;KACR;KACD,CAAC;;GAIJ,MAAM,2BAA2B,OAAO,EAAE,cAAoB;AAC5D,WAAO,oBACL;KACE;KACA,cAAc;KACd,+BAA+B;KAC/B;KACA;KACA,aAAa;KACd,EACD,YAAY;AACV,SAAI;AACF,aAAO,MAAM,mBAAmB;OAC9B;OACA;OACA;OACA;OACA;OACA;OACD,CAAC;cACK,KAAK;AACZ,UAAI,eAAe,SACjB,QAAO;AAET,YAAM;;MAGX;;AAgBH,UAAO,wBAVK,MAAM,kBAChB,CAAC,GAJiB,4BAA4B,KAC7C,MAAM,EAAE,QAAQ,OAClB,EAEkB,yBAAyB,EAC1C;IACE;IACA,UAAU,IAAI;IACd,aAAa;IACb,SAAS,sBAAsB,aAAa,QAAQ;IACrD,CACF,EAEiC,UAAU,SAAS,UAAU;YACvD;AACR,OAAI,UAAU,CAAC,cAKb,QAAO,WAAW,SAAS;AAE7B,YAAS;;;AAIb,QAAO,eAAe,qBAAqB;;AAG7C,eAAe,uBACb,UACA,SACA,WACmB;AACnB,KAAI,CAAC,WAAW,SAAS,CACvB,QAAO;AAGT,KAAI,mBAAmB,SAAS,EAAE;AAChC,MAAI,QAAQ,QAAQ,IAAI,iBAAiB,KAAK,OAC5C,QAAO,SAAS,KACd;GAAE,GAAG,SAAS;GAAS,sBAAsB;GAAM,EACnD,EAAE,SAAS,SAAS,SAAS,CAC9B;AAEH,SAAO;;CAGT,MAAM,OAAO,SAAS;AACtB,KAAI,KAAK,MAAM,OAAO,KAAK,OAAO,YAAY,CAAC,KAAK,GAAG,WAAW,IAAI,CACpE,OAAM,IAAI,MACR,oNAAoN,KAAK,UAAU,KAAK,GACzO;AAGH,KACE;EAAC;EAAU;EAAU;EAAO,CAAC,MAC1B,MAAM,OAAQ,KAAc,OAAO,WACrC,CAED,OAAM,IAAI,MACR,+IAA+I,OAAO,KACpJ,KACD,CACE,QAAQ,MAAM,OAAQ,KAAc,OAAO,WAAW,CACtD,KAAK,MAAM,IAAI,EAAE,GAAG,CACpB,KAAK,KAAK,GACd;CAIH,MAAM,YADS,MAAM,WAAW,EACR,gBAAgB,SAAS;AAEjD,KAAI,QAAQ,QAAQ,IAAI,iBAAiB,KAAK,OAC5C,QAAO,SAAS,KACd;EAAE,GAAG,SAAS;EAAS,sBAAsB;EAAM,EACnD,EAAE,SAAS,SAAS,SAAS,CAC9B;AAGH,QAAO;;AAGT,eAAe,mBAAmB,EAChC,WACA,SACA,KACA,eACA,SACA,8BAWoB;CACpB,MAAM,SAAS,MAAM,WAAW;CAEhC,MAAM,WADe,oBAAoB,OAAO,SAAS,IAAI,CAC/B;CAI9B,MAAM,EAAE,eAAe,YAAY,gBACjC,OAAO,iBAAiB,SAAS;CAEnC,MAAM,eAAe,cAAc,YAAY,UAAU,KAAA;CAGzD,MAAM,mBAAiD,EAAE;AAIzD,MAAK,MAAM,SAAS,eAAe;EACjC,MAAM,mBAAmB,MAAM,QAAQ,QAAQ;AAG/C,MAAI,kBAAkB;GACpB,MAAM,YAAY,mBAAmB,iBAAiB;AACtD,QAAK,MAAM,KAAK,UACd,KAAI,CAAC,2BAA2B,IAAI,EAAE,CACpC,kBAAiB,KAAK,EAAE,QAAQ,OAAO;;;CAO/C,MAAM,SAAS,YAAY,QAAQ;CACnC,IAAI,iBAAiB;AACrB,KAAI,QAAQ,YAAY,cAAc;EACpC,MAAM,WACJ,OAAO,OAAO,aAAa,aACvB,OAAO,SAAS,EAAE,iBAAiB,MAAW,GAAG,CAAC,GAClD,OAAO;EAEb,MAAM,gBAAgB,QAAQ,OAAO,aAAa;EAGlD,MAAM,UACJ,kBAAkB,SACb,SAAS,WAAW,SAAS,UAAU,SAAS,SAChD,SAAS,kBAAkB,SAAS;AAC3C,mBACE,kBAAkB,UAAU,YAAY,KAAA,KAAa,CAAC,SAAS;AAEjE,MAAI,SAAS;GACX,MAAM,WAAW,CAAC,CAAC,WAAW,QAAQ;AAEtC,OAAI,OAAO,YAAY,WACrB,kBAAiB,KAAK,oBAAoB,SAAS,SAAS,CAAC;QACxD;AACL,QAAI,QAAQ,YAAY,QAAQ;KAC9B,MAAM,qBAAqB,mBAAmB,QAAQ,WAAW;AACjE,UAAK,MAAM,KAAK,mBACd,kBAAiB,KAAK,EAAE,QAAQ,OAAO;;AAG3C,QAAI,QAAQ,QACV,kBAAiB,KAAK,oBAAoB,QAAQ,SAAS,SAAS,CAAC;;;;AAO7E,kBAAiB,MAAM,QACrB,cAAc,IAAI,SAAS,cAAc,CAC1C;CAED,MAAM,MAAM,MAAM,kBAAkB,kBAAkB;EACpD;EACA;EACA,QAAQ;EACR;EACA,aAAa;EACd,CAAC;AAIF,KAAI,gBAAgB;AAClB,MAAI,CAAC,IAAI,SACP,yBAAwB;EAG1B,MAAM,WAAW,MAAM,uBACrB,IAAI,UACJ,SACA,UACD;AACD,SAAO,IAAI,SAAS,MAAM,SAAS;;AAGrC,QAAO,IAAI"}
{"version":3,"file":"createStartHandler.js","names":[],"sources":["../../src/createStartHandler.ts"],"sourcesContent":["import { createMemoryHistory } from '@tanstack/history'\nimport {\n createCsrfMiddleware,\n createNullProtoObject,\n csrfSymbol,\n flattenMiddlewares,\n mergeHeaders,\n safeObjectMerge,\n} from '@tanstack/start-client-core'\nimport {\n executeRewriteInput,\n isRedirect,\n isResolvedRedirect,\n} from '@tanstack/router-core'\nimport {\n attachRouterServerSsrUtils,\n getNormalizedURL,\n getOrigin,\n} from '@tanstack/router-core/ssr/server'\nimport {\n getStartContext,\n runWithStartContext,\n} from '@tanstack/start-storage-context'\nimport { requestHandler } from './request-response'\nimport { getStartManifest } from './router-manifest'\nimport { handleServerAction } from './server-functions-handler'\nimport { createEarlyHintsCollector } from './early-hints'\nimport {\n createCachedBaseManifestLoader,\n createFinalManifestResolver,\n} from './finalManifest'\n\nimport { HEADERS } from './constants'\nimport { ServerFunctionSerializationAdapter } from './serializer/ServerFunctionSerializationAdapter'\nimport type {\n AnyFunctionMiddleware,\n AnyRequestMiddleware,\n AnyStartInstanceOptions,\n RouteMethod,\n RouteMethodHandlerFn,\n RouterEntry,\n StartEntry,\n} from '@tanstack/start-client-core'\nimport type { RequestHandler } from './request-handler'\nimport type {\n AnyRoute,\n AnyRouter,\n AnySerializationAdapter,\n Register,\n} from '@tanstack/router-core'\nimport type { HandlerCallback } from '@tanstack/router-core/ssr/server'\nimport type { FinalManifestOptions } from './finalManifest'\n\ntype TODO = any\n\ntype AnyMiddlewareServerFn =\n | AnyRequestMiddleware['options']['server']\n | AnyFunctionMiddleware['options']['server']\n\nexport interface CreateStartHandlerOptions extends FinalManifestOptions {\n handler: HandlerCallback<AnyRouter>\n}\n\nfunction getStartResponseHeaders(opts: { router: AnyRouter }) {\n const headers = mergeHeaders(\n {\n 'Content-Type': 'text/html; charset=utf-8',\n },\n ...opts.router.stores.matches.get().map((match) => {\n return match.headers\n }),\n )\n return headers\n}\n\ninterface PluginAdaptersEntry {\n hasPluginAdapters: boolean\n pluginSerializationAdapters: Array<AnySerializationAdapter>\n}\n\ninterface Entries {\n startEntry: StartEntry\n routerEntry: RouterEntry\n pluginAdapters: PluginAdaptersEntry\n}\n\n// Cached entries - promises stored immediately to prevent concurrent imports\n// that can cause race conditions during module initialization\nlet entriesPromise: Promise<Entries> | undefined\nlet hasWarnedMissingCsrfMiddleware = false\nconst defaultCsrfMiddleware = createCsrfMiddleware({\n filter: (ctx) => ctx.handlerType === 'serverFn',\n})\nconst getCachedBaseManifest = createCachedBaseManifestLoader(() =>\n getStartManifest(),\n)\nconst getProdBaseManifest: typeof getStartManifest = () =>\n getCachedBaseManifest()\nconst getBaseManifest =\n process.env.TSS_DEV_SERVER === 'true' ? getStartManifest : getProdBaseManifest\nconst createEarlyHintsForRequest: typeof createEarlyHintsCollector =\n process.env.TSS_DEV_SERVER === 'true'\n ? () => undefined\n : createEarlyHintsCollector\n\nasync function loadEntries(): Promise<Entries> {\n const [routerEntry, startEntry, pluginAdapters] = await Promise.all([\n // @ts-ignore When building, we currently don't respect tsconfig.ts' `include` so we are not picking up the .d.ts from start-client-core\n import('#tanstack-router-entry'),\n // @ts-ignore When building, we currently don't respect tsconfig.ts' `include` so we are not picking up the .d.ts from start-client-core\n import('#tanstack-start-entry'),\n // @ts-ignore When building, we currently don't respect tsconfig.ts' `include` so we are not picking up the .d.ts from start-client-core\n import('#tanstack-start-plugin-adapters'),\n ])\n return {\n routerEntry: routerEntry as unknown as RouterEntry,\n startEntry: startEntry as unknown as StartEntry,\n pluginAdapters: pluginAdapters as unknown as PluginAdaptersEntry,\n }\n}\n\nfunction getEntries() {\n if (!entriesPromise) {\n entriesPromise = loadEntries()\n }\n return entriesPromise\n}\n\nfunction hasCsrfMiddleware(\n middlewares: Array<AnyRequestMiddleware | AnyFunctionMiddleware>,\n): boolean {\n return middlewares.some((middleware) => csrfSymbol in middleware)\n}\n\nfunction warnMissingCsrfMiddlewareOnce() {\n if (hasWarnedMissingCsrfMiddleware) return\n hasWarnedMissingCsrfMiddleware = true\n\n console.warn(`TanStack Start server functions are not protected by the CSRF middleware.\n\nServer functions are same-origin RPC endpoints and should be protected from cross-site requests.\n\nAdd the CSRF middleware in src/start.ts:\n\n const csrfMiddleware = createCsrfMiddleware({\n filter: (ctx) => ctx.handlerType === 'serverFn',\n })\n\n export const startInstance = createStart(() => ({\n requestMiddleware: [csrfMiddleware],\n }))\n\nIf you intentionally handle CSRF another way, disable this warning:\n\n tanstackStart({\n serverFns: {\n disableCsrfMiddlewareWarning: true,\n },\n })`)\n}\n\n// Pre-computed constants\nconst ROUTER_BASEPATH = process.env.TSS_ROUTER_BASEPATH || '/'\nconst SERVER_FN_BASE = process.env.TSS_SERVER_FN_BASE\nconst IS_PRERENDERING = process.env.TSS_PRERENDERING === 'true'\nconst IS_SHELL_ENV = process.env.TSS_SHELL === 'true'\nconst IS_DEV = process.env.NODE_ENV === 'development'\n\n// Reusable error messages\nconst ERR_NO_RESPONSE = IS_DEV\n ? `It looks like you forgot to return a response from your server route handler. If you want to defer to the app router, make sure to have a component set in this route.`\n : 'Internal Server Error'\n\nconst ERR_NO_DEFER = IS_DEV\n ? `You cannot defer to the app router if there is no component defined on this route.`\n : 'Internal Server Error'\n\nfunction throwRouteHandlerError(): never {\n throw new Error(ERR_NO_RESPONSE)\n}\n\nfunction throwIfMayNotDefer(): never {\n throw new Error(ERR_NO_DEFER)\n}\n\n/**\n * Check if a value is a special response (Response or Redirect)\n */\nfunction isSpecialResponse(value: unknown): value is Response {\n return value instanceof Response || isRedirect(value)\n}\n\n/**\n * Normalize middleware result to context shape\n */\nfunction handleCtxResult(result: TODO) {\n if (isSpecialResponse(result)) {\n return { response: result }\n }\n return result\n}\n\n/**\n * Execute a middleware chain\n */\nfunction executeMiddleware(middlewares: Array<TODO>, ctx: TODO): Promise<TODO> {\n let index = -1\n\n const next = async (nextCtx?: TODO): Promise<TODO> => {\n // Merge context if provided using safeObjectMerge for prototype pollution prevention\n if (nextCtx) {\n if (nextCtx.context) {\n ctx.context = safeObjectMerge(ctx.context, nextCtx.context)\n }\n // Copy own properties except context (Object.keys returns only own enumerable properties)\n for (const key of Object.keys(nextCtx)) {\n if (key !== 'context') {\n ctx[key] = nextCtx[key]\n }\n }\n }\n\n index++\n const middleware = middlewares[index]\n if (!middleware) return ctx\n\n let result: TODO\n try {\n result = await middleware({ ...ctx, next })\n } catch (err) {\n if (isSpecialResponse(err)) {\n ctx.response = err\n return ctx\n }\n throw err\n }\n\n const normalized = handleCtxResult(result)\n if (normalized) {\n if (normalized.response !== undefined) {\n ctx.response = normalized.response\n }\n if (normalized.context) {\n ctx.context = safeObjectMerge(ctx.context, normalized.context)\n }\n }\n\n return ctx\n }\n\n return next()\n}\n\n/**\n * Wrap a route handler as middleware\n */\nfunction handlerToMiddleware(\n handler: RouteMethodHandlerFn<any, AnyRoute, any, any, any, any, any>,\n mayDefer: boolean = false,\n): TODO {\n if (mayDefer) {\n return handler\n }\n return async (ctx: TODO) => {\n const response = await handler({ ...ctx, next: throwIfMayNotDefer })\n if (!response) {\n throwRouteHandlerError()\n }\n return response\n }\n}\n\n/**\n * Creates the TanStack Start request handler.\n *\n * @example Backwards-compatible usage (handler callback only):\n * ```ts\n * export default createStartHandler(defaultStreamHandler)\n * ```\n *\n * @example With CDN URL rewriting:\n * ```ts\n * export default createStartHandler({\n * handler: defaultStreamHandler,\n * transformAssets: 'https://cdn.example.com',\n * })\n * ```\n *\n * @example With per-request URL rewriting:\n * ```ts\n * export default createStartHandler({\n * handler: defaultStreamHandler,\n * transformAssets: {\n * transform: ({ url }) => {\n * const cdnBase = getRequest().headers.get('x-cdn-base') || ''\n * return { href: `${cdnBase}${url}` }\n * },\n * cache: false,\n * },\n * })\n * ```\n */\nexport function createStartHandler<TRegister = Register>(\n cbOrOptions: HandlerCallback<AnyRouter> | CreateStartHandlerOptions,\n): RequestHandler<TRegister> {\n const handlerOptions: FinalManifestOptions =\n typeof cbOrOptions === 'function' ? {} : cbOrOptions\n const cb: HandlerCallback<AnyRouter> =\n typeof cbOrOptions === 'function' ? cbOrOptions : cbOrOptions.handler\n const finalManifestResolver = createFinalManifestResolver({\n ...handlerOptions,\n cacheCreateTransform: process.env.TSS_DEV_SERVER !== 'true',\n })\n const resolveManifestForRequest =\n process.env.TSS_DEV_SERVER === 'true'\n ? finalManifestResolver.resolveUncached\n : finalManifestResolver.resolveCached\n\n if (process.env.TSS_DEV_SERVER !== 'true') {\n finalManifestResolver.warmup({\n getBaseManifest: () => getBaseManifest(undefined),\n })\n }\n\n const startRequestResolver: RequestHandler<Register> = async (\n request,\n requestOpts,\n ) => {\n let router: AnyRouter | null = null as AnyRouter | null\n let cbWillCleanup = false as boolean\n\n try {\n // normalizing and sanitizing the pathname here for server, so we always deal with the same format during SSR.\n // during normalization paths like '//posts' are flattened to '/posts'.\n // in these cases we would prefer to redirect to the new path\n const { url, handledProtocolRelativeURL } = getNormalizedURL(request.url)\n const href = url.pathname + url.search + url.hash\n const origin = getOrigin(request)\n\n if (handledProtocolRelativeURL) {\n return Response.redirect(url, 308)\n }\n\n const entries = await getEntries()\n const hasStartInstance = !!entries.startEntry.startInstance\n const startOptions: AnyStartInstanceOptions =\n (await entries.startEntry.startInstance?.getOptions()) ||\n ({} as AnyStartInstanceOptions)\n\n const { hasPluginAdapters, pluginSerializationAdapters } =\n entries.pluginAdapters\n\n const serializationAdapters = [\n ...(startOptions.serializationAdapters || []),\n ...(hasPluginAdapters ? pluginSerializationAdapters : []),\n ServerFunctionSerializationAdapter,\n ]\n\n const requestStartOptions = {\n ...startOptions,\n requestMiddleware: hasStartInstance\n ? startOptions.requestMiddleware\n : [defaultCsrfMiddleware],\n serializationAdapters,\n }\n\n // Flatten request middlewares once\n const flattenedRequestMiddlewares = requestStartOptions.requestMiddleware\n ? flattenMiddlewares(requestStartOptions.requestMiddleware)\n : []\n\n // Create set for deduplication\n const executedRequestMiddlewares = new Set<TODO>(\n flattenedRequestMiddlewares,\n )\n\n // Memoized router getter\n const getRouter = async (): Promise<AnyRouter> => {\n if (router) return router\n\n router = await entries.routerEntry.getRouter()\n\n let isShell = IS_SHELL_ENV\n if (IS_PRERENDERING && !isShell) {\n isShell = request.headers.get(HEADERS.TSS_SHELL) === 'true'\n }\n\n const history = createMemoryHistory({\n initialEntries: [href],\n })\n\n router.update({\n history,\n isShell,\n isPrerendering: IS_PRERENDERING,\n origin: router.options.origin ?? origin,\n ...{\n defaultSsr: requestStartOptions.defaultSsr,\n serializationAdapters: [\n ...requestStartOptions.serializationAdapters,\n ...(router.options.serializationAdapters || []),\n ],\n },\n basepath: ROUTER_BASEPATH,\n })\n\n return router\n }\n\n // Check for server function requests first (early exit)\n if (SERVER_FN_BASE && url.pathname.startsWith(SERVER_FN_BASE)) {\n if (\n process.env.NODE_ENV !== 'production' &&\n process.env.TSS_DISABLE_CSRF_MIDDLEWARE_WARNING !== 'true' &&\n !hasCsrfMiddleware(flattenedRequestMiddlewares)\n ) {\n warnMissingCsrfMiddlewareOnce()\n }\n\n const serverFnId = url.pathname\n .slice(SERVER_FN_BASE.length)\n .split('/')[0]\n\n if (!serverFnId) {\n throw new Error('Invalid server action param for serverFnId')\n }\n\n const serverFnHandler = async ({ context }: TODO) => {\n return runWithStartContext(\n {\n getRouter,\n startOptions: requestStartOptions,\n contextAfterGlobalMiddlewares: context,\n request,\n executedRequestMiddlewares,\n handlerType: 'serverFn',\n },\n () =>\n handleServerAction({\n request,\n context: requestOpts?.context,\n serverFnId,\n }),\n )\n }\n\n const middlewares = flattenedRequestMiddlewares.map(\n (d) => d.options.server,\n )\n const ctx = await executeMiddleware([...middlewares, serverFnHandler], {\n request,\n pathname: url.pathname,\n handlerType: 'serverFn',\n context: createNullProtoObject(requestOpts?.context),\n })\n\n return handleRedirectResponse(ctx.response, request, getRouter)\n }\n\n // Router execution function\n const executeRouter = async (\n serverContext: TODO,\n matchedRoutes?: ReadonlyArray<AnyRoute>,\n ): Promise<Response> => {\n const acceptHeader = request.headers.get('Accept') || '*/*'\n const acceptParts = acceptHeader.split(',')\n const supportedMimeTypes = ['*/*', 'text/html']\n\n const isSupported = supportedMimeTypes.some((mimeType) =>\n acceptParts.some((part) => part.trim().startsWith(mimeType)),\n )\n\n if (!isSupported) {\n return Response.json(\n { error: 'Only HTML requests are supported here' },\n { status: 500 },\n )\n }\n\n const manifest = await resolveManifestForRequest({\n request,\n requestInlineCss: requestOpts?.inlineCss,\n getBaseManifest: () => getBaseManifest(matchedRoutes),\n })\n\n const earlyHints = createEarlyHintsForRequest({\n onEarlyHints: requestOpts?.onEarlyHints,\n responseLinkHeader: requestOpts?.responseLinkHeader,\n })\n\n earlyHints?.collectStatic({ manifest, matchedRoutes })\n\n const routerInstance = await getRouter()\n\n attachRouterServerSsrUtils({\n router: routerInstance,\n manifest,\n getRequestAssets: () =>\n getStartContext({ throwIfNotFound: false })?.requestAssets,\n includeUnmatchedRouteAssets: false,\n })\n\n routerInstance.update({ additionalContext: { serverContext } })\n await routerInstance.load()\n\n if (routerInstance.state.redirect) {\n return routerInstance.state.redirect\n }\n\n earlyHints?.collectDynamic(routerInstance.stores.matches.get())\n\n // Pass request-scoped assets to dehydrate for manifest injection\n const ctx = getStartContext({ throwIfNotFound: false })\n await routerInstance.serverSsr!.dehydrate({\n requestAssets: ctx?.requestAssets,\n })\n\n const responseHeaders = getStartResponseHeaders({\n router: routerInstance,\n })\n earlyHints?.appendResponseHeaders(responseHeaders)\n cbWillCleanup = true\n\n return cb({\n request,\n router: routerInstance,\n responseHeaders,\n })\n }\n\n // Main request handler\n const requestHandlerMiddleware = async ({ context }: TODO) => {\n return runWithStartContext(\n {\n getRouter,\n startOptions: requestStartOptions,\n contextAfterGlobalMiddlewares: context,\n request,\n executedRequestMiddlewares,\n handlerType: 'router',\n },\n async () => {\n try {\n return await handleServerRoutes({\n getRouter,\n request,\n url,\n executeRouter,\n context,\n executedRequestMiddlewares,\n })\n } catch (err) {\n if (err instanceof Response) {\n return err\n }\n throw err\n }\n },\n )\n }\n\n const middlewares = flattenedRequestMiddlewares.map(\n (d) => d.options.server,\n )\n const ctx = await executeMiddleware(\n [...middlewares, requestHandlerMiddleware],\n {\n request,\n pathname: url.pathname,\n handlerType: 'router',\n context: createNullProtoObject(requestOpts?.context),\n },\n )\n\n return handleRedirectResponse(ctx.response, request, getRouter)\n } finally {\n if (router && !cbWillCleanup) {\n // Clean up router SSR state if it was set up but won't be cleaned up by the callback\n // (e.g., in redirect cases or early returns before the callback is invoked).\n // When the callback runs, it handles cleanup (either via transformStreamWithRouter\n // for streaming, or directly in renderRouterToString for non-streaming).\n router.serverSsr?.cleanup()\n }\n router = null\n }\n }\n\n return requestHandler(startRequestResolver)\n}\n\nasync function handleRedirectResponse(\n response: Response,\n request: Request,\n getRouter: () => Promise<AnyRouter>,\n): Promise<Response> {\n if (!isRedirect(response)) {\n return response\n }\n\n if (isResolvedRedirect(response)) {\n if (request.headers.get('x-tsr-serverFn') === 'true') {\n return Response.json(\n { ...response.options, isSerializedRedirect: true },\n { headers: response.headers },\n )\n }\n return response\n }\n\n const opts = response.options\n if (opts.to && typeof opts.to === 'string' && !opts.to.startsWith('/')) {\n throw new Error(\n `Server side redirects must use absolute paths via the 'href' or 'to' options. The redirect() method's \"to\" property accepts an internal path only. Use the \"href\" property to provide an external URL. Received: ${JSON.stringify(opts)}`,\n )\n }\n\n if (\n ['params', 'search', 'hash'].some(\n (d) => typeof (opts as TODO)[d] === 'function',\n )\n ) {\n throw new Error(\n `Server side redirects must use static search, params, and hash values and do not support functional values. Received functional values for: ${Object.keys(\n opts,\n )\n .filter((d) => typeof (opts as TODO)[d] === 'function')\n .map((d) => `\"${d}\"`)\n .join(', ')}`,\n )\n }\n\n const router = await getRouter()\n const redirect = router.resolveRedirect(response)\n\n if (request.headers.get('x-tsr-serverFn') === 'true') {\n return Response.json(\n { ...response.options, isSerializedRedirect: true },\n { headers: response.headers },\n )\n }\n\n return redirect\n}\n\nasync function handleServerRoutes({\n getRouter,\n request,\n url,\n executeRouter,\n context,\n executedRequestMiddlewares,\n}: {\n getRouter: () => Promise<AnyRouter>\n request: Request\n url: URL\n executeRouter: (\n serverContext: any,\n matchedRoutes?: ReadonlyArray<AnyRoute>,\n ) => Promise<Response>\n context: any\n executedRequestMiddlewares: Set<AnyRequestMiddleware>\n}): Promise<Response> {\n const router = await getRouter()\n const rewrittenUrl = executeRewriteInput(router.rewrite, url)\n const pathname = rewrittenUrl.pathname\n // this will perform a fuzzy match, however for server routes we need an exact match\n // if the route is not an exact match, executeRouter will handle rendering the app router\n // the match will be cached internally, so no extra work is done during the app router render\n const { matchedRoutes, foundRoute, routeParams } =\n router.getMatchedRoutes(pathname)\n\n const isExactMatch = foundRoute && routeParams['**'] === undefined\n\n // Collect and dedupe route middlewares\n const routeMiddlewares: Array<AnyMiddlewareServerFn> = []\n\n // Collect middleware from matched routes, filtering out those already executed\n // in the request phase\n for (const route of matchedRoutes) {\n const serverMiddleware = route.options.server?.middleware as\n | Array<AnyRequestMiddleware>\n | undefined\n if (serverMiddleware) {\n const flattened = flattenMiddlewares(serverMiddleware)\n for (const m of flattened) {\n if (!executedRequestMiddlewares.has(m)) {\n routeMiddlewares.push(m.options.server)\n }\n }\n }\n }\n\n // Add handler middleware if exact match\n const server = foundRoute?.options.server\n let isHeadFallback = false\n if (server?.handlers && isExactMatch) {\n const handlers =\n typeof server.handlers === 'function'\n ? server.handlers({ createHandlers: (d: any) => d })\n : server.handlers\n\n const requestMethod = request.method.toUpperCase() as RouteMethod\n // Per RFC 9110 §9.3.2, HEAD must return the same header fields as GET.\n // Priority for HEAD: explicit HEAD handler → GET → ANY (last resort).\n const handler =\n requestMethod === 'HEAD'\n ? (handlers['HEAD'] ?? handlers['GET'] ?? handlers['ANY'])\n : (handlers[requestMethod] ?? handlers['ANY'])\n isHeadFallback =\n requestMethod === 'HEAD' && handler !== undefined && !handlers['HEAD']\n\n if (handler) {\n const mayDefer = !!foundRoute.options.component\n\n if (typeof handler === 'function') {\n routeMiddlewares.push(handlerToMiddleware(handler, mayDefer))\n } else {\n if (handler.middleware?.length) {\n const handlerMiddlewares = flattenMiddlewares(handler.middleware)\n for (const m of handlerMiddlewares) {\n routeMiddlewares.push(m.options.server)\n }\n }\n if (handler.handler) {\n routeMiddlewares.push(handlerToMiddleware(handler.handler, mayDefer))\n }\n }\n }\n }\n\n // Final middleware: execute router with matched routes for dev styles\n routeMiddlewares.push((ctx: TODO) =>\n executeRouter(ctx.context, matchedRoutes),\n )\n\n const ctx = await executeMiddleware(routeMiddlewares, {\n request,\n context,\n params: routeParams,\n pathname,\n handlerType: 'router',\n })\n\n // RFC 9110 §9.3.2: HEAD must carry the same header fields as GET but no body.\n // Resolve any redirect before stripping so the Location header survives.\n if (isHeadFallback) {\n if (!ctx.response) {\n throwRouteHandlerError()\n }\n\n const resolved = await handleRedirectResponse(\n ctx.response,\n request,\n getRouter,\n )\n return new Response(null, resolved)\n }\n\n return ctx.response\n}\n"],"mappings":";;;;;;;;;;;;;AA+DA,SAAS,wBAAwB,MAA6B;AAS5D,QARgB,aACd,EACE,gBAAgB,4BACjB,EACD,GAAG,KAAK,OAAO,OAAO,QAAQ,KAAK,CAAC,KAAK,UAAU;AACjD,SAAO,MAAM;GACb,CACH;;AAiBH,IAAI;AACJ,IAAI,iCAAiC;AACrC,IAAM,wBAAwB,qBAAqB,EACjD,SAAS,QAAQ,IAAI,gBAAgB,YACtC,CAAC;AACF,IAAM,wBAAwB,qCAC5B,kBAAkB,CACnB;AACD,IAAM,4BACJ,uBAAuB;AACzB,IAAM,kBACJ,QAAQ,IAAI,mBAAmB,SAAS,mBAAmB;AAC7D,IAAM,6BACJ,QAAQ,IAAI,mBAAmB,eACrB,KAAA,IACN;AAEN,eAAe,cAAgC;CAC7C,MAAM,CAAC,aAAa,YAAY,kBAAkB,MAAM,QAAQ,IAAI;EAElE,OAAO;EAEP,OAAO;EAEP,OAAO;EACR,CAAC;AACF,QAAO;EACQ;EACD;EACI;EACjB;;AAGH,SAAS,aAAa;AACpB,KAAI,CAAC,eACH,kBAAiB,aAAa;AAEhC,QAAO;;AAGT,SAAS,kBACP,aACS;AACT,QAAO,YAAY,MAAM,eAAe,cAAc,WAAW;;AAGnE,SAAS,gCAAgC;AACvC,KAAI,+BAAgC;AACpC,kCAAiC;AAEjC,SAAQ,KAAK;;;;;;;;;;;;;;;;;;;;MAoBT;;AAIN,IAAM,kBAAkB,QAAQ,IAAI,uBAAuB;AAC3D,IAAM,iBAAiB,QAAQ,IAAI;AACnC,IAAM,kBAAkB,QAAQ,IAAI,qBAAqB;AACzD,IAAM,eAAe,QAAQ,IAAI,cAAc;AAC/C,IAAM,SAAA,QAAA,IAAA,aAAkC;AAGxC,IAAM,kBAAkB,SACpB,2KACA;AAEJ,IAAM,eAAe,SACjB,uFACA;AAEJ,SAAS,yBAAgC;AACvC,OAAM,IAAI,MAAM,gBAAgB;;AAGlC,SAAS,qBAA4B;AACnC,OAAM,IAAI,MAAM,aAAa;;;;;AAM/B,SAAS,kBAAkB,OAAmC;AAC5D,QAAO,iBAAiB,YAAY,WAAW,MAAM;;;;;AAMvD,SAAS,gBAAgB,QAAc;AACrC,KAAI,kBAAkB,OAAO,CAC3B,QAAO,EAAE,UAAU,QAAQ;AAE7B,QAAO;;;;;AAMT,SAAS,kBAAkB,aAA0B,KAA0B;CAC7E,IAAI,QAAQ;CAEZ,MAAM,OAAO,OAAO,YAAkC;AAEpD,MAAI,SAAS;AACX,OAAI,QAAQ,QACV,KAAI,UAAU,gBAAgB,IAAI,SAAS,QAAQ,QAAQ;AAG7D,QAAK,MAAM,OAAO,OAAO,KAAK,QAAQ,CACpC,KAAI,QAAQ,UACV,KAAI,OAAO,QAAQ;;AAKzB;EACA,MAAM,aAAa,YAAY;AAC/B,MAAI,CAAC,WAAY,QAAO;EAExB,IAAI;AACJ,MAAI;AACF,YAAS,MAAM,WAAW;IAAE,GAAG;IAAK;IAAM,CAAC;WACpC,KAAK;AACZ,OAAI,kBAAkB,IAAI,EAAE;AAC1B,QAAI,WAAW;AACf,WAAO;;AAET,SAAM;;EAGR,MAAM,aAAa,gBAAgB,OAAO;AAC1C,MAAI,YAAY;AACd,OAAI,WAAW,aAAa,KAAA,EAC1B,KAAI,WAAW,WAAW;AAE5B,OAAI,WAAW,QACb,KAAI,UAAU,gBAAgB,IAAI,SAAS,WAAW,QAAQ;;AAIlE,SAAO;;AAGT,QAAO,MAAM;;;;;AAMf,SAAS,oBACP,SACA,WAAoB,OACd;AACN,KAAI,SACF,QAAO;AAET,QAAO,OAAO,QAAc;EAC1B,MAAM,WAAW,MAAM,QAAQ;GAAE,GAAG;GAAK,MAAM;GAAoB,CAAC;AACpE,MAAI,CAAC,SACH,yBAAwB;AAE1B,SAAO;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;AAkCX,SAAgB,mBACd,aAC2B;CAC3B,MAAM,iBACJ,OAAO,gBAAgB,aAAa,EAAE,GAAG;CAC3C,MAAM,KACJ,OAAO,gBAAgB,aAAa,cAAc,YAAY;CAChE,MAAM,wBAAwB,4BAA4B;EACxD,GAAG;EACH,sBAAsB,QAAQ,IAAI,mBAAmB;EACtD,CAAC;CACF,MAAM,4BACJ,QAAQ,IAAI,mBAAmB,SAC3B,sBAAsB,kBACtB,sBAAsB;AAE5B,KAAI,QAAQ,IAAI,mBAAmB,OACjC,uBAAsB,OAAO,EAC3B,uBAAuB,gBAAgB,KAAA,EAAU,EAClD,CAAC;CAGJ,MAAM,uBAAiD,OACrD,SACA,gBACG;EACH,IAAI,SAA2B;EAC/B,IAAI,gBAAgB;AAEpB,MAAI;GAIF,MAAM,EAAE,KAAK,+BAA+B,iBAAiB,QAAQ,IAAI;GACzE,MAAM,OAAO,IAAI,WAAW,IAAI,SAAS,IAAI;GAC7C,MAAM,SAAS,UAAU,QAAQ;AAEjC,OAAI,2BACF,QAAO,SAAS,SAAS,KAAK,IAAI;GAGpC,MAAM,UAAU,MAAM,YAAY;GAClC,MAAM,mBAAmB,CAAC,CAAC,QAAQ,WAAW;GAC9C,MAAM,eACH,MAAM,QAAQ,WAAW,eAAe,YAAY,IACpD,EAAE;GAEL,MAAM,EAAE,mBAAmB,gCACzB,QAAQ;GAEV,MAAM,wBAAwB;IAC5B,GAAI,aAAa,yBAAyB,EAAE;IAC5C,GAAI,oBAAoB,8BAA8B,EAAE;IACxD;IACD;GAED,MAAM,sBAAsB;IAC1B,GAAG;IACH,mBAAmB,mBACf,aAAa,oBACb,CAAC,sBAAsB;IAC3B;IACD;GAGD,MAAM,8BAA8B,oBAAoB,oBACpD,mBAAmB,oBAAoB,kBAAkB,GACzD,EAAE;GAGN,MAAM,6BAA6B,IAAI,IACrC,4BACD;GAGD,MAAM,YAAY,YAAgC;AAChD,QAAI,OAAQ,QAAO;AAEnB,aAAS,MAAM,QAAQ,YAAY,WAAW;IAE9C,IAAI,UAAU;AACd,QAAI,mBAAmB,CAAC,QACtB,WAAU,QAAQ,QAAQ,IAAI,QAAQ,UAAU,KAAK;IAGvD,MAAM,UAAU,oBAAoB,EAClC,gBAAgB,CAAC,KAAK,EACvB,CAAC;AAEF,WAAO,OAAO;KACZ;KACA;KACA,gBAAgB;KAChB,QAAQ,OAAO,QAAQ,UAAU;KAE/B,YAAY,oBAAoB;KAChC,uBAAuB,CACrB,GAAG,oBAAoB,uBACvB,GAAI,OAAO,QAAQ,yBAAyB,EAAE,CAC/C;KAEH,UAAU;KACX,CAAC;AAEF,WAAO;;AAIT,OAAI,kBAAkB,IAAI,SAAS,WAAW,eAAe,EAAE;AAC7D,QAAA,QAAA,IAAA,aAC2B,gBACzB,QAAQ,IAAI,wCAAwC,UACpD,CAAC,kBAAkB,4BAA4B,CAE/C,gCAA+B;IAGjC,MAAM,aAAa,IAAI,SACpB,MAAM,eAAe,OAAO,CAC5B,MAAM,IAAI,CAAC;AAEd,QAAI,CAAC,WACH,OAAM,IAAI,MAAM,6CAA6C;IAG/D,MAAM,kBAAkB,OAAO,EAAE,cAAoB;AACnD,YAAO,oBACL;MACE;MACA,cAAc;MACd,+BAA+B;MAC/B;MACA;MACA,aAAa;MACd,QAEC,mBAAmB;MACjB;MACA,SAAS,aAAa;MACtB;MACD,CAAC,CACL;;AAaH,WAAO,wBAPK,MAAM,kBAAkB,CAAC,GAHjB,4BAA4B,KAC7C,MAAM,EAAE,QAAQ,OAClB,EACoD,gBAAgB,EAAE;KACrE;KACA,UAAU,IAAI;KACd,aAAa;KACb,SAAS,sBAAsB,aAAa,QAAQ;KACrD,CAAC,EAEgC,UAAU,SAAS,UAAU;;GAIjE,MAAM,gBAAgB,OACpB,eACA,kBACsB;IAEtB,MAAM,eADe,QAAQ,QAAQ,IAAI,SAAS,IAAI,OACrB,MAAM,IAAI;AAO3C,QAAI,CANuB,CAAC,OAAO,YAAY,CAER,MAAM,aAC3C,YAAY,MAAM,SAAS,KAAK,MAAM,CAAC,WAAW,SAAS,CAAC,CAC7D,CAGC,QAAO,SAAS,KACd,EAAE,OAAO,yCAAyC,EAClD,EAAE,QAAQ,KAAK,CAChB;IAGH,MAAM,WAAW,MAAM,0BAA0B;KAC/C;KACA,kBAAkB,aAAa;KAC/B,uBAAuB,gBAAgB,cAAc;KACtD,CAAC;IAEF,MAAM,aAAa,2BAA2B;KAC5C,cAAc,aAAa;KAC3B,oBAAoB,aAAa;KAClC,CAAC;AAEF,gBAAY,cAAc;KAAE;KAAU;KAAe,CAAC;IAEtD,MAAM,iBAAiB,MAAM,WAAW;AAExC,+BAA2B;KACzB,QAAQ;KACR;KACA,wBACE,gBAAgB,EAAE,iBAAiB,OAAO,CAAC,EAAE;KAC/C,6BAA6B;KAC9B,CAAC;AAEF,mBAAe,OAAO,EAAE,mBAAmB,EAAE,eAAe,EAAE,CAAC;AAC/D,UAAM,eAAe,MAAM;AAE3B,QAAI,eAAe,MAAM,SACvB,QAAO,eAAe,MAAM;AAG9B,gBAAY,eAAe,eAAe,OAAO,QAAQ,KAAK,CAAC;IAG/D,MAAM,MAAM,gBAAgB,EAAE,iBAAiB,OAAO,CAAC;AACvD,UAAM,eAAe,UAAW,UAAU,EACxC,eAAe,KAAK,eACrB,CAAC;IAEF,MAAM,kBAAkB,wBAAwB,EAC9C,QAAQ,gBACT,CAAC;AACF,gBAAY,sBAAsB,gBAAgB;AAClD,oBAAgB;AAEhB,WAAO,GAAG;KACR;KACA,QAAQ;KACR;KACD,CAAC;;GAIJ,MAAM,2BAA2B,OAAO,EAAE,cAAoB;AAC5D,WAAO,oBACL;KACE;KACA,cAAc;KACd,+BAA+B;KAC/B;KACA;KACA,aAAa;KACd,EACD,YAAY;AACV,SAAI;AACF,aAAO,MAAM,mBAAmB;OAC9B;OACA;OACA;OACA;OACA;OACA;OACD,CAAC;cACK,KAAK;AACZ,UAAI,eAAe,SACjB,QAAO;AAET,YAAM;;MAGX;;AAgBH,UAAO,wBAVK,MAAM,kBAChB,CAAC,GAJiB,4BAA4B,KAC7C,MAAM,EAAE,QAAQ,OAClB,EAEkB,yBAAyB,EAC1C;IACE;IACA,UAAU,IAAI;IACd,aAAa;IACb,SAAS,sBAAsB,aAAa,QAAQ;IACrD,CACF,EAEiC,UAAU,SAAS,UAAU;YACvD;AACR,OAAI,UAAU,CAAC,cAKb,QAAO,WAAW,SAAS;AAE7B,YAAS;;;AAIb,QAAO,eAAe,qBAAqB;;AAG7C,eAAe,uBACb,UACA,SACA,WACmB;AACnB,KAAI,CAAC,WAAW,SAAS,CACvB,QAAO;AAGT,KAAI,mBAAmB,SAAS,EAAE;AAChC,MAAI,QAAQ,QAAQ,IAAI,iBAAiB,KAAK,OAC5C,QAAO,SAAS,KACd;GAAE,GAAG,SAAS;GAAS,sBAAsB;GAAM,EACnD,EAAE,SAAS,SAAS,SAAS,CAC9B;AAEH,SAAO;;CAGT,MAAM,OAAO,SAAS;AACtB,KAAI,KAAK,MAAM,OAAO,KAAK,OAAO,YAAY,CAAC,KAAK,GAAG,WAAW,IAAI,CACpE,OAAM,IAAI,MACR,oNAAoN,KAAK,UAAU,KAAK,GACzO;AAGH,KACE;EAAC;EAAU;EAAU;EAAO,CAAC,MAC1B,MAAM,OAAQ,KAAc,OAAO,WACrC,CAED,OAAM,IAAI,MACR,+IAA+I,OAAO,KACpJ,KACD,CACE,QAAQ,MAAM,OAAQ,KAAc,OAAO,WAAW,CACtD,KAAK,MAAM,IAAI,EAAE,GAAG,CACpB,KAAK,KAAK,GACd;CAIH,MAAM,YADS,MAAM,WAAW,EACR,gBAAgB,SAAS;AAEjD,KAAI,QAAQ,QAAQ,IAAI,iBAAiB,KAAK,OAC5C,QAAO,SAAS,KACd;EAAE,GAAG,SAAS;EAAS,sBAAsB;EAAM,EACnD,EAAE,SAAS,SAAS,SAAS,CAC9B;AAGH,QAAO;;AAGT,eAAe,mBAAmB,EAChC,WACA,SACA,KACA,eACA,SACA,8BAWoB;CACpB,MAAM,SAAS,MAAM,WAAW;CAEhC,MAAM,WADe,oBAAoB,OAAO,SAAS,IAAI,CAC/B;CAI9B,MAAM,EAAE,eAAe,YAAY,gBACjC,OAAO,iBAAiB,SAAS;CAEnC,MAAM,eAAe,cAAc,YAAY,UAAU,KAAA;CAGzD,MAAM,mBAAiD,EAAE;AAIzD,MAAK,MAAM,SAAS,eAAe;EACjC,MAAM,mBAAmB,MAAM,QAAQ,QAAQ;AAG/C,MAAI,kBAAkB;GACpB,MAAM,YAAY,mBAAmB,iBAAiB;AACtD,QAAK,MAAM,KAAK,UACd,KAAI,CAAC,2BAA2B,IAAI,EAAE,CACpC,kBAAiB,KAAK,EAAE,QAAQ,OAAO;;;CAO/C,MAAM,SAAS,YAAY,QAAQ;CACnC,IAAI,iBAAiB;AACrB,KAAI,QAAQ,YAAY,cAAc;EACpC,MAAM,WACJ,OAAO,OAAO,aAAa,aACvB,OAAO,SAAS,EAAE,iBAAiB,MAAW,GAAG,CAAC,GAClD,OAAO;EAEb,MAAM,gBAAgB,QAAQ,OAAO,aAAa;EAGlD,MAAM,UACJ,kBAAkB,SACb,SAAS,WAAW,SAAS,UAAU,SAAS,SAChD,SAAS,kBAAkB,SAAS;AAC3C,mBACE,kBAAkB,UAAU,YAAY,KAAA,KAAa,CAAC,SAAS;AAEjE,MAAI,SAAS;GACX,MAAM,WAAW,CAAC,CAAC,WAAW,QAAQ;AAEtC,OAAI,OAAO,YAAY,WACrB,kBAAiB,KAAK,oBAAoB,SAAS,SAAS,CAAC;QACxD;AACL,QAAI,QAAQ,YAAY,QAAQ;KAC9B,MAAM,qBAAqB,mBAAmB,QAAQ,WAAW;AACjE,UAAK,MAAM,KAAK,mBACd,kBAAiB,KAAK,EAAE,QAAQ,OAAO;;AAG3C,QAAI,QAAQ,QACV,kBAAiB,KAAK,oBAAoB,QAAQ,SAAS,SAAS,CAAC;;;;AAO7E,kBAAiB,MAAM,QACrB,cAAc,IAAI,SAAS,cAAc,CAC1C;CAED,MAAM,MAAM,MAAM,kBAAkB,kBAAkB;EACpD;EACA;EACA,QAAQ;EACR;EACA,aAAa;EACd,CAAC;AAIF,KAAI,gBAAgB;AAClB,MAAI,CAAC,IAAI,SACP,yBAAwB;EAG1B,MAAM,WAAW,MAAM,uBACrB,IAAI,UACJ,SACA,UACD;AACD,SAAO,IAAI,SAAS,MAAM,SAAS;;AAGrC,QAAO,IAAI"}

@@ -30,2 +30,10 @@ import { AnyRoute, AnyRouteMatch, AssetCrossOrigin, Manifest } from '@tanstack/router-core';

};
export interface EarlyHintsCollector {
collectStatic: (opts: {
manifest: Manifest;
matchedRoutes?: ReadonlyArray<AnyRoute>;
}) => void;
collectDynamic: (matches: ReadonlyArray<AnyRouteMatch>) => void;
appendResponseHeaders: (headers: Headers) => void;
}
export declare function serializeEarlyHint(hint: EarlyHint): string;

@@ -50,1 +58,5 @@ export declare function collectStaticHintsFromManifest(manifest: Manifest, matchedRoutes: ReadonlyArray<AnyRoute>): Array<EarlyHint>;

}): Array<string>;
export declare function createEarlyHintsCollector(opts: {
onEarlyHints?: OnEarlyHints;
responseLinkHeader?: boolean | ResponseLinkHeaderOptions;
} | undefined): EarlyHintsCollector | undefined;

@@ -170,5 +170,91 @@ import { getStylesheetHref, resolveManifestAssetLink } from "@tanstack/router-core";

}
function notifyEarlyHints(phase, event, onEarlyHints) {
try {
const result = onEarlyHints(event);
if (result) Promise.resolve(result).catch((err) => {
console.error(`Error sending ${phase} early hints:`, err);
});
} catch (err) {
console.error(`Error sending ${phase} early hints:`, err);
}
}
function getResponseLinkHeaderFilter(responseLinkHeader) {
if (typeof responseLinkHeader !== "object") return;
return responseLinkHeader.filter;
}
function appendResponseLinkHeaders(opts) {
for (const link of getResponseLinkHeaderEntries(opts)) opts.responseHeaders.append("Link", link);
}
function collectResponseLinkHeaderEntries(opts) {
for (let index = 0; index < opts.event.hints.length; index++) opts.entries.push({
phase: opts.phase,
hint: opts.event.hints[index],
link: opts.event.links[index]
});
}
function collectEarlyHintsPhase(opts) {
const event = opts.onEarlyHints ? createEarlyHintsEvent({
phase: opts.phase,
hints: opts.hints,
sentLinks: opts.sentLinks,
sentHints: opts.sentHints
}) : void 0;
if (event) notifyEarlyHints(opts.phase, event, opts.onEarlyHints);
if (!opts.responseLinkHeaderEntries) return;
if (event) {
collectResponseLinkHeaderEntries({
phase: opts.phase,
event,
entries: opts.responseLinkHeaderEntries
});
return;
}
createResponseLinkHeaderEntries({
phase: opts.phase,
hints: opts.hints,
sentLinks: opts.sentLinks,
entries: opts.responseLinkHeaderEntries
});
}
function createEarlyHintsCollector(opts) {
if (process.env.TSS_DEV_SERVER === "true" || !opts?.onEarlyHints && !opts?.responseLinkHeader) return;
const sentLinks = /* @__PURE__ */ new Set();
const sentHints = opts.onEarlyHints ? new Array() : void 0;
const responseLinkHeaderEntries = opts.responseLinkHeader ? new Array() : void 0;
const responseLinkHeaderFilter = getResponseLinkHeaderFilter(opts.responseLinkHeader);
return {
collectStatic: ({ manifest, matchedRoutes }) => {
if (!matchedRoutes?.length) return;
collectEarlyHintsPhase({
phase: "static",
hints: collectStaticHintsFromManifest(manifest, matchedRoutes),
sentLinks,
sentHints,
onEarlyHints: opts.onEarlyHints,
responseLinkHeaderEntries
});
},
collectDynamic: (matches) => {
collectEarlyHintsPhase({
phase: "dynamic",
hints: collectDynamicHintsFromMatches(matches),
sentLinks,
sentHints,
onEarlyHints: opts.onEarlyHints,
responseLinkHeaderEntries
});
},
appendResponseHeaders: (headers) => {
if (!responseLinkHeaderEntries?.length) return;
appendResponseLinkHeaders({
responseHeaders: headers,
entries: responseLinkHeaderEntries,
filter: responseLinkHeaderFilter
});
}
};
}
//#endregion
export { collectDynamicHintsFromMatches, collectStaticHintsFromManifest, createEarlyHintsEvent, createResponseLinkHeaderEntries, getResponseLinkHeaderEntries };
export { createEarlyHintsCollector };
//# sourceMappingURL=early-hints.js.map

@@ -1,1 +0,1 @@

{"version":3,"file":"early-hints.js","names":[],"sources":["../../src/early-hints.ts"],"sourcesContent":["import {\n getStylesheetHref,\n resolveManifestAssetLink,\n} from '@tanstack/router-core'\nimport type {\n AnyRoute,\n AnyRouteMatch,\n AssetCrossOrigin,\n Manifest,\n RouterManagedTag,\n} from '@tanstack/router-core'\n\nexport type EarlyHint = {\n href: string\n rel: 'preload' | 'modulepreload' | 'preconnect' | 'dns-prefetch'\n as?: 'fetch' | 'font' | 'image' | 'script' | 'style' | 'track'\n crossOrigin?: AssetCrossOrigin | ''\n type?: string\n integrity?: string\n referrerPolicy?: string\n fetchPriority?: string\n}\n\nexport type EarlyHintsPhase = 'static' | 'dynamic'\n\nexport type EarlyHintsEvent = {\n phase: EarlyHintsPhase\n hints: ReadonlyArray<EarlyHint>\n links: Array<string>\n allHints: ReadonlyArray<EarlyHint>\n allLinks: Array<string>\n}\n\nexport type OnEarlyHints = (event: EarlyHintsEvent) => void | Promise<void>\n\nexport type ResponseLinkHeaderEntry = {\n phase: EarlyHintsPhase\n hint: EarlyHint\n link: string\n}\n\nexport type ResponseLinkHeaderFilter = (\n entry: ResponseLinkHeaderEntry,\n) => boolean\n\nexport type ResponseLinkHeaderOptions = {\n filter?: ResponseLinkHeaderFilter\n}\n\nconst LINK_PARAM_TOKEN_RE = /^[!#$%&'*+\\-.^_`|~0-9A-Za-z]+$/\nconst PRELOAD_AS_VALUES = new Set<EarlyHint['as']>([\n 'fetch',\n 'font',\n 'image',\n 'script',\n 'style',\n 'track',\n])\n\nfunction buildLinkParam(name: string, value: string | undefined): string {\n if (value === undefined) return name\n if (LINK_PARAM_TOKEN_RE.test(value)) return `${name}=${value}`\n return `${name}=${JSON.stringify(value)}`\n}\n\nexport function serializeEarlyHint(hint: EarlyHint): string {\n const parts = [`<${hint.href}>`, buildLinkParam('rel', hint.rel)]\n if (hint.as) parts.push(buildLinkParam('as', hint.as))\n if (hint.crossOrigin !== undefined) {\n parts.push(buildLinkParam('crossorigin', hint.crossOrigin || undefined))\n }\n if (hint.type) parts.push(buildLinkParam('type', hint.type))\n if (hint.integrity) parts.push(buildLinkParam('integrity', hint.integrity))\n if (hint.referrerPolicy) {\n parts.push(buildLinkParam('referrerpolicy', hint.referrerPolicy))\n }\n if (hint.fetchPriority) {\n parts.push(buildLinkParam('fetchpriority', hint.fetchPriority))\n }\n return parts.join('; ')\n}\n\nfunction getStringAttr(\n attrs: Record<string, any> | undefined,\n name: string,\n fallbackName?: string,\n): string | undefined {\n const value =\n attrs?.[name] ?? (fallbackName ? attrs?.[fallbackName] : undefined)\n return typeof value === 'string' ? value : undefined\n}\n\nfunction getPreloadAs(\n attrs: Record<string, any> | undefined,\n): EarlyHint['as'] | undefined {\n const as = getStringAttr(attrs, 'as')\n return as && PRELOAD_AS_VALUES.has(as as EarlyHint['as'])\n ? (as as EarlyHint['as'])\n : undefined\n}\n\nfunction addEarlyHintFetchAttrs(\n hint: EarlyHint,\n attrs: Record<string, any> | undefined,\n) {\n const crossOrigin = getStringAttr(attrs, 'crossOrigin', 'crossorigin') as\n | EarlyHint['crossOrigin']\n | undefined\n const type = getStringAttr(attrs, 'type')\n const integrity = getStringAttr(attrs, 'integrity')\n const referrerPolicy = getStringAttr(\n attrs,\n 'referrerPolicy',\n 'referrerpolicy',\n )\n const fetchPriority = getStringAttr(attrs, 'fetchPriority', 'fetchpriority')\n\n if (crossOrigin !== undefined) hint.crossOrigin = crossOrigin\n if (type) hint.type = type\n if (integrity) hint.integrity = integrity\n if (referrerPolicy) hint.referrerPolicy = referrerPolicy\n if (fetchPriority) hint.fetchPriority = fetchPriority\n}\n\nfunction linkAttrsToEarlyHint(\n attrs: Record<string, any> | undefined,\n): EarlyHint | undefined {\n const href = getStringAttr(attrs, 'href')\n const rel = getStringAttr(attrs, 'rel')\n if (!href || !rel) return undefined\n\n const relTokens = rel.split(/\\s+/)\n let hintRel: EarlyHint['rel'] | undefined\n let hintAs: EarlyHint['as'] | undefined\n\n if (relTokens.includes('modulepreload')) {\n hintRel = 'modulepreload'\n hintAs = 'script'\n } else if (relTokens.includes('stylesheet')) {\n hintRel = 'preload'\n hintAs = 'style'\n } else if (relTokens.includes('preload')) {\n hintAs = getPreloadAs(attrs)\n if (!hintAs) return undefined\n hintRel = 'preload'\n } else if (relTokens.includes('preconnect')) {\n hintRel = 'preconnect'\n hintAs = undefined\n } else if (relTokens.includes('dns-prefetch')) {\n hintRel = 'dns-prefetch'\n hintAs = undefined\n }\n\n if (!hintRel) return undefined\n\n const hint: EarlyHint = {\n href,\n rel: hintRel,\n }\n\n if (hintAs) hint.as = hintAs\n addEarlyHintFetchAttrs(hint, attrs)\n\n return hint\n}\n\nexport function collectStaticHintsFromManifest(\n manifest: Manifest,\n matchedRoutes: ReadonlyArray<AnyRoute>,\n): Array<EarlyHint> {\n const hints: Array<EarlyHint> = []\n\n for (const route of matchedRoutes) {\n const routeManifest = manifest.routes[route.id]\n if (!routeManifest) continue\n\n for (const link of routeManifest.preloads ?? []) {\n const { href, crossOrigin } = resolveManifestAssetLink(link)\n const hint: EarlyHint = { href, rel: 'modulepreload', as: 'script' }\n if (crossOrigin !== undefined) hint.crossOrigin = crossOrigin\n hints.push(hint)\n }\n\n for (const asset of routeManifest.assets ?? []) {\n if (asset.tag !== 'link') continue\n\n const stylesheetHref = getStylesheetHref(asset)\n if (stylesheetHref) {\n if (manifest.inlineCss?.styles[stylesheetHref] !== undefined) continue\n\n const hint: EarlyHint = {\n href: stylesheetHref,\n rel: 'preload',\n as: 'style',\n }\n addEarlyHintFetchAttrs(hint, asset.attrs)\n hints.push(hint)\n continue\n }\n\n const hint = linkAttrsToEarlyHint(asset.attrs)\n if (hint) {\n hints.push(hint)\n }\n }\n }\n\n return hints\n}\n\nexport function collectDynamicHintsFromMatches(\n matches: ReadonlyArray<AnyRouteMatch>,\n): Array<EarlyHint> {\n const hints: Array<EarlyHint> = []\n\n for (const match of matches) {\n const links = match.links\n if (!Array.isArray(links)) continue\n\n for (const link of links as Array<RouterManagedTag['attrs']>) {\n const hint = linkAttrsToEarlyHint(link)\n if (hint) hints.push(hint)\n }\n }\n\n return hints\n}\n\nexport function createEarlyHintsEvent(opts: {\n phase: EarlyHintsPhase\n hints: ReadonlyArray<EarlyHint>\n sentLinks: Set<string>\n sentHints: Array<EarlyHint>\n}): EarlyHintsEvent | undefined {\n const nextHints: Array<EarlyHint> = []\n const nextLinks: Array<string> = []\n\n for (const hint of opts.hints) {\n const link = serializeEarlyHint(hint)\n if (opts.sentLinks.has(link)) continue\n opts.sentLinks.add(link)\n opts.sentHints.push(hint)\n nextHints.push(hint)\n nextLinks.push(link)\n }\n\n if (!nextHints.length && opts.phase !== 'dynamic') return undefined\n\n return {\n phase: opts.phase,\n hints: nextHints,\n links: nextLinks,\n allHints: opts.sentHints.slice(),\n allLinks: Array.from(opts.sentLinks),\n }\n}\n\nexport function createResponseLinkHeaderEntries(opts: {\n phase: EarlyHintsPhase\n hints: ReadonlyArray<EarlyHint>\n sentLinks: Set<string>\n entries: Array<ResponseLinkHeaderEntry>\n}) {\n for (const hint of opts.hints) {\n const link = serializeEarlyHint(hint)\n if (opts.sentLinks.has(link)) continue\n\n opts.sentLinks.add(link)\n opts.entries.push({ phase: opts.phase, hint, link })\n }\n}\n\nexport function getResponseLinkHeaderEntries(opts: {\n entries: ReadonlyArray<ResponseLinkHeaderEntry>\n filter?: ResponseLinkHeaderFilter\n}): Array<string> {\n if (!opts.filter) {\n return opts.entries.map((entry) => entry.link)\n }\n\n try {\n const links: Array<string> = []\n\n for (const entry of opts.entries) {\n if (opts.filter(entry)) {\n links.push(entry.link)\n }\n }\n\n return links\n } catch (err) {\n console.error('Error filtering response Link headers:', err)\n return []\n }\n}\n"],"mappings":";;AAiDA,IAAM,sBAAsB;AAC5B,IAAM,oBAAoB,IAAI,IAAqB;CACjD;CACA;CACA;CACA;CACA;CACA;CACD,CAAC;AAEF,SAAS,eAAe,MAAc,OAAmC;AACvE,KAAI,UAAU,KAAA,EAAW,QAAO;AAChC,KAAI,oBAAoB,KAAK,MAAM,CAAE,QAAO,GAAG,KAAK,GAAG;AACvD,QAAO,GAAG,KAAK,GAAG,KAAK,UAAU,MAAM;;AAGzC,SAAgB,mBAAmB,MAAyB;CAC1D,MAAM,QAAQ,CAAC,IAAI,KAAK,KAAK,IAAI,eAAe,OAAO,KAAK,IAAI,CAAC;AACjE,KAAI,KAAK,GAAI,OAAM,KAAK,eAAe,MAAM,KAAK,GAAG,CAAC;AACtD,KAAI,KAAK,gBAAgB,KAAA,EACvB,OAAM,KAAK,eAAe,eAAe,KAAK,eAAe,KAAA,EAAU,CAAC;AAE1E,KAAI,KAAK,KAAM,OAAM,KAAK,eAAe,QAAQ,KAAK,KAAK,CAAC;AAC5D,KAAI,KAAK,UAAW,OAAM,KAAK,eAAe,aAAa,KAAK,UAAU,CAAC;AAC3E,KAAI,KAAK,eACP,OAAM,KAAK,eAAe,kBAAkB,KAAK,eAAe,CAAC;AAEnE,KAAI,KAAK,cACP,OAAM,KAAK,eAAe,iBAAiB,KAAK,cAAc,CAAC;AAEjE,QAAO,MAAM,KAAK,KAAK;;AAGzB,SAAS,cACP,OACA,MACA,cACoB;CACpB,MAAM,QACJ,QAAQ,UAAU,eAAe,QAAQ,gBAAgB,KAAA;AAC3D,QAAO,OAAO,UAAU,WAAW,QAAQ,KAAA;;AAG7C,SAAS,aACP,OAC6B;CAC7B,MAAM,KAAK,cAAc,OAAO,KAAK;AACrC,QAAO,MAAM,kBAAkB,IAAI,GAAsB,GACpD,KACD,KAAA;;AAGN,SAAS,uBACP,MACA,OACA;CACA,MAAM,cAAc,cAAc,OAAO,eAAe,cAAc;CAGtE,MAAM,OAAO,cAAc,OAAO,OAAO;CACzC,MAAM,YAAY,cAAc,OAAO,YAAY;CACnD,MAAM,iBAAiB,cACrB,OACA,kBACA,iBACD;CACD,MAAM,gBAAgB,cAAc,OAAO,iBAAiB,gBAAgB;AAE5E,KAAI,gBAAgB,KAAA,EAAW,MAAK,cAAc;AAClD,KAAI,KAAM,MAAK,OAAO;AACtB,KAAI,UAAW,MAAK,YAAY;AAChC,KAAI,eAAgB,MAAK,iBAAiB;AAC1C,KAAI,cAAe,MAAK,gBAAgB;;AAG1C,SAAS,qBACP,OACuB;CACvB,MAAM,OAAO,cAAc,OAAO,OAAO;CACzC,MAAM,MAAM,cAAc,OAAO,MAAM;AACvC,KAAI,CAAC,QAAQ,CAAC,IAAK,QAAO,KAAA;CAE1B,MAAM,YAAY,IAAI,MAAM,MAAM;CAClC,IAAI;CACJ,IAAI;AAEJ,KAAI,UAAU,SAAS,gBAAgB,EAAE;AACvC,YAAU;AACV,WAAS;YACA,UAAU,SAAS,aAAa,EAAE;AAC3C,YAAU;AACV,WAAS;YACA,UAAU,SAAS,UAAU,EAAE;AACxC,WAAS,aAAa,MAAM;AAC5B,MAAI,CAAC,OAAQ,QAAO,KAAA;AACpB,YAAU;YACD,UAAU,SAAS,aAAa,EAAE;AAC3C,YAAU;AACV,WAAS,KAAA;YACA,UAAU,SAAS,eAAe,EAAE;AAC7C,YAAU;AACV,WAAS,KAAA;;AAGX,KAAI,CAAC,QAAS,QAAO,KAAA;CAErB,MAAM,OAAkB;EACtB;EACA,KAAK;EACN;AAED,KAAI,OAAQ,MAAK,KAAK;AACtB,wBAAuB,MAAM,MAAM;AAEnC,QAAO;;AAGT,SAAgB,+BACd,UACA,eACkB;CAClB,MAAM,QAA0B,EAAE;AAElC,MAAK,MAAM,SAAS,eAAe;EACjC,MAAM,gBAAgB,SAAS,OAAO,MAAM;AAC5C,MAAI,CAAC,cAAe;AAEpB,OAAK,MAAM,QAAQ,cAAc,YAAY,EAAE,EAAE;GAC/C,MAAM,EAAE,MAAM,gBAAgB,yBAAyB,KAAK;GAC5D,MAAM,OAAkB;IAAE;IAAM,KAAK;IAAiB,IAAI;IAAU;AACpE,OAAI,gBAAgB,KAAA,EAAW,MAAK,cAAc;AAClD,SAAM,KAAK,KAAK;;AAGlB,OAAK,MAAM,SAAS,cAAc,UAAU,EAAE,EAAE;AAC9C,OAAI,MAAM,QAAQ,OAAQ;GAE1B,MAAM,iBAAiB,kBAAkB,MAAM;AAC/C,OAAI,gBAAgB;AAClB,QAAI,SAAS,WAAW,OAAO,oBAAoB,KAAA,EAAW;IAE9D,MAAM,OAAkB;KACtB,MAAM;KACN,KAAK;KACL,IAAI;KACL;AACD,2BAAuB,MAAM,MAAM,MAAM;AACzC,UAAM,KAAK,KAAK;AAChB;;GAGF,MAAM,OAAO,qBAAqB,MAAM,MAAM;AAC9C,OAAI,KACF,OAAM,KAAK,KAAK;;;AAKtB,QAAO;;AAGT,SAAgB,+BACd,SACkB;CAClB,MAAM,QAA0B,EAAE;AAElC,MAAK,MAAM,SAAS,SAAS;EAC3B,MAAM,QAAQ,MAAM;AACpB,MAAI,CAAC,MAAM,QAAQ,MAAM,CAAE;AAE3B,OAAK,MAAM,QAAQ,OAA2C;GAC5D,MAAM,OAAO,qBAAqB,KAAK;AACvC,OAAI,KAAM,OAAM,KAAK,KAAK;;;AAI9B,QAAO;;AAGT,SAAgB,sBAAsB,MAKN;CAC9B,MAAM,YAA8B,EAAE;CACtC,MAAM,YAA2B,EAAE;AAEnC,MAAK,MAAM,QAAQ,KAAK,OAAO;EAC7B,MAAM,OAAO,mBAAmB,KAAK;AACrC,MAAI,KAAK,UAAU,IAAI,KAAK,CAAE;AAC9B,OAAK,UAAU,IAAI,KAAK;AACxB,OAAK,UAAU,KAAK,KAAK;AACzB,YAAU,KAAK,KAAK;AACpB,YAAU,KAAK,KAAK;;AAGtB,KAAI,CAAC,UAAU,UAAU,KAAK,UAAU,UAAW,QAAO,KAAA;AAE1D,QAAO;EACL,OAAO,KAAK;EACZ,OAAO;EACP,OAAO;EACP,UAAU,KAAK,UAAU,OAAO;EAChC,UAAU,MAAM,KAAK,KAAK,UAAU;EACrC;;AAGH,SAAgB,gCAAgC,MAK7C;AACD,MAAK,MAAM,QAAQ,KAAK,OAAO;EAC7B,MAAM,OAAO,mBAAmB,KAAK;AACrC,MAAI,KAAK,UAAU,IAAI,KAAK,CAAE;AAE9B,OAAK,UAAU,IAAI,KAAK;AACxB,OAAK,QAAQ,KAAK;GAAE,OAAO,KAAK;GAAO;GAAM;GAAM,CAAC;;;AAIxD,SAAgB,6BAA6B,MAG3B;AAChB,KAAI,CAAC,KAAK,OACR,QAAO,KAAK,QAAQ,KAAK,UAAU,MAAM,KAAK;AAGhD,KAAI;EACF,MAAM,QAAuB,EAAE;AAE/B,OAAK,MAAM,SAAS,KAAK,QACvB,KAAI,KAAK,OAAO,MAAM,CACpB,OAAM,KAAK,MAAM,KAAK;AAI1B,SAAO;UACA,KAAK;AACZ,UAAQ,MAAM,0CAA0C,IAAI;AAC5D,SAAO,EAAE"}
{"version":3,"file":"early-hints.js","names":[],"sources":["../../src/early-hints.ts"],"sourcesContent":["import {\n getStylesheetHref,\n resolveManifestAssetLink,\n} from '@tanstack/router-core'\nimport type {\n AnyRoute,\n AnyRouteMatch,\n AssetCrossOrigin,\n Manifest,\n RouterManagedTag,\n} from '@tanstack/router-core'\n\nexport type EarlyHint = {\n href: string\n rel: 'preload' | 'modulepreload' | 'preconnect' | 'dns-prefetch'\n as?: 'fetch' | 'font' | 'image' | 'script' | 'style' | 'track'\n crossOrigin?: AssetCrossOrigin | ''\n type?: string\n integrity?: string\n referrerPolicy?: string\n fetchPriority?: string\n}\n\nexport type EarlyHintsPhase = 'static' | 'dynamic'\n\nexport type EarlyHintsEvent = {\n phase: EarlyHintsPhase\n hints: ReadonlyArray<EarlyHint>\n links: Array<string>\n allHints: ReadonlyArray<EarlyHint>\n allLinks: Array<string>\n}\n\nexport type OnEarlyHints = (event: EarlyHintsEvent) => void | Promise<void>\n\nexport type ResponseLinkHeaderEntry = {\n phase: EarlyHintsPhase\n hint: EarlyHint\n link: string\n}\n\nexport type ResponseLinkHeaderFilter = (\n entry: ResponseLinkHeaderEntry,\n) => boolean\n\nexport type ResponseLinkHeaderOptions = {\n filter?: ResponseLinkHeaderFilter\n}\n\nexport interface EarlyHintsCollector {\n collectStatic: (opts: {\n manifest: Manifest\n matchedRoutes?: ReadonlyArray<AnyRoute>\n }) => void\n collectDynamic: (matches: ReadonlyArray<AnyRouteMatch>) => void\n appendResponseHeaders: (headers: Headers) => void\n}\n\nconst LINK_PARAM_TOKEN_RE = /^[!#$%&'*+\\-.^_`|~0-9A-Za-z]+$/\nconst PRELOAD_AS_VALUES = new Set<EarlyHint['as']>([\n 'fetch',\n 'font',\n 'image',\n 'script',\n 'style',\n 'track',\n])\n\nfunction buildLinkParam(name: string, value: string | undefined): string {\n if (value === undefined) return name\n if (LINK_PARAM_TOKEN_RE.test(value)) return `${name}=${value}`\n return `${name}=${JSON.stringify(value)}`\n}\n\nexport function serializeEarlyHint(hint: EarlyHint): string {\n const parts = [`<${hint.href}>`, buildLinkParam('rel', hint.rel)]\n if (hint.as) parts.push(buildLinkParam('as', hint.as))\n if (hint.crossOrigin !== undefined) {\n parts.push(buildLinkParam('crossorigin', hint.crossOrigin || undefined))\n }\n if (hint.type) parts.push(buildLinkParam('type', hint.type))\n if (hint.integrity) parts.push(buildLinkParam('integrity', hint.integrity))\n if (hint.referrerPolicy) {\n parts.push(buildLinkParam('referrerpolicy', hint.referrerPolicy))\n }\n if (hint.fetchPriority) {\n parts.push(buildLinkParam('fetchpriority', hint.fetchPriority))\n }\n return parts.join('; ')\n}\n\nfunction getStringAttr(\n attrs: Record<string, any> | undefined,\n name: string,\n fallbackName?: string,\n): string | undefined {\n const value =\n attrs?.[name] ?? (fallbackName ? attrs?.[fallbackName] : undefined)\n return typeof value === 'string' ? value : undefined\n}\n\nfunction getPreloadAs(\n attrs: Record<string, any> | undefined,\n): EarlyHint['as'] | undefined {\n const as = getStringAttr(attrs, 'as')\n return as && PRELOAD_AS_VALUES.has(as as EarlyHint['as'])\n ? (as as EarlyHint['as'])\n : undefined\n}\n\nfunction addEarlyHintFetchAttrs(\n hint: EarlyHint,\n attrs: Record<string, any> | undefined,\n) {\n const crossOrigin = getStringAttr(attrs, 'crossOrigin', 'crossorigin') as\n | EarlyHint['crossOrigin']\n | undefined\n const type = getStringAttr(attrs, 'type')\n const integrity = getStringAttr(attrs, 'integrity')\n const referrerPolicy = getStringAttr(\n attrs,\n 'referrerPolicy',\n 'referrerpolicy',\n )\n const fetchPriority = getStringAttr(attrs, 'fetchPriority', 'fetchpriority')\n\n if (crossOrigin !== undefined) hint.crossOrigin = crossOrigin\n if (type) hint.type = type\n if (integrity) hint.integrity = integrity\n if (referrerPolicy) hint.referrerPolicy = referrerPolicy\n if (fetchPriority) hint.fetchPriority = fetchPriority\n}\n\nfunction linkAttrsToEarlyHint(\n attrs: Record<string, any> | undefined,\n): EarlyHint | undefined {\n const href = getStringAttr(attrs, 'href')\n const rel = getStringAttr(attrs, 'rel')\n if (!href || !rel) return undefined\n\n const relTokens = rel.split(/\\s+/)\n let hintRel: EarlyHint['rel'] | undefined\n let hintAs: EarlyHint['as'] | undefined\n\n if (relTokens.includes('modulepreload')) {\n hintRel = 'modulepreload'\n hintAs = 'script'\n } else if (relTokens.includes('stylesheet')) {\n hintRel = 'preload'\n hintAs = 'style'\n } else if (relTokens.includes('preload')) {\n hintAs = getPreloadAs(attrs)\n if (!hintAs) return undefined\n hintRel = 'preload'\n } else if (relTokens.includes('preconnect')) {\n hintRel = 'preconnect'\n hintAs = undefined\n } else if (relTokens.includes('dns-prefetch')) {\n hintRel = 'dns-prefetch'\n hintAs = undefined\n }\n\n if (!hintRel) return undefined\n\n const hint: EarlyHint = {\n href,\n rel: hintRel,\n }\n\n if (hintAs) hint.as = hintAs\n addEarlyHintFetchAttrs(hint, attrs)\n\n return hint\n}\n\nexport function collectStaticHintsFromManifest(\n manifest: Manifest,\n matchedRoutes: ReadonlyArray<AnyRoute>,\n): Array<EarlyHint> {\n const hints: Array<EarlyHint> = []\n\n for (const route of matchedRoutes) {\n const routeManifest = manifest.routes[route.id]\n if (!routeManifest) continue\n\n for (const link of routeManifest.preloads ?? []) {\n const { href, crossOrigin } = resolveManifestAssetLink(link)\n const hint: EarlyHint = { href, rel: 'modulepreload', as: 'script' }\n if (crossOrigin !== undefined) hint.crossOrigin = crossOrigin\n hints.push(hint)\n }\n\n for (const asset of routeManifest.assets ?? []) {\n if (asset.tag !== 'link') continue\n\n const stylesheetHref = getStylesheetHref(asset)\n if (stylesheetHref) {\n if (manifest.inlineCss?.styles[stylesheetHref] !== undefined) continue\n\n const hint: EarlyHint = {\n href: stylesheetHref,\n rel: 'preload',\n as: 'style',\n }\n addEarlyHintFetchAttrs(hint, asset.attrs)\n hints.push(hint)\n continue\n }\n\n const hint = linkAttrsToEarlyHint(asset.attrs)\n if (hint) {\n hints.push(hint)\n }\n }\n }\n\n return hints\n}\n\nexport function collectDynamicHintsFromMatches(\n matches: ReadonlyArray<AnyRouteMatch>,\n): Array<EarlyHint> {\n const hints: Array<EarlyHint> = []\n\n for (const match of matches) {\n const links = match.links\n if (!Array.isArray(links)) continue\n\n for (const link of links as Array<RouterManagedTag['attrs']>) {\n const hint = linkAttrsToEarlyHint(link)\n if (hint) hints.push(hint)\n }\n }\n\n return hints\n}\n\nexport function createEarlyHintsEvent(opts: {\n phase: EarlyHintsPhase\n hints: ReadonlyArray<EarlyHint>\n sentLinks: Set<string>\n sentHints: Array<EarlyHint>\n}): EarlyHintsEvent | undefined {\n const nextHints: Array<EarlyHint> = []\n const nextLinks: Array<string> = []\n\n for (const hint of opts.hints) {\n const link = serializeEarlyHint(hint)\n if (opts.sentLinks.has(link)) continue\n opts.sentLinks.add(link)\n opts.sentHints.push(hint)\n nextHints.push(hint)\n nextLinks.push(link)\n }\n\n if (!nextHints.length && opts.phase !== 'dynamic') return undefined\n\n return {\n phase: opts.phase,\n hints: nextHints,\n links: nextLinks,\n allHints: opts.sentHints.slice(),\n allLinks: Array.from(opts.sentLinks),\n }\n}\n\nexport function createResponseLinkHeaderEntries(opts: {\n phase: EarlyHintsPhase\n hints: ReadonlyArray<EarlyHint>\n sentLinks: Set<string>\n entries: Array<ResponseLinkHeaderEntry>\n}) {\n for (const hint of opts.hints) {\n const link = serializeEarlyHint(hint)\n if (opts.sentLinks.has(link)) continue\n\n opts.sentLinks.add(link)\n opts.entries.push({ phase: opts.phase, hint, link })\n }\n}\n\nexport function getResponseLinkHeaderEntries(opts: {\n entries: ReadonlyArray<ResponseLinkHeaderEntry>\n filter?: ResponseLinkHeaderFilter\n}): Array<string> {\n if (!opts.filter) {\n return opts.entries.map((entry) => entry.link)\n }\n\n try {\n const links: Array<string> = []\n\n for (const entry of opts.entries) {\n if (opts.filter(entry)) {\n links.push(entry.link)\n }\n }\n\n return links\n } catch (err) {\n console.error('Error filtering response Link headers:', err)\n return []\n }\n}\n\nfunction notifyEarlyHints(\n phase: EarlyHintsPhase,\n event: EarlyHintsEvent,\n onEarlyHints: OnEarlyHints,\n) {\n try {\n const result = onEarlyHints(event)\n if (result) {\n void Promise.resolve(result).catch((err) => {\n console.error(`Error sending ${phase} early hints:`, err)\n })\n }\n } catch (err) {\n console.error(`Error sending ${phase} early hints:`, err)\n }\n}\n\nfunction getResponseLinkHeaderFilter(\n responseLinkHeader: boolean | ResponseLinkHeaderOptions | undefined,\n): ResponseLinkHeaderFilter | undefined {\n if (typeof responseLinkHeader !== 'object') {\n return undefined\n }\n\n return responseLinkHeader.filter\n}\n\nfunction appendResponseLinkHeaders(opts: {\n responseHeaders: Headers\n entries: ReadonlyArray<ResponseLinkHeaderEntry>\n filter?: ResponseLinkHeaderFilter\n}) {\n for (const link of getResponseLinkHeaderEntries(opts)) {\n opts.responseHeaders.append('Link', link)\n }\n}\n\nfunction collectResponseLinkHeaderEntries(opts: {\n phase: EarlyHintsPhase\n event: EarlyHintsEvent\n entries: Array<ResponseLinkHeaderEntry>\n}) {\n for (let index = 0; index < opts.event.hints.length; index++) {\n opts.entries.push({\n phase: opts.phase,\n hint: opts.event.hints[index]!,\n link: opts.event.links[index]!,\n })\n }\n}\n\nfunction collectEarlyHintsPhase(opts: {\n phase: EarlyHintsPhase\n hints: ReadonlyArray<EarlyHint>\n sentLinks: Set<string>\n sentHints?: Array<EarlyHint>\n onEarlyHints?: OnEarlyHints\n responseLinkHeaderEntries?: Array<ResponseLinkHeaderEntry>\n}) {\n const event = opts.onEarlyHints\n ? createEarlyHintsEvent({\n phase: opts.phase,\n hints: opts.hints,\n sentLinks: opts.sentLinks,\n sentHints: opts.sentHints!,\n })\n : undefined\n\n if (event) {\n notifyEarlyHints(opts.phase, event, opts.onEarlyHints!)\n }\n\n if (!opts.responseLinkHeaderEntries) return\n\n if (event) {\n collectResponseLinkHeaderEntries({\n phase: opts.phase,\n event,\n entries: opts.responseLinkHeaderEntries,\n })\n return\n }\n\n createResponseLinkHeaderEntries({\n phase: opts.phase,\n hints: opts.hints,\n sentLinks: opts.sentLinks,\n entries: opts.responseLinkHeaderEntries,\n })\n}\n\nexport function createEarlyHintsCollector(\n opts:\n | {\n onEarlyHints?: OnEarlyHints\n responseLinkHeader?: boolean | ResponseLinkHeaderOptions\n }\n | undefined,\n): EarlyHintsCollector | undefined {\n if (\n process.env.TSS_DEV_SERVER === 'true' ||\n (!opts?.onEarlyHints && !opts?.responseLinkHeader)\n ) {\n return undefined\n }\n\n const sentLinks = new Set<string>()\n const sentHints = opts.onEarlyHints ? new Array<EarlyHint>() : undefined\n const responseLinkHeaderEntries = opts.responseLinkHeader\n ? new Array<ResponseLinkHeaderEntry>()\n : undefined\n const responseLinkHeaderFilter = getResponseLinkHeaderFilter(\n opts.responseLinkHeader,\n )\n\n return {\n collectStatic: ({ manifest, matchedRoutes }) => {\n if (!matchedRoutes?.length) return\n\n collectEarlyHintsPhase({\n phase: 'static',\n hints: collectStaticHintsFromManifest(manifest, matchedRoutes),\n sentLinks,\n sentHints,\n onEarlyHints: opts.onEarlyHints,\n responseLinkHeaderEntries,\n })\n },\n collectDynamic: (matches) => {\n collectEarlyHintsPhase({\n phase: 'dynamic',\n hints: collectDynamicHintsFromMatches(matches),\n sentLinks,\n sentHints,\n onEarlyHints: opts.onEarlyHints,\n responseLinkHeaderEntries,\n })\n },\n appendResponseHeaders: (headers) => {\n if (!responseLinkHeaderEntries?.length) return\n\n appendResponseLinkHeaders({\n responseHeaders: headers,\n entries: responseLinkHeaderEntries,\n filter: responseLinkHeaderFilter,\n })\n },\n }\n}\n"],"mappings":";;AA0DA,IAAM,sBAAsB;AAC5B,IAAM,oBAAoB,IAAI,IAAqB;CACjD;CACA;CACA;CACA;CACA;CACA;CACD,CAAC;AAEF,SAAS,eAAe,MAAc,OAAmC;AACvE,KAAI,UAAU,KAAA,EAAW,QAAO;AAChC,KAAI,oBAAoB,KAAK,MAAM,CAAE,QAAO,GAAG,KAAK,GAAG;AACvD,QAAO,GAAG,KAAK,GAAG,KAAK,UAAU,MAAM;;AAGzC,SAAgB,mBAAmB,MAAyB;CAC1D,MAAM,QAAQ,CAAC,IAAI,KAAK,KAAK,IAAI,eAAe,OAAO,KAAK,IAAI,CAAC;AACjE,KAAI,KAAK,GAAI,OAAM,KAAK,eAAe,MAAM,KAAK,GAAG,CAAC;AACtD,KAAI,KAAK,gBAAgB,KAAA,EACvB,OAAM,KAAK,eAAe,eAAe,KAAK,eAAe,KAAA,EAAU,CAAC;AAE1E,KAAI,KAAK,KAAM,OAAM,KAAK,eAAe,QAAQ,KAAK,KAAK,CAAC;AAC5D,KAAI,KAAK,UAAW,OAAM,KAAK,eAAe,aAAa,KAAK,UAAU,CAAC;AAC3E,KAAI,KAAK,eACP,OAAM,KAAK,eAAe,kBAAkB,KAAK,eAAe,CAAC;AAEnE,KAAI,KAAK,cACP,OAAM,KAAK,eAAe,iBAAiB,KAAK,cAAc,CAAC;AAEjE,QAAO,MAAM,KAAK,KAAK;;AAGzB,SAAS,cACP,OACA,MACA,cACoB;CACpB,MAAM,QACJ,QAAQ,UAAU,eAAe,QAAQ,gBAAgB,KAAA;AAC3D,QAAO,OAAO,UAAU,WAAW,QAAQ,KAAA;;AAG7C,SAAS,aACP,OAC6B;CAC7B,MAAM,KAAK,cAAc,OAAO,KAAK;AACrC,QAAO,MAAM,kBAAkB,IAAI,GAAsB,GACpD,KACD,KAAA;;AAGN,SAAS,uBACP,MACA,OACA;CACA,MAAM,cAAc,cAAc,OAAO,eAAe,cAAc;CAGtE,MAAM,OAAO,cAAc,OAAO,OAAO;CACzC,MAAM,YAAY,cAAc,OAAO,YAAY;CACnD,MAAM,iBAAiB,cACrB,OACA,kBACA,iBACD;CACD,MAAM,gBAAgB,cAAc,OAAO,iBAAiB,gBAAgB;AAE5E,KAAI,gBAAgB,KAAA,EAAW,MAAK,cAAc;AAClD,KAAI,KAAM,MAAK,OAAO;AACtB,KAAI,UAAW,MAAK,YAAY;AAChC,KAAI,eAAgB,MAAK,iBAAiB;AAC1C,KAAI,cAAe,MAAK,gBAAgB;;AAG1C,SAAS,qBACP,OACuB;CACvB,MAAM,OAAO,cAAc,OAAO,OAAO;CACzC,MAAM,MAAM,cAAc,OAAO,MAAM;AACvC,KAAI,CAAC,QAAQ,CAAC,IAAK,QAAO,KAAA;CAE1B,MAAM,YAAY,IAAI,MAAM,MAAM;CAClC,IAAI;CACJ,IAAI;AAEJ,KAAI,UAAU,SAAS,gBAAgB,EAAE;AACvC,YAAU;AACV,WAAS;YACA,UAAU,SAAS,aAAa,EAAE;AAC3C,YAAU;AACV,WAAS;YACA,UAAU,SAAS,UAAU,EAAE;AACxC,WAAS,aAAa,MAAM;AAC5B,MAAI,CAAC,OAAQ,QAAO,KAAA;AACpB,YAAU;YACD,UAAU,SAAS,aAAa,EAAE;AAC3C,YAAU;AACV,WAAS,KAAA;YACA,UAAU,SAAS,eAAe,EAAE;AAC7C,YAAU;AACV,WAAS,KAAA;;AAGX,KAAI,CAAC,QAAS,QAAO,KAAA;CAErB,MAAM,OAAkB;EACtB;EACA,KAAK;EACN;AAED,KAAI,OAAQ,MAAK,KAAK;AACtB,wBAAuB,MAAM,MAAM;AAEnC,QAAO;;AAGT,SAAgB,+BACd,UACA,eACkB;CAClB,MAAM,QAA0B,EAAE;AAElC,MAAK,MAAM,SAAS,eAAe;EACjC,MAAM,gBAAgB,SAAS,OAAO,MAAM;AAC5C,MAAI,CAAC,cAAe;AAEpB,OAAK,MAAM,QAAQ,cAAc,YAAY,EAAE,EAAE;GAC/C,MAAM,EAAE,MAAM,gBAAgB,yBAAyB,KAAK;GAC5D,MAAM,OAAkB;IAAE;IAAM,KAAK;IAAiB,IAAI;IAAU;AACpE,OAAI,gBAAgB,KAAA,EAAW,MAAK,cAAc;AAClD,SAAM,KAAK,KAAK;;AAGlB,OAAK,MAAM,SAAS,cAAc,UAAU,EAAE,EAAE;AAC9C,OAAI,MAAM,QAAQ,OAAQ;GAE1B,MAAM,iBAAiB,kBAAkB,MAAM;AAC/C,OAAI,gBAAgB;AAClB,QAAI,SAAS,WAAW,OAAO,oBAAoB,KAAA,EAAW;IAE9D,MAAM,OAAkB;KACtB,MAAM;KACN,KAAK;KACL,IAAI;KACL;AACD,2BAAuB,MAAM,MAAM,MAAM;AACzC,UAAM,KAAK,KAAK;AAChB;;GAGF,MAAM,OAAO,qBAAqB,MAAM,MAAM;AAC9C,OAAI,KACF,OAAM,KAAK,KAAK;;;AAKtB,QAAO;;AAGT,SAAgB,+BACd,SACkB;CAClB,MAAM,QAA0B,EAAE;AAElC,MAAK,MAAM,SAAS,SAAS;EAC3B,MAAM,QAAQ,MAAM;AACpB,MAAI,CAAC,MAAM,QAAQ,MAAM,CAAE;AAE3B,OAAK,MAAM,QAAQ,OAA2C;GAC5D,MAAM,OAAO,qBAAqB,KAAK;AACvC,OAAI,KAAM,OAAM,KAAK,KAAK;;;AAI9B,QAAO;;AAGT,SAAgB,sBAAsB,MAKN;CAC9B,MAAM,YAA8B,EAAE;CACtC,MAAM,YAA2B,EAAE;AAEnC,MAAK,MAAM,QAAQ,KAAK,OAAO;EAC7B,MAAM,OAAO,mBAAmB,KAAK;AACrC,MAAI,KAAK,UAAU,IAAI,KAAK,CAAE;AAC9B,OAAK,UAAU,IAAI,KAAK;AACxB,OAAK,UAAU,KAAK,KAAK;AACzB,YAAU,KAAK,KAAK;AACpB,YAAU,KAAK,KAAK;;AAGtB,KAAI,CAAC,UAAU,UAAU,KAAK,UAAU,UAAW,QAAO,KAAA;AAE1D,QAAO;EACL,OAAO,KAAK;EACZ,OAAO;EACP,OAAO;EACP,UAAU,KAAK,UAAU,OAAO;EAChC,UAAU,MAAM,KAAK,KAAK,UAAU;EACrC;;AAGH,SAAgB,gCAAgC,MAK7C;AACD,MAAK,MAAM,QAAQ,KAAK,OAAO;EAC7B,MAAM,OAAO,mBAAmB,KAAK;AACrC,MAAI,KAAK,UAAU,IAAI,KAAK,CAAE;AAE9B,OAAK,UAAU,IAAI,KAAK;AACxB,OAAK,QAAQ,KAAK;GAAE,OAAO,KAAK;GAAO;GAAM;GAAM,CAAC;;;AAIxD,SAAgB,6BAA6B,MAG3B;AAChB,KAAI,CAAC,KAAK,OACR,QAAO,KAAK,QAAQ,KAAK,UAAU,MAAM,KAAK;AAGhD,KAAI;EACF,MAAM,QAAuB,EAAE;AAE/B,OAAK,MAAM,SAAS,KAAK,QACvB,KAAI,KAAK,OAAO,MAAM,CACpB,OAAM,KAAK,MAAM,KAAK;AAI1B,SAAO;UACA,KAAK;AACZ,UAAQ,MAAM,0CAA0C,IAAI;AAC5D,SAAO,EAAE;;;AAIb,SAAS,iBACP,OACA,OACA,cACA;AACA,KAAI;EACF,MAAM,SAAS,aAAa,MAAM;AAClC,MAAI,OACG,SAAQ,QAAQ,OAAO,CAAC,OAAO,QAAQ;AAC1C,WAAQ,MAAM,iBAAiB,MAAM,gBAAgB,IAAI;IACzD;UAEG,KAAK;AACZ,UAAQ,MAAM,iBAAiB,MAAM,gBAAgB,IAAI;;;AAI7D,SAAS,4BACP,oBACsC;AACtC,KAAI,OAAO,uBAAuB,SAChC;AAGF,QAAO,mBAAmB;;AAG5B,SAAS,0BAA0B,MAIhC;AACD,MAAK,MAAM,QAAQ,6BAA6B,KAAK,CACnD,MAAK,gBAAgB,OAAO,QAAQ,KAAK;;AAI7C,SAAS,iCAAiC,MAIvC;AACD,MAAK,IAAI,QAAQ,GAAG,QAAQ,KAAK,MAAM,MAAM,QAAQ,QACnD,MAAK,QAAQ,KAAK;EAChB,OAAO,KAAK;EACZ,MAAM,KAAK,MAAM,MAAM;EACvB,MAAM,KAAK,MAAM,MAAM;EACxB,CAAC;;AAIN,SAAS,uBAAuB,MAO7B;CACD,MAAM,QAAQ,KAAK,eACf,sBAAsB;EACpB,OAAO,KAAK;EACZ,OAAO,KAAK;EACZ,WAAW,KAAK;EAChB,WAAW,KAAK;EACjB,CAAC,GACF,KAAA;AAEJ,KAAI,MACF,kBAAiB,KAAK,OAAO,OAAO,KAAK,aAAc;AAGzD,KAAI,CAAC,KAAK,0BAA2B;AAErC,KAAI,OAAO;AACT,mCAAiC;GAC/B,OAAO,KAAK;GACZ;GACA,SAAS,KAAK;GACf,CAAC;AACF;;AAGF,iCAAgC;EAC9B,OAAO,KAAK;EACZ,OAAO,KAAK;EACZ,WAAW,KAAK;EAChB,SAAS,KAAK;EACf,CAAC;;AAGJ,SAAgB,0BACd,MAMiC;AACjC,KACE,QAAQ,IAAI,mBAAmB,UAC9B,CAAC,MAAM,gBAAgB,CAAC,MAAM,mBAE/B;CAGF,MAAM,4BAAY,IAAI,KAAa;CACnC,MAAM,YAAY,KAAK,eAAe,IAAI,OAAkB,GAAG,KAAA;CAC/D,MAAM,4BAA4B,KAAK,qBACnC,IAAI,OAAgC,GACpC,KAAA;CACJ,MAAM,2BAA2B,4BAC/B,KAAK,mBACN;AAED,QAAO;EACL,gBAAgB,EAAE,UAAU,oBAAoB;AAC9C,OAAI,CAAC,eAAe,OAAQ;AAE5B,0BAAuB;IACrB,OAAO;IACP,OAAO,+BAA+B,UAAU,cAAc;IAC9D;IACA;IACA,cAAc,KAAK;IACnB;IACD,CAAC;;EAEJ,iBAAiB,YAAY;AAC3B,0BAAuB;IACrB,OAAO;IACP,OAAO,+BAA+B,QAAQ;IAC9C;IACA;IACA,cAAc,KAAK;IACnB;IACD,CAAC;;EAEJ,wBAAwB,YAAY;AAClC,OAAI,CAAC,2BAA2B,OAAQ;AAExC,6BAA0B;IACxB,iBAAiB;IACjB,SAAS;IACT,QAAQ;IACT,CAAC;;EAEL"}
export { createStartHandler } from './createStartHandler.js';
export type { CreateStartHandlerOptions } from './createStartHandler.js';
export type { TransformAssets, TransformAssetsFn, TransformAssetsContext, TransformAssetsOptions, TransformAssetsObjectShorthand, TransformAssetsCrossOriginConfig, TransformAssetResult, TransformAssetUrls, TransformAssetUrlsFn, TransformAssetUrlsContext, TransformAssetUrlsOptions, AssetUrlType, TransformAssetKind, } from './transformAssetUrls.js';
export type { TransformAssets, TransformAssetsFn, TransformAssetsContext, TransformAssetsOptions, TransformAssetsObjectShorthand, TransformAssetsCrossOriginConfig, TransformAssetResult, TransformAssetKind, CreateTransformAssetsContext, } from './transformAssetUrls.js';
export { attachRouterServerSsrUtils, createRequestHandler, defineHandlerCallback, transformReadableStreamWithRouter, transformPipeableStreamWithRouter, } from '@tanstack/router-core/ssr/server';

@@ -5,0 +5,0 @@ export type { HandlerCallback } from '@tanstack/router-core/ssr/server';

@@ -45,3 +45,13 @@ import { OnEarlyHints, ResponseLinkHeaderOptions } from './early-hints.js';

};
export type RequestOptions<TRegister> = EarlyHintsOptions & (TRegister extends {
type InlineCssOptions = {
/**
* Controls whether Start inlines build-collected CSS for this request.
*
* This only has an effect when the build was created with
* `server.build.inlineCss` enabled. Defaults to `true` so builds with inline
* CSS enabled continue to inline CSS unless a request opts out.
*/
inlineCss?: boolean;
};
export type RequestOptions<TRegister> = EarlyHintsOptions & InlineCssOptions & (TRegister extends {
server: {

@@ -48,0 +58,0 @@ requestContext: infer TRequestContext;

import { AssetCrossOrigin, Awaitable, Manifest, RouterManagedTag } from '@tanstack/router-core';
export type { AssetCrossOrigin };
export type TransformAssetKind = 'modulepreload' | 'stylesheet' | 'clientEntry';
type TransformAssetsShorthandCrossOriginKind = Exclude<TransformAssetKind, 'clientEntry'>;
export type AssetUrlType = TransformAssetKind;
export interface TransformAssetsContext {
export type TransformAssetsContext = {
url: string;
kind: TransformAssetKind;
}
kind: 'modulepreload';
} | {
url: string;
kind: 'stylesheet';
} | {
url: string;
kind: 'clientEntry';
} | {
url: string;
kind: 'css-url';
stylesheetHref: string;
};
export type TransformAssetKind = TransformAssetsContext['kind'];
type TransformAssetsShorthandCrossOriginKind = Exclude<TransformAssetKind, 'clientEntry' | 'css-url'>;
export type TransformAssetResult = string | {

@@ -15,8 +24,3 @@ href: string;

export type TransformAssetsFn = (context: TransformAssetsContext) => Awaitable<TransformAssetResult>;
export interface TransformAssetUrlsContext {
url: string;
type: AssetUrlType;
}
export type TransformAssetUrlsFn = (context: TransformAssetUrlsContext) => Awaitable<string>;
export type CreateTransformAssetUrlsContext = {
export type CreateTransformAssetsContext = {
/** True when the server is computing the cached manifest during startup warmup. */

@@ -34,9 +38,4 @@ warmup: true;

};
/**
* Async factory that runs once per manifest computation and returns the
* per-asset transform.
*/
export type CreateTransformAssetUrlsFn = (ctx: CreateTransformAssetUrlsContext) => Awaitable<TransformAssetUrlsFn>;
export type CreateTransformAssetsFn = (ctx: CreateTransformAssetUrlsContext) => Awaitable<TransformAssetsFn>;
type TransformAssetUrlsOptionsBase = {
export type CreateTransformAssetsFn = (ctx: CreateTransformAssetsContext) => Awaitable<TransformAssetsFn>;
type TransformAssetsOptionsBase = {
/**

@@ -65,31 +64,9 @@ * Whether to cache the transformed manifest after the first request.

};
export type TransformAssetUrlsOptions = (TransformAssetUrlsOptionsBase & {
/**
* The transform to apply to asset URLs. Can be a string prefix or a callback.
*
* **String** — prepended to every asset URL.
* **Callback** — receives `{ url, type }` and returns a new URL.
*/
transform: string | TransformAssetUrlsFn;
createTransform?: never;
}) | (TransformAssetUrlsOptionsBase & {
/**
* Create a per-asset transform function.
*
* This factory runs once per manifest computation (per request when
* `cache: false`, or once per server when `cache: true`). It can do async
* setup work (fetch config, read from a KV, etc.) and return a fast
* per-asset transformer.
*/
createTransform: CreateTransformAssetUrlsFn;
transform?: never;
});
export type TransformAssetsOptions = (TransformAssetUrlsOptionsBase & {
export type TransformAssetsOptions = (TransformAssetsOptionsBase & {
transform: string | TransformAssetsFn;
createTransform?: never;
}) | (TransformAssetUrlsOptionsBase & {
}) | (TransformAssetsOptionsBase & {
createTransform: CreateTransformAssetsFn;
transform?: never;
});
export type TransformAssetUrls = string | TransformAssetUrlsFn | TransformAssetUrlsOptions;
/**

@@ -141,6 +118,3 @@ * Per-kind crossOrigin configuration for the object shorthand.

};
export declare function warnDeprecatedTransformAssetUrls(): void;
export declare function resolveTransformAssetsConfig(transform: TransformAssets): ResolvedTransformAssetsConfig;
export declare function adaptTransformAssetUrlsToTransformAssets(transformFn: TransformAssetUrlsFn): TransformAssetsFn;
export declare function adaptTransformAssetUrlsConfigToTransformAssets(transform: TransformAssetUrls): TransformAssets;
export interface StartManifestWithClientEntry {

@@ -159,9 +133,12 @@ manifest: Manifest;

clone?: boolean;
inlineCss?: boolean;
}): Promise<Manifest>;
/**
* Builds a final Manifest from a StartManifestWithClientEntry without any
* URL transforms. Used when no transformAssetUrls option is provided.
* URL transforms. Used when no transformAssets option is provided.
*
* Returns a new manifest object so the cached base manifest is never mutated.
*/
export declare function buildManifestWithClientEntry(source: StartManifestWithClientEntry): Manifest;
export declare function buildManifestWithClientEntry(source: StartManifestWithClientEntry, opts?: {
inlineCss?: boolean;
}): Manifest;
import { resolveManifestAssetLink, rootRouteId } from "@tanstack/router-core";
//#region src/transformAssetUrls.ts
var hasWarnedAboutDeprecatedTransformAssetUrls = false;
function warnDeprecatedTransformAssetUrls() {
if ((process.env.NODE_ENV === "development" || process.env.TSS_DEV_SERVER === "true") && !hasWarnedAboutDeprecatedTransformAssetUrls) {
hasWarnedAboutDeprecatedTransformAssetUrls = true;
console.warn("[TanStack Start] `transformAssetUrls` is deprecated. Use `transformAssets` instead.");
}
}
function normalizeTransformAssetResult(result) {

@@ -14,2 +7,35 @@ if (typeof result === "string") return { href: result };

}
function escapeCssString(value) {
return value.replace(/\\/g, "\\\\").replace(/"/g, "\\\"").replace(/\n/g, "\\a ").replace(/\r/g, "\\d ").replace(/\f/g, "\\c ");
}
async function transformInlineCssTemplate(options) {
const { strings, urls } = options.template;
if (strings.length !== urls.length + 1) throw new Error(`TanStack Start inlineCss template for ${options.stylesheetHref} is invalid`);
let css = strings[0];
for (let index = 0; index < urls.length; index++) {
const transformed = normalizeTransformAssetResult(await options.transformFn({
kind: "css-url",
url: urls[index],
stylesheetHref: options.stylesheetHref
}));
css += escapeCssString(transformed.href) + strings[index + 1];
}
return css;
}
async function transformInlineCssStyles(inlineCss, transformFn) {
const transformedStyles = {};
const transformedEntries = await Promise.all(Object.entries(inlineCss.styles).map(async ([stylesheetHref, css]) => {
const template = inlineCss.templates?.[stylesheetHref];
return [stylesheetHref, template ? await transformInlineCssTemplate({
stylesheetHref,
template,
transformFn
}) : css];
}));
for (const [stylesheetHref, css] of transformedEntries) transformedStyles[stylesheetHref] = css;
return {
styles: transformedStyles,
...inlineCss.templates ? { templates: inlineCss.templates } : {}
};
}
function resolveTransformAssetsCrossOrigin(config, kind) {

@@ -43,3 +69,3 @@ if (!config) return void 0;

const href = `${prefix}${url}`;
if (kind === "clientEntry") return { href };
if (kind === "clientEntry" || kind === "css-url") return { href };
const co = resolveTransformAssetsCrossOrigin(crossOrigin, kind);

@@ -65,23 +91,2 @@ return co ? {

}
function adaptTransformAssetUrlsToTransformAssets(transformFn) {
return async ({ url, kind }) => ({ href: await transformFn({
url,
type: kind
}) });
}
function adaptTransformAssetUrlsConfigToTransformAssets(transform) {
warnDeprecatedTransformAssetUrls();
if (typeof transform === "string") return transform;
if (typeof transform === "function") return adaptTransformAssetUrlsToTransformAssets(transform);
if ("createTransform" in transform && transform.createTransform) return {
createTransform: async (ctx) => adaptTransformAssetUrlsToTransformAssets(await transform.createTransform(ctx)),
cache: transform.cache,
warmup: transform.warmup
};
return {
transform: typeof transform.transform === "string" ? transform.transform : adaptTransformAssetUrlsToTransformAssets(transform.transform),
cache: transform.cache,
warmup: transform.warmup
};
}
/**

@@ -109,2 +114,4 @@ * Builds the client entry `<script>` tag from a (possibly transformed) client

const manifest = structuredClone(source.manifest);
if (!(_opts?.inlineCss !== false)) delete manifest.inlineCss;
else if (manifest.inlineCss) manifest.inlineCss = await transformInlineCssStyles(manifest.inlineCss, transformFn);
for (const route of Object.values(manifest.routes)) {

@@ -121,3 +128,3 @@ if (route.preloads) route.preloads = await Promise.all(route.preloads.map(async (link) => {

}));
if (route.assets && !source.manifest.inlineCss) {
if (route.assets && !manifest.inlineCss) {
for (const asset of route.assets) if (asset.tag === "link" && asset.attrs?.href) {

@@ -147,7 +154,7 @@ const rel = asset.attrs.rel;

* Builds a final Manifest from a StartManifestWithClientEntry without any
* URL transforms. Used when no transformAssetUrls option is provided.
* URL transforms. Used when no transformAssets option is provided.
*
* Returns a new manifest object so the cached base manifest is never mutated.
*/
function buildManifestWithClientEntry(source) {
function buildManifestWithClientEntry(source, opts) {
const scriptTag = buildClientEntryScriptTag(source.clientEntry, source.injectedHeadScripts);

@@ -163,3 +170,3 @@ const baseRootRoute = source.manifest.routes[rootRouteId];

return {
inlineCss: source.manifest.inlineCss,
...opts?.inlineCss === false ? {} : { inlineCss: structuredClone(source.manifest.inlineCss) },
routes

@@ -169,4 +176,4 @@ };

//#endregion
export { adaptTransformAssetUrlsConfigToTransformAssets, buildManifestWithClientEntry, resolveTransformAssetsConfig, transformManifestAssets };
export { buildManifestWithClientEntry, resolveTransformAssetsConfig, transformManifestAssets };
//# sourceMappingURL=transformAssetUrls.js.map

@@ -1,1 +0,1 @@

{"version":3,"file":"transformAssetUrls.js","names":[],"sources":["../../src/transformAssetUrls.ts"],"sourcesContent":["import { resolveManifestAssetLink, rootRouteId } from '@tanstack/router-core'\n\nimport type {\n AssetCrossOrigin,\n Awaitable,\n Manifest,\n ManifestAssetLink,\n RouterManagedTag,\n} from '@tanstack/router-core'\n\nexport type { AssetCrossOrigin }\n\nexport type TransformAssetKind = 'modulepreload' | 'stylesheet' | 'clientEntry'\n\ntype TransformAssetsShorthandCrossOriginKind = Exclude<\n TransformAssetKind,\n 'clientEntry'\n>\n\nexport type AssetUrlType = TransformAssetKind\n\nexport interface TransformAssetsContext {\n url: string\n kind: TransformAssetKind\n}\n\nexport type TransformAssetResult =\n | string\n | {\n href: string\n crossOrigin?: AssetCrossOrigin\n }\n\nexport type TransformAssetsFn = (\n context: TransformAssetsContext,\n) => Awaitable<TransformAssetResult>\n\nexport interface TransformAssetUrlsContext {\n url: string\n type: AssetUrlType\n}\n\nexport type TransformAssetUrlsFn = (\n context: TransformAssetUrlsContext,\n) => Awaitable<string>\n\nexport type CreateTransformAssetUrlsContext =\n | {\n /** True when the server is computing the cached manifest during startup warmup. */\n warmup: true\n }\n | {\n /**\n * The current Request.\n *\n * Only available during request handling (i.e. when `warmup: false`).\n */\n request: Request\n /** False when transforming URLs as part of request handling. */\n warmup: false\n }\n\n/**\n * Async factory that runs once per manifest computation and returns the\n * per-asset transform.\n */\nexport type CreateTransformAssetUrlsFn = (\n ctx: CreateTransformAssetUrlsContext,\n) => Awaitable<TransformAssetUrlsFn>\n\nexport type CreateTransformAssetsFn = (\n ctx: CreateTransformAssetUrlsContext,\n) => Awaitable<TransformAssetsFn>\n\ntype TransformAssetUrlsOptionsBase = {\n /**\n * Whether to cache the transformed manifest after the first request.\n *\n * When `true` (default), the transform runs once on the first request and\n * the resulting manifest is reused for all subsequent requests in production.\n *\n * Set to `false` for per-request transforms (e.g. geo-routing to different\n * CDNs based on request headers).\n *\n * @default true\n */\n cache?: boolean\n\n /**\n * When `true`, warms up the cached transformed manifest in the background when\n * the server starts (production only).\n *\n * This can reduce latency for the first request when `cache` is `true`.\n * Has no effect when `cache: false` (per-request transforms) or in dev mode.\n *\n * @default false\n */\n warmup?: boolean\n}\n\nexport type TransformAssetUrlsOptions =\n | (TransformAssetUrlsOptionsBase & {\n /**\n * The transform to apply to asset URLs. Can be a string prefix or a callback.\n *\n * **String** — prepended to every asset URL.\n * **Callback** — receives `{ url, type }` and returns a new URL.\n */\n transform: string | TransformAssetUrlsFn\n createTransform?: never\n })\n | (TransformAssetUrlsOptionsBase & {\n /**\n * Create a per-asset transform function.\n *\n * This factory runs once per manifest computation (per request when\n * `cache: false`, or once per server when `cache: true`). It can do async\n * setup work (fetch config, read from a KV, etc.) and return a fast\n * per-asset transformer.\n */\n createTransform: CreateTransformAssetUrlsFn\n transform?: never\n })\n\nexport type TransformAssetsOptions =\n | (TransformAssetUrlsOptionsBase & {\n transform: string | TransformAssetsFn\n createTransform?: never\n })\n | (TransformAssetUrlsOptionsBase & {\n createTransform: CreateTransformAssetsFn\n transform?: never\n })\n\nexport type TransformAssetUrls =\n | string\n | TransformAssetUrlsFn\n | TransformAssetUrlsOptions\n\n/**\n * Per-kind crossOrigin configuration for the object shorthand.\n *\n * Accepts either a single value applied to all asset kinds, or a per-kind\n * record (matching `HeadContent`'s `assetCrossOrigin` shape):\n *\n * ```ts\n * // All assets get the same value\n * crossOrigin: 'anonymous'\n *\n * // Different values per kind\n * crossOrigin: { modulepreload: 'anonymous', stylesheet: 'use-credentials' }\n * ```\n */\nexport type TransformAssetsCrossOriginConfig =\n | AssetCrossOrigin\n | Partial<Record<TransformAssetsShorthandCrossOriginKind, AssetCrossOrigin>>\n\n/**\n * Object shorthand for `transformAssets`. Combines a URL prefix with optional\n * per-asset `crossOrigin` without needing a callback:\n *\n * ```ts\n * transformAssets: {\n * prefix: 'https://cdn.example.com',\n * crossOrigin: 'anonymous',\n * }\n * ```\n */\nexport interface TransformAssetsObjectShorthand {\n /** URL prefix prepended to every asset URL. */\n prefix: string\n /**\n * Optional crossOrigin attribute applied to manifest-managed `<link>` assets.\n *\n * Accepts a single value or a per-kind record.\n */\n crossOrigin?: TransformAssetsCrossOriginConfig\n}\n\nexport type TransformAssets =\n | string\n | TransformAssetsFn\n | TransformAssetsObjectShorthand\n | TransformAssetsOptions\n\nexport type ResolvedTransformAssetsConfig =\n | {\n type: 'transform'\n transformFn: TransformAssetsFn\n cache: boolean\n }\n | {\n type: 'createTransform'\n createTransform: CreateTransformAssetsFn\n cache: boolean\n }\n\nlet hasWarnedAboutDeprecatedTransformAssetUrls = false\n\nexport function warnDeprecatedTransformAssetUrls() {\n if (\n (process.env.NODE_ENV === 'development' ||\n process.env.TSS_DEV_SERVER === 'true') &&\n !hasWarnedAboutDeprecatedTransformAssetUrls\n ) {\n hasWarnedAboutDeprecatedTransformAssetUrls = true\n console.warn(\n '[TanStack Start] `transformAssetUrls` is deprecated. Use `transformAssets` instead.',\n )\n }\n}\n\nfunction normalizeTransformAssetResult(\n result: TransformAssetResult,\n): Exclude<TransformAssetResult, string> {\n if (typeof result === 'string') {\n return { href: result }\n }\n\n return result\n}\n\nfunction resolveTransformAssetsCrossOrigin(\n config: TransformAssetsCrossOriginConfig | undefined,\n kind: TransformAssetsShorthandCrossOriginKind,\n): AssetCrossOrigin | undefined {\n if (!config) return undefined\n if (typeof config === 'string') return config\n\n return config[kind]\n}\n\nfunction isObjectShorthand(\n transform: TransformAssetsObjectShorthand | TransformAssetsOptions,\n): transform is TransformAssetsObjectShorthand {\n return 'prefix' in transform\n}\n\nexport function resolveTransformAssetsConfig(\n transform: TransformAssets,\n): ResolvedTransformAssetsConfig {\n if (typeof transform === 'string') {\n const prefix = transform\n return {\n type: 'transform',\n transformFn: ({ url }) => ({ href: `${prefix}${url}` }),\n cache: true,\n }\n }\n\n if (typeof transform === 'function') {\n return {\n type: 'transform',\n transformFn: transform,\n cache: true,\n }\n }\n\n // Object shorthand: { prefix, crossOrigin? }\n if (isObjectShorthand(transform)) {\n const { prefix, crossOrigin } = transform\n\n return {\n type: 'transform',\n transformFn: ({ url, kind }) => {\n const href = `${prefix}${url}`\n\n if (kind === 'clientEntry') {\n return { href }\n }\n\n const co = resolveTransformAssetsCrossOrigin(crossOrigin, kind)\n return co ? { href, crossOrigin: co } : { href }\n },\n cache: true,\n }\n }\n\n if ('createTransform' in transform && transform.createTransform) {\n return {\n type: 'createTransform',\n createTransform: transform.createTransform,\n cache: transform.cache !== false,\n }\n }\n\n const transformFn =\n typeof transform.transform === 'string'\n ? ((({ url }: TransformAssetsContext) => ({\n href: `${transform.transform}${url}`,\n })) as TransformAssetsFn)\n : transform.transform\n\n return {\n type: 'transform',\n transformFn,\n cache: transform.cache !== false,\n }\n}\n\nexport function adaptTransformAssetUrlsToTransformAssets(\n transformFn: TransformAssetUrlsFn,\n): TransformAssetsFn {\n return async ({ url, kind }) => ({\n href: await transformFn({ url, type: kind }),\n })\n}\n\nexport function adaptTransformAssetUrlsConfigToTransformAssets(\n transform: TransformAssetUrls,\n): TransformAssets {\n warnDeprecatedTransformAssetUrls()\n\n if (typeof transform === 'string') {\n return transform\n }\n\n if (typeof transform === 'function') {\n return adaptTransformAssetUrlsToTransformAssets(transform)\n }\n\n if ('createTransform' in transform && transform.createTransform) {\n return {\n createTransform: async (ctx: CreateTransformAssetUrlsContext) =>\n adaptTransformAssetUrlsToTransformAssets(\n await transform.createTransform(ctx),\n ),\n cache: transform.cache,\n warmup: transform.warmup,\n }\n }\n\n return {\n transform:\n typeof transform.transform === 'string'\n ? transform.transform\n : adaptTransformAssetUrlsToTransformAssets(transform.transform),\n cache: transform.cache,\n warmup: transform.warmup,\n }\n}\n\nexport interface StartManifestWithClientEntry {\n manifest: Manifest\n clientEntry: string\n /** Script content prepended before the client entry import (dev only) */\n injectedHeadScripts?: string\n}\n\n/**\n * Builds the client entry `<script>` tag from a (possibly transformed) client\n * entry URL and optional injected head scripts.\n */\nexport function buildClientEntryScriptTag(\n clientEntry: string,\n injectedHeadScripts?: string,\n): RouterManagedTag {\n const clientEntryLiteral = JSON.stringify(clientEntry)\n let script = `import(${clientEntryLiteral})`\n if (injectedHeadScripts) {\n script = `${injectedHeadScripts};${script}`\n }\n return {\n tag: 'script',\n attrs: {\n type: 'module',\n async: true,\n },\n children: script,\n }\n}\n\nfunction assignManifestAssetLink(\n link: ManifestAssetLink,\n next: { href: string; crossOrigin?: AssetCrossOrigin },\n): ManifestAssetLink {\n if (typeof link === 'string') {\n return next.crossOrigin ? next : next.href\n }\n\n return next.crossOrigin ? next : { href: next.href }\n}\n\nexport async function transformManifestAssets(\n source: StartManifestWithClientEntry,\n transformFn: TransformAssetsFn,\n _opts?: {\n clone?: boolean\n },\n): Promise<Manifest> {\n const manifest = structuredClone(source.manifest)\n\n for (const route of Object.values(manifest.routes)) {\n if (route.preloads) {\n route.preloads = await Promise.all(\n route.preloads.map(async (link) => {\n const resolved = resolveManifestAssetLink(link)\n const result = normalizeTransformAssetResult(\n await transformFn({\n url: resolved.href,\n kind: 'modulepreload',\n }),\n )\n\n return assignManifestAssetLink(link, {\n href: result.href,\n crossOrigin: result.crossOrigin,\n })\n }),\n )\n }\n\n if (route.assets && !source.manifest.inlineCss) {\n for (const asset of route.assets) {\n if (asset.tag === 'link' && asset.attrs?.href) {\n const rel = asset.attrs.rel\n const relTokens = typeof rel === 'string' ? rel.split(/\\s+/) : []\n\n if (!relTokens.includes('stylesheet')) {\n continue\n }\n\n const result = normalizeTransformAssetResult(\n await transformFn({\n url: asset.attrs.href,\n kind: 'stylesheet',\n }),\n )\n\n asset.attrs.href = result.href\n if (result.crossOrigin) {\n asset.attrs.crossOrigin = result.crossOrigin\n } else {\n delete asset.attrs.crossOrigin\n }\n }\n }\n }\n }\n\n const transformedClientEntry = normalizeTransformAssetResult(\n await transformFn({\n url: source.clientEntry,\n kind: 'clientEntry',\n }),\n )\n\n const rootRoute = (manifest.routes[rootRouteId] =\n manifest.routes[rootRouteId] || {})\n rootRoute.assets = rootRoute.assets || []\n rootRoute.assets.push(\n buildClientEntryScriptTag(\n transformedClientEntry.href,\n source.injectedHeadScripts,\n ),\n )\n\n return manifest\n}\n\n/**\n * Builds a final Manifest from a StartManifestWithClientEntry without any\n * URL transforms. Used when no transformAssetUrls option is provided.\n *\n * Returns a new manifest object so the cached base manifest is never mutated.\n */\nexport function buildManifestWithClientEntry(\n source: StartManifestWithClientEntry,\n): Manifest {\n const scriptTag = buildClientEntryScriptTag(\n source.clientEntry,\n source.injectedHeadScripts,\n )\n\n const baseRootRoute = source.manifest.routes[rootRouteId]\n const routes = {\n ...source.manifest.routes,\n [rootRouteId]: {\n ...baseRootRoute,\n assets: [...(baseRootRoute?.assets || []), scriptTag],\n },\n }\n\n return { inlineCss: source.manifest.inlineCss, routes }\n}\n"],"mappings":";;AAqMA,IAAI,6CAA6C;AAEjD,SAAgB,mCAAmC;AACjD,MAAA,QAAA,IAAA,aAC4B,iBACxB,QAAQ,IAAI,mBAAmB,WACjC,CAAC,4CACD;AACA,+CAA6C;AAC7C,UAAQ,KACN,sFACD;;;AAIL,SAAS,8BACP,QACuC;AACvC,KAAI,OAAO,WAAW,SACpB,QAAO,EAAE,MAAM,QAAQ;AAGzB,QAAO;;AAGT,SAAS,kCACP,QACA,MAC8B;AAC9B,KAAI,CAAC,OAAQ,QAAO,KAAA;AACpB,KAAI,OAAO,WAAW,SAAU,QAAO;AAEvC,QAAO,OAAO;;AAGhB,SAAS,kBACP,WAC6C;AAC7C,QAAO,YAAY;;AAGrB,SAAgB,6BACd,WAC+B;AAC/B,KAAI,OAAO,cAAc,UAAU;EACjC,MAAM,SAAS;AACf,SAAO;GACL,MAAM;GACN,cAAc,EAAE,WAAW,EAAE,MAAM,GAAG,SAAS,OAAO;GACtD,OAAO;GACR;;AAGH,KAAI,OAAO,cAAc,WACvB,QAAO;EACL,MAAM;EACN,aAAa;EACb,OAAO;EACR;AAIH,KAAI,kBAAkB,UAAU,EAAE;EAChC,MAAM,EAAE,QAAQ,gBAAgB;AAEhC,SAAO;GACL,MAAM;GACN,cAAc,EAAE,KAAK,WAAW;IAC9B,MAAM,OAAO,GAAG,SAAS;AAEzB,QAAI,SAAS,cACX,QAAO,EAAE,MAAM;IAGjB,MAAM,KAAK,kCAAkC,aAAa,KAAK;AAC/D,WAAO,KAAK;KAAE;KAAM,aAAa;KAAI,GAAG,EAAE,MAAM;;GAElD,OAAO;GACR;;AAGH,KAAI,qBAAqB,aAAa,UAAU,gBAC9C,QAAO;EACL,MAAM;EACN,iBAAiB,UAAU;EAC3B,OAAO,UAAU,UAAU;EAC5B;AAUH,QAAO;EACL,MAAM;EACN,aARA,OAAO,UAAU,cAAc,aACxB,EAAE,WAAmC,EACtC,MAAM,GAAG,UAAU,YAAY,OAChC,KACD,UAAU;EAKd,OAAO,UAAU,UAAU;EAC5B;;AAGH,SAAgB,yCACd,aACmB;AACnB,QAAO,OAAO,EAAE,KAAK,YAAY,EAC/B,MAAM,MAAM,YAAY;EAAE;EAAK,MAAM;EAAM,CAAC,EAC7C;;AAGH,SAAgB,+CACd,WACiB;AACjB,mCAAkC;AAElC,KAAI,OAAO,cAAc,SACvB,QAAO;AAGT,KAAI,OAAO,cAAc,WACvB,QAAO,yCAAyC,UAAU;AAG5D,KAAI,qBAAqB,aAAa,UAAU,gBAC9C,QAAO;EACL,iBAAiB,OAAO,QACtB,yCACE,MAAM,UAAU,gBAAgB,IAAI,CACrC;EACH,OAAO,UAAU;EACjB,QAAQ,UAAU;EACnB;AAGH,QAAO;EACL,WACE,OAAO,UAAU,cAAc,WAC3B,UAAU,YACV,yCAAyC,UAAU,UAAU;EACnE,OAAO,UAAU;EACjB,QAAQ,UAAU;EACnB;;;;;;AAcH,SAAgB,0BACd,aACA,qBACkB;CAElB,IAAI,SAAS,UADc,KAAK,UAAU,YAAY,CACZ;AAC1C,KAAI,oBACF,UAAS,GAAG,oBAAoB,GAAG;AAErC,QAAO;EACL,KAAK;EACL,OAAO;GACL,MAAM;GACN,OAAO;GACR;EACD,UAAU;EACX;;AAGH,SAAS,wBACP,MACA,MACmB;AACnB,KAAI,OAAO,SAAS,SAClB,QAAO,KAAK,cAAc,OAAO,KAAK;AAGxC,QAAO,KAAK,cAAc,OAAO,EAAE,MAAM,KAAK,MAAM;;AAGtD,eAAsB,wBACpB,QACA,aACA,OAGmB;CACnB,MAAM,WAAW,gBAAgB,OAAO,SAAS;AAEjD,MAAK,MAAM,SAAS,OAAO,OAAO,SAAS,OAAO,EAAE;AAClD,MAAI,MAAM,SACR,OAAM,WAAW,MAAM,QAAQ,IAC7B,MAAM,SAAS,IAAI,OAAO,SAAS;GAEjC,MAAM,SAAS,8BACb,MAAM,YAAY;IAChB,KAHa,yBAAyB,KAAK,CAG7B;IACd,MAAM;IACP,CAAC,CACH;AAED,UAAO,wBAAwB,MAAM;IACnC,MAAM,OAAO;IACb,aAAa,OAAO;IACrB,CAAC;IACF,CACH;AAGH,MAAI,MAAM,UAAU,CAAC,OAAO,SAAS;QAC9B,MAAM,SAAS,MAAM,OACxB,KAAI,MAAM,QAAQ,UAAU,MAAM,OAAO,MAAM;IAC7C,MAAM,MAAM,MAAM,MAAM;AAGxB,QAAI,EAFc,OAAO,QAAQ,WAAW,IAAI,MAAM,MAAM,GAAG,EAAE,EAElD,SAAS,aAAa,CACnC;IAGF,MAAM,SAAS,8BACb,MAAM,YAAY;KAChB,KAAK,MAAM,MAAM;KACjB,MAAM;KACP,CAAC,CACH;AAED,UAAM,MAAM,OAAO,OAAO;AAC1B,QAAI,OAAO,YACT,OAAM,MAAM,cAAc,OAAO;QAEjC,QAAO,MAAM,MAAM;;;;CAO7B,MAAM,yBAAyB,8BAC7B,MAAM,YAAY;EAChB,KAAK,OAAO;EACZ,MAAM;EACP,CAAC,CACH;CAED,MAAM,YAAa,SAAS,OAAO,eACjC,SAAS,OAAO,gBAAgB,EAAE;AACpC,WAAU,SAAS,UAAU,UAAU,EAAE;AACzC,WAAU,OAAO,KACf,0BACE,uBAAuB,MACvB,OAAO,oBACR,CACF;AAED,QAAO;;;;;;;;AAST,SAAgB,6BACd,QACU;CACV,MAAM,YAAY,0BAChB,OAAO,aACP,OAAO,oBACR;CAED,MAAM,gBAAgB,OAAO,SAAS,OAAO;CAC7C,MAAM,SAAS;EACb,GAAG,OAAO,SAAS;GAClB,cAAc;GACb,GAAG;GACH,QAAQ,CAAC,GAAI,eAAe,UAAU,EAAE,EAAG,UAAU;GACtD;EACF;AAED,QAAO;EAAE,WAAW,OAAO,SAAS;EAAW;EAAQ"}
{"version":3,"file":"transformAssetUrls.js","names":[],"sources":["../../src/transformAssetUrls.ts"],"sourcesContent":["import { resolveManifestAssetLink, rootRouteId } from '@tanstack/router-core'\n\nimport type {\n AssetCrossOrigin,\n Awaitable,\n Manifest,\n ManifestAssetLink,\n RouterManagedTag,\n} from '@tanstack/router-core'\n\nexport type { AssetCrossOrigin }\n\nexport type TransformAssetsContext =\n | {\n url: string\n kind: 'modulepreload'\n }\n | {\n url: string\n kind: 'stylesheet'\n }\n | {\n url: string\n kind: 'clientEntry'\n }\n | {\n url: string\n kind: 'css-url'\n stylesheetHref: string\n }\n\nexport type TransformAssetKind = TransformAssetsContext['kind']\n\ntype TransformAssetsShorthandCrossOriginKind = Exclude<\n TransformAssetKind,\n 'clientEntry' | 'css-url'\n>\n\nexport type TransformAssetResult =\n | string\n | {\n href: string\n crossOrigin?: AssetCrossOrigin\n }\n\nexport type TransformAssetsFn = (\n context: TransformAssetsContext,\n) => Awaitable<TransformAssetResult>\n\nexport type CreateTransformAssetsContext =\n | {\n /** True when the server is computing the cached manifest during startup warmup. */\n warmup: true\n }\n | {\n /**\n * The current Request.\n *\n * Only available during request handling (i.e. when `warmup: false`).\n */\n request: Request\n /** False when transforming URLs as part of request handling. */\n warmup: false\n }\n\nexport type CreateTransformAssetsFn = (\n ctx: CreateTransformAssetsContext,\n) => Awaitable<TransformAssetsFn>\n\ntype TransformAssetsOptionsBase = {\n /**\n * Whether to cache the transformed manifest after the first request.\n *\n * When `true` (default), the transform runs once on the first request and\n * the resulting manifest is reused for all subsequent requests in production.\n *\n * Set to `false` for per-request transforms (e.g. geo-routing to different\n * CDNs based on request headers).\n *\n * @default true\n */\n cache?: boolean\n\n /**\n * When `true`, warms up the cached transformed manifest in the background when\n * the server starts (production only).\n *\n * This can reduce latency for the first request when `cache` is `true`.\n * Has no effect when `cache: false` (per-request transforms) or in dev mode.\n *\n * @default false\n */\n warmup?: boolean\n}\n\nexport type TransformAssetsOptions =\n | (TransformAssetsOptionsBase & {\n transform: string | TransformAssetsFn\n createTransform?: never\n })\n | (TransformAssetsOptionsBase & {\n createTransform: CreateTransformAssetsFn\n transform?: never\n })\n\n/**\n * Per-kind crossOrigin configuration for the object shorthand.\n *\n * Accepts either a single value applied to all asset kinds, or a per-kind\n * record (matching `HeadContent`'s `assetCrossOrigin` shape):\n *\n * ```ts\n * // All assets get the same value\n * crossOrigin: 'anonymous'\n *\n * // Different values per kind\n * crossOrigin: { modulepreload: 'anonymous', stylesheet: 'use-credentials' }\n * ```\n */\nexport type TransformAssetsCrossOriginConfig =\n | AssetCrossOrigin\n | Partial<Record<TransformAssetsShorthandCrossOriginKind, AssetCrossOrigin>>\n\n/**\n * Object shorthand for `transformAssets`. Combines a URL prefix with optional\n * per-asset `crossOrigin` without needing a callback:\n *\n * ```ts\n * transformAssets: {\n * prefix: 'https://cdn.example.com',\n * crossOrigin: 'anonymous',\n * }\n * ```\n */\nexport interface TransformAssetsObjectShorthand {\n /** URL prefix prepended to every asset URL. */\n prefix: string\n /**\n * Optional crossOrigin attribute applied to manifest-managed `<link>` assets.\n *\n * Accepts a single value or a per-kind record.\n */\n crossOrigin?: TransformAssetsCrossOriginConfig\n}\n\nexport type TransformAssets =\n | string\n | TransformAssetsFn\n | TransformAssetsObjectShorthand\n | TransformAssetsOptions\n\nexport type ResolvedTransformAssetsConfig =\n | {\n type: 'transform'\n transformFn: TransformAssetsFn\n cache: boolean\n }\n | {\n type: 'createTransform'\n createTransform: CreateTransformAssetsFn\n cache: boolean\n }\n\nfunction normalizeTransformAssetResult(\n result: TransformAssetResult,\n): Exclude<TransformAssetResult, string> {\n if (typeof result === 'string') {\n return { href: result }\n }\n\n return result\n}\n\nfunction escapeCssString(value: string) {\n return value\n .replace(/\\\\/g, '\\\\\\\\')\n .replace(/\"/g, '\\\\\"')\n .replace(/\\n/g, '\\\\a ')\n .replace(/\\r/g, '\\\\d ')\n .replace(/\\f/g, '\\\\c ')\n}\n\nasync function transformInlineCssTemplate(options: {\n stylesheetHref: string\n template: { strings: Array<string>; urls: Array<string> }\n transformFn: TransformAssetsFn\n}) {\n const { strings, urls } = options.template\n\n if (strings.length !== urls.length + 1) {\n throw new Error(\n `TanStack Start inlineCss template for ${options.stylesheetHref} is invalid`,\n )\n }\n\n let css = strings[0]!\n\n for (let index = 0; index < urls.length; index++) {\n const transformed = normalizeTransformAssetResult(\n await options.transformFn({\n kind: 'css-url',\n url: urls[index]!,\n stylesheetHref: options.stylesheetHref,\n }),\n )\n\n css += escapeCssString(transformed.href) + strings[index + 1]!\n }\n\n return css\n}\n\nasync function transformInlineCssStyles(\n inlineCss: NonNullable<Manifest['inlineCss']>,\n transformFn: TransformAssetsFn,\n) {\n const transformedStyles: Record<string, string> = {}\n\n const transformedEntries = await Promise.all(\n Object.entries(inlineCss.styles).map(async ([stylesheetHref, css]) => {\n const template = inlineCss.templates?.[stylesheetHref]\n return [\n stylesheetHref,\n template\n ? await transformInlineCssTemplate({\n stylesheetHref,\n template,\n transformFn,\n })\n : css,\n ] as const\n }),\n )\n\n for (const [stylesheetHref, css] of transformedEntries) {\n transformedStyles[stylesheetHref] = css\n }\n\n return {\n styles: transformedStyles,\n ...(inlineCss.templates ? { templates: inlineCss.templates } : {}),\n }\n}\n\nfunction resolveTransformAssetsCrossOrigin(\n config: TransformAssetsCrossOriginConfig | undefined,\n kind: TransformAssetsShorthandCrossOriginKind,\n): AssetCrossOrigin | undefined {\n if (!config) return undefined\n if (typeof config === 'string') return config\n\n return config[kind]\n}\n\nfunction isObjectShorthand(\n transform: TransformAssetsObjectShorthand | TransformAssetsOptions,\n): transform is TransformAssetsObjectShorthand {\n return 'prefix' in transform\n}\n\nexport function resolveTransformAssetsConfig(\n transform: TransformAssets,\n): ResolvedTransformAssetsConfig {\n if (typeof transform === 'string') {\n const prefix = transform\n return {\n type: 'transform',\n transformFn: ({ url }) => ({ href: `${prefix}${url}` }),\n cache: true,\n }\n }\n\n if (typeof transform === 'function') {\n return {\n type: 'transform',\n transformFn: transform,\n cache: true,\n }\n }\n\n // Object shorthand: { prefix, crossOrigin? }\n if (isObjectShorthand(transform)) {\n const { prefix, crossOrigin } = transform\n\n return {\n type: 'transform',\n transformFn: ({ url, kind }) => {\n const href = `${prefix}${url}`\n\n if (kind === 'clientEntry' || kind === 'css-url') {\n return { href }\n }\n\n const co = resolveTransformAssetsCrossOrigin(crossOrigin, kind)\n return co ? { href, crossOrigin: co } : { href }\n },\n cache: true,\n }\n }\n\n if ('createTransform' in transform && transform.createTransform) {\n return {\n type: 'createTransform',\n createTransform: transform.createTransform,\n cache: transform.cache !== false,\n }\n }\n\n const transformFn =\n typeof transform.transform === 'string'\n ? ((({ url }: TransformAssetsContext) => ({\n href: `${transform.transform}${url}`,\n })) as TransformAssetsFn)\n : transform.transform\n\n return {\n type: 'transform',\n transformFn,\n cache: transform.cache !== false,\n }\n}\n\nexport interface StartManifestWithClientEntry {\n manifest: Manifest\n clientEntry: string\n /** Script content prepended before the client entry import (dev only) */\n injectedHeadScripts?: string\n}\n\n/**\n * Builds the client entry `<script>` tag from a (possibly transformed) client\n * entry URL and optional injected head scripts.\n */\nexport function buildClientEntryScriptTag(\n clientEntry: string,\n injectedHeadScripts?: string,\n): RouterManagedTag {\n const clientEntryLiteral = JSON.stringify(clientEntry)\n let script = `import(${clientEntryLiteral})`\n if (injectedHeadScripts) {\n script = `${injectedHeadScripts};${script}`\n }\n return {\n tag: 'script',\n attrs: {\n type: 'module',\n async: true,\n },\n children: script,\n }\n}\n\nfunction assignManifestAssetLink(\n link: ManifestAssetLink,\n next: { href: string; crossOrigin?: AssetCrossOrigin },\n): ManifestAssetLink {\n if (typeof link === 'string') {\n return next.crossOrigin ? next : next.href\n }\n\n return next.crossOrigin ? next : { href: next.href }\n}\n\nexport async function transformManifestAssets(\n source: StartManifestWithClientEntry,\n transformFn: TransformAssetsFn,\n _opts?: {\n clone?: boolean\n inlineCss?: boolean\n },\n): Promise<Manifest> {\n const manifest = structuredClone(source.manifest)\n const inlineCssEnabled = _opts?.inlineCss !== false\n\n if (!inlineCssEnabled) {\n delete manifest.inlineCss\n } else if (manifest.inlineCss) {\n manifest.inlineCss = await transformInlineCssStyles(\n manifest.inlineCss,\n transformFn,\n )\n }\n\n for (const route of Object.values(manifest.routes)) {\n if (route.preloads) {\n route.preloads = await Promise.all(\n route.preloads.map(async (link) => {\n const resolved = resolveManifestAssetLink(link)\n const result = normalizeTransformAssetResult(\n await transformFn({\n url: resolved.href,\n kind: 'modulepreload',\n }),\n )\n\n return assignManifestAssetLink(link, {\n href: result.href,\n crossOrigin: result.crossOrigin,\n })\n }),\n )\n }\n\n if (route.assets && !manifest.inlineCss) {\n for (const asset of route.assets) {\n if (asset.tag === 'link' && asset.attrs?.href) {\n const rel = asset.attrs.rel\n const relTokens = typeof rel === 'string' ? rel.split(/\\s+/) : []\n\n if (!relTokens.includes('stylesheet')) {\n continue\n }\n\n const result = normalizeTransformAssetResult(\n await transformFn({\n url: asset.attrs.href,\n kind: 'stylesheet',\n }),\n )\n\n asset.attrs.href = result.href\n if (result.crossOrigin) {\n asset.attrs.crossOrigin = result.crossOrigin\n } else {\n delete asset.attrs.crossOrigin\n }\n }\n }\n }\n }\n\n const transformedClientEntry = normalizeTransformAssetResult(\n await transformFn({\n url: source.clientEntry,\n kind: 'clientEntry',\n }),\n )\n\n const rootRoute = (manifest.routes[rootRouteId] =\n manifest.routes[rootRouteId] || {})\n rootRoute.assets = rootRoute.assets || []\n rootRoute.assets.push(\n buildClientEntryScriptTag(\n transformedClientEntry.href,\n source.injectedHeadScripts,\n ),\n )\n\n return manifest\n}\n\n/**\n * Builds a final Manifest from a StartManifestWithClientEntry without any\n * URL transforms. Used when no transformAssets option is provided.\n *\n * Returns a new manifest object so the cached base manifest is never mutated.\n */\nexport function buildManifestWithClientEntry(\n source: StartManifestWithClientEntry,\n opts?: { inlineCss?: boolean },\n): Manifest {\n const scriptTag = buildClientEntryScriptTag(\n source.clientEntry,\n source.injectedHeadScripts,\n )\n\n const baseRootRoute = source.manifest.routes[rootRouteId]\n const routes = {\n ...source.manifest.routes,\n [rootRouteId]: {\n ...baseRootRoute,\n assets: [...(baseRootRoute?.assets || []), scriptTag],\n },\n }\n\n return {\n ...(opts?.inlineCss === false\n ? {}\n : { inlineCss: structuredClone(source.manifest.inlineCss) }),\n routes,\n }\n}\n"],"mappings":";;AAmKA,SAAS,8BACP,QACuC;AACvC,KAAI,OAAO,WAAW,SACpB,QAAO,EAAE,MAAM,QAAQ;AAGzB,QAAO;;AAGT,SAAS,gBAAgB,OAAe;AACtC,QAAO,MACJ,QAAQ,OAAO,OAAO,CACtB,QAAQ,MAAM,OAAM,CACpB,QAAQ,OAAO,OAAO,CACtB,QAAQ,OAAO,OAAO,CACtB,QAAQ,OAAO,OAAO;;AAG3B,eAAe,2BAA2B,SAIvC;CACD,MAAM,EAAE,SAAS,SAAS,QAAQ;AAElC,KAAI,QAAQ,WAAW,KAAK,SAAS,EACnC,OAAM,IAAI,MACR,yCAAyC,QAAQ,eAAe,aACjE;CAGH,IAAI,MAAM,QAAQ;AAElB,MAAK,IAAI,QAAQ,GAAG,QAAQ,KAAK,QAAQ,SAAS;EAChD,MAAM,cAAc,8BAClB,MAAM,QAAQ,YAAY;GACxB,MAAM;GACN,KAAK,KAAK;GACV,gBAAgB,QAAQ;GACzB,CAAC,CACH;AAED,SAAO,gBAAgB,YAAY,KAAK,GAAG,QAAQ,QAAQ;;AAG7D,QAAO;;AAGT,eAAe,yBACb,WACA,aACA;CACA,MAAM,oBAA4C,EAAE;CAEpD,MAAM,qBAAqB,MAAM,QAAQ,IACvC,OAAO,QAAQ,UAAU,OAAO,CAAC,IAAI,OAAO,CAAC,gBAAgB,SAAS;EACpE,MAAM,WAAW,UAAU,YAAY;AACvC,SAAO,CACL,gBACA,WACI,MAAM,2BAA2B;GAC/B;GACA;GACA;GACD,CAAC,GACF,IACL;GACD,CACH;AAED,MAAK,MAAM,CAAC,gBAAgB,QAAQ,mBAClC,mBAAkB,kBAAkB;AAGtC,QAAO;EACL,QAAQ;EACR,GAAI,UAAU,YAAY,EAAE,WAAW,UAAU,WAAW,GAAG,EAAE;EAClE;;AAGH,SAAS,kCACP,QACA,MAC8B;AAC9B,KAAI,CAAC,OAAQ,QAAO,KAAA;AACpB,KAAI,OAAO,WAAW,SAAU,QAAO;AAEvC,QAAO,OAAO;;AAGhB,SAAS,kBACP,WAC6C;AAC7C,QAAO,YAAY;;AAGrB,SAAgB,6BACd,WAC+B;AAC/B,KAAI,OAAO,cAAc,UAAU;EACjC,MAAM,SAAS;AACf,SAAO;GACL,MAAM;GACN,cAAc,EAAE,WAAW,EAAE,MAAM,GAAG,SAAS,OAAO;GACtD,OAAO;GACR;;AAGH,KAAI,OAAO,cAAc,WACvB,QAAO;EACL,MAAM;EACN,aAAa;EACb,OAAO;EACR;AAIH,KAAI,kBAAkB,UAAU,EAAE;EAChC,MAAM,EAAE,QAAQ,gBAAgB;AAEhC,SAAO;GACL,MAAM;GACN,cAAc,EAAE,KAAK,WAAW;IAC9B,MAAM,OAAO,GAAG,SAAS;AAEzB,QAAI,SAAS,iBAAiB,SAAS,UACrC,QAAO,EAAE,MAAM;IAGjB,MAAM,KAAK,kCAAkC,aAAa,KAAK;AAC/D,WAAO,KAAK;KAAE;KAAM,aAAa;KAAI,GAAG,EAAE,MAAM;;GAElD,OAAO;GACR;;AAGH,KAAI,qBAAqB,aAAa,UAAU,gBAC9C,QAAO;EACL,MAAM;EACN,iBAAiB,UAAU;EAC3B,OAAO,UAAU,UAAU;EAC5B;AAUH,QAAO;EACL,MAAM;EACN,aARA,OAAO,UAAU,cAAc,aACxB,EAAE,WAAmC,EACtC,MAAM,GAAG,UAAU,YAAY,OAChC,KACD,UAAU;EAKd,OAAO,UAAU,UAAU;EAC5B;;;;;;AAcH,SAAgB,0BACd,aACA,qBACkB;CAElB,IAAI,SAAS,UADc,KAAK,UAAU,YAAY,CACZ;AAC1C,KAAI,oBACF,UAAS,GAAG,oBAAoB,GAAG;AAErC,QAAO;EACL,KAAK;EACL,OAAO;GACL,MAAM;GACN,OAAO;GACR;EACD,UAAU;EACX;;AAGH,SAAS,wBACP,MACA,MACmB;AACnB,KAAI,OAAO,SAAS,SAClB,QAAO,KAAK,cAAc,OAAO,KAAK;AAGxC,QAAO,KAAK,cAAc,OAAO,EAAE,MAAM,KAAK,MAAM;;AAGtD,eAAsB,wBACpB,QACA,aACA,OAImB;CACnB,MAAM,WAAW,gBAAgB,OAAO,SAAS;AAGjD,KAAI,EAFqB,OAAO,cAAc,OAG5C,QAAO,SAAS;UACP,SAAS,UAClB,UAAS,YAAY,MAAM,yBACzB,SAAS,WACT,YACD;AAGH,MAAK,MAAM,SAAS,OAAO,OAAO,SAAS,OAAO,EAAE;AAClD,MAAI,MAAM,SACR,OAAM,WAAW,MAAM,QAAQ,IAC7B,MAAM,SAAS,IAAI,OAAO,SAAS;GAEjC,MAAM,SAAS,8BACb,MAAM,YAAY;IAChB,KAHa,yBAAyB,KAAK,CAG7B;IACd,MAAM;IACP,CAAC,CACH;AAED,UAAO,wBAAwB,MAAM;IACnC,MAAM,OAAO;IACb,aAAa,OAAO;IACrB,CAAC;IACF,CACH;AAGH,MAAI,MAAM,UAAU,CAAC,SAAS;QACvB,MAAM,SAAS,MAAM,OACxB,KAAI,MAAM,QAAQ,UAAU,MAAM,OAAO,MAAM;IAC7C,MAAM,MAAM,MAAM,MAAM;AAGxB,QAAI,EAFc,OAAO,QAAQ,WAAW,IAAI,MAAM,MAAM,GAAG,EAAE,EAElD,SAAS,aAAa,CACnC;IAGF,MAAM,SAAS,8BACb,MAAM,YAAY;KAChB,KAAK,MAAM,MAAM;KACjB,MAAM;KACP,CAAC,CACH;AAED,UAAM,MAAM,OAAO,OAAO;AAC1B,QAAI,OAAO,YACT,OAAM,MAAM,cAAc,OAAO;QAEjC,QAAO,MAAM,MAAM;;;;CAO7B,MAAM,yBAAyB,8BAC7B,MAAM,YAAY;EAChB,KAAK,OAAO;EACZ,MAAM;EACP,CAAC,CACH;CAED,MAAM,YAAa,SAAS,OAAO,eACjC,SAAS,OAAO,gBAAgB,EAAE;AACpC,WAAU,SAAS,UAAU,UAAU,EAAE;AACzC,WAAU,OAAO,KACf,0BACE,uBAAuB,MACvB,OAAO,oBACR,CACF;AAED,QAAO;;;;;;;;AAST,SAAgB,6BACd,QACA,MACU;CACV,MAAM,YAAY,0BAChB,OAAO,aACP,OAAO,oBACR;CAED,MAAM,gBAAgB,OAAO,SAAS,OAAO;CAC7C,MAAM,SAAS;EACb,GAAG,OAAO,SAAS;GAClB,cAAc;GACb,GAAG;GACH,QAAQ,CAAC,GAAI,eAAe,UAAU,EAAE,EAAG,UAAU;GACtD;EACF;AAED,QAAO;EACL,GAAI,MAAM,cAAc,QACpB,EAAE,GACF,EAAE,WAAW,gBAAgB,OAAO,SAAS,UAAU,EAAE;EAC7D;EACD"}
{
"name": "@tanstack/start-server-core",
"version": "1.168.0",
"version": "1.168.1",
"description": "Modern and scalable routing for React applications",

@@ -69,6 +69,6 @@ "author": "Tanner Linsley",

"seroval": "^1.5.4",
"@tanstack/router-core": "1.170.0",
"@tanstack/history": "1.162.0",
"@tanstack/start-client-core": "1.169.0",
"@tanstack/start-storage-context": "1.167.0"
"@tanstack/router-core": "1.170.1",
"@tanstack/start-storage-context": "1.167.1",
"@tanstack/start-client-core": "1.169.1"
},

@@ -75,0 +75,0 @@ "devDependencies": {

@@ -44,3 +44,3 @@ ---

handler: defaultStreamHandler,
transformAssetUrls: 'https://cdn.example.com',
transformAssets: 'https://cdn.example.com',
})

@@ -47,0 +47,0 @@ ```

@@ -27,15 +27,7 @@ import { createMemoryHistory } from '@tanstack/history'

import { handleServerAction } from './server-functions-handler'
import { createEarlyHintsCollector } from './early-hints'
import {
adaptTransformAssetUrlsConfigToTransformAssets,
buildManifestWithClientEntry,
resolveTransformAssetsConfig,
transformManifestAssets,
} from './transformAssetUrls'
import {
collectDynamicHintsFromMatches,
collectStaticHintsFromManifest,
createEarlyHintsEvent,
createResponseLinkHeaderEntries,
getResponseLinkHeaderEntries,
} from './early-hints'
createCachedBaseManifestLoader,
createFinalManifestResolver,
} from './finalManifest'

@@ -55,24 +47,9 @@ import { HEADERS } from './constants'

import type {
EarlyHint,
EarlyHintsEvent,
EarlyHintsPhase,
OnEarlyHints,
ResponseLinkHeaderEntry,
ResponseLinkHeaderFilter,
ResponseLinkHeaderOptions,
} from './early-hints'
import type {
AnyRoute,
AnyRouter,
AnySerializationAdapter,
Manifest,
Register,
} from '@tanstack/router-core'
import type { HandlerCallback } from '@tanstack/router-core/ssr/server'
import type {
StartManifestWithClientEntry,
TransformAssetUrls,
TransformAssets,
TransformAssetsFn,
} from './transformAssetUrls'
import type { FinalManifestOptions } from './finalManifest'

@@ -85,135 +62,4 @@ type TODO = any

export interface CreateStartHandlerOptions {
export interface CreateStartHandlerOptions extends FinalManifestOptions {
handler: HandlerCallback<AnyRouter>
/**
* Transform asset URLs and attributes at runtime, e.g. to prepend a CDN prefix.
*
* **String** — a URL prefix prepended to every asset URL (cached by default):
* ```ts
* createStartHandler({
* handler: defaultStreamHandler,
* transformAssets: 'https://cdn.example.com',
* })
* ```
*
* **Object shorthand** — a URL prefix with optional `crossOrigin`:
* ```ts
* createStartHandler({
* handler: defaultStreamHandler,
* transformAssets: {
* prefix: 'https://cdn.example.com',
* crossOrigin: 'anonymous',
* },
* })
* ```
*
* `crossOrigin` accepts a single value or a per-kind record:
* ```ts
* transformAssets: {
* prefix: 'https://cdn.example.com',
* crossOrigin: {
* modulepreload: 'anonymous',
* stylesheet: 'use-credentials',
* },
* }
* ```
*
* **Callback** — receives `{ kind, url }` and returns either a string URL or
* `{ href, crossOrigin? }` (cached by default — runs once on first request):
* ```ts
* createStartHandler({
* handler: defaultStreamHandler,
* transformAssets: ({ kind, url }) => {
* const href = `https://cdn.example.com${url}`
*
* if (kind === 'modulepreload') {
* return { href, crossOrigin: 'anonymous' }
* }
*
* return { href }
* },
* })
* ```
*
* **Object** — for explicit cache control:
* ```ts
* createStartHandler({
* handler: defaultStreamHandler,
* transformAssets: {
* transform: ({ url }) => {
* const region = getRequest().headers.get('x-region') || 'us'
* return { href: `https://cdn-${region}.example.com${url}` }
* },
* cache: false,
* },
* })
* ```
*
* `kind` is one of `'modulepreload' | 'stylesheet' | 'clientEntry'`.
* `crossOrigin` applies to manifest-managed `<link>` assets.
*
* By default, the transformed manifest is cached after the first request
* (`cache: true`). Set `cache: false` for per-request transforms.
*
* If you're using a cached transform, you can optionally set `warmup: true`
* (object form only) to compute the transformed manifest in the background at
* server startup.
*
* Note: This only transforms URLs managed by TanStack Start's manifest
* (JS preloads, CSS links, and the client entry script). For asset imports
* used directly in components (e.g. `import logo from './logo.svg'`),
* configure Vite's `experimental.renderBuiltUrl` in your vite.config.ts.
*/
transformAssets?: TransformAssets
/**
* @deprecated Use `transformAssets` instead.
*
* **String** — a URL prefix prepended to every asset URL (cached by default):
* ```ts
* createStartHandler({
* handler: defaultStreamHandler,
* transformAssetUrls: 'https://cdn.example.com',
* })
* ```
*
* **Callback** — receives `{ url, type }` and returns a new URL
* (cached by default — runs once on first request):
* ```ts
* createStartHandler({
* handler: defaultStreamHandler,
* transformAssetUrls: ({ url, type }) => {
* return `https://cdn.example.com${url}`
* },
* })
* ```
*
* **Object** — for explicit cache control:
* ```ts
* createStartHandler({
* handler: defaultStreamHandler,
* transformAssetUrls: {
* transform: ({ url }) => {
* const region = getRequest().headers.get('x-region') || 'us'
* return `https://cdn-${region}.example.com${url}`
* },
* cache: false, // transform per-request
* },
* })
* ```
*
* `type` is one of `'modulepreload' | 'stylesheet' | 'clientEntry'`.
*
* By default, the transformed manifest is cached after the first request
* (`cache: true`). Set `cache: false` for per-request transforms.
*
* If you're using a cached transform, you can optionally set `warmup: true`
* (object form only) to compute the transformed manifest in the background at
* server startup.
*
* Note: This only transforms URLs managed by TanStack Start's manifest
* (JS preloads, CSS links, and the client entry script). For asset imports
* used directly in components (e.g. `import logo from './logo.svg'`),
* configure Vite's `experimental.renderBuiltUrl` in your vite.config.ts.
*/
transformAssetUrls?: TransformAssetUrls
}

@@ -233,102 +79,2 @@

function notifyEarlyHints(
phase: EarlyHintsPhase,
event: EarlyHintsEvent,
onEarlyHints: OnEarlyHints,
) {
try {
const result = onEarlyHints(event)
if (result) {
void Promise.resolve(result).catch((err) => {
console.error(`Error sending ${phase} early hints:`, err)
})
}
} catch (err) {
console.error(`Error sending ${phase} early hints:`, err)
}
}
function getResponseLinkHeaderFilter(
responseLinkHeader: boolean | ResponseLinkHeaderOptions | undefined,
): ResponseLinkHeaderFilter | undefined {
if (typeof responseLinkHeader !== 'object') {
return undefined
}
return responseLinkHeader.filter
}
function appendResponseLinkHeaders(opts: {
responseHeaders: Headers
entries: ReadonlyArray<ResponseLinkHeaderEntry>
filter?: ResponseLinkHeaderFilter
}) {
if (!opts.filter) {
for (const entry of opts.entries) {
opts.responseHeaders.append('Link', entry.link)
}
return
}
const links = getResponseLinkHeaderEntries(opts)
for (const link of links) {
opts.responseHeaders.append('Link', link)
}
}
function collectResponseLinkHeaderEntries(opts: {
phase: EarlyHintsPhase
event: EarlyHintsEvent
entries: Array<ResponseLinkHeaderEntry>
}) {
for (let index = 0; index < opts.event.hints.length; index++) {
opts.entries.push({
phase: opts.phase,
hint: opts.event.hints[index]!,
link: opts.event.links[index]!,
})
}
}
function handleCollectedEarlyHints(opts: {
phase: EarlyHintsPhase
hints: ReadonlyArray<EarlyHint>
sentLinks: Set<string>
sentHints?: Array<EarlyHint>
onEarlyHints?: OnEarlyHints
responseLinkHeaderEntries?: Array<ResponseLinkHeaderEntry>
}) {
const event = opts.onEarlyHints
? createEarlyHintsEvent({
phase: opts.phase,
hints: opts.hints,
sentLinks: opts.sentLinks,
sentHints: opts.sentHints!,
})
: undefined
if (event) {
notifyEarlyHints(opts.phase, event, opts.onEarlyHints!)
}
if (!opts.responseLinkHeaderEntries) return
if (event) {
collectResponseLinkHeaderEntries({
phase: opts.phase,
event,
entries: opts.responseLinkHeaderEntries,
})
return
}
createResponseLinkHeaderEntries({
phase: opts.phase,
hints: opts.hints,
sentLinks: opts.sentLinks,
entries: opts.responseLinkHeaderEntries,
})
}
interface PluginAdaptersEntry {

@@ -348,3 +94,2 @@ hasPluginAdapters: boolean

let entriesPromise: Promise<Entries> | undefined
let baseManifestPromise: Promise<StartManifestWithClientEntry> | undefined
let hasWarnedMissingCsrfMiddleware = false

@@ -354,9 +99,14 @@ const defaultCsrfMiddleware = createCsrfMiddleware({

})
const getCachedBaseManifest = createCachedBaseManifestLoader(() =>
getStartManifest(),
)
const getProdBaseManifest: typeof getStartManifest = () =>
getCachedBaseManifest()
const getBaseManifest =
process.env.TSS_DEV_SERVER === 'true' ? getStartManifest : getProdBaseManifest
const createEarlyHintsForRequest: typeof createEarlyHintsCollector =
process.env.TSS_DEV_SERVER === 'true'
? () => undefined
: createEarlyHintsCollector
/**
* Cached final manifest (with client entry script tag). In production,
* this is computed once and reused for every request when caching is enabled.
*/
let cachedFinalManifestPromise: Promise<Manifest> | undefined
async function loadEntries(): Promise<Entries> {

@@ -418,57 +168,2 @@ const [routerEntry, startEntry, pluginAdapters] = await Promise.all([

/**
* Returns the raw manifest data (without client entry script tag baked in).
* In dev mode, always returns fresh data. In prod, cached.
*/
function getBaseManifest(
matchedRoutes?: ReadonlyArray<AnyRoute>,
): Promise<StartManifestWithClientEntry> {
// In dev mode, always get fresh manifest (no caching) to include route-specific dev styles
if (process.env.TSS_DEV_SERVER === 'true') {
return getStartManifest(matchedRoutes)
}
// In prod, cache the base manifest
if (!baseManifestPromise) {
baseManifestPromise = getStartManifest()
}
return baseManifestPromise
}
/**
* Resolves a final Manifest for a given request.
*
* - No transform: builds client entry script tag and returns (cached in prod).
* - Cached transform: transforms all URLs + builds script tag, caches result.
* - Per-request transform: deep-clones base manifest, transforms per-request.
*/
async function resolveManifest(
matchedRoutes: ReadonlyArray<AnyRoute> | undefined,
transformFn: TransformAssetsFn | undefined,
cache: boolean,
): Promise<Manifest> {
const base = await getBaseManifest(matchedRoutes)
const computeFinalManifest = async () => {
return transformFn
? await transformManifestAssets(base, transformFn, { clone: !cache })
: buildManifestWithClientEntry(base)
}
// In dev, always compute fresh to include route-specific dev styles.
if (process.env.TSS_DEV_SERVER === 'true') {
return computeFinalManifest()
}
// In prod, cache unless we're explicitly doing per-request transforms.
if (!transformFn || cache) {
if (!cachedFinalManifestPromise) {
cachedFinalManifestPromise = computeFinalManifest()
}
return cachedFinalManifestPromise
}
// Per-request transform — deep-clone and transform every time.
return computeFinalManifest()
}
// Pre-computed constants

@@ -618,92 +313,18 @@ const ROUTER_BASEPATH = process.env.TSS_ROUTER_BASEPATH || '/'

): RequestHandler<TRegister> {
// Normalize the overloaded argument
const handlerOptions: FinalManifestOptions =
typeof cbOrOptions === 'function' ? {} : cbOrOptions
const cb: HandlerCallback<AnyRouter> =
typeof cbOrOptions === 'function' ? cbOrOptions : cbOrOptions.handler
const transformAssetsOption: TransformAssets | undefined =
typeof cbOrOptions === 'function' ? undefined : cbOrOptions.transformAssets
const transformAssetUrlsOption: TransformAssetUrls | undefined =
typeof cbOrOptions === 'function'
? undefined
: cbOrOptions.transformAssetUrls
const finalManifestResolver = createFinalManifestResolver({
...handlerOptions,
cacheCreateTransform: process.env.TSS_DEV_SERVER !== 'true',
})
const resolveManifestForRequest =
process.env.TSS_DEV_SERVER === 'true'
? finalManifestResolver.resolveUncached
: finalManifestResolver.resolveCached
const transformOption =
transformAssetsOption !== undefined
? resolveTransformAssetsConfig(transformAssetsOption)
: transformAssetUrlsOption !== undefined
? resolveTransformAssetsConfig(
adaptTransformAssetUrlsConfigToTransformAssets(
transformAssetUrlsOption,
),
)
: undefined
const warmupTransformManifest =
(!!transformAssetsOption &&
typeof transformAssetsOption === 'object' &&
'warmup' in transformAssetsOption &&
transformAssetsOption.warmup === true) ||
(!!transformAssetUrlsOption &&
typeof transformAssetUrlsOption === 'object' &&
transformAssetUrlsOption.warmup === true)
// Pre-resolve the transform function and cache flag
const resolvedTransformConfig = transformOption
const cache = resolvedTransformConfig ? resolvedTransformConfig.cache : true
const shouldCacheCreateTransform =
cache && process.env.TSS_DEV_SERVER !== 'true'
// Memoize a single createTransform() result when caching is enabled outside
// of the dev server.
let cachedCreateTransformPromise: Promise<TransformAssetsFn> | undefined
const getTransformFn = async (
opts: { warmup: true } | { warmup: false; request: Request },
): Promise<TransformAssetsFn | undefined> => {
if (!resolvedTransformConfig) return undefined
if (resolvedTransformConfig.type === 'createTransform') {
if (shouldCacheCreateTransform) {
if (!cachedCreateTransformPromise) {
cachedCreateTransformPromise = Promise.resolve(
resolvedTransformConfig.createTransform(opts),
).catch((error) => {
cachedCreateTransformPromise = undefined
throw error
})
}
return cachedCreateTransformPromise
}
return resolvedTransformConfig.createTransform(opts)
}
return resolvedTransformConfig.transformFn
}
// Background warmup for cached transforms (production only)
if (
warmupTransformManifest &&
cache &&
process.env.TSS_DEV_SERVER !== 'true' &&
!cachedFinalManifestPromise
) {
// NOTE: Do not call resolveManifest() here.
// resolveManifest() reads from cachedFinalManifestPromise, and since we set
// cachedFinalManifestPromise to this warmup promise, that would create a
// self-referential promise and hang forever.
const warmupPromise = (async () => {
const base = await getBaseManifest(undefined)
const transformFn = await getTransformFn({ warmup: true })
return transformFn
? await transformManifestAssets(base, transformFn, { clone: false })
: buildManifestWithClientEntry(base)
})()
cachedFinalManifestPromise = warmupPromise
warmupPromise.catch(() => {
// If warmup fails, allow the next request to retry.
if (cachedFinalManifestPromise === warmupPromise) {
cachedFinalManifestPromise = undefined
}
cachedCreateTransformPromise = undefined
if (process.env.TSS_DEV_SERVER !== 'true') {
finalManifestResolver.warmup({
getBaseManifest: () => getBaseManifest(undefined),
})

@@ -867,40 +488,14 @@ }

const manifest = await resolveManifest(
matchedRoutes,
await getTransformFn({ warmup: false, request }),
cache,
)
const manifest = await resolveManifestForRequest({
request,
requestInlineCss: requestOpts?.inlineCss,
getBaseManifest: () => getBaseManifest(matchedRoutes),
})
const onEarlyHints = requestOpts?.onEarlyHints
const responseLinkHeader = requestOpts?.responseLinkHeader
const shouldCollectEarlyHints =
process.env.TSS_DEV_SERVER !== 'true' &&
(!!onEarlyHints || !!responseLinkHeader)
const sentEarlyHintLinks = shouldCollectEarlyHints
? new Set<string>()
: undefined
const sentEarlyHints = onEarlyHints ? new Array<EarlyHint>() : undefined
const responseLinkHeaderEntries =
shouldCollectEarlyHints && responseLinkHeader
? new Array<ResponseLinkHeaderEntry>()
: undefined
const responseLinkHeaderFilter = shouldCollectEarlyHints
? getResponseLinkHeaderFilter(responseLinkHeader)
: undefined
const earlyHints = createEarlyHintsForRequest({
onEarlyHints: requestOpts?.onEarlyHints,
responseLinkHeader: requestOpts?.responseLinkHeader,
})
if (
shouldCollectEarlyHints &&
sentEarlyHintLinks &&
matchedRoutes?.length
) {
const hints = collectStaticHintsFromManifest(manifest, matchedRoutes)
handleCollectedEarlyHints({
phase: 'static',
hints,
sentLinks: sentEarlyHintLinks,
sentHints: sentEarlyHints,
onEarlyHints,
responseLinkHeaderEntries,
})
}
earlyHints?.collectStatic({ manifest, matchedRoutes })

@@ -924,14 +519,3 @@ const routerInstance = await getRouter()

if (shouldCollectEarlyHints && sentEarlyHintLinks) {
const loadedMatches = routerInstance.stores.matches.get()
const hints = collectDynamicHintsFromMatches(loadedMatches)
handleCollectedEarlyHints({
phase: 'dynamic',
hints,
sentLinks: sentEarlyHintLinks,
sentHints: sentEarlyHints,
onEarlyHints,
responseLinkHeaderEntries,
})
}
earlyHints?.collectDynamic(routerInstance.stores.matches.get())

@@ -947,9 +531,3 @@ // Pass request-scoped assets to dehydrate for manifest injection

})
if (responseLinkHeaderEntries?.length) {
appendResponseLinkHeaders({
responseHeaders,
entries: responseLinkHeaderEntries,
filter: responseLinkHeaderFilter,
})
}
earlyHints?.appendResponseHeaders(responseHeaders)
cbWillCleanup = true

@@ -956,0 +534,0 @@

@@ -50,2 +50,11 @@ import {

export interface EarlyHintsCollector {
collectStatic: (opts: {
manifest: Manifest
matchedRoutes?: ReadonlyArray<AnyRoute>
}) => void
collectDynamic: (matches: ReadonlyArray<AnyRouteMatch>) => void
appendResponseHeaders: (headers: Headers) => void
}
const LINK_PARAM_TOKEN_RE = /^[!#$%&'*+\-.^_`|~0-9A-Za-z]+$/

@@ -297,1 +306,151 @@ const PRELOAD_AS_VALUES = new Set<EarlyHint['as']>([

}
function notifyEarlyHints(
phase: EarlyHintsPhase,
event: EarlyHintsEvent,
onEarlyHints: OnEarlyHints,
) {
try {
const result = onEarlyHints(event)
if (result) {
void Promise.resolve(result).catch((err) => {
console.error(`Error sending ${phase} early hints:`, err)
})
}
} catch (err) {
console.error(`Error sending ${phase} early hints:`, err)
}
}
function getResponseLinkHeaderFilter(
responseLinkHeader: boolean | ResponseLinkHeaderOptions | undefined,
): ResponseLinkHeaderFilter | undefined {
if (typeof responseLinkHeader !== 'object') {
return undefined
}
return responseLinkHeader.filter
}
function appendResponseLinkHeaders(opts: {
responseHeaders: Headers
entries: ReadonlyArray<ResponseLinkHeaderEntry>
filter?: ResponseLinkHeaderFilter
}) {
for (const link of getResponseLinkHeaderEntries(opts)) {
opts.responseHeaders.append('Link', link)
}
}
function collectResponseLinkHeaderEntries(opts: {
phase: EarlyHintsPhase
event: EarlyHintsEvent
entries: Array<ResponseLinkHeaderEntry>
}) {
for (let index = 0; index < opts.event.hints.length; index++) {
opts.entries.push({
phase: opts.phase,
hint: opts.event.hints[index]!,
link: opts.event.links[index]!,
})
}
}
function collectEarlyHintsPhase(opts: {
phase: EarlyHintsPhase
hints: ReadonlyArray<EarlyHint>
sentLinks: Set<string>
sentHints?: Array<EarlyHint>
onEarlyHints?: OnEarlyHints
responseLinkHeaderEntries?: Array<ResponseLinkHeaderEntry>
}) {
const event = opts.onEarlyHints
? createEarlyHintsEvent({
phase: opts.phase,
hints: opts.hints,
sentLinks: opts.sentLinks,
sentHints: opts.sentHints!,
})
: undefined
if (event) {
notifyEarlyHints(opts.phase, event, opts.onEarlyHints!)
}
if (!opts.responseLinkHeaderEntries) return
if (event) {
collectResponseLinkHeaderEntries({
phase: opts.phase,
event,
entries: opts.responseLinkHeaderEntries,
})
return
}
createResponseLinkHeaderEntries({
phase: opts.phase,
hints: opts.hints,
sentLinks: opts.sentLinks,
entries: opts.responseLinkHeaderEntries,
})
}
export function createEarlyHintsCollector(
opts:
| {
onEarlyHints?: OnEarlyHints
responseLinkHeader?: boolean | ResponseLinkHeaderOptions
}
| undefined,
): EarlyHintsCollector | undefined {
if (
process.env.TSS_DEV_SERVER === 'true' ||
(!opts?.onEarlyHints && !opts?.responseLinkHeader)
) {
return undefined
}
const sentLinks = new Set<string>()
const sentHints = opts.onEarlyHints ? new Array<EarlyHint>() : undefined
const responseLinkHeaderEntries = opts.responseLinkHeader
? new Array<ResponseLinkHeaderEntry>()
: undefined
const responseLinkHeaderFilter = getResponseLinkHeaderFilter(
opts.responseLinkHeader,
)
return {
collectStatic: ({ manifest, matchedRoutes }) => {
if (!matchedRoutes?.length) return
collectEarlyHintsPhase({
phase: 'static',
hints: collectStaticHintsFromManifest(manifest, matchedRoutes),
sentLinks,
sentHints,
onEarlyHints: opts.onEarlyHints,
responseLinkHeaderEntries,
})
},
collectDynamic: (matches) => {
collectEarlyHintsPhase({
phase: 'dynamic',
hints: collectDynamicHintsFromMatches(matches),
sentLinks,
sentHints,
onEarlyHints: opts.onEarlyHints,
responseLinkHeaderEntries,
})
},
appendResponseHeaders: (headers) => {
if (!responseLinkHeaderEntries?.length) return
appendResponseLinkHeaders({
responseHeaders: headers,
entries: responseLinkHeaderEntries,
filter: responseLinkHeaderFilter,
})
},
}
}

@@ -12,8 +12,4 @@ export { createStartHandler } from './createStartHandler'

TransformAssetResult,
TransformAssetUrls,
TransformAssetUrlsFn,
TransformAssetUrlsContext,
TransformAssetUrlsOptions,
AssetUrlType,
TransformAssetKind,
CreateTransformAssetsContext,
} from './transformAssetUrls'

@@ -20,0 +16,0 @@

@@ -48,3 +48,15 @@ import type { OnEarlyHints, ResponseLinkHeaderOptions } from './early-hints'

type InlineCssOptions = {
/**
* Controls whether Start inlines build-collected CSS for this request.
*
* This only has an effect when the build was created with
* `server.build.inlineCss` enabled. Defaults to `true` so builds with inline
* CSS enabled continue to inline CSS unless a request opts out.
*/
inlineCss?: boolean
}
export type RequestOptions<TRegister> = EarlyHintsOptions &
InlineCssOptions &
(TRegister extends {

@@ -51,0 +63,0 @@ server: { requestContext: infer TRequestContext }

@@ -13,16 +13,28 @@ import { resolveManifestAssetLink, rootRouteId } from '@tanstack/router-core'

export type TransformAssetKind = 'modulepreload' | 'stylesheet' | 'clientEntry'
export type TransformAssetsContext =
| {
url: string
kind: 'modulepreload'
}
| {
url: string
kind: 'stylesheet'
}
| {
url: string
kind: 'clientEntry'
}
| {
url: string
kind: 'css-url'
stylesheetHref: string
}
export type TransformAssetKind = TransformAssetsContext['kind']
type TransformAssetsShorthandCrossOriginKind = Exclude<
TransformAssetKind,
'clientEntry'
'clientEntry' | 'css-url'
>
export type AssetUrlType = TransformAssetKind
export interface TransformAssetsContext {
url: string
kind: TransformAssetKind
}
export type TransformAssetResult =

@@ -39,12 +51,3 @@ | string

export interface TransformAssetUrlsContext {
url: string
type: AssetUrlType
}
export type TransformAssetUrlsFn = (
context: TransformAssetUrlsContext,
) => Awaitable<string>
export type CreateTransformAssetUrlsContext =
export type CreateTransformAssetsContext =
| {

@@ -65,15 +68,7 @@ /** True when the server is computing the cached manifest during startup warmup. */

/**
* Async factory that runs once per manifest computation and returns the
* per-asset transform.
*/
export type CreateTransformAssetUrlsFn = (
ctx: CreateTransformAssetUrlsContext,
) => Awaitable<TransformAssetUrlsFn>
export type CreateTransformAssetsFn = (
ctx: CreateTransformAssetUrlsContext,
ctx: CreateTransformAssetsContext,
) => Awaitable<TransformAssetsFn>
type TransformAssetUrlsOptionsBase = {
type TransformAssetsOptionsBase = {
/**

@@ -104,32 +99,8 @@ * Whether to cache the transformed manifest after the first request.

export type TransformAssetUrlsOptions =
| (TransformAssetUrlsOptionsBase & {
/**
* The transform to apply to asset URLs. Can be a string prefix or a callback.
*
* **String** — prepended to every asset URL.
* **Callback** — receives `{ url, type }` and returns a new URL.
*/
transform: string | TransformAssetUrlsFn
createTransform?: never
})
| (TransformAssetUrlsOptionsBase & {
/**
* Create a per-asset transform function.
*
* This factory runs once per manifest computation (per request when
* `cache: false`, or once per server when `cache: true`). It can do async
* setup work (fetch config, read from a KV, etc.) and return a fast
* per-asset transformer.
*/
createTransform: CreateTransformAssetUrlsFn
transform?: never
})
export type TransformAssetsOptions =
| (TransformAssetUrlsOptionsBase & {
| (TransformAssetsOptionsBase & {
transform: string | TransformAssetsFn
createTransform?: never
})
| (TransformAssetUrlsOptionsBase & {
| (TransformAssetsOptionsBase & {
createTransform: CreateTransformAssetsFn

@@ -139,7 +110,2 @@ transform?: never

export type TransformAssetUrls =
| string
| TransformAssetUrlsFn
| TransformAssetUrlsOptions
/**

@@ -203,17 +169,2 @@ * Per-kind crossOrigin configuration for the object shorthand.

let hasWarnedAboutDeprecatedTransformAssetUrls = false
export function warnDeprecatedTransformAssetUrls() {
if (
(process.env.NODE_ENV === 'development' ||
process.env.TSS_DEV_SERVER === 'true') &&
!hasWarnedAboutDeprecatedTransformAssetUrls
) {
hasWarnedAboutDeprecatedTransformAssetUrls = true
console.warn(
'[TanStack Start] `transformAssetUrls` is deprecated. Use `transformAssets` instead.',
)
}
}
function normalizeTransformAssetResult(

@@ -229,2 +180,73 @@ result: TransformAssetResult,

function escapeCssString(value: string) {
return value
.replace(/\\/g, '\\\\')
.replace(/"/g, '\\"')
.replace(/\n/g, '\\a ')
.replace(/\r/g, '\\d ')
.replace(/\f/g, '\\c ')
}
async function transformInlineCssTemplate(options: {
stylesheetHref: string
template: { strings: Array<string>; urls: Array<string> }
transformFn: TransformAssetsFn
}) {
const { strings, urls } = options.template
if (strings.length !== urls.length + 1) {
throw new Error(
`TanStack Start inlineCss template for ${options.stylesheetHref} is invalid`,
)
}
let css = strings[0]!
for (let index = 0; index < urls.length; index++) {
const transformed = normalizeTransformAssetResult(
await options.transformFn({
kind: 'css-url',
url: urls[index]!,
stylesheetHref: options.stylesheetHref,
}),
)
css += escapeCssString(transformed.href) + strings[index + 1]!
}
return css
}
async function transformInlineCssStyles(
inlineCss: NonNullable<Manifest['inlineCss']>,
transformFn: TransformAssetsFn,
) {
const transformedStyles: Record<string, string> = {}
const transformedEntries = await Promise.all(
Object.entries(inlineCss.styles).map(async ([stylesheetHref, css]) => {
const template = inlineCss.templates?.[stylesheetHref]
return [
stylesheetHref,
template
? await transformInlineCssTemplate({
stylesheetHref,
template,
transformFn,
})
: css,
] as const
}),
)
for (const [stylesheetHref, css] of transformedEntries) {
transformedStyles[stylesheetHref] = css
}
return {
styles: transformedStyles,
...(inlineCss.templates ? { templates: inlineCss.templates } : {}),
}
}
function resolveTransformAssetsCrossOrigin(

@@ -275,3 +297,3 @@ config: TransformAssetsCrossOriginConfig | undefined,

if (kind === 'clientEntry') {
if (kind === 'clientEntry' || kind === 'css-url') {
return { href }

@@ -309,44 +331,2 @@ }

export function adaptTransformAssetUrlsToTransformAssets(
transformFn: TransformAssetUrlsFn,
): TransformAssetsFn {
return async ({ url, kind }) => ({
href: await transformFn({ url, type: kind }),
})
}
export function adaptTransformAssetUrlsConfigToTransformAssets(
transform: TransformAssetUrls,
): TransformAssets {
warnDeprecatedTransformAssetUrls()
if (typeof transform === 'string') {
return transform
}
if (typeof transform === 'function') {
return adaptTransformAssetUrlsToTransformAssets(transform)
}
if ('createTransform' in transform && transform.createTransform) {
return {
createTransform: async (ctx: CreateTransformAssetUrlsContext) =>
adaptTransformAssetUrlsToTransformAssets(
await transform.createTransform(ctx),
),
cache: transform.cache,
warmup: transform.warmup,
}
}
return {
transform:
typeof transform.transform === 'string'
? transform.transform
: adaptTransformAssetUrlsToTransformAssets(transform.transform),
cache: transform.cache,
warmup: transform.warmup,
}
}
export interface StartManifestWithClientEntry {

@@ -398,6 +378,17 @@ manifest: Manifest

clone?: boolean
inlineCss?: boolean
},
): Promise<Manifest> {
const manifest = structuredClone(source.manifest)
const inlineCssEnabled = _opts?.inlineCss !== false
if (!inlineCssEnabled) {
delete manifest.inlineCss
} else if (manifest.inlineCss) {
manifest.inlineCss = await transformInlineCssStyles(
manifest.inlineCss,
transformFn,
)
}
for (const route of Object.values(manifest.routes)) {

@@ -423,3 +414,3 @@ if (route.preloads) {

if (route.assets && !source.manifest.inlineCss) {
if (route.assets && !manifest.inlineCss) {
for (const asset of route.assets) {

@@ -474,3 +465,3 @@ if (asset.tag === 'link' && asset.attrs?.href) {

* Builds a final Manifest from a StartManifestWithClientEntry without any
* URL transforms. Used when no transformAssetUrls option is provided.
* URL transforms. Used when no transformAssets option is provided.
*

@@ -481,2 +472,3 @@ * Returns a new manifest object so the cached base manifest is never mutated.

source: StartManifestWithClientEntry,
opts?: { inlineCss?: boolean },
): Manifest {

@@ -497,3 +489,8 @@ const scriptTag = buildClientEntryScriptTag(

return { inlineCss: source.manifest.inlineCss, routes }
return {
...(opts?.inlineCss === false
? {}
: { inlineCss: structuredClone(source.manifest.inlineCss) }),
routes,
}
}