akte/dist/AkteApp.js

var __defProp = Object.defineProperty;
var __defNormalProp = (obj, key, value) => key in obj ? __defProp(obj, key, { enumerable: true, configurable: true, writable: true, value }) : obj[key] = value;
var __publicField = (obj, key, value) => {
  __defNormalProp(obj, typeof key !== "symbol" ? key + "" : key, value);
  return value;
};
import { resolve, join, dirname } from "node:path";
import { mkdir, writeFile } from "node:fs/promises";
import { createRouter } from "radix3";
import { NotFoundError } from "./errors.js";
import { runCLI } from "./runCLI.js";
import { akteWelcome } from "./akteWelcome.js";
import { __PRODUCTION__ } from "./lib/__PRODUCTION__.js";
import { createDebugger } from "./lib/createDebugger.js";
import { pathToRouterPath } from "./lib/pathToRouterPath.js";
import { isCLI } from "./lib/isCLI.js";
const debug = createDebugger("akte:app");
const debugWrite = createDebugger("akte:app:write");
const debugRender = createDebugger("akte:app:render");
const debugRouter = createDebugger("akte:app:router");
const debugCache = createDebugger("akte:app:cache");
class AkteApp {
  constructor(config) {
    __publicField(this, "config");
    __publicField(this, "_globalDataCache");
    __publicField(this, "_router");
    if (!__PRODUCTION__) {
      if (config.files.length === 0 && akteWelcome) {
        config.files.push(akteWelcome);
      }
    }
    this.config = config;
    debug("defined with %o files", this.config.files.length);
    if (isCLI) {
      runCLI(this);
    }
  }
  /**
   * Readonly array of {@link AkteFiles} registered within the app.
   *
   * @experimental Programmatic API might still change not following SemVer.
   */
  get files() {
    return this.config.files;
  }
  /**
   * Looks up the Akte file responsible for rendering the path.
   *
   * @param path - Path to lookup, e.g. "/foo"
   * @returns A match featuring the path, the path parameters if any, and the
   *   Akte file.
   * @throws {@link NotFoundError} When no Akte file is found for handling
   *   looked up path.
   * @experimental Programmatic API might still change not following SemVer.
   */
  lookup(path) {
    const pathWithExtension = pathToRouterPath(path);
    debugRouter("looking up %o (%o)", path, pathWithExtension);
    const maybeMatch = this.getRouter().lookup(pathWithExtension);
    if (!maybeMatch || !maybeMatch.file) {
      debugRouter("not found %o", path);
      throw new NotFoundError(path);
    }
    return {
      ...maybeMatch,
      path
    };
  }
  /**
   * Renders a match from {@link lookup}.
   *
   * @param match - Match to render.
   * @returns Rendered file.
   * @throws {@link NotFoundError} When the Akte file could not render the match
   *   (404), with an optional `cause` attached to it for uncaught errors (500)
   * @experimental Programmatic API might still change not following SemVer.
   */
  async render(match) {
    debugRender("rendering %o...", match.path);
    const params = match.params || {};
    const globalData = match.globalData || await this.getGlobalData();
    try {
      const content = await match.file.render({
        path: match.path,
        params,
        globalData,
        data: match.data
      });
      debugRender("rendered %o", match.path);
      return content;
    } catch (error) {
      if (error instanceof NotFoundError) {
        throw error;
      }
      debugRender("could not render %o", match.path);
      throw new NotFoundError(match.path, { cause: error });
    }
  }
  /**
   * Renders all Akte files.
   *
   * @returns Rendered files map.
   * @experimental Programmatic API might still change not following SemVer.
   */
  async renderAll() {
    debugRender("rendering all files...");
    const globalData = await this.getGlobalData();
    const renderAll = async (akteFiles) => {
      try {
        const files2 = await akteFiles.renderAll({ globalData });
        return files2;
      } catch (error) {
        debug.error("Akte → Failed to build %o\n", akteFiles.path);
        throw error;
      }
    };
    const promises = [];
    for (const akteFiles of this.config.files) {
      promises.push(renderAll(akteFiles));
    }
    const rawFilesArray = await Promise.all(promises);
    const files = {};
    for (const rawFiles of rawFilesArray) {
      for (const path in rawFiles) {
        if (path in files) {
          debug.warn("  Multiple files built %o, only the first one is preserved", path);
          continue;
        }
        files[path] = rawFiles[path];
      }
    }
    const rendered = Object.keys(files).length;
    debugRender(`done, %o ${rendered > 1 ? "files" : "file"} rendered`, rendered);
    return files;
  }
  /**
   * Writes a map of rendered Akte files to the specified `outDir`, or the app
   * specified one (defaults to `"dist"`).
   *
   * @param args - A map of rendered Akte files, and an optional `outDir`
   * @experimental Programmatic API might still change not following SemVer.
   */
  async writeAll(args) {
    var _a;
    debugWrite("writing all files...");
    const outDir = args.outDir ?? ((_a = this.config.build) == null ? void 0 : _a.outDir) ?? "dist";
    const outDirPath = resolve(outDir);
    const controller = new AbortController();
    const write = async (path, content) => {
      const filePath = join(outDirPath, path);
      const fileDir = dirname(filePath);
      try {
        await mkdir(fileDir, { recursive: true });
        await writeFile(filePath, content, {
          encoding: "utf-8",
          signal: controller.signal
        });
      } catch (error) {
        if (controller.signal.aborted) {
          return;
        }
        controller.abort();
        debug.error("Akte → Failed to write %o\n", path);
        throw error;
      }
      debugWrite("%o", path);
      debugWrite.log("  %o", path);
    };
    const promises = [];
    for (const path in args.files) {
      promises.push(write(path, args.files[path]));
    }
    await Promise.all(promises);
    debugWrite(`done, %o ${promises.length > 1 ? "files" : "file"} written`, promises.length);
  }
  /**
   * Build (renders and write) all Akte files to the specified `outDir`, or the
   * app specified one (defaults to `"dist"`).
   *
   * @param args - An optional `outDir`
   * @returns Built files array.
   * @experimental Programmatic API might still change not following SemVer.
   */
  async buildAll(args) {
    const files = await this.renderAll();
    await this.writeAll({ ...args, files });
    return Object.keys(files);
  }
  /**
   * Akte caches all `globalData`, `data`, `bulkData` calls for performance.
   * This method can be used to clear the cache.
   *
   * @param alsoClearFileCache - Also clear cache on all registered Akte files.
   * @experimental Programmatic API might still change not following SemVer.
   */
  clearCache(alsoClearFileCache = false) {
    debugCache("clearing...");
    this._globalDataCache = void 0;
    this._router = void 0;
    if (alsoClearFileCache) {
      for (const file of this.config.files) {
        file.clearCache();
      }
    }
    debugCache("cleared");
  }
  /**
   * Readonly cache of the app's definition `globalData` method.
   *
   * @experimental Programmatic API might still change not following SemVer.
   */
  get globalDataCache() {
    return this._globalDataCache;
  }
  /**
   * Retrieves data from the app's definition `globalData` method.
   *
   * @param context - Context to get global data with.
   * @returns Retrieved global data.
   * @remark Returned global data may come from cache.
   * @experimental Programmatic API might still change not following SemVer.
   */
  getGlobalData() {
    var _a, _b;
    if (!this._globalDataCache) {
      debugCache("retrieving global data...");
      const globalDataPromise = ((_b = (_a = this.config).globalData) == null ? void 0 : _b.call(_a)) ?? void 0;
      if (globalDataPromise instanceof Promise) {
        globalDataPromise.then(() => {
          debugCache("retrieved global data");
        });
      } else {
        debugCache("retrieved global data");
      }
      this._globalDataCache = globalDataPromise;
    } else {
      debugCache("using cached global data");
    }
    return this._globalDataCache;
  }
  getRouter() {
    if (!this._router) {
      debugCache("creating router...");
      const router = createRouter();
      for (const file of this.config.files) {
        const path = pathToRouterPath(file.path);
        router.insert(pathToRouterPath(file.path), { file });
        debugRouter("registered %o", path);
        if (file.path.endsWith("/**")) {
          const catchAllPath = pathToRouterPath(file.path.replace(/\/\*\*$/, ""));
          router.insert(catchAllPath, {
            file
          });
          debugRouter("registered %o", catchAllPath);
          debugCache(pathToRouterPath(file.path.replace(/\/\*\*$/, "")));
        }
      }
      this._router = router;
      debugCache("created router");
    } else {
      debugCache("using cached router");
    }
    return this._router;
  }
}
export {
  AkteApp
};
//# sourceMappingURL=AkteApp.js.map