es6 native

src/inc/cfg.mjs

@@ -0,0 +1,70 @@
+import sql from "./sql";
+
+let cfg = {
+  client: {},
+  main: {},
+  websrv: {},
+  trigger: {}
+};
+
+const read = () => new Promise((resolve, reject) => {
+  sql.any("select * from cfg").then(rows => {
+    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();
+  })
+  .catch(err => {
+    reject("no cfg");
+  })
+});
+
+const write = (kat, key, value, type, cb) => {
+  if (type === "json")
+    value = JSON.stringify(value);
+
+  console.log(kat, key, value, type);
+  sql.any("select * from cfg where class = $1 && key = $2 limit 1", [kat, key]).then(rows => {
+    if (rows.length > 0) {
+      sql.any("update cfg set value = $1 where class = $2 && key = $3", [value, kat, key]).then(rows => {
+        read().then(() => {
+          if(cb) cb();
+        });
+      })
+      .catch(err => {
+        console.log("on update", err);
+      });
+    }
+    else {
+      sql.any("insert into cfg (class, key, value, type) values ($1, $2, $3, $4)", [kat, key, value, type]).then(rows => {
+        read().then(() => {
+          if (cb) cb();
+        });
+      })
+      .catch(err => {
+        console.log("on insert", err);
+      });
+    }
+  })
+  .then(err => {
+    console.log("on select", err);
+  });
+};
+
+
+export { cfg, read, write };