feat: update to mongodb 4.x driver

NodeBB · Oct 19, 2021 · 10d1bb9 · 10d1bb9
1 parent c9794f0
commit 10d1bb9
Show file tree

Hide file tree

Showing 3 changed files with 13 additions and 7 deletions.
diff --git a/lib/channel.js b/lib/channel.js
@@ -61,7 +61,10 @@ Channel.prototype.publish = function (event, message, callback) {
     this.ready(function (collection) {
         collection.insertOne({ event: event, message: message }, options, function (err, docs) {
             if (err) return callback(err);
-            callback(null, docs.ops[0]);
+            collection.findOne({_id: docs.insertedId}, function (err, doc) {
+                if (err) return callback(err);
+                callback(err, doc);
+            })
         });
     });
 
@@ -210,7 +213,11 @@ Channel.prototype.latest = function (latest, callback) {
 
                 collection.insertOne({ 'dummy': true }, { safe: true }, function (err, docs) {
                     if (err) return cb(err);
-                    callback(err, docs.ops[0], collection);
+                    collection.findOne({_id: docs.insertedId}, function (err, doc) {
+                        if (err) return cb(err);
+                        callback(err, doc, collection);
+                    })
+
                 });
             });
     }

diff --git a/lib/connection.js b/lib/connection.js
@@ -14,7 +14,6 @@ function Connection(uri, options) {
     var self = this;
 
     options || (options = {});
-    options.autoReconnect != null || (options.autoReconnect = true);
 
     // It's a Db instance.
     if (uri.collection) {
@@ -25,7 +24,7 @@ function Connection(uri, options) {
             self.client = client;
             self.db = client.db();
             self.emit('connect', self.db);
-            self.db.on('error', function (err) {
+            self.client.on('error', function (err) {
                 self.emit('error', err);
             });
         });
@@ -54,8 +53,8 @@ Object.defineProperty(Connection.prototype, 'state', {
         if (this.destroyed) {
             state = 'destroyed';
         }
-        else if (this.db) {
-            state = this.db.serverConfig.isConnected()
+        else if (this.client) {
+            state = this.client.topology.isConnected()
                 ? 'connected' : 'disconnected';
         } else {
             state = 'connecting';

diff --git a/package.json b/package.json
@@ -24,7 +24,7 @@
     "url": "git://github.com/NodeBB/mubsub.git"
   },
   "dependencies": {
-    "mongodb": "^3.6.0"
+    "mongodb": "^4.1.3"
   },
   "devDependencies": {
     "mocha": "^2.2.5"