import handleWebPages from "./web-pages/handle-web-pages"; import handleRoutes from "./handle-routes"; import isDevelopment from "../../utils/is-development"; import handleHmr from "./handle-hmr"; import handlePublic from "./handle-public"; import handleFiles from "./handle-files"; import handleBunextPublicAssets from "./handle-bunext-public-assets"; import checkExcludedPatterns from "../../utils/check-excluded-patterns"; import { AppData } from "../../data/app-data"; import { log } from "../../utils/log"; import fullRebuild from "./full-rebuild"; import grabRouter from "../../utils/grab-router"; const HMR_RETRY_COOLDOWN_MS = 5000; let lastHmrRetryTime = 0; export default async function bunextRequestHandler({ req: initial_req, server, }) { const is_dev = isDevelopment(); let req = initial_req.clone(); try { let url = new URL(req.url); if (checkExcludedPatterns({ path: url.pathname })) { return Response.json({ success: false, msg: `Invalid Path` }, { status: 404 }); } let response = undefined; if (global.BUNEXT_CONSTANTS.config?.middleware) { const middleware_res = await global.BUNEXT_CONSTANTS.config.middleware({ req: initial_req, url, }); if (middleware_res instanceof Response) { return middleware_res; } if (middleware_res instanceof Request) { req = middleware_res; url = new URL(req.url); } } if (is_dev && url.pathname == AppData["BunextHMRRetryRoute"]) { const now = Date.now(); if (now - lastHmrRetryTime < HMR_RETRY_COOLDOWN_MS) { return new Response("Too Many Requests", { status: 429 }); } lastHmrRetryTime = now; await fullRebuild({ msg: `HMR Retry Rebuild ...` }); return new Response("Modules Rebuilt"); } if (url.pathname === "/__hmr" && is_dev) { return handleHmr({ req }); } else if (url.pathname.startsWith("/.bunext")) { response = await handleBunextPublicAssets({ req }); } else if (url.pathname.startsWith("/api/")) { response = await handleRoutes({ req }); } else if (url.pathname.startsWith("/public/")) { response = await handlePublic({ req }); } else if (url.pathname.match(/\.[^/]+$/)) { response = await handleFiles({ req }); // Paths like `/users/john.doe` look like files but can be pages. if (response.status == 404 && grabRouter()?.match(url.pathname)?.filePath) { response = await handleWebPages({ req }); } } else { response = await handleWebPages({ req }); } if (!response) { throw new Error(`No Response generated`); } if (is_dev) { response.headers.set("Cache-Control", "no-cache, no-store, must-revalidate"); } return response; } catch (error) { log.error(`Server Error: ${error?.message || error}\n${error?.stack || ""}`); if (is_dev) { return new Response(`Server Error: ${error?.message || error}`, { status: 500, }); } return new Response("Internal Server Error", { status: 500 }); } }