lowkie - npm Package Compare versions

Comparing version 1.3.2 to 1.3.3

lib/schema.js

@@ -118,2 +118,4 @@ 'use strict';
       let lowkieDocument = options.argumentsList;
+    // console.log({this.lowkie})
+    // console.log('this.lowkie',this.lowkie)
 
@@ -123,6 +125,11 @@ // let { target, thisArg, argumentsList, } = options;
         try {
-          let newDoc = (Array.isArray(lowkieDocument)) ?
-            lowkieDocument.map(lowkiedoc => this.createDoc(lowkiedoc)) :
-            this.createDoc(lowkieDocument);
-          lokiCollectionInsert.call(lowkieInstance, newDoc);
+          let newDoc = lowkieDocument;
+          if (this.lowkie && this.lowkie.config && this.lowkie.config.strictSchemas) {
+            newDoc = (Array.isArray(lowkieDocument))
+            ? lowkieDocument.map(lowkiedoc => this.createDoc(lowkiedoc))
+            : this.createDoc(lowkieDocument);
+            lokiCollectionInsert.call(lowkieInstance, newDoc);
+          } else {
+            lokiCollectionInsert.call(lowkieInstance, lowkieDocument);
+          }
           this.lowkie.dbs[this.dbconnection].saveDatabase((err) => {
@@ -149,2 +156,14 @@ if (err) reject(err);
     let lowkieDocument = options.argumentsList;
+    function removeDoc(doc) {
+      return new Promise((resolve, reject) => {
+        try {
+          let t = setTimeout(() => { 
+            lokiCollectionRemove.call(lowkieInstance, doc);
+            resolve(doc);
+          }, 10);
+        } catch (e) {
+          reject(e);
+        }
+      });
+    }
 
@@ -154,13 +173,13 @@ // let { target, thisArg, argumentsList, } = options;
       try {
-        if (Array.isArray(lowkieDocument)) {
-          lowkieDocument.forEach(delDoc => {
-            lokiCollectionRemove.call(lowkieInstance, delDoc);
-          });
-        } else {
-          lokiCollectionRemove.call(lowkieInstance, lowkieDocument);
-        }
-        this.lowkie.dbs[this.dbconnection].saveDatabase((err) => {
-          if (err) reject(err);
-          else return resolve(lowkieDocument);
-        });
+        let deletePromise = (Array.isArray(lowkieDocument))
+          ? Promise.all(lowkieDocument.map(ld=>removeDoc(ld)))
+          : removeDoc(lowkieDocument);
+        deletePromise
+          .then(() => {
+            this.lowkie.dbs[this.dbconnection].saveDatabase((err) => {
+              if (err) reject(err);
+              else return resolve(lowkieDocument);
+            });
+          })
+          .catch(reject);
       } catch (e) {
@@ -167,0 +186,0 @@ reject(e);

package.json

 {
   "name": "lowkie",
-  "version": "1.3.2",
+  "version": "1.3.3",
   "license": "MIT",
@@ -5,0 +5,0 @@ "main": "index.js",

No alert changes

Improved metrics

Total package byte prevSize

6200085

Lines of code

38066

increased by0.05%

Worsened metrics

Number of package files

82

decreased by-1.2%

No dependency changes