feat: add nodeRed custom storage based on Unstorage

becem-gharbi · May 17, 2023 · 0d30cbf · 0d30cbf
1 parent 2b14d08
commit 0d30cbf
Show file tree

Hide file tree

Showing 6 changed files with 17 additions and 12 deletions.
diff --git a/src/settings.ts b/src/settings.ts
@@ -2,9 +2,16 @@ import type { LocalSettings } from "@node-red/runtime";
 import { dirname, resolve } from "path";
 import { fileURLToPath } from "url";
 import { storageModule } from "./storage.js";
+import { createStorage } from "unstorage";
+import fsDriver from "unstorage/drivers/fs";
 
 const cwd = dirname(fileURLToPath(import.meta.url));
 
+const storage = createStorage({
+  //@ts-ignore
+  driver: fsDriver({ base: "./tmp" }),
+});
+
 export const settings: LocalSettings = {
   httpAdminRoot: "/",
   httpNodeRoot: "/api",
@@ -16,4 +23,8 @@ export const settings: LocalSettings = {
   credentialSecret: "secret",
   //@ts-ignore
   storageModule: storageModule,
+  storageSettings: {
+    storage: storage,
+    appName: process.env.APP_NAME || "default",
+  },
 };
diff --git a/src/storage.ts b/src/storage.ts
@@ -1,22 +1,17 @@
 //@ts-nocheck
 import type { StorageModule } from "@node-red/runtime";
-import { createStorage, prefixStorage, Storage } from "unstorage";
-import fsDriver from "unstorage/drivers/fs";
+import { prefixStorage, Storage } from "unstorage";
 
 var appname: string;
 
 var appStorage: Storage;
 var libraryStorage: Storage;
 
 export const storageModule: StorageModule = {
-  init: () => {
-    appname = "app0";
+  init: ({ storageSettings }) => {
+    appname = storageSettings.appName;
 
-    const unstorage = createStorage({
-      driver: fsDriver({ base: "./tmp" }),
-    });
-
-    appStorage = prefixStorage(unstorage, appname);
+    appStorage = prefixStorage(storageSettings.storage, appname);
 
     libraryStorage = prefixStorage(appStorage, "library");
   },

diff --git a/tmp/app0/credentials b/tmp/app0/credentials
diff --git a/tmp/app0/flows b/tmp/app0/flows
diff --git a/tmp/default/flows b/tmp/default/flows
@@ -0,0 +1 @@
+[{"id":"6dfb4bdf1ac54c22","type":"tab","label":"Flow 1","disabled":false,"info":"","env":[]},{"id":"0887201e20338fb8","type":"inject","z":"6dfb4bdf1ac54c22","name":"","props":[{"p":"payload"},{"p":"topic","vt":"str"}],"repeat":"","crontab":"","once":false,"onceDelay":0.1,"topic":"","payload":"","payloadType":"date","x":240,"y":140,"wires":[["f18a2a6ae94cd838"]]},{"id":"f18a2a6ae94cd838","type":"debug","z":"6dfb4bdf1ac54c22","name":"debug 1","active":true,"tosidebar":true,"console":false,"tostatus":false,"complete":"false","statusVal":"","statusType":"auto","x":560,"y":140,"wires":[]}]
Original file line number	Diff line number	Diff line change
		@@ -0,0 +1 @@
		[{"id":"6dfb4bdf1ac54c22","type":"tab","label":"Flow 1","disabled":false,"info":"","env":[]},{"id":"0887201e20338fb8","type":"inject","z":"6dfb4bdf1ac54c22","name":"","props":[{"p":"payload"},{"p":"topic","vt":"str"}],"repeat":"","crontab":"","once":false,"onceDelay":0.1,"topic":"","payload":"","payloadType":"date","x":240,"y":140,"wires":[["f18a2a6ae94cd838"]]},{"id":"f18a2a6ae94cd838","type":"debug","z":"6dfb4bdf1ac54c22","name":"debug 1","active":true,"tosidebar":true,"console":false,"tostatus":false,"complete":"false","statusVal":"","statusType":"auto","x":560,"y":140,"wires":[]}]