import { ensureDir } from "https://deno.land/std@0.145.0/fs/ensure_dir.ts";import { join } from "https://deno.land/std@0.145.0/path/mod.ts";import init, { parcelCSS, parseDeps as parseDepsWasmFn, transform as transformWasmFn,} from "./dist/compiler.js";import wasm from "./dist/wasm.js";import { VERSION } from "./version.ts";import type { DependencyDescriptor, TransformCSSOptions, TransformCSSResult, TransformOptions, TransformResult,} from "./types.ts";
let modulesCache: string | null = null;let wasmReady: Promise<void> | boolean = false;
if (typeof Deno.run === "function") { const p = Deno.run({ cmd: [Deno.execPath(), "info", "--json"], stdout: "piped", stderr: "null", }); const output = (new TextDecoder()).decode(await p.output()); const info = JSON.parse(output); modulesCache = info?.modulesCache || null; await p.status(); p.close();}
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; }}
export async function initWasm() { const start = performance.now(); if (import.meta.url.startsWith("https://") && modulesCache) { const cacheDir = join( modulesCache, `https/deno.land/x/aleph_compiler@${VERSION}/dist`, ); const cachePath = join(cacheDir, "compiler.wasm"); if (await existsFile(cachePath)) { const file = await Deno.open(cachePath, { read: true }); await init( new Response(file.readable, { headers: [["Content-Type", "application/wasm"]], }), ); } else { const wasmData = wasm(); await init(wasmData); await ensureDir(cacheDir); await Deno.writeFile(cachePath, wasmData); } } else { await init(wasm()); } wasmReady = true; console.debug( `Initialized aleph-compiler WebAssembly in ${ (performance.now() - start).toFixed(2) }ms.`, );}
async function checkWasmReady() { if (wasmReady === true) return; if (wasmReady === false) wasmReady = initWasm(); await wasmReady;}
export async function parseDeps( specifier: string, code: string, options: Pick<TransformOptions, "importMap" | "lang"> = {},): Promise<DependencyDescriptor[]> { await checkWasmReady(); return parseDepsWasmFn(specifier, code, options);}
export async function transform( specifier: string, code: string, options: TransformOptions = {},): Promise<TransformResult> { await checkWasmReady(); try { return transformWasmFn(specifier, code, options); } catch (error) { if ( options.minify && (error.stack ?? error.messsage ?? "").includes("ThreadPoolBuildError") ) { if (options.minify.compress) { return await transform(specifier, code, { ...options, minify: { compress: false }, }); } else { return transformWasmFn(specifier, code, { ...options, minify: undefined, }); } } else { throw error; } }}
export async function transformCSS( specifier: string, code: string, options: TransformCSSOptions = {},): Promise<TransformCSSResult> { await checkWasmReady(); return parcelCSS(specifier, code, options);}