compatibility with new mongodb version (3.x)

Author: adrai

README.md

@@ -596,7 +596,7 @@ and you can use it in this way
 
 # License
 
-Copyright (c) 2017 Adriano Raiano, Jan Muehlemann
+Copyright (c) 2018 Adriano Raiano, Jan Muehlemann
 
 Permission is hereby granted, free of charge, to any person obtaining a copy
 of this software and associated documentation files (the "Software"), to deal

index.js

@@ -1,5 +1,3 @@
-'use strict';
-
 var Eventstore = require('./lib/eventstore'),
   Base = require('./lib/base'),
   _ = require('lodash'),

lib/base.js

@@ -1,5 +1,3 @@
-'use strict';
-
 var util = require('util'),
   EventEmitter = require('events').EventEmitter,
   prequire = require('parent-require'),

lib/databases/azuretable.js

@@ -1,6 +1,3 @@
-'use strict';
-
-
 var util = require('util'),
   Store = require('../base'),
   _ = require('lodash'),

lib/databases/dynamodb.js

@@ -1,5 +1,3 @@
-'use strict';
-
 var util = require('util'),
   Store = require('../base'),
   _ = require('lodash'),

lib/databases/elasticsearch.js

@@ -1,5 +1,3 @@
-'use strict';
-
 var util = require('util'),
   Store = require('../base'),
   _ = require('lodash'),

lib/databases/inmemory.js

@@ -1,5 +1,3 @@
-'use strict';
-
 var util = require('util'),
   Store = require('../base'),
   _ = require('lodash'),

lib/databases/mongodb.js

@@ -1,5 +1,3 @@
-'use strict';
-
 var util = require('util'),
   Store = require('../base'),
   _ = require('lodash'),
@@ -73,17 +71,38 @@ _.extend(Mongo.prototype, {
       connectionUrl = 'mongodb://' + authString + memberString + '/' + options.dbName + optionsString;
     }
 
-    var client = new mongo.MongoClient();
+    var client;
 
-    client.connect(connectionUrl, options.options, function(err, db) {
-      if (err) {
-        debug(err);
-        if (callback) callback(err);
-        return;
-      }
+    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;
+        self.db = db;
+        initDb();
+      });
+    }
 
+    function initDb() {
       self.db.on('close', function() {
         self.emit('disconnect');
         self.stopHeartbeat();
@@ -123,7 +142,7 @@ _.extend(Mongo.prototype, {
       }
 
       finish();
-    });
+    }
   },
 
   stopHeartbeat: function () {

lib/databases/redis.js

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

lib/databases/tingodb.js

@@ -1,5 +1,3 @@
-'use strict';
-
 var util = require('util'),
   Store = require('../base'),
   _ = require('lodash'),