fix(context): add callbacks for async operations

package.json

@@ -16,6 +16,7 @@
     "dist"
   ],
   "scripts": {
+    "dev": "cd playground && npm run dev",
     "build": "rimraf dist && tsup src/**/*.ts --format cjs,esm --dts",
     "release": "npm run build && changelogen --release && npm publish && git push --follow-tags"
   },

playground/package.json

@@ -13,15 +13,14 @@
   "license": "MIT",
   "devDependencies": {
     "@types/express": "^4.17.17",
-    "@types/node": "^20.2.0",
+    "@types/node": "^20.2.3",
     "@types/node-red": "^1.3.1",
     "changelogen": "^0.5.3",
     "rimraf": "^5.0.1",
     "ts-node": "^10.9.1",
     "typescript": "^5.0.4"
   },
   "dependencies": {
-    "@bg-dev/node-red-unstorage": "^0.1.5",
     "dotenv": "^16.0.3",
     "express": "^4.18.2",
     "mongodb": "^5.5.0",

playground/src/index.ts

@@ -68,6 +68,14 @@ const settings: LocalSettings = {
       },
     ],
   },
+
+  // logging: {
+  //   console: {
+  //     level: "trace",
+  //     audit: false,
+  //     metrics: false,
+  //   },
+  // },
 };
 
 const app = express();

src/context.ts

@@ -10,41 +10,66 @@ var ContextStore = function (args: {
   this.appStorage = prefixStorage(storage, args.app);
 };
 
-ContextStore.prototype.get = function (scope: string, key: string | string[]) {
-  if (Array.isArray(key)) {
-    return Promise.all(
-      key.map((el) => this.appStorage.getItem(scope + ":" + el))
-    );
-  }
+ContextStore.prototype.get = function (
+  scope: string,
+  key: string | string[],
+  cb: (error: Error, ...values: string[]) => void
+) {
+  try {
+    if (Array.isArray(key)) {
+      Promise.all(
+        key.map((el) => this.appStorage.getItem(scope + ":" + el))
+      ).then((result) => cb(undefined, ...result));
+    }
 
-  return this.appStorage.getItem(scope + ":" + key);
+    this.appStorage
+      .getItem(scope + ":" + key)
+      .then((result) => cb(undefined, result));
+  } catch (error) {
+    cb(error);
+  }
 };
 
 ContextStore.prototype.set = function (
   scope: string,
   key: string | string[],
-  value: string | string[]
+  value: string | string[],
+  cb: (error?: Error) => void
 ) {
-  if (Array.isArray(key)) {
-    const values = [...value];
-    return Promise.all(
-      key.map((el, index) =>
-        this.appStorage.setItem(scope + ":" + el, values[index] || null)
-      )
-    );
-  }
+  try {
+    if (Array.isArray(key)) {
+      const values = [...value];
 
-  return this.appStorage.setItem(scope + ":" + key, value);
+      Promise.all(
+        key.map((el, index) =>
+          this.appStorage.setItem(scope + ":" + el, values[index] || null)
+        )
+      ).then(() => cb());
+    } else {
+      this.appStorage.setItem(scope + ":" + key, value).then(() => cb());
+    }
+  } catch (error) {
+    cb(error);
+  }
 };
 
-ContextStore.prototype.keys = function (scope: string) {
-  return this.appStorage
-    .getKeys(scope)
-    .then((result) => result.map((el) => el.split(":")[1]));
+ContextStore.prototype.keys = function (
+  scope: string,
+  cb: (error: Error, ...values: string[]) => void
+) {
+  try {
+    this.appStorage.getKeys(scope).then((result) => {
+      const keys = result.map((el) => el.split(":")[1]);
+
+      cb(undefined, keys);
+    });
+  } catch (error) {
+    cb(error);
+  }
 };
 
 ContextStore.prototype.delete = function (scope: string) {
-  return this.appStorage
+  this.appStorage
     .getKeys(scope)
     .then((result) =>
       Promise.all(result.map((key) => this.appStorage.removeItem(key)))