Very Popular
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463import { generateErrorHtml, TransformError } from "../runtime/core/error.ts";import log, { type LevelName } from "../lib/log.ts";import util from "../lib/util.ts";import { createContext } from "./context.ts";import { handleHMR, watch } from "./dev.ts";import { fromFileUrl, join, serve as stdServe, serveTls } from "./deps.ts";import depGraph from "./graph.ts";import { existsFile, fixResponse, getAlephPkgUri, getDeploymentId, getImportMap, getJSXConfig, globalIt, isNpmPkg, regFullVersion, restoreUrl, toLocalPath,} from "./helpers.ts";import { loadAndFixIndexHtml } from "./html.ts";import { getContentType } from "./media_type.ts";import renderer from "./renderer.ts";import { fetchRouteData, initRouter } from "./routing.ts";import transformer from "./transformer.ts";import { optimize } from "./optimizer.ts";import type { AlephConfig, ConnInfo, ErrorHandler, FetchHandler, HTMLRewriterHandlers, Middleware, ModuleLoader, Router, ServeInit,} from "./types.ts";
/** The options for the Aleph.js server. */export type ServerOptions = Omit<ServeInit, "onError"> & { certFile?: string; keyFile?: string; fetch?: FetchHandler; logLevel?: LevelName; onError?: ErrorHandler;} & AlephConfig;
/** Start the Aleph.js server. */export function serve(options: ServerOptions = {}) { const { baseUrl, fetch, loaders, middlewares, onError, optimization, router: routerConfig, session, ssr, unocss } = options; const appDir = options?.baseUrl ? fromFileUrl(new URL(".", options.baseUrl)) : undefined; const optimizeMode = Deno.args.includes("--optimize"); const isDev = Deno.args.includes("--dev");
// inject aleph config to global const config: AlephConfig = { baseUrl, loaders, middlewares, optimization, router: routerConfig, session, ssr, unocss, }; Reflect.set(globalThis, "__ALEPH_CONFIG", config);
if (routerConfig && routerConfig.routes) { if (isDev) { routerConfig.routes = undefined; } else if (util.isFilledArray(routerConfig.routes.depGraph?.modules)) { // restore the dependency graph from the re-import route modules routerConfig.routes.depGraph.modules.forEach((module) => { depGraph.mark(module.specifier, module); }); } }
// set the log level if (import.meta.url.startsWith("file:")) { // set log level to debug when debug aleph.js itself. log.setLevel("debug"); } else if (options.logLevel) { log.setLevel(options.logLevel); }
// server handler const handler = async (req: Request, connInfo: ConnInfo): Promise<Response> => { const { pathname, searchParams } = new URL(req.url);
// handle HMR socket if (pathname === "/-/hmr") { if (isDev) { return handleHMR(req); } const { socket, response } = Deno.upgradeWebSocket(req); socket.addEventListener("open", () => { // close the hot-reloading websocket and tell the client to reload the page socket.send(JSON.stringify({ type: "reload" })); setTimeout(() => { socket.close(); }, 50); }); return response; }
const customHTMLRewriter: [selector: string, handlers: HTMLRewriterHandlers][] = []; const ctx = createContext(req, { connInfo, customHTMLRewriter, session }); const postMiddlewares: Middleware[] = [];
// use eager middlewares if (Array.isArray(middlewares)) { for (let i = 0, l = middlewares.length; i < l; i++) { const mw = middlewares[i]; const handler = mw.fetch; if (typeof handler === "function") { if (mw.eager) { try { let res = handler(req, ctx); if (res instanceof Promise) { res = await res; } if (res instanceof Response) { return res; } if (typeof res === "function") { setTimeout(res, 0); } } catch (err) { const res = onError?.(err, { by: "middleware", url: req.url, context: ctx, }); if (res instanceof Response) { return res; } log.error(`[middleare${mw.name ? `(${mw.name})` : ""}]`, err); return new Response(generateErrorHtml(err.stack ?? err.message), { status: 500, headers: [["Content-Type", "text/html; charset=utf-8"]], }); } } else { postMiddlewares.push(mw); } } } }
// transform modules let loader: ModuleLoader | undefined; if ( !searchParams.has("raw") && ( (loader = loaders?.find((l) => l.test(pathname))) || transformer.test(pathname) ) ) { // check the optimized output if (!isDev && !optimizeMode) { let outFile = join(appDir ?? Deno.cwd(), optimization?.outputDir ?? "./output", pathname); if (pathname.startsWith("/-/") && isNpmPkg(restoreUrl(pathname))) { outFile += ".js"; } if (await existsFile(outFile)) { const file = await Deno.open(outFile, { read: true }); const headers = new Headers(); if (outFile.endsWith(".css")) { headers.set("Content-Type", "text/css; charset=utf-8"); } else { headers.set("Content-Type", "application/javascript; charset=utf-8"); } if (searchParams.get("v") || (pathname.startsWith("/-/") && regFullVersion.test(pathname))) { headers.append("Cache-Control", "public, max-age=31536000, immutable"); } return new Response(file.readable, { headers }); } } try { const [importMap, jsxConfig] = await Promise.all([ getImportMap(appDir), getJSXConfig(appDir), ]); const hydratable = Boolean(ssr); const reactRefresh = Boolean(Deno.env.get("REACT_REFRESH")); return await transformer.fetch(req, { importMap, jsxConfig, loader, hydratable, isDev, reactRefresh, }); } catch (err) { console.log(err); if (err instanceof TransformError) { log.error(err); const alephPkgUri = toLocalPath(getAlephPkgUri()); return new Response( `import { showTransformError } from "${alephPkgUri}/runtime/core/error.ts";showTransformError(${ JSON.stringify(err) });export default null;`, { headers: [ ["Content-Type", "application/javascript; charset=utf-8"], ["X-Transform-Error", "true"], ], }, ); } else if (!(err instanceof Deno.errors.NotFound)) { log.error(err); return onError?.(err, { by: "transform", url: req.url }) ?? new Response(generateErrorHtml(err.stack ?? err.message), { status: 500, headers: [["Content-Type", "text/html;"]], }); } } }
// serve static files const contentType = getContentType(pathname); if (!pathname.startsWith("/.") && contentType !== "application/octet-stream") { try { let filePath = appDir ? join(appDir, pathname) : `.${pathname}`; let stat = await Deno.lstat(filePath); if (stat.isDirectory && pathname !== "/") { filePath = `${util.trimSuffix(filePath, "/")}/index.html`; stat = await Deno.lstat(filePath); } if (stat.isFile) { const headers = new Headers({ "Content-Type": contentType }); const deployId = getDeploymentId(); let etag: string | null = null; if (deployId) { etag = `W/${btoa(pathname).replace(/[^a-z0-9]/g, "")}-${deployId}`; } else { const { mtime, size } = stat; if (mtime) { etag = `W/${mtime.getTime().toString(16)}-${size.toString(16)}`; headers.append("Last-Modified", new Date(mtime).toUTCString()); } } if (etag) { if (req.headers.get("If-None-Match") === etag) { return new Response(null, { status: 304 }); } headers.append("ETag", etag); } if (searchParams.get("v") || regFullVersion.test(pathname)) { headers.append( "Cache-Control", "public, max-age=31536000, immutable", ); } const file = await Deno.open(filePath, { read: true }); return new Response(file.readable, { headers }); } } catch (err) { if (!(err instanceof Deno.errors.NotFound)) { log.error(err); return onError?.(err, { by: "fs", url: req.url }) ?? new Response(generateErrorHtml(err.stack ?? err.message), { status: 500, headers: [["Content-Type", "text/html;"]], }); } } }
// use post middlewares for (const mw of postMiddlewares) { try { let res = mw.fetch(req, ctx); if (res instanceof Promise) { res = await res; } if (res instanceof Response) { return res; } if (typeof res === "function") { setTimeout(res, 0); } } catch (err) { const res = onError?.(err, { by: "middleware", url: req.url, context: ctx, }); if (res instanceof Response) { return res; } log.error(`[middleare${mw.name ? `(${mw.name})` : ""}]`, err); return new Response(generateErrorHtml(err.stack ?? err.message), { status: 500, headers: [["Content-Type", "text/html;"]], }); } }
// use the `fetch` handler if available if (typeof fetch === "function") { return fetch(req, ctx); }
// request route api const router: Router | null = await globalIt( "__ALEPH_ROUTER", () => routerConfig ? initRouter(routerConfig, appDir) : Promise.resolve(null), ); if (router && router.routes.length > 0) { const reqData = req.method === "GET" && (searchParams.has("_data_") || req.headers.get("Accept") === "application/json"); try { const resp = await fetchRouteData(req, ctx, router, reqData); if (resp) { return resp; } } catch (err) { // javascript syntax error if (err instanceof TypeError && !reqData) { return new Response(generateErrorHtml(err.stack ?? err.message), { status: 500, headers: [["Content-Type", "text/html;"]], }); }
// use the `onError` if available const res = onError?.(err, { by: "route-data-fetch", url: req.url, context: ctx, }); if (res instanceof Response) { return fixResponse(res, ctx.headers, reqData); }
// user throw a response if (err instanceof Response) { return fixResponse(err, ctx.headers, reqData); }
// prints the error stack if (err instanceof Error || typeof err === "string") { log.error(err); }
// return the error as a json const status: number = util.isUint(err.status ?? err.code) ? err.status ?? err.code : 500; return Response.json({ ...err, status, message: err.message ?? String(err), stack: err.stack, }, { status, headers: ctx.headers, }); } }
// don't render those special asset files switch (pathname) { case "/favicon.ico": case "/robots.txt": return new Response("Not found", { status: 404 }); }
const indexHtml = await globalIt( "__ALEPH_INDEX_HTML", () => loadAndFixIndexHtml(join(appDir ?? ".", "index.html"), { ssr: typeof ssr === "function" ? {} : ssr, hmr: isDev ? { url: Deno.env.get("HMR_WS_URL") } : undefined, }), ); if (!indexHtml) { return new Response("Not found", { status: 404 }); }
// return index.html if (!ssr) { const deployId = getDeploymentId(); let etag: string | undefined; if (deployId) { etag = `W/${btoa("./index.html").replace(/[^a-z0-9]/g, "")}-${deployId}`; } else { const { mtime, size } = await Deno.lstat(join(appDir ?? ".", "./index.html")); if (mtime) { etag = `W/${mtime.getTime().toString(16)}-${size.toString(16)}`; ctx.headers.set("Last-Modified", new Date(mtime).toUTCString()); } } if (etag) { if (req.headers.get("If-None-Match") === etag) { return new Response(null, { status: 304 }); } ctx.headers.set("ETag", etag); } ctx.headers.set("Cache-Control", "public, max-age=0, must-revalidate"); ctx.headers.set("Content-Type", "text/html; charset=utf-8"); return new Response(indexHtml, { headers: ctx.headers }); }
// SSR try { return await renderer.fetch(req, ctx, { indexHtml, router, customHTMLRewriter, ssr, isDev, }); } catch (err) { if (err instanceof Response) { return err; } let message: string; if (err instanceof Error) { message = err.stack as string; log.error("SSR", err); } else { message = err?.toString?.() || String(err); } const cc = ssr && typeof ssr !== "function" ? ssr.cacheControl : "public"; ctx.headers.append("Cache-Control", `${cc}, max-age=0, must-revalidate`); ctx.headers.append("Content-Type", "text/html; charset=utf-8"); return new Response(generateErrorHtml(message, "SSR"), { headers: ctx.headers, }); } };
// optimize the application for production if (optimizeMode) { optimize(handler, config, appDir); return; }
const port = options.port ?? 3000; if (isDev) { Deno.env.set("ALEPH_SERVER_PORT", port.toString()); watch(appDir); }
const { hostname, certFile, keyFile, signal } = options; const useTls = certFile && keyFile; const onListen = (arg: { port: number; hostname: string }) => { if (!getDeploymentId()) { log.info( `Server ready on ${useTls ? "https" : "http"}://localhost:${port}`, ); } options.onListen?.(arg); }; if (useTls) { serveTls(handler, { hostname, port, certFile, keyFile, signal, onListen }); } else { stdServe(handler, { hostname, port, signal, onListen }); }}