included and tested the updateMany method

Elijah-trillionz · Aug 1, 2022 · a841f00 · a841f00
1 parent 58e504a
commit a841f00
Show file tree

Hide file tree

Showing 2 changed files with 52 additions and 3 deletions.
diff --git a/src/database.ts b/src/database.ts
@@ -135,7 +135,7 @@ class JSONDB {
           });
         }
 
-        this.validateData(oldData, async (err: ErrorObj) => {
+        this.validateData(newData, async (err: ErrorObj) => {
           if (err) return reject(err);
 
           await this.update(oldData, newData, (err: ErrorObj) => {
@@ -151,6 +151,39 @@ class JSONDB {
     });
   }
 
+  updateMany(filter: Object, newData: Object) {
+    return new Promise(async (resolve, reject) => {
+      try {
+        const oldData = await this.findMany(filter);
+
+        if (oldData.length < 1) {
+          return reject({
+            message: "No data was found to be updated",
+            errorCode: 612,
+            error: "NOT_FOUND",
+          });
+        }
+
+        this.validateData(newData, async (err: ErrorObj) => {
+          if (err) return reject(err);
+
+          oldData.forEach((value) => {
+            (async () => {
+              await this.update(value, newData, (err: ErrorObj) => {
+                if (err) return reject(err);
+
+                resolve("Done");
+              });
+            })();
+          });
+        });
+      } catch (e) {
+        // for errors thrown when the findMany method encounters an error
+        reject(e);
+      }
+    });
+  }
+
   // helper functions
 
   // find an object from data
@@ -222,7 +255,7 @@ class JSONDB {
   }
 
   // validate schema: used in the update and the create method
-  validateSchema = (data: Object, cb: Function) => {
+  private validateSchema = (data: Object, cb: Function) => {
     const valid = this.validate(data);
     if (!valid) {
       const { keyword, params, message } = this.validate.errors[0];

diff --git a/src/server.ts b/src/server.ts
@@ -42,7 +42,7 @@ async function addNewUser() {
     console.log(err);
   }
 }
-addNewUser();
+// addNewUser();
 
 async function getAllUsers() {
   const response = await users.allData;
@@ -68,3 +68,19 @@ async function updateUser() {
   }
 }
 // updateUser();
+
+async function updateMany() {
+  try {
+    const res = await users.updateMany(
+      { username: "starsboys" },
+      {
+        likes: [{ id: 1 }],
+        age: 10,
+      }
+    );
+    console.log(res);
+  } catch (e) {
+    console.log(e);
+  }
+}
+updateMany();