846fd904a6
feat(SW-2859): Create trpc package * Add isEdge, safeTry and dataCache to new common package * Add eslint and move prettier config * Clean up tests * Create trpc package and move initialization * Move errors and a few procedures * Move telemetry to common package * Move tokenManager to common package * Add Sentry to procedures * Clean up procedures * Fix self-referencing imports * Add exports to packages and lint rule to prevent relative imports * Add env to trpc package * Add eslint to trpc package * Apply lint rules * Use direct imports from trpc package * Add lint-staged config to trpc * Move lang enum to common * Restructure trpc package folder structure * Fix lang imports Approved-by: Linus Flood
77 lines
2.0 KiB
TypeScript
77 lines
2.0 KiB
TypeScript
import { type NextMiddleware, NextResponse } from "next/server"
|
|
|
|
import { getCacheClient } from "@scandic-hotels/common/dataCache"
|
|
|
|
import { notFound } from "@/server/errors/next"
|
|
import { getPublicNextURL } from "@/server/utils"
|
|
|
|
import { findLang } from "@/utils/languages"
|
|
|
|
import { getDefaultRequestHeaders } from "./utils"
|
|
|
|
import type { Lang } from "@scandic-hotels/common/constants/language"
|
|
|
|
import type { MiddlewareMatcher } from "@/types/middleware"
|
|
|
|
async function fetchAndCacheRedirect(lang: Lang, pathname: string) {
|
|
const cacheKey = `${lang}:redirect:${pathname}`
|
|
const cache = await getCacheClient()
|
|
|
|
return await cache.cacheOrGet(
|
|
cacheKey,
|
|
async () => {
|
|
const matchedRedirect = await fetch(
|
|
"https://redirect-scandic-hotels.netlify.app",
|
|
{
|
|
method: "POST",
|
|
body: JSON.stringify({ lang, pathname }),
|
|
headers: {
|
|
"Content-Type": "application/json",
|
|
},
|
|
signal: AbortSignal.timeout(15_000),
|
|
}
|
|
)
|
|
|
|
if (matchedRedirect.ok) {
|
|
const result = await matchedRedirect.text()
|
|
|
|
if (result) {
|
|
return result
|
|
}
|
|
}
|
|
return null
|
|
},
|
|
// longer once tested
|
|
"1d"
|
|
)
|
|
}
|
|
|
|
export const middleware: NextMiddleware = async (request) => {
|
|
const lang = findLang(request.nextUrl.pathname)!
|
|
const headers = getDefaultRequestHeaders(request)
|
|
try {
|
|
const matchedRedirect = await fetchAndCacheRedirect(
|
|
lang,
|
|
request.nextUrl.pathname
|
|
)
|
|
|
|
if (matchedRedirect) {
|
|
const newUrl = new URL(matchedRedirect, getPublicNextURL(request))
|
|
headers.set("Cache-control", "public, max-age=14400") // 4 hours
|
|
return NextResponse.redirect(newUrl, {
|
|
headers,
|
|
status: 308,
|
|
})
|
|
}
|
|
headers.set("x-continue", "1")
|
|
return NextResponse.next({ headers })
|
|
} catch (e) {
|
|
console.error("Redirect error: ", e)
|
|
throw notFound()
|
|
}
|
|
}
|
|
|
|
export const matcher: MiddlewareMatcher = (_) => {
|
|
return true
|
|
}
|