Uwev2/src/inc/cfg.js

import sql from "./sql.js";

let cfg = {
  client: {},
  main: {},
  websrv: {},
  trigger: {}
};

const read = () => new Promise((resolve, reject) => {
  sql.exec("select * from `cfg`", (err, rows) => {
    if(err || rows.length < 1)
      reject({ error: "no cfg" });
    else {
      for (let row in rows) {
        cfg[rows[row].class][rows[row].key] = {
          val: ((type, value) => {
            switch (type) {
              case "string":
                return value;
              case "int":
                return parseInt(value);
              case "bool":
                return value === "true";
              case "json":
                return JSON.parse(value);
            }
          })(rows[row].type, rows[row].value),
          hidden: rows[row].hidden === 1,
          type: rows[row].type
        }
      }
      resolve();
    }
  });
});

const write = (kat, key, value, type, cb) => {
  if (type === "json")
    value = JSON.stringify(value);

  console.log(kat, key, value, type);
  sql.exec("select * from `cfg` where `class` = ? && `key` = ? limit 1", [kat, key], (err, rows) => {
    console.log(rows);
    if (rows.length > 0) {
      sql.exec("update `cfg` set `value` = ? where `class` = ? && `key` = ?", [value, kat, key], (err) => {
        console.log("updated", err);
        read().then(() => {
          if(cb) cb();
        });
      });
    }
    else {
      sql.exec("insert into `cfg` (`class`,`key`,`value`,`type`) values (?,?,?,?)", [kat, key, value, type], (err) => {
        console.log("inserted", err);
        read().then(() => {
          if (cb) cb();
        });
      });
    }
  });
};


export { cfg, read, write };