metrics.test.js

//Imports
  const processes = require("child_process")
  const yaml = require("js-yaml")
  const fs = require("fs")
  const path = require("path")
  const url = require("url")
  const axios = require("axios")
  const faker = require("faker")
  const ejs = require("ejs")

//Github action
  const action = yaml.load(fs.readFileSync(path.join(__dirname, "../action.yml"), "utf8"))
  action.defaults = Object.fromEntries(Object.entries(action.inputs).map(([key, {default:value}]) => [key, value]))
  action.input = vars => Object.fromEntries([...Object.entries(action.defaults), ...Object.entries(vars)].map(([key, value]) => [`INPUT_${key.toLocaleUpperCase()}`, value]))
  action.run = async (vars) => await new Promise((solve, reject) => {
    let [stdout, stderr] = ["", ""]
    const env = {...process.env, ...action.input(vars), GITHUB_REPOSITORY:"lowlighter/metrics"}
    const child = processes.spawn("node", ["source/app/action/index.mjs"], {env})
    child.stdout.on("data", data => stdout += data)
    child.stderr.on("data", data => stderr += data)
    child.on("close", code => {
      if (code === 0)
        return solve(true)
      console.log(stdout, stderr)
      reject(stdout)
    })
  })

//Web instance
  const web = {}
  web.run = async (vars) => (await axios(`http://localhost:3000/lowlighter?${new url.URLSearchParams(Object.fromEntries(Object.entries(vars).map(([key, value]) => [key.replace(/^plugin_/, "").replace(/_/g, "."), value])))}`)).status === 200
  web.start = async () => new Promise(solve => {
    let stdout = ""
    web.instance = processes.spawn("node", ["source/app/web/index.mjs"], {env:{...process.env, USE_MOCKED_DATA:true, NO_SETTINGS:true}})
    web.instance.stdout.on("data", data => (stdout += data, /Server ready !/.test(stdout) ? solve() : null))
    web.instance.stderr.on("data", data => console.error(`${data}`))
  })
  web.stop = async () => await web.instance.kill("SIGKILL")

//Web instance placeholder
  require("./../source/app/web/statics/app.placeholder.js")
  const placeholder = globalThis.placeholder
  delete globalThis.placeholder
  placeholder.init({faker, ejs, axios:{async get(url) { return axios(`http://localhost:3000${url}`) }}})
  placeholder.run = async (vars) => {
    const options = Object.fromEntries(Object.entries(vars).map(([key, value]) => [key.replace(/^plugin_/, "").replace(/_/g, "."), value]))
    const enabled = Object.fromEntries(Object.entries(vars).filter(([key]) => /^plugin_[a-z]+$/.test(key)))
    const config = Object.fromEntries(Object.entries(options).filter(([key]) => /^config[.]/.test(key)))
    const base = Object.fromEntries(Object.entries(options).filter(([key]) => /^base[.]/.test(key)))
    return typeof await placeholder({
      templates:{selected:vars.template},
      plugins:{enabled:{...enabled, base}, options},
      config,
      version:"TEST",
      user:"lowlighter",
      avatar:"https://github.com/lowlighter.png",
    }) === "string"
  }

//Setup
  beforeAll(async done => {
    //Clean community template
      await fs.promises.rmdir(path.join(__dirname, "../source/templates/@classic"), {recursive:true})
    //Start web instance
      await web.start()
    done()
  })
//Teardown
  afterAll(async done => {
    //Stop web instance
      await web.stop()
    //Clean community template
      await fs.promises.rmdir(path.join(__dirname, "../source/templates/@classic"), {recursive:true})
    done()
  })

//Load metadata (as jest doesn't support ESM modules, we use this dirty hack)
  const metadata = JSON.parse(`${processes.spawnSync("node", [
    "--input-type", "module",
    "--eval", 'import metadata from "./source/app/metrics/metadata.mjs";console.log(JSON.stringify(await metadata({log:false})))'
  ]).stdout}`)

//Build tests index
  const tests = []
  for (const name in metadata.plugins) {
    const cases = yaml
      .load(fs.readFileSync(path.join(__dirname, "../source/plugins", name, "tests.yml"), "utf8"))
      .map(({name:test, with:inputs, modes = [], timeout}) => {
        const skip = new Set(Object.entries(metadata.templates).filter(([_, {readme:{compatibility}}]) => !compatibility[name]).map(([template]) => template))
        if (!(metadata.plugins[name].supports.includes("repository")))
          skip.add("repository")
        return [test, inputs, {skip:[...skip], modes, timeout}]
      })
    tests.push(...cases)
  }

//Tests run
  describe("GitHub Action", () =>
    describe.each([
      ["classic", {}],
      ["terminal", {}],
      ["repository", {repo:"metrics"}],
    ])("Template : %s", (template, query) => {
      for (const [name, input, {skip = [], modes = [], timeout} = {}] of tests)
        if ((skip.includes(template))||((modes.length)&&(!modes.includes("action"))))
          test.skip(name, () => null)
        else
          test(name, async () => expect(await action.run({template, base:"", query:JSON.stringify(query), plugins_errors_fatal:true, dryrun:true, use_mocked_data:true, verify:true, ...input})).toBe(true), timeout)
    })
  )

  describe("Web instance", () =>
    describe.each([
      ["classic", {}],
      ["terminal", {}],
      ["repository", {repo:"metrics"}],
    ])("Template : %s", (template, query) => {
      for (const [name, input, {skip = [], modes = [], timeout} = {}] of tests)
        if ((skip.includes(template))||((modes.length)&&(!modes.includes("web"))))
          test.skip(name, () => null)
        else
          test(name, async () => expect(await web.run({template, base:0, ...query, plugins_errors_fatal:true, verify:true, ...input})).toBe(true), timeout)
    })
  )

  describe("Web instance (placeholder)", () =>
    describe.each([
      ["classic", {}],
      ["terminal", {}],
    ])("Template : %s", (template, query) => {
      for (const [name, input, {skip = [], modes = [], timeout} = {}] of tests)
        if ((skip.includes(template))||((modes.length)&&(!modes.includes("placeholder"))))
          test.skip(name, () => null)
        else
          test(name, async () => expect(await placeholder.run({template, base:0, ...query, ...input})).toBe(true), timeout)
    })
  )