cqrs-saga - npm Package Compare versions

Comparing version 1.9.1 to 1.10.0

index.js

@@ -1,3 +0,1 @@
-'use strict';
-
 var ProcessManagement = require('./lib/pm'),
@@ -4,0 +2,0 @@ _ = require('lodash'),

lib/definitionBase.js

@@ -1,3 +0,1 @@
-'use strict';
-
 var _ = require('lodash');
@@ -4,0 +2,0 @@

lib/definitions/saga.js

@@ -1,3 +0,1 @@
-'use strict';
-
 var Definition = require('../definitionBase'),
@@ -4,0 +2,0 @@ SagaModel = require('../sagaModel'),

lib/errors/alreadyHandledError.js

@@ -1,3 +0,1 @@
-'use strict';
-
 // Grab the util module that's bundled with Node
@@ -4,0 +2,0 @@ var util = require('util');

lib/errors/alreadyHandlingError.js

@@ -1,3 +0,1 @@
-'use strict';
-
 // Grab the util module that's bundled with Node
@@ -4,0 +2,0 @@ var util = require('util');

lib/errors/concurrencyError.js

@@ -1,3 +0,1 @@
-'use strict';
-
 // Grab the util module that's bundled with Node
@@ -4,0 +2,0 @@ var util = require('util');

lib/eventDispatcher.js

@@ -1,3 +0,1 @@
-'use strict';
-
 var debug = require('debug')('saga:eventDispatcher'),
@@ -4,0 +2,0 @@ _ = require('lodash'),

lib/orderQueue.js

@@ -1,3 +0,1 @@
-'use strict';
-
 var debug = require('debug')('saga:orderQueue'),
@@ -4,0 +2,0 @@ _ = require('lodash'),

lib/pm.js

@@ -1,3 +0,1 @@
-'use strict';
-
 var debug = require('debug')('saga'),
@@ -4,0 +2,0 @@ async = require('async'),

lib/revisionGuard.js

@@ -1,3 +0,1 @@
-'use strict';
-
 var debug = require('debug')('saga:revisionGuard'),
@@ -4,0 +2,0 @@ _ = require('lodash'),

lib/revisionGuardStore/base.js

@@ -1,3 +0,1 @@
-'use strict';
-
 var util = require('util'),
@@ -4,0 +2,0 @@ EventEmitter = require('events').EventEmitter,

lib/revisionGuardStore/databases/azureTable.js

@@ -1,3 +0,1 @@
-'use strict';
-
 var util = require('util'),
@@ -4,0 +2,0 @@ Store = require('../base'),

lib/revisionGuardStore/databases/inmemory.js

@@ -1,3 +0,1 @@
-'use strict';
-
 var util = require('util'),
@@ -4,0 +2,0 @@ Store = require('../base'),

lib/revisionGuardStore/databases/mongodb.js

@@ -1,3 +0,1 @@
-'use strict';
-
 var util = require('util'),
@@ -72,31 +70,54 @@ Store = require('../base'),
 
-    var client = new mongo.MongoClient();
+    var client;
 
-    client.connect(connectionUrl, options.options, function(err, db) {
-      if (err) {
-        if (callback) callback(err);
-      } else {
+    if (mongo.MongoClient.length === 2) {
+      client = new mongo.MongoClient(connectionUrl, options.options);
+      client.connect(function(err, cl) {
+        if (err) {
+          debug(err);
+          if (callback) callback(err);
+          return;
+        }
+
+        self.db = cl.db(cl.s.options.dbName);
+        if (!self.db.close) {
+          self.db.close = cl.close.bind(cl);
+        }
+        initDb();
+      });
+    } else {
+      client = new mongo.MongoClient();
+      client.connect(connectionUrl, options.options, function(err, db) {
+        if (err) {
+          debug(err);
+          if (callback) callback(err);
+          return;
+        }
+
         self.db = db;
+        initDb();
+      });
+    }
 
-        self.db.on('close', function() {
-          self.emit('disconnect');
-          self.stopHeartbeat();
-        });
+    function initDb() {
+      self.db.on('close', function() {
+        self.emit('disconnect');
+        self.stopHeartbeat();
+      });
 
-        var finish = function (err) {
-          self.store = self.db.collection(options.collectionName);
-//          self.store.ensureIndex({ 'aggregateId': 1, date: 1 }, function() {});
-          if (!err) {
-            self.emit('connect');
+      var finish = function (err) {
+        self.store = self.db.collection(options.collectionName);
+//        self.store.ensureIndex({ 'aggregateId': 1, date: 1 }, function() {});
+        if (!err) {
+          self.emit('connect');
 
-            if (self.options.heartbeat) {
-              self.startHeartbeat();
-            }
+          if (self.options.heartbeat) {
+            self.startHeartbeat();
           }
-          if (callback) callback(err, self);
-        };
+        }
+        if (callback) callback(err, self);
+      };
 
-        finish();
-      }
-    });
+      finish();
+    }
   },
@@ -103,0 +124,0 @@

lib/revisionGuardStore/databases/redis.js

@@ -1,3 +0,1 @@
-'use strict';
-
 var util = require('util'),
@@ -4,0 +2,0 @@ Store = require('../base'),

lib/revisionGuardStore/databases/tingodb.js

@@ -1,3 +0,1 @@
-'use strict';
-
 var util = require('util'),
@@ -4,0 +2,0 @@ Store = require('../base'),

lib/revisionGuardStore/index.js

@@ -1,3 +0,1 @@
-'use strict';
-
 var tolerate = require('tolerance'),
@@ -4,0 +2,0 @@ _ = require('lodash'),

lib/sagaModel.js

@@ -1,3 +0,1 @@
-'use strict';
-
 var debug = require('debug')('saga:sagaModel'),
@@ -4,0 +2,0 @@ dotty = require('dotty'),

lib/store/base.js

@@ -1,3 +0,1 @@
-'use strict';
-
 var util = require('util'),
@@ -4,0 +2,0 @@ EventEmitter = require('events').EventEmitter,

lib/store/databases/azuretable.js

@@ -1,3 +0,1 @@
-'use strict';
-
 var util = require('util'),
@@ -4,0 +2,0 @@ Store = require('../base'),

lib/store/databases/inmemory.js

@@ -1,3 +0,1 @@
-'use strict';
-
 var util = require('util'),
@@ -4,0 +2,0 @@ Store = require('../base'),

lib/store/databases/mongodb.js

@@ -1,3 +0,1 @@
-'use strict';
-
 var util = require('util'),
@@ -4,0 +2,0 @@ Store = require('../base'),

lib/store/databases/redis.js

@@ -1,3 +0,1 @@
-'use strict';
-
 var util = require('util'),
@@ -4,0 +2,0 @@ Store = require('../base'),

lib/store/index.js

@@ -1,3 +0,1 @@
-'use strict';
-
 var tolerate = require('tolerance'),
@@ -4,0 +2,0 @@ _ = require('lodash'),

lib/structure/structureLoader.js

@@ -1,3 +0,1 @@
-'use strict';
-
 var debug = require('debug')('saga:structureLoader'),
@@ -4,0 +2,0 @@ path = require('path'),

lib/structure/structureParser.js

@@ -1,3 +0,1 @@
-'use strict';
-
 var debug = require('debug')('saga:structureParser'),
@@ -4,0 +2,0 @@ _ = require('lodash'),

lib/structure/structureSearcher.js

@@ -1,3 +0,1 @@
-'use strict';
-
 var debug = require('debug')('saga:structureSearcher'),
@@ -4,0 +2,0 @@ _ = require('lodash');

package.json

 {
   "author": "adrai",
   "name": "cqrs-saga",
-  "version": "1.9.1",
+  "version": "1.10.0",
   "private": false,
@@ -15,3 +15,3 @@ "main": "index.js",
     "async": "1.5.2",
-    "debug": "3.0.1",
+    "debug": "3.1.0",
     "dotty": "0.0.2",
@@ -30,3 +30,3 @@ "jsondate": "0.0.1",
     "mocha": "3.x.x",
-    "mongodb": ">= 0.0.1",
+    "mongodb": "2.1.x",
     "redis": ">= 0.10.1",
@@ -33,0 +33,0 @@ "tingodb": ">= 0.0.1"

README.md

@@ -555,3 +555,3 @@ # Introduction
 
-Copyright (c) 2015 Adriano Raiano
+Copyright (c) 2018 Adriano Raiano
 
@@ -558,0 +558,0 @@ Permission is hereby granted, free of charge, to any person obtaining a copy

releasenotes.md

@@ -0,1 +1,4 @@
+## [v1.10.0](https://github.com/adrai/node-cqrs-saga/compare/v1.9.1...v1.10.0)
+- compatibility with new mongodb version (3.x)
+
 ## [v1.9.1](https://github.com/adrai/node-cqrs-saga/compare/v1.9.0...v1.9.1)
@@ -2,0 +5,0 @@ - add possibility to call removeTimeout after getTimeoutSagas and getOlderSagas [#42](https://github.com/adrai/node-cqrs-saga/issues/#42) thanks to [edro](https://github.com/edro)

No alert changes

Improved metrics

Total package byte prevSize

174166

increased by0.13%

Worsened metrics

Lines of code

4643

decreased by-0.13%

Dependency changes

• + Addeddebug@3.1.0(transitive)

• - Removeddebug@3.0.1(transitive)

• Updateddebug@3.1.0