Popular
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213import { URLPatternCompat, type URLPatternInput } from "../framework/core/url_pattern.ts";import log from "../lib/log.ts";import util from "../lib/util.ts";import { extname, fromFileUrl, globToRegExp, join, resolve } from "./deps.ts";import graph from "./graph.ts";import { fixResponse, getAlephConfig, getFiles, toResponse } from "./helpers.ts";import type { Route, RouteConfig, RouteMatch, RouteMeta } from "./types.ts";
/** import the route module. */export async function importRouteModule({ filename, pattern }: RouteMeta, appDir?: string) { const config = getAlephConfig(); let mod: Record<string, unknown>; if ( Deno.env.get("ALEPH_ENV") !== "development" && (config?.routes && pattern.pathname in config.routes) ) { mod = config.routes[pattern.pathname]; } else { const version = graph.get(filename)?.version; const devPort = Deno.env.get("ALEPH_DEV_SERVER_PORT"); let url: string; if (devPort) { url = `http://localhost:${devPort}${filename.slice(1)}?ssr&v=${(version ?? graph.globalVersion).toString(36)}`; } else { const root = appDir ?? (config?.baseUrl ? fromFileUrl(new URL(".", config.baseUrl)) : Deno.cwd()); url = `file://${join(root, filename)}${version ? "#" + version.toString(36) : ""}`; } mod = await import(url); } return mod;}
export async function fetchRouteData( req: Request, ctx: Record<string, unknown>, routeConfig: RouteConfig, reqData: boolean,): Promise<Response | void> { const { pathname, host } = new URL(req.url); if (routeConfig.routes.length > 0) { let pathnameInput = pathname; if (pathnameInput !== "/") { pathnameInput = util.trimSuffix(pathname, "/"); } let matched: RouteMatch | null = null; // find the direct match for (const [pattern, meta] of routeConfig.routes) { const ret = pattern.exec({ host, pathname: pathnameInput }); if (ret) { matched = [ret, meta]; break; } } if (!matched) { // find index route for (const [pattern, meta] of routeConfig.routes) { if (meta.pattern.pathname.endsWith("/index")) { const ret = pattern.exec({ host, pathname: pathnameInput + "/index" }); if (ret) { matched = [ret, meta]; break; } } } } if (matched) { const { method } = req; const [ret, meta] = matched; const mod = await importRouteModule(meta, routeConfig.appDir); const dataConfig = util.isPlainObject(mod.data) ? mod.data : mod; if (method !== "GET" || mod.default === undefined || reqData) { Object.assign(ctx.params as Record<string, string>, ret.pathname.groups); const anyFetcher = dataConfig.any ?? dataConfig.ANY; if (typeof anyFetcher === "function") { const res = await anyFetcher(req, ctx); if (res instanceof Response) { return res; } } const fetcher = dataConfig[method.toLowerCase()] ?? dataConfig[method]; if (typeof fetcher === "function") { const res = await fetcher(req, ctx); const headers = ctx.headers as unknown as Headers; // todo: set cache for "GET" with `cacheTtl` option headers.set("cache-control", "no-cache, no-store, must-revalidate"); if (res instanceof Response) { return fixResponse(res, headers, reqData); } return toResponse(res, headers); } return new Response("Method Not Allowed", { status: 405 }); } } }}
/* check if the filename is a route */export function isRouteFile(filename: string): boolean { const routeConfig: RouteConfig | null | undefined = Reflect.get(globalThis, "__ALEPH_ROUTE_CONFIG"); const index = routeConfig?.routes.findIndex(([_, meta]) => meta.filename === filename); if (index !== undefined && index !== -1) { return true; } const config = getAlephConfig(); if (config?.routeGlob) { const reg = toRouteRegExp(config.routeGlob); return reg.test(filename); } return false;}
type RouteRegExp = { prefix: string; test(filename: string): boolean; exec(filename: string): URLPatternInput | null;};
/** initialize routes from routes config */export async function initRoutes(glob: string, appDir?: string): Promise<RouteConfig> { const reg = toRouteRegExp(glob); const files = await getFiles(appDir ? resolve(appDir) : Deno.cwd()); const routes: Route[] = []; let _app: Route | undefined = undefined; let _404: Route | undefined = undefined; files.forEach((filename) => { const pattern = reg.exec(filename); if (pattern && pattern.pathname !== "/_export" && !pattern.pathname.endsWith("_test")) { const route: Route = [ new URLPatternCompat(pattern), { pattern, filename }, ]; routes.push(route); if (pattern.pathname === "/_app") { _app = route; } else if (pattern.pathname === "/_404") { _404 = route; } } }); if (routes.length > 0) { // sort routes by length of pathname routes.sort((a, b) => getRouteOrder(a) - getRouteOrder(b)); // check nesting routes routes.forEach(([_, meta]) => { const { pattern: { pathname } } = meta; const nesting = pathname === "/_app" || (pathname !== "/" && !pathname.endsWith("/index") && routes.findIndex(([_, { pattern: { pathname: p } }]) => p !== pathname && p.startsWith(pathname + "/")) !== -1); if (nesting) { meta.nesting = true; } }); }
log.debug(`${routes.length} routes found`); return { routes, prefix: reg.prefix, appDir: appDir ? resolve(appDir) : undefined, _404, _app, };}
/** convert route config to `RouteRegExp` */export function toRouteRegExp(glob: string): RouteRegExp { const prefix = util.trimSuffix(util.splitBy(glob, "*")[0], "/"); const reg = globToRegExp("./" + util.trimPrefix(glob, "./")); return { prefix, test: (s: string) => s !== prefix + "/_export.ts" && reg.test(s), exec: (filename: string): URLPatternInput | null => { if (reg.test(filename)) { const parts = util.splitPath(util.trimPrefix(filename, prefix)).map((part) => { // replace `/blog/[...path]` to `/blog/:path+` if (part.startsWith("[...") && part.includes("]") && part.length > 5) { return ":" + part.slice(4).replace("]", "+"); } // replace `/blog/[id]` to `/blog/:id` if (part.startsWith("[") && part.includes("]") && part.length > 2) { return ":" + part.slice(1).replace("]", ""); } // replace `/blog/$id` to `/blog/:id` if (part.startsWith("$") && part.length > 1) { return ":" + part.slice(1); } return part; }); let host: string | undefined = undefined; if (parts.length > 1 && /^@[a-z0-9\.\-]+\.[a-z0-9]+$/.test(parts[0])) { host = parts.shift()!.slice(1); } const basename = parts.pop()!; const pathname = "/" + [...parts, util.trimSuffix(basename, extname(basename))].join("/"); return { host, pathname: pathname === "/index" ? "/" : pathname }; } return null; }, };}
/** get route order by pathname length */function getRouteOrder([_, meta]: Route): number { const { pattern, filename } = meta; switch (pattern.pathname) { case "/_404": case "/_app": return 0; default: return filename.split("/").length + (pattern.pathname.split("/:").length - 1) * 0.01; }}