keuss - npm Package Compare versions

Comparing version 1.7.1 to 1.7.2

package.json

 {
   "name": "keuss",
-  "version": "1.7.1",
+  "version": "1.7.2",
   "keywords": [
@@ -30,3 +30,3 @@ "queue",
     "@nodebb/mubsub": "~1.8.0",
-    "async": "~3.2.3",
+    "async": "~3.2.4",
     "async-lock": "~1.3.1",
@@ -38,14 +38,14 @@ "debug": "~4.3.4",
     "mongodb": "~4.5.0",
-    "uuid": "~8.3.2",
-    "why-is-node-running": "^2.2.2"
+    "uuid": "~8.3.2"
   },
   "devDependencies": {
     "chance": "~1.1.8",
-    "mocha": "~9.2.2",
-    "should": "~13.2.3"
+    "mocha": "~10.2.0",
+    "should": "~13.2.3",
+    "why-is-node-running": "^2.2.2"
   },
   "scripts": {
-    "test": "mocha --reporter spec --check-leaks --no-timeouts --exit test/",
-    "test-with-coverage": "nyc --reporter=html -- mocha --reporter spec --check-leaks --no-timeouts --exit test/"
+    "test": "docker compose up -d; sleep 5; mocha --reporter spec --check-leaks --no-timeouts --exit test/ ; docker compose down",
+    "test-with-coverage": "docker compose up -d; sleep 5; nyc --reporter=html -- mocha --reporter spec --check-leaks --no-timeouts --exit ; test/docker compose down"
   }
 }

QFactory-MongoDB-defaults.js

@@ -14,3 +14,3 @@ const QFactory = require ('./QFactory');
     if (!this._opts.url) {
-      this._opts.url = 'http://localhost:27017/keuss';
+      this._opts.url = 'mongodb://localhost:27017/keuss';
       debug ('added url default to %s: %o', this._name, this._opts.url);
@@ -17,0 +17,0 @@ }

Queue.js

@@ -446,3 +446,3 @@ var async = require ('async');
       cb (err, res);
-    });
+    }, obj);
   }
@@ -769,3 +769,3 @@
       });
-    });
+    }, obj);
   }
@@ -772,0 +772,0 @@ }

test/backends_deadletter.js

@@ -80,8 +80,9 @@ var async =  require ('async');
 [
-  {label: 'Simple MongoDB',     mq: require ('../backends/mongo')},
-  {label: 'Pipelined MongoDB',  mq: require ('../backends/pl-mongo')},
-  {label: 'Tape MongoDB',       mq: require ('../backends/ps-mongo')},
-  {label: 'Stream MongoDB',     mq: require ('../backends/stream-mongo')},
-  {label: 'Redis OrderedQueue', mq: require ('../backends/redis-oq')},
-  {label: 'MongoDB SafeBucket', mq: require ('../backends/bucket-mongo-safe')}
+//  {label: 'Simple MongoDB',     mq: require ('../backends/mongo')},
+//  {label: 'Pipelined MongoDB',  mq: require ('../backends/pl-mongo')},
+//  {label: 'Tape MongoDB',       mq: require ('../backends/ps-mongo')},
+//  {label: 'Stream MongoDB',     mq: require ('../backends/stream-mongo')},
+//  {label: 'Redis OrderedQueue', mq: require ('../backends/redis-oq')},
+//  {label: 'MongoDB SafeBucket', mq: require ('../backends/bucket-mongo-safe')},
+  {label: 'Mongo IntraOrder',   mq: require ('../backends/intraorder')},
 ].forEach(function (MQ_item) {
@@ -88,0 +89,0 @@ describe('rollback and deadletters with ' + MQ_item.label + ' queue backend', function () {

test/backends_payload.js

@@ -13,9 +13,10 @@ var async =  require ('async');
 [
-  {label: 'Simple MongoDB',         mq: require ('../backends/mongo')},
-  {label: 'Pipelined MongoDB',      mq: require ('../backends/pl-mongo')},
-  {label: 'Tape MongoDB',           mq: require ('../backends/ps-mongo')},
-  {label: 'Stream MongoDB',         mq: require ('../backends/stream-mongo')},
-  {label: 'Safe MongoDB Buckets',   mq: require ('../backends/bucket-mongo-safe')},
-  {label: 'Redis List',             mq: require ('../backends/redis-list')},
-  {label: 'Redis OrderedQueue',     mq: require ('../backends/redis-oq')},
+  {label: 'Simple MongoDB',       mq: require ('../backends/mongo')},
+  {label: 'Pipelined MongoDB',    mq: require ('../backends/pl-mongo')},
+  {label: 'Tape MongoDB',         mq: require ('../backends/ps-mongo')},
+  {label: 'Stream MongoDB',       mq: require ('../backends/stream-mongo')},
+  {label: 'Safe MongoDB Buckets', mq: require ('../backends/bucket-mongo-safe')},
+  {label: 'Redis List',           mq: require ('../backends/redis-list')},
+  {label: 'Redis OrderedQueue',   mq: require ('../backends/redis-oq')},
+  {label: 'Mongo IntraOrder',     mq: require ('../backends/intraorder')},
 ].forEach(function (MQ_item) {
@@ -22,0 +23,0 @@ describe('payload aspects on ' + MQ_item.label + ' queue backend, round 1', function () {

test/backends_reserve-commit-rollback.js

@@ -18,3 +18,4 @@ var async =  require ('async');
  // {label: 'Safe MongoDB Buckets', mq: require ('../backends/bucket-mongo-safe')},
-  {label: 'Redis OrderedQueue',   mq: require ('../backends/redis-oq')}
+  {label: 'Redis OrderedQueue',   mq: require ('../backends/redis-oq')},
+  {label: 'Mongo IntraOrder',     mq: require ('../backends/intraorder')},
 ].forEach(function (MQ_item) {
@@ -134,3 +135,5 @@ describe('reserve-commit-rollback with ' + MQ_item.label + ' queue backend', function () {
         cb => q.next_t((err, res) => {
-          should.equal(res, null);
+          if (q.type () !=  'mongo:intraorder') {
+            should.equal(res, null);
+          }
           cb();
@@ -257,3 +260,5 @@ })
           q.next_t(function (err, res) {
-            should.equal(res, null);
+            if (q.type () !=  'mongo:intraorder') {
+              should.equal(res, null);
+            }
             cb();
@@ -610,2 +615,3 @@ });
       var id = null;
+      var obj = null;
 
@@ -624,2 +630,3 @@ async.series([
           id = res._id;
+          obj = res;
           res.payload.should.eql({
@@ -647,3 +654,3 @@ elem: 1,
           cb();
-        }),
+        }, obj),
         cb => q.size((err, size) => {
@@ -658,7 +665,9 @@ size.should.equal(0);
         cb => q.next_t((err, res) => {
-          should.equal(res, null);
+          if (q.type () !=  'mongo:intraorder') {
+            should.equal(res, null);
+          }
           cb();
         }),
       ], (err, results) => {
-        done();
+        done(err);
       });
@@ -670,2 +679,3 @@ });
       var id = null;
+      var obj = null;
 
@@ -694,2 +704,3 @@ async.series([
             id = res._id;
+            obj = res;
             res.payload.should.eql({
@@ -749,3 +760,3 @@ elem: 1,
             cb();
-          })
+          }, obj)
         },
@@ -795,3 +806,5 @@ function (cb) {
           q.next_t(function (err, res) {
-            should.equal(res, null);
+            if (q.type () !=  'mongo:intraorder') {
+              should.equal(res, null);
+            }
             cb();
@@ -808,2 +821,3 @@ })
       var id = null;
+      var obj = null;
 
@@ -822,2 +836,3 @@ async.series([
             id = res._id;
+            obj = res;
             res.payload.should.eql({
@@ -850,3 +865,3 @@ elem: 1,
         function (cb) {
-          q.ok(id, function (err, res) {
+          q.ok(obj, function (err, res) {
             res.should.equal(true);
@@ -870,3 +885,5 @@ cb();
           q.next_t(function (err, res) {
-            should.equal(res, null);
+            if (q.type () !=  'mongo:intraorder') {
+              should.equal(res, null);
+            }
             cb();
@@ -893,6 +910,7 @@ })
     it('should manage rollback on invalid id as expected', function (done) {
-      if (MQ_item.label == 'Redis OrderedQueue') return done ();
-
       var q = factory.queue('test_queue_10');
 
+      if (q.type () ==  'redis:oq') return done ();
+      if (q.type () ==  'mongo:intraorder') return done ();
+
       async.series([
@@ -943,6 +961,7 @@ function (cb) {
           state.reserved_id = res._id;
+          state.reserved_obj = res;
           cb (null, res._id);
         }),
         cb => _get_all_sizes (q, cb),
-        cb => q.ok (state.reserved_id, cb),
+        cb => q.ok (state.reserved_id, cb, state.reserved_obj),
         cb => _get_all_sizes (q, cb),
@@ -949,0 +968,0 @@ cb => q.pop ('me', cb),

test/pause.js

@@ -17,2 +17,3 @@
   {label: 'Safe MongoDB Bucket', backend: require ('../backends/bucket-mongo-safe')},
+  {label: 'Mongo IntraOrder',    backend: require ('../backends/intraorder')},
 ].forEach (backend_item => {
@@ -19,0 +20,0 @@ [

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

428057

increased by6.37%

Dependency count

9

decreased by-10%

Number of package files

82

increased by5.13%

Lines of code

11529

increased by5.98%

Worsened metrics

Dev dependency count

4

increased by33.33%

Dependency changes

• - Removedwhy-is-node-running@^2.2.2

• - Removedsiginfo@2.0.0(transitive)

• - Removedstackback@0.0.2(transitive)

• - Removedwhy-is-node-running@2.3.0(transitive)

• Updatedasync@~3.2.4