Very Popular
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469import { basename, dirname, globToRegExp, join } from "https://deno.land/std@0.144.0/path/mod.ts";import { JSONC } from "https://deno.land/x/jsonc_parser@v0.0.1/src/jsonc.ts";import { createGenerator, type UnoGenerator } from "../lib/@unocss/core.ts";import { cacheFetch } from "./cache.ts";import { getContentType } from "../lib/media_type.ts";import log from "../lib/log.ts";import util from "../lib/util.ts";import { isCanary, VERSION } from "../version.ts";import type { AlephConfig, ImportMap, JSXConfig, ModuleLoader } from "./types.ts";
export const regFullVersion = /@\d+\.\d+\.\d+/;export const builtinModuleExts = ["tsx", "ts", "mts", "jsx", "js", "mjs"];
/** Stores and returns the `fn` output in the `globalThis` object */export async function globalIt<T>(name: string, fn: () => Promise<T>): Promise<T> { const v: T | undefined = Reflect.get(globalThis, name); if (v !== undefined) { return v; } const ret = await fn(); if (ret !== undefined) { Reflect.set(globalThis, name, ret); } return ret;}
/** Stores and returns the `fn` output in the `globalThis` object synchronously. */export function globalItSync<T>(name: string, fn: () => T): T { const v: T | undefined = Reflect.get(globalThis, name); if (v !== undefined) { return v; } const ret = fn(); if (ret !== undefined) { Reflect.set(globalThis, name, ret); } return ret;}
/* Get Aleph.js package URI. */export function getAlephPkgUri(): string { return globalItSync("__ALEPH_PKG_URI", () => { const uriFromEnv = Deno.env.get("ALEPH_PKG_URI"); if (uriFromEnv) { return uriFromEnv; } const DEV_PORT = Deno.env.get("ALEPH_DEV_PORT"); if (DEV_PORT) { return `http://localhost:${DEV_PORT}`; } const version = Deno.env.get("ALEPH_VERSION") || VERSION; return `https://deno.land/x/${isCanary ? "aleph_canary" : "aleph"}@${version}`; });}
/** Get the UnoCSS generator, return `null` if the presets are empty. */export function getUnoGenerator(): UnoGenerator | null { const config: AlephConfig | undefined = Reflect.get(globalThis, "__ALEPH_CONFIG"); if (config === undefined) { return null; } return globalItSync("__UNO_GENERATOR", () => { if (config?.unocss?.presets) { return createGenerator(config.unocss); } return null; });}
/** Get the deployment ID. */export function getDeploymentId(): string | undefined { return Deno.env.get("DENO_DEPLOYMENT_ID");}
export type CookieOptions = { expires?: number | Date; maxAge?: number; domain?: string; path?: string; httpOnly?: boolean; secure?: boolean; sameSite?: "lax" | "strict" | "none";};
export function setCookieHeader(name: string, value: string, options?: CookieOptions): string { const cookie = [`${name}=${value}`]; if (options) { if (options.expires) { cookie.push(`Expires=${new Date(options.expires).toUTCString()}`); } if (options.maxAge) { cookie.push(`Max-Age=${options.maxAge}`); } if (options.domain) { cookie.push(`Domain=${options.domain}`); } if (options.path) { cookie.push(`Path=${options.path}`); } if (options.httpOnly) { cookie.push("HttpOnly"); } if (options.secure) { cookie.push("Secure"); } if (options.sameSite) { cookie.push(`SameSite=${options.sameSite}`); } } return cookie.join("; ");}
export function toResponse(v: unknown, headers: Headers): Response { if ( typeof v === "string" || v instanceof ArrayBuffer || v instanceof Uint8Array || v instanceof ReadableStream ) { return new Response(v, { headers: headers }); } if (v instanceof Blob || v instanceof File) { headers.set("Content-Type", v.type); headers.set("Content-Length", v.size.toString()); return new Response(v, { headers: headers }); } if (util.isPlainObject(v) || Array.isArray(v)) { return Response.json(v, { headers }); } if (v === null) { return new Response(null, { headers }); } throw new Error("Invalid response type: " + typeof v);}
export function fixResponse(res: Response, addtionHeaders: Headers, fixRedirect: boolean): Response { if (res.status >= 300 && res.status < 400 && fixRedirect) { return Response.json({ redirect: { location: res.headers.get("Location"), status: res.status } }, { status: 501, headers: addtionHeaders, }); } let headers: Headers | null = null; addtionHeaders.forEach((value, name) => { if (!headers) { headers = new Headers(res.headers); } headers.set(name, value); }); if (headers) { return new Response(res.body, { status: res.status, statusText: res.statusText, headers }); } return res;}
/** * fix remote url to local path. * e.g. `https://esm.sh/react@17.0.2?dev` -> `/-/esm.sh/react@17.0.2?dev` */export function toLocalPath(url: string): string { if (util.isLikelyHttpURL(url)) { let { hostname, pathname, port, protocol, search } = new URL(url); const isHttp = protocol === "http:"; if ((isHttp && port === "80") || (protocol === "https:" && port === "443")) { port = ""; } return [ "/-/", isHttp && "http_", hostname, port && "_" + port, util.trimSuffix(pathname, "/"), search, ].filter(Boolean).join(""); } return url;}
/** * restore the remote url from local path. * e.g. `/-/esm.sh/react@17.0.2` -> `https://esm.sh/react@17.0.2` */export function restoreUrl(pathname: string): string { let [h, ...rest] = pathname.substring(3).split("/"); let protocol = "https"; if (h.startsWith("http_")) { h = h.substring(5); protocol = "http"; } const [host, port] = h.split("_"); return `${protocol}://${host}${port ? ":" + port : ""}/${rest.join("/")}`;}
/** init loaders in `CLI` mode, or use prebuild loaders */export async function initModuleLoaders(importMap?: ImportMap): Promise<ModuleLoader[]> { const loaders: ModuleLoader[] = []; if (Deno.env.get("ALEPH_CLI")) { const { imports, __filename } = importMap ?? await loadImportMap(); for (const key in imports) { if (/^\*\.{?(\w+, ?)*\w+}?$/i.test(key)) { let src = imports[key]; if (src.endsWith("!loader")) { src = util.trimSuffix(src, "!loader"); if (src.startsWith("./") || src.startsWith("../")) { src = "file://" + join(dirname(__filename), src); } let { default: loader } = await import(src); if (typeof loader === "function") { loader = new loader(); } if (loader !== null && typeof loader === "object" && typeof loader.load === "function") { const glob = "/**/" + key; const reg = globToRegExp(glob); const Loader = { meta: { src, glob }, test: (pathname: string) => reg.test(pathname), load: (specifier: string, content: string, env: Record<string, unknown>) => loader.load(specifier, content, env), }; loaders.push(Loader); } } } } } return loaders;}
/* check whether or not the given path exists as a directory. */export async function existsDir(path: string): Promise<boolean> { try { const stat = await Deno.lstat(path); return stat.isDirectory; } catch (err) { if (err instanceof Deno.errors.NotFound) { return false; } throw err; }}
/* check whether or not the given path exists as regular file. */export async function existsFile(path: string): Promise<boolean> { try { const stat = await Deno.lstat(path); return stat.isFile; } catch (err) { if (err instanceof Deno.errors.NotFound) { return false; } throw err; }}
/* find file in the directory */export async function findFile(filenames: string[], cwd = Deno.cwd()): Promise<string | undefined> { for (const filename of filenames) { const fullPath = join(cwd, filename); if (await existsFile(fullPath)) { return fullPath; } } return void 0;}
// get files in the directoryexport async function getFiles( dir: string, filter?: (filename: string) => boolean, __path: string[] = [],): Promise<string[]> { const list: string[] = []; if (await existsDir(dir)) { for await (const dirEntry of Deno.readDir(dir)) { if (dirEntry.isDirectory) { list.push(...await getFiles(join(dir, dirEntry.name), filter, [...__path, dirEntry.name])); } else { const filename = [".", ...__path, dirEntry.name].join("/"); if (!filter || filter(filename)) { list.push(filename); } } } } return list;}
/* read source code from fs/cdn/cache */export async function readCode(specifier: string, cwd = Deno.cwd()): Promise<[code: string, contentType: string]> { if (util.isLikelyHttpURL(specifier)) { const url = new URL(specifier); if (url.hostname === "esm.sh" && !url.searchParams.has("target")) { url.searchParams.set("target", "esnext"); } const res = await cacheFetch(url.href); if (res.status >= 400) { throw new Error(`fetch ${url.href}: ${res.status} - ${res.statusText}`); } return [await res.text(), res.headers.get("Content-Type") || getContentType(url.pathname)]; }
specifier = util.splitBy(specifier, "?")[0]; return [await Deno.readTextFile(join(cwd, specifier)), getContentType(specifier)];}
/** Load the JSX config base the given import maps and the existing deno config. */export async function loadJSXConfig(importMap: ImportMap): Promise<JSXConfig> { const jsxConfig: JSXConfig = {}; const denoConfigFile = await findFile(["deno.jsonc", "deno.json", "tsconfig.json"]);
if (denoConfigFile) { try { const { compilerOptions } = await parseJSONFile(denoConfigFile); const { jsx, jsxImportSource, jsxFactory } = (compilerOptions || {}) as Record<string, unknown>; if ( (jsx === undefined || jsx === "react-jsx" || jsx === "react-jsxdev") && util.isFilledString(jsxImportSource) ) { jsxConfig.jsxImportSource = jsxImportSource; jsxConfig.jsxRuntime = jsxImportSource.includes("preact") ? "preact" : "react"; } else if (jsx === undefined || jsx === "react") { jsxConfig.jsxRuntime = jsxFactory === "h" ? "preact" : "react"; } } catch (error) { log.error(`Failed to parse ${basename(denoConfigFile)}: ${error.message}`); } } else if (Deno.env.get("ALEPH_DEV_ROOT")) { const jsonFile = join(Deno.env.get("ALEPH_DEV_ROOT")!, "deno.json"); const { compilerOptions } = await parseJSONFile(jsonFile); const { jsx, jsxImportSource, jsxFactory } = (compilerOptions || {}) as Record<string, unknown>; if ( (jsx === undefined || jsx === "react-jsx" || jsx === "react-jsxdev") && util.isFilledString(jsxImportSource) ) { jsxConfig.jsxImportSource = jsxImportSource; jsxConfig.jsxRuntime = jsxImportSource.includes("preact") ? "preact" : "react"; } else if (jsx === undefined || jsx === "react") { jsxConfig.jsxRuntime = jsxFactory === "h" ? "preact" : "react"; } }
let fuzzRuntimeUrl: string | null = null;
for (const url of Object.values(importMap.imports)) { let m = url.match(/^https?:\/\/esm\.sh\/(p?react)@(\d+\.\d+\.\d+(-[a-z\d.]+)*)(\?|$)/); if (!m) { m = url.match(/^https?:\/\/esm\.sh\/(p?react)@.+/); } if (m) { const { searchParams } = new URL(url); if (searchParams.has("pin")) { jsxConfig.jsxRuntimeCdnVersion = util.trimPrefix(searchParams.get("pin")!, "v"); } if (!jsxConfig.jsxRuntime) { jsxConfig.jsxRuntime = m[1] as "react" | "preact"; } if (m[2]) { jsxConfig.jsxRuntimeVersion = m[2]; if (jsxConfig.jsxImportSource) { jsxConfig.jsxImportSource = `https://esm.sh/${jsxConfig.jsxRuntime}@${m[2]}`; } } else { fuzzRuntimeUrl = url; } break; } }
// get acctual react version from esm.sh if (fuzzRuntimeUrl) { log.info(`Checking ${jsxConfig.jsxRuntime} version...`); const text = await fetch(fuzzRuntimeUrl).then((resp) => resp.text()); const m = text.match(/https?:\/\/cdn\.esm\.sh\/(v\d+)\/p?react@(\d+\.\d+\.\d+(-[a-z\d.]+)*)\//); if (m) { jsxConfig.jsxRuntimeCdnVersion = m[1].slice(1); jsxConfig.jsxRuntimeVersion = m[2]; if (jsxConfig.jsxImportSource) { jsxConfig.jsxImportSource = `https://esm.sh/${jsxConfig.jsxRuntime}@${m[2]}`; } log.info(`${jsxConfig.jsxRuntime}@${jsxConfig.jsxRuntimeVersion} is used`); } }
return jsxConfig;}
/** Load the import maps from the json file. */export async function loadImportMap(): Promise<ImportMap> { const importMap: ImportMap = { __filename: "", imports: {}, scopes: {} };
if (Deno.env.get("ALEPH_DEV")) { const alephPkgUri = Deno.env.get("ALEPH_PKG_URI") ?? `http://localhost:${Deno.env.get("ALEPH_DEV_PORT")}`; const importMapFile = join(Deno.env.get("ALEPH_DEV_ROOT")!, "import_map.json"); const { __filename, imports, scopes } = await parseImportMap(importMapFile); Object.assign(importMap, { __filename, imports: { ...imports, "@unocss/": `${alephPkgUri}/lib/@unocss/`, "aleph/": `${alephPkgUri}/`, "aleph/server": `${alephPkgUri}/server/mod.ts`, "aleph/react": `${alephPkgUri}/framework/react/mod.ts`, "aleph/vue": `${alephPkgUri}/framework/vue/mod.ts`, }, scopes, }); }
const importMapFile = await findFile(["import_map", "import-map", "importmap", "importMap"].map((v) => `${v}.json`)); if (importMapFile) { try { const { __filename, imports, scopes } = await parseImportMap(importMapFile); Object.assign(importMap, { __filename }); Object.assign(importMap.imports, imports); Object.assign(importMap.scopes, scopes); } catch (e) { log.error("loadImportMap:", e.message); } }
return importMap;}
export async function parseJSONFile(jsonFile: string): Promise<Record<string, unknown>> { const raw = await Deno.readTextFile(jsonFile); if (jsonFile.endsWith(".jsonc")) { return JSONC.parse(raw); } return JSON.parse(raw);}
export async function parseImportMap(importMapFile: string): Promise<ImportMap> { const importMap: ImportMap = { __filename: importMapFile, imports: {}, scopes: {} }; const data = await parseJSONFile(importMapFile); const imports: Record<string, string> = toStringMap(data.imports); const scopes: Record<string, Record<string, string>> = {}; if (util.isPlainObject(data.scopes)) { Object.entries(data.scopes).forEach(([scope, imports]) => { scopes[scope] = toStringMap(imports); }); } Object.assign(importMap, { imports, scopes }); return importMap;}
function toStringMap(v: unknown): Record<string, string> { const m: Record<string, string> = {}; if (util.isPlainObject(v)) { Object.entries(v).forEach(([key, value]) => { if (key === "") { return; } if (util.isFilledString(value)) { m[key] = value; return; } if (util.isFilledArray(value)) { for (const v of value) { if (util.isFilledString(v)) { m[key] = v; return; } } } }); } return m;}