caminte - npm Package Compare versions

Comparing version 0.3.6 to 0.3.7

lib/abstract-class.js

@@ -14,3 +14,2 @@ /**
 var Hookable = hkb.Hookable;
-// var DEFAULT_CACHE_LIMIT = 1000;
 var BASE_TYPES = ['String', 'Boolean', 'Number', 'Date', 'Text', 'JSON', 'UUID'];
@@ -204,3 +203,3 @@
 };
-AbstractClass.promise = deferPromise;
+
 AbstractClass.q = {
@@ -224,5 +223,5 @@ conditions: {},
             if (err) {
-                p.reject(err);
+                if(!callback) p.reject(err);
             } else {
-                p.resolve(data);
+                if(!callback) p.resolve(data);
             }
@@ -273,7 +272,6 @@ return callback && callback(err, data);
             if (!valid) {
-                var err = new Error(modelName + ' validation error');
-                p.reject(err);
-                return callback && callback(err, obj);
+                if(!callback) p.reject(new Error('Validation error'));
+                return callback && callback(new Error('Validation error'), obj);
             } else {
-                return create();
+                create();
             }
@@ -346,3 +344,3 @@ });
             if (err) {
-                p.reject(err);
+                if(!callback) p.reject(err);
                 return callback && callback(err);
@@ -353,5 +351,5 @@ }
                     if (err) {
-                        p.reject(err);
+                        if(!callback) p.reject(err);
                     } else {
-                        p.resolve(inst);
+                        if(!callback) p.resolve();
                     }
@@ -365,5 +363,5 @@ return callback && callback(err);
                     if (err) {
-                        p.reject(err);
+                        if(!callback) p.reject(err);
                     } else {
-                        p.resolve(obj);
+                        if(!callback) p.resolve();
                     }
@@ -381,7 +379,7 @@ return callback && callback(err);
                     err = new Error('Found more than one record');
-                    p.reject(err);
+                    if(!callback) p.reject(err);
                     return callback && callback(err, insts);
                 }
                 if (err.message && !/NotFound/gi.test(err.message)) {
-                    p.reject(err);
+                    if(!callback) p.reject(err);
                     return callback && callback(err, insts);
@@ -394,5 +392,5 @@ }
                     if (err) {
-                        p.reject(err);
+                        if(!callback) p.reject(err);
                     } else {
-                        p.resolve(inst);
+                        if(!callback) p.resolve(inst);
                     }
@@ -406,5 +404,5 @@ return callback && callback(err, inst);
                     if (err) {
-                        p.reject(err);
+                        if(!callback) p.reject(err);
                     } else {
-                        p.resolve(obj);
+                        if(!callback) p.resolve(obj);
                     }
@@ -437,20 +435,22 @@ return callback && callback(err, obj);
     }
-    var self = this, p = deferPromise();
-    self.findOne({where: query}, function (err, record) {
+    var self = this;
+    var p = deferPromise();
+    this.findOne({where: query}, function (err, record) {
         if (err) {
-            p.reject(err);
+            if(!callback) p.reject(err);
             return callback && callback(err);
-        } else if (record) {
-            p.resolve(record);
+        }
+        if (record) {
+            if(!callback) p.resolve(record);
             return callback && callback(null, record);
-        } else {
-            data = helpers.merge(query, data);
-            self.create(data).then(function (record) {
-                p.resolve(record);
-                return callback && callback(null, record);
-            }).catch(function (err) {
-                p.reject(err);
-                return callback && callback(err, null);
-            });
         }
+        data = helpers.merge(query, data);
+        self.create(data, function (err, record) {
+            if (err) {
+                if(!callback) p.reject(err);
+            } else {
+                if(!callback) p.resolve(record);
+            }
+            return callback && callback(err, record);
+        });
     });
@@ -475,5 +475,5 @@ return p.promise;
             if (err) {
-                p.reject(err);
+                if(!callback) p.reject(err);
             } else {
-                p.resolve(data);
+                if(!callback) p.resolve(data);
             }
@@ -484,3 +484,3 @@ return callback && callback(err, data);
         var err = new Error('Model::exists requires positive id argument');
-        p.reject(err);
+        if(!callback) p.reject(err);
         return callback && callback(err);
@@ -533,6 +533,6 @@ }
                 // }
-                p.resolve(data);
+                if(!callback) p.resolve(data);
                 return callback && callback(err, data);
             } else {
-                p.reject(err);
+                if(!callback) p.reject(err);
                 return callback && callback(err, []);
@@ -567,5 +567,5 @@ }
         if (err) {
-            p.reject(err);
+            if(!callback) p.reject(err);
         } else {
-            p.resolve(obj);
+            if(!callback) p.resolve(obj);
         }
@@ -594,6 +594,6 @@ return callback && callback(err, obj);
         }
-        var self = this;
+
         if (typeof params === 'undefined') {
-            self.q.params.limit = 1;
-            return self;
+            this.q.params.limit = 1;
+            return this;
         } else {
@@ -605,14 +605,12 @@ var p = deferPromise();
             }
-            params = buildQuery(params, self);
+            params = buildQuery(params, this);
             params.limit = 1;
-            self
-                .all(params)
-                .then(function (collection) {
-                    p.resolve(collection[0]);
-                    return callback && callback(null, collection[0] || null);
-                })
-                .catch(function (err) {
-                    p.reject(err);
+            this.all(params, function (err, collection) {
+                if (err || !collection || !collection.length > 0) {
+                    if(!callback) p.reject(err);
                     return callback && callback(err, null);
-                });
+                }
+                if(!callback) p.resolve(collection[0]);
+                return callback && callback(err, collection[0]);
+            });
             return p.promise;
@@ -642,5 +640,5 @@ }
         if (err) {
-            p.reject(err);
+            if(!callback) p.reject(err);
         } else {
-            p.resolve(null);
+            if(!callback) p.resolve(null);
         }
@@ -668,7 +666,7 @@ return callback && callback(err);
     params = buildQuery(params, this);
-    this.schema.adapter.count(this.modelName, function (err, count) {
+    this.schema.adapter.count(this.modelName, function(err, count){
         if (err) {
-            p.reject(err);
+            if(!callback) p.reject(err);
         } else {
-            p.resolve(count);
+            if(!callback) p.resolve(count);
         }
@@ -995,5 +993,5 @@ return callback && callback(err, count);
                 if (err) {
-                    p.reject(err);
+                    if(!callback) p.reject(err);
                 } else {
-                    p.resolve(null);
+                    if(!callback) p.resolve(null);
                 }
@@ -1003,6 +1001,6 @@ return callback && callback(err);
         } else {
-            p.reject(err);
+            if(!callback) p.reject(err);
             return callback && callback(err);
         }
-    });
+    }.bind(this));
     return p.promise;
@@ -1119,9 +1117,9 @@ };
         if (options && typeof options !== 'function') args.push(options);
-        else if (typeof options === 'function') callback = options;
+        else if(typeof options === 'function') callback = options;
         args.push(function (err, affected) {
             affected = {affected: affected || 0};
             if (err) {
-                p.reject(err);
+                if(!callback) p.reject(err);
             } else {
-                p.resolve(affected);
+                if(!callback) p.resolve(affected);
             }
@@ -1133,3 +1131,3 @@ return callback && callback(err, affected);
         var err = new Error('Method update undefined for this adapter');
-        p.reject(err);
+        if(!callback) p.reject(err);
         callback && callback(err);
@@ -1136,0 +1134,0 @@ }

package.json

 {
     "name": "caminte",
     "description": "ORM for every database: redis, mysql, neo4j, mongodb, rethinkdb, postgres, sqlite, tingodb",
-    "version": "0.3.6",
+    "version": "0.3.7",
     "author": {
@@ -6,0 +6,0 @@ "name": "Aleksej Gordejev",

README.md

@@ -1,4 +0,4 @@
-[![Build Status](https://travis-ci.org/biggora/caminte.png?branch=master)](https://travis-ci.org/biggora/caminte)
-[![Dependency Status](https://gemnasium.com/biggora/caminte.png)](https://gemnasium.com/biggora/caminte)
-[![NPM version](https://badge.fury.io/js/caminte.png)](http://badge.fury.io/js/caminte)
+[![Build Status](https://travis-ci.org/biggora/caminte.svg?branch=master)](https://travis-ci.org/biggora/caminte)
+[![Dependency Status](https://gemnasium.com/biggora/caminte.svg)](https://gemnasium.com/biggora/caminte)
+[![NPM version](https://badge.fury.io/js/caminte.svg)](http://badge.fury.io/js/caminte)
 ## About CaminteJS
@@ -5,0 +5,0 @@

Fixed alerts

Environment variable access

Supply chain risk

Package accesses environment variables, which may be a sign of credential stuffing or data theft.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

710830

increased by0.04%

Number of low supply chain risk alerts

68

decreased by-5.56%

Worsened metrics

Lines of code

14330

decreased by-0.03%

No dependency changes