cqrs-eventdenormalizer - npm Package Compare versions

Comparing version 1.9.31 to 1.9.32

lib/revisionGuardStore/databases/mongodb.js

@@ -47,30 +47,36 @@ 'use strict';
 
-    var server;
+    var connectionUrl;
 
-    if (options.servers && Array.isArray(options.servers)){
-      var servers = [];
+    if (options.url) {
+      connectionUrl = options.url;
+    } else {
+      var members = options.servers
+        ? options.servers
+        : [{host: options.host, port: options.port}];
 
-      options.servers.forEach(function(item){
-        if(item.host && item.port) {
-          servers.push(new mongo.Server(item.host, item.port, item.options));
-        }
-      });
+      var memberString = _(members).map(function(m) { return m.host + ':' + m.port });
+      var authString = options.username && options.password
+        ? options.username + ':' + options.password + '@'
+        : '';
+      var optionsString = options.authSource
+        ? '?authSource=' + options.authSource
+        : '';
 
-      server = new mongo.ReplSet(servers);
-    } else {
-      server = new mongo.Server(options.host, options.port, options.options);
+      connectionUrl = 'mongodb://' + authString + memberString + '/' + options.dbName + optionsString;
     }
 
-    this.db = new mongo.Db(options.dbName, server, { safe: true });
-    this.db.on('close', function() {
-      self.emit('disconnect');
-      self.stopHeartbeat();
-    });
+    var client = new mongo.MongoClient();
 
-    this.db.open(function (err, client) {
+    client.connect(connectionUrl, options.options, function(err, db) {
       if (err) {
         if (callback) callback(err);
       } else {
+        self.db = db;
+
+        self.db.on('close', function() {
+          self.emit('disconnect');
+          self.stopHeartbeat();
+        });
+
         var finish = function (err) {
-          self.client = client;
           self.store = self.db.collection(options.collectionName);
@@ -88,10 +94,3 @@ //          self.store.ensureIndex({ 'aggregateId': 1, date: 1 }, function() {});
 
-        if (options.authSource && options.username) {
-          // Authenticate with authSource
-          client.authenticate(options.username, options.password, {authSource: options.authSource}, finish);
-        } else if (options.username) {
-          client.authenticate(options.username, options.password, finish);
-        } else {
-          finish();
-        }
+        finish();
       }
@@ -98,0 +97,0 @@ });

package.json

 {
   "author": "adrai",
   "name": "cqrs-eventdenormalizer",
-  "version": "1.9.31",
+  "version": "1.9.32",
   "private": false,
@@ -24,3 +24,3 @@ "main": "index.js",
     "tolerance": "1.0.0",
-    "viewmodel": "1.5.14"
+    "viewmodel": "1.5.15"
   },
@@ -27,0 +27,0 @@ "devDependencies": {

README.md

@@ -85,2 +85,3 @@ # Introduction
 	    // password: 'secret'                          // optional
+      // url: 'mongodb://user:pass@host:port/db?opts // optional
 	  },
@@ -87,0 +88,0 @@

releasenotes.md

@@ -0,1 +1,4 @@
+## [v1.9.32](https://github.com/adrai/node-cqrs-eventdenormalizer/compare/v1.9.31...v1.9.32)
+- Support mongo connection string
+
 ## [v1.9.31](https://github.com/adrai/node-cqrs-eventdenormalizer/compare/v1.9.30...v1.9.31)
@@ -2,0 +5,0 @@ - fix replay race condition when deleting and creating multiple times

No alert changes

Improved metrics

Total package byte prevSize

171358

increased by0.05%

Number of lines in readme file

826

increased by0.12%

Worsened metrics

Lines of code

3966

decreased by-0.08%

Dependency changes

• + Addedviewmodel@1.5.15(transitive)

• - Removedviewmodel@1.5.14(transitive)

• Updatedviewmodel@1.5.15