{"version":3,"file":"app-middleware.js","names":[],"sources":["../../src/server/app-middleware.ts"],"sourcesContent":["import type { NextI18nConfig } from \"../config/next-config.js\";\nimport { isExternalUrl, proxyExternalRequest } from \"../config/config-matchers.js\";\nimport { applyMiddlewareRequestHeaders, setHeadersContext } from \"vinext/shims/headers\";\nimport { setNavigationContext } from \"vinext/shims/navigation\";\nimport { FLIGHT_HEADERS, VINEXT_MW_CTX_HEADER } from \"./headers.js\";\nimport { buildRequestHeadersFromMiddlewareResponse } from \"./middleware-request-headers.js\";\nimport { mergeMiddlewareResponseHeaders } from \"./middleware-response-headers.js\";\nimport { executeMiddleware, type MiddlewareModule } from \"./middleware-runtime.js\";\nimport { cloneRequestWithHeaders, processMiddlewareHeaders } from \"./request-pipeline.js\";\nimport { internalServerErrorResponse } from \"./http-error-responses.js\";\n\nexport type AppMiddlewareContext = {\n  headers: Headers | null;\n  requestHeaders: Headers | null;\n  status: number | null;\n};\n\nexport type ApplyAppMiddlewareOptions = {\n  basePath?: string;\n  cleanPathname: string;\n  context: AppMiddlewareContext;\n  i18nConfig?: NextI18nConfig | null;\n  isProxy: boolean;\n  module: MiddlewareModule;\n  request: Request;\n};\n\nexport type ApplyAppMiddlewareResult =\n  | {\n      kind: \"continue\";\n      cleanPathname: string;\n      search: string | null;\n    }\n  | {\n      kind: \"response\";\n      response: Response;\n    };\n\ntype ForwardedMiddlewareContext = {\n  h?: unknown;\n  r?: unknown;\n  s?: unknown;\n};\n\n// Re-exported from headers.ts for backward compatibility.\nexport { FLIGHT_HEADERS } from \"./headers.js\";\n\nconst FLIGHT_HEADER_SET = new Set(FLIGHT_HEADERS);\n\nfunction isForwardedMiddlewareContext(value: unknown): value is ForwardedMiddlewareContext {\n  return !!value && typeof value === \"object\";\n}\n\nfunction requestWithoutFlightHeaders(request: Request): Request {\n  let hasFlightHeader = false;\n  const headers = new Headers();\n\n  for (const [key, value] of request.headers) {\n    if (FLIGHT_HEADER_SET.has(key.toLowerCase())) {\n      hasFlightHeader = true;\n    } else {\n      headers.append(key, value);\n    }\n  }\n\n  if (!hasFlightHeader) return request;\n  const source = request.body ? request.clone() : request;\n  return cloneRequestWithHeaders(source, headers);\n}\n\nfunction appendForwardedHeader(headers: Headers, value: unknown): void {\n  if (!Array.isArray(value) || value.length < 2) return;\n  const key = value[0];\n  const headerValue = value[1];\n  if (typeof key === \"string\" && typeof headerValue === \"string\") {\n    headers.append(key, headerValue);\n  }\n}\n\nfunction responseFromMiddlewareRedirect(result: {\n  redirectStatus?: number;\n  redirectUrl?: string;\n  response?: Response;\n  responseHeaders?: Headers;\n}): Response {\n  if (result.response) return result.response;\n\n  const headers = new Headers(result.responseHeaders);\n  if (result.redirectUrl) {\n    headers.set(\"Location\", result.redirectUrl);\n  }\n  return new Response(null, {\n    status: result.redirectStatus ?? 307,\n    headers,\n  });\n}\n\nexport function isExternalMiddlewareRewrite(rewriteUrl: string, request: Request): boolean {\n  const rewriteParsed = new URL(rewriteUrl, request.url);\n  return rewriteParsed.origin !== new URL(request.url).origin;\n}\n\nfunction requestWithMiddlewareRequestHeaders(\n  request: Request,\n  middlewareHeaders: Headers | null,\n): Request {\n  const nextHeaders = middlewareHeaders\n    ? buildRequestHeadersFromMiddlewareResponse(request.headers, middlewareHeaders, {\n        preserveCredentialHeaders: true,\n      })\n    : null;\n  if (!nextHeaders) return request;\n\n  const init: RequestInit = {\n    method: request.method,\n    headers: nextHeaders,\n    body: request.body,\n  };\n  if (request.body) {\n    Object.defineProperty(init, \"duplex\", { value: \"half\", enumerable: true });\n  }\n\n  return new Request(request.url, init);\n}\n\nexport async function proxyExternalMiddlewareRewrite(\n  request: Request,\n  rewriteUrl: string,\n  context: AppMiddlewareContext,\n): Promise<Response> {\n  const proxyRequest = requestWithMiddlewareRequestHeaders(\n    request,\n    context.requestHeaders ?? context.headers,\n  );\n  setHeadersContext(null);\n  setNavigationContext(null);\n\n  const proxyResponse = await proxyExternalRequest(proxyRequest, rewriteUrl);\n  const headers = new Headers(proxyResponse.headers);\n  processMiddlewareHeaders(headers);\n\n  if (!context.headers) {\n    return new Response(proxyResponse.body, {\n      status: proxyResponse.status,\n      statusText: proxyResponse.statusText,\n      headers,\n    });\n  }\n\n  const middlewareHeaders = new Headers(context.headers);\n  processMiddlewareHeaders(middlewareHeaders);\n  mergeMiddlewareResponseHeaders(headers, middlewareHeaders);\n  return new Response(proxyResponse.body, {\n    status: proxyResponse.status,\n    statusText: proxyResponse.statusText,\n    headers,\n  });\n}\n\nfunction applyForwardedMiddlewareContext(\n  request: Request,\n  context: AppMiddlewareContext,\n): { applied: boolean; rewriteUrl?: string } {\n  if (process.env.NODE_ENV === \"production\") {\n    return { applied: false };\n  }\n\n  const header = request.headers.get(VINEXT_MW_CTX_HEADER);\n  if (!header) return { applied: false };\n\n  try {\n    const data = JSON.parse(header);\n    if (!isForwardedMiddlewareContext(data)) return { applied: false };\n\n    if (Array.isArray(data.h) && data.h.length > 0) {\n      context.headers = new Headers();\n      for (const entry of data.h) {\n        appendForwardedHeader(context.headers, entry);\n      }\n    }\n    if (typeof data.s === \"number\") {\n      context.status = data.s;\n    }\n    if (typeof data.r === \"string\" && data.r.length > 0) {\n      return { applied: true, rewriteUrl: data.r };\n    }\n    return { applied: true };\n  } catch (e) {\n    console.error(\"[vinext] Failed to parse forwarded middleware context:\", e);\n    return { applied: false };\n  }\n}\n\nexport async function applyAppMiddleware(\n  options: ApplyAppMiddlewareOptions,\n): Promise<ApplyAppMiddlewareResult> {\n  const forwarded = applyForwardedMiddlewareContext(options.request, options.context);\n  const middlewareRequest = requestWithoutFlightHeaders(options.request);\n  let cleanPathname = options.cleanPathname;\n  let search: string | null = null;\n\n  if (forwarded.rewriteUrl) {\n    try {\n      if (isExternalMiddlewareRewrite(forwarded.rewriteUrl, middlewareRequest)) {\n        return {\n          kind: \"response\",\n          response: await proxyExternalMiddlewareRewrite(\n            middlewareRequest,\n            forwarded.rewriteUrl,\n            options.context,\n          ),\n        };\n      }\n      const rewriteParsed = new URL(forwarded.rewriteUrl, middlewareRequest.url);\n      cleanPathname = rewriteParsed.pathname;\n      search = rewriteParsed.search;\n    } catch (e) {\n      console.error(\"[vinext] Failed to apply forwarded middleware rewrite:\", e);\n      forwarded.applied = false;\n    }\n  }\n\n  if (!forwarded.applied) {\n    const result = await executeMiddleware({\n      basePath: options.basePath,\n      i18nConfig: options.i18nConfig,\n      isProxy: options.isProxy,\n      module: options.module,\n      normalizedPathname: cleanPathname,\n      request: middlewareRequest,\n    });\n\n    if (!result.continue) {\n      if (result.redirectUrl) {\n        return { kind: \"response\", response: responseFromMiddlewareRedirect(result) };\n      }\n      if (result.response) {\n        return { kind: \"response\", response: result.response };\n      }\n      return { kind: \"response\", response: internalServerErrorResponse() };\n    }\n\n    if (result.responseHeaders) {\n      options.context.headers = new Headers(result.responseHeaders);\n    }\n\n    if (result.status !== undefined) {\n      options.context.status = result.status;\n    }\n\n    if (result.rewriteUrl) {\n      if (result.rewriteStatus !== undefined) {\n        options.context.status = result.rewriteStatus;\n      }\n      if (isExternalUrl(result.rewriteUrl)) {\n        return {\n          kind: \"response\",\n          response: await proxyExternalMiddlewareRewrite(\n            middlewareRequest,\n            result.rewriteUrl,\n            options.context,\n          ),\n        };\n      }\n      const rewriteParsed = new URL(result.rewriteUrl, middlewareRequest.url);\n      cleanPathname = rewriteParsed.pathname;\n      search = rewriteParsed.search;\n    }\n  }\n\n  if (options.context.headers) {\n    options.context.requestHeaders = new Headers(options.context.headers);\n    applyMiddlewareRequestHeaders(options.context.headers);\n    processMiddlewareHeaders(options.context.headers);\n  }\n\n  return { kind: \"continue\", cleanPathname, search };\n}\n"],"mappings":";;;;;;;;;;AA+CA,MAAM,oBAAoB,IAAI,IAAI,eAAe;AAEjD,SAAS,6BAA6B,OAAqD;CACzF,OAAO,CAAC,CAAC,SAAS,OAAO,UAAU;;AAGrC,SAAS,4BAA4B,SAA2B;CAC9D,IAAI,kBAAkB;CACtB,MAAM,UAAU,IAAI,SAAS;CAE7B,KAAK,MAAM,CAAC,KAAK,UAAU,QAAQ,SACjC,IAAI,kBAAkB,IAAI,IAAI,aAAa,CAAC,EAC1C,kBAAkB;MAElB,QAAQ,OAAO,KAAK,MAAM;CAI9B,IAAI,CAAC,iBAAiB,OAAO;CAE7B,OAAO,wBADQ,QAAQ,OAAO,QAAQ,OAAO,GAAG,SACT,QAAQ;;AAGjD,SAAS,sBAAsB,SAAkB,OAAsB;CACrE,IAAI,CAAC,MAAM,QAAQ,MAAM,IAAI,MAAM,SAAS,GAAG;CAC/C,MAAM,MAAM,MAAM;CAClB,MAAM,cAAc,MAAM;CAC1B,IAAI,OAAO,QAAQ,YAAY,OAAO,gBAAgB,UACpD,QAAQ,OAAO,KAAK,YAAY;;AAIpC,SAAS,+BAA+B,QAK3B;CACX,IAAI,OAAO,UAAU,OAAO,OAAO;CAEnC,MAAM,UAAU,IAAI,QAAQ,OAAO,gBAAgB;CACnD,IAAI,OAAO,aACT,QAAQ,IAAI,YAAY,OAAO,YAAY;CAE7C,OAAO,IAAI,SAAS,MAAM;EACxB,QAAQ,OAAO,kBAAkB;EACjC;EACD,CAAC;;AAGJ,SAAgB,4BAA4B,YAAoB,SAA2B;CAEzF,OAAO,IADmB,IAAI,YAAY,QAAQ,IAC9B,CAAC,WAAW,IAAI,IAAI,QAAQ,IAAI,CAAC;;AAGvD,SAAS,oCACP,SACA,mBACS;CACT,MAAM,cAAc,oBAChB,0CAA0C,QAAQ,SAAS,mBAAmB,EAC5E,2BAA2B,MAC5B,CAAC,GACF;CACJ,IAAI,CAAC,aAAa,OAAO;CAEzB,MAAM,OAAoB;EACxB,QAAQ,QAAQ;EAChB,SAAS;EACT,MAAM,QAAQ;EACf;CACD,IAAI,QAAQ,MACV,OAAO,eAAe,MAAM,UAAU;EAAE,OAAO;EAAQ,YAAY;EAAM,CAAC;CAG5E,OAAO,IAAI,QAAQ,QAAQ,KAAK,KAAK;;AAGvC,eAAsB,+BACpB,SACA,YACA,SACmB;CACnB,MAAM,eAAe,oCACnB,SACA,QAAQ,kBAAkB,QAAQ,QACnC;CACD,kBAAkB,KAAK;CACvB,qBAAqB,KAAK;CAE1B,MAAM,gBAAgB,MAAM,qBAAqB,cAAc,WAAW;CAC1E,MAAM,UAAU,IAAI,QAAQ,cAAc,QAAQ;CAClD,yBAAyB,QAAQ;CAEjC,IAAI,CAAC,QAAQ,SACX,OAAO,IAAI,SAAS,cAAc,MAAM;EACtC,QAAQ,cAAc;EACtB,YAAY,cAAc;EAC1B;EACD,CAAC;CAGJ,MAAM,oBAAoB,IAAI,QAAQ,QAAQ,QAAQ;CACtD,yBAAyB,kBAAkB;CAC3C,+BAA+B,SAAS,kBAAkB;CAC1D,OAAO,IAAI,SAAS,cAAc,MAAM;EACtC,QAAQ,cAAc;EACtB,YAAY,cAAc;EAC1B;EACD,CAAC;;AAGJ,SAAS,gCACP,SACA,SAC2C;CAC3C,IAAI,QAAQ,IAAI,aAAa,cAC3B,OAAO,EAAE,SAAS,OAAO;CAG3B,MAAM,SAAS,QAAQ,QAAQ,IAAI,qBAAqB;CACxD,IAAI,CAAC,QAAQ,OAAO,EAAE,SAAS,OAAO;CAEtC,IAAI;EACF,MAAM,OAAO,KAAK,MAAM,OAAO;EAC/B,IAAI,CAAC,6BAA6B,KAAK,EAAE,OAAO,EAAE,SAAS,OAAO;EAElE,IAAI,MAAM,QAAQ,KAAK,EAAE,IAAI,KAAK,EAAE,SAAS,GAAG;GAC9C,QAAQ,UAAU,IAAI,SAAS;GAC/B,KAAK,MAAM,SAAS,KAAK,GACvB,sBAAsB,QAAQ,SAAS,MAAM;;EAGjD,IAAI,OAAO,KAAK,MAAM,UACpB,QAAQ,SAAS,KAAK;EAExB,IAAI,OAAO,KAAK,MAAM,YAAY,KAAK,EAAE,SAAS,GAChD,OAAO;GAAE,SAAS;GAAM,YAAY,KAAK;GAAG;EAE9C,OAAO,EAAE,SAAS,MAAM;UACjB,GAAG;EACV,QAAQ,MAAM,0DAA0D,EAAE;EAC1E,OAAO,EAAE,SAAS,OAAO;;;AAI7B,eAAsB,mBACpB,SACmC;CACnC,MAAM,YAAY,gCAAgC,QAAQ,SAAS,QAAQ,QAAQ;CACnF,MAAM,oBAAoB,4BAA4B,QAAQ,QAAQ;CACtE,IAAI,gBAAgB,QAAQ;CAC5B,IAAI,SAAwB;CAE5B,IAAI,UAAU,YACZ,IAAI;EACF,IAAI,4BAA4B,UAAU,YAAY,kBAAkB,EACtE,OAAO;GACL,MAAM;GACN,UAAU,MAAM,+BACd,mBACA,UAAU,YACV,QAAQ,QACT;GACF;EAEH,MAAM,gBAAgB,IAAI,IAAI,UAAU,YAAY,kBAAkB,IAAI;EAC1E,gBAAgB,cAAc;EAC9B,SAAS,cAAc;UAChB,GAAG;EACV,QAAQ,MAAM,0DAA0D,EAAE;EAC1E,UAAU,UAAU;;CAIxB,IAAI,CAAC,UAAU,SAAS;EACtB,MAAM,SAAS,MAAM,kBAAkB;GACrC,UAAU,QAAQ;GAClB,YAAY,QAAQ;GACpB,SAAS,QAAQ;GACjB,QAAQ,QAAQ;GAChB,oBAAoB;GACpB,SAAS;GACV,CAAC;EAEF,IAAI,CAAC,OAAO,UAAU;GACpB,IAAI,OAAO,aACT,OAAO;IAAE,MAAM;IAAY,UAAU,+BAA+B,OAAO;IAAE;GAE/E,IAAI,OAAO,UACT,OAAO;IAAE,MAAM;IAAY,UAAU,OAAO;IAAU;GAExD,OAAO;IAAE,MAAM;IAAY,UAAU,6BAA6B;IAAE;;EAGtE,IAAI,OAAO,iBACT,QAAQ,QAAQ,UAAU,IAAI,QAAQ,OAAO,gBAAgB;EAG/D,IAAI,OAAO,WAAW,KAAA,GACpB,QAAQ,QAAQ,SAAS,OAAO;EAGlC,IAAI,OAAO,YAAY;GACrB,IAAI,OAAO,kBAAkB,KAAA,GAC3B,QAAQ,QAAQ,SAAS,OAAO;GAElC,IAAI,cAAc,OAAO,WAAW,EAClC,OAAO;IACL,MAAM;IACN,UAAU,MAAM,+BACd,mBACA,OAAO,YACP,QAAQ,QACT;IACF;GAEH,MAAM,gBAAgB,IAAI,IAAI,OAAO,YAAY,kBAAkB,IAAI;GACvE,gBAAgB,cAAc;GAC9B,SAAS,cAAc;;;CAI3B,IAAI,QAAQ,QAAQ,SAAS;EAC3B,QAAQ,QAAQ,iBAAiB,IAAI,QAAQ,QAAQ,QAAQ,QAAQ;EACrE,8BAA8B,QAAQ,QAAQ,QAAQ;EACtD,yBAAyB,QAAQ,QAAQ,QAAQ;;CAGnD,OAAO;EAAE,MAAM;EAAY;EAAe;EAAQ"}