refactor: add credentials & flows & settings storage handlers

package.json

@@ -21,7 +21,9 @@
     "typescript": "^5.0.4"
   },
   "dependencies": {
+    "dotenv": "^16.0.3",
     "express": "^4.18.2",
+    "mongodb": "^5.5.0",
     "node-red": "^3.0.2",
     "node-red-contrib-sendgrid": "^0.2.1",
     "unstorage": "^1.6.0"

src/index.ts

@@ -1,3 +1,6 @@
+import * as dotenv from "dotenv";
+dotenv.config();
+
 import express from "express";
 import { createServer } from "http";
 import nodered from "node-red";

src/models/credentials.ts

@@ -1,3 +1,5 @@
+import { appStorage } from "../storage.js";
+
 interface ICredentials {
   appname: string;
   credentials: string;
@@ -6,12 +8,33 @@ interface ICredentials {
 export default {
   findOne: (
     where: { appname: string },
-    cb: (err: Error, credentials: ICredentials) => void
-  ) => {},
+    cb: (err: Error | null, credentials?: ICredentials) => void
+  ) => {
+    appStorage
+      .getItem("credentials")
+      .then((value) => {
+        const entity: ICredentials = {
+          appname: where.appname,
+          credentials: value && value.toString(),
+        };
+        cb(null, entity);
+      })
+      .catch(cb);
+  },
 
   findOneAndUpdate: (
     where: { appname: string },
     data: { credentials: any },
-    cb: (err: Error, credentials: ICredentials) => {}
-  ) => {},
+    cb: (err: Error | null, credentials?: ICredentials) => {}
+  ) => {
+    const entity: ICredentials = {
+      appname: where.appname,
+      credentials: data.credentials,
+    };
+
+    appStorage
+      .setItem("credentials", entity)
+      .then(() => cb(null, entity))
+      .catch(cb);
+  },
 };

src/models/flows.ts

@@ -1,3 +1,5 @@
+import { appStorage } from "../storage.js";
+
 interface IFlows {
   appname: string;
   flow: any;
@@ -6,12 +8,33 @@ interface IFlows {
 export default {
   findOne: (
     where: { appname: string },
-    cb: (err: Error, flows: IFlows) => void
-  ) => {},
+    cb: (err: Error | null, flows?: IFlows) => void
+  ) => {
+    appStorage
+      .getItem("flows")
+      .then((value) => {
+        const entity: IFlows = {
+          appname: where.appname,
+          flow: value,
+        };
+        cb(null, entity);
+      })
+      .catch(cb);
+  },
 
   findOneAndUpdate: (
     where: { appname: string },
     data: { flow: any },
-    cb: (err: Error, flows: IFlows) => {}
-  ) => {},
+    cb: (err: Error | null, flows?: IFlows) => {}
+  ) => {
+    const entity: IFlows = {
+      appname: where.appname,
+      flow: data.flow,
+    };
+
+    appStorage
+      .setItem("flows", entity)
+      .then(() => cb(null, entity))
+      .catch(cb);
+  },
 };

src/models/library.ts

@@ -1,3 +1,5 @@
+import { appStorage } from "../storage.js";
+
 interface ILibrary {
   appname: string;
   type: string;
@@ -9,12 +11,34 @@ interface ILibrary {
 export default {
   findOne: (
     where: { appname: string; type: string; name: string },
-    cb: (err: Error, library: ILibrary) => void
-  ) => {},
+    cb: (err: Error | null, library?: ILibrary) => void
+  ) => {
+    appStorage
+      .getItem("library")
+      .then((value) => {
+        const parsed = JSON.parse(value.toString()) as ILibrary;
+
+        cb(null, parsed);
+      })
+      .catch(cb);
+  },
 
   findOneAndUpdate: (
     where: { appname: string; name: string },
     data: { name: string; meta: any; body: any; type: string },
-    cb: (err: Error, library: ILibrary) => {}
-  ) => {},
+    cb: (err: Error | null, library?: ILibrary) => {}
+  ) => {
+    const entity: ILibrary = {
+      appname: where.appname,
+      name: where.name,
+      body: data.body,
+      meta: data.meta,
+      type: data.type,
+    };
+
+    appStorage
+      .setItem("library", entity)
+      .then(() => cb(null, entity))
+      .catch(cb);
+  },
 };