data/utils/engine.js

import { join } from "https://deno.land/std@0.208.0/path/mod.ts";
import { emptyDir } from "https://deno.land/std@0.196.0/fs/empty_dir.ts";
import { parse, stringify } from "npm:yaml";
import { exists } from "https://deno.land/std@0.213.0/fs/exists.ts";
import { copy } from "https://deno.land/std@0.214.0/fs/copy.ts";

const SRC_DIR = "./src";
const DEST_DIR = "./dist";
const SCHEMA_DIR = "./schema";

export class Engine {
  constructor() {
    this.index = {};
    this.db = {};
    this.schemas = {};
  }

  async init() {
    // load schemas
    for await (const dirEntry of Deno.readDir(SCHEMA_DIR)) {
      const [fn, _] = dirEntry.name.split(".");
      this.schemas[fn] = await readYamlFile(join(SCHEMA_DIR, dirEntry.name));
    }
    // load
    this.index = await readYamlFile(join(SRC_DIR, "index.yaml"));
    this.rendered = await this.render(this.index);
  }

  async loadDir(src, opts = {}, full = {}) {
    const out = {};
    const dir = join(SRC_DIR, src);
    console.log(`reading dir=${dir}`);

    if (await exists(join(dir, "index.yaml"))) {
      const out = await readYamlFile(join(dir, "index.yaml"));
      if (opts.loader === "events") {
        // check speaker connection
        for (const ev of out) {
          if (ev.speakers) {
            for (const spId of ev.speakers) {
              if (!full.people.find((p) => p.id === spId)) {
                throw new Error(`Speaker not exists: ${spId} (event ${ev.id})`);
              }
            }
          }
        }
      }
      return out;
    }

    let images = [];
    if (await exists(join(dir, "_images"))) {
      for await (const ie of Deno.readDir(join(dir, "_images"))) {
        const [id, ext] = ie.name.split(".");
        images.push({ id, ext });
      }
    }
    const arr = [];
    for await (const dirEntry of Deno.readDir(dir)) {
      const [fn, ext] = dirEntry.name.split(".");

      if (!ext && !fn.startsWith("_")) {
        const obj = Object.assign(
          { id: fn },
          await this.loadDir(join(src, fn), opts, full),
        );
        arr.push(obj);
      }
      if (ext === "yaml" && fn !== "index") {
        const item = Object.assign(
          { id: fn },
          await readYamlFile(join(dir, dirEntry.name)),
        );
        if (opts.loader === "person") {
          // load image
          const img = images.find((i) => i.id === fn);
          if (img) {
            item.imageUrl =
              `https://data.web3privacy.info/img/people/${img.id}.${img.ext}`;
          }
        }
        arr.push(item);
      }
    }
    return arr;
  }

  async render(src) {
    const out = {};
    for (const key of Object.keys(src)) {
      const val = src[key];
      if (typeof val === "object" && val.$load) {
        out[key] = await this.loadDir(val.$load, val.$opts, out);
        continue;
      }

      out[key] = val;
    }
    return out;
  }

  async build() {
    await emptyDir(DEST_DIR);
    //await writeJSONFile(join(DEST_DIR, "index.json"), this.index);
    // copy images
    await emptyDir(join(DEST_DIR, "img"));
    await copy(
      join(SRC_DIR, "people", "_images"),
      join(DEST_DIR, "img", "people"),
    );

    await writeJSONFile(
      join(DEST_DIR, "index.json"),
      Object.assign({}, this.rendered),
    );
    /*for (const col of Object.keys(this.db)) {
      await writeJSONFile(join(DEST_DIR, `${col}.json`), this.db[col]);
    }*/
  }
}

async function readYamlFile(fn) {
  return parse(await Deno.readTextFile(fn));
}

async function writeJSONFile(fn, data) {
  console.log(`File written: ${fn}`);
  return Deno.writeTextFile(fn, JSON.stringify(data, null, 2));
}