bump mongodb and adapt code

lib/storage/metadata/mongoclient/LogConsumer.js

@@ -1,6 +1,6 @@
 'use strict'; // eslint-disable-line
 
-const MongoClient = require('mongodb').MongoClient;
+const { MongoClient } = require('mongodb');
 const ListRecordStream = require('./ListRecordStream');
 const MongoUtils = require('./utils');
 
@@ -16,10 +16,11 @@ class LogConsumer {
      * @param {string} logger - logger
      */
     constructor(mongoConfig, logger) {
-        const { authCredentials, replicaSetHosts, replicaSet, database } = mongoConfig;
+        const { authCredentials, replicaSetHosts, replicaSet, database, readPreference } = mongoConfig;
         const cred = MongoUtils.credPrefix(authCredentials);
         this._mongoUrl = `mongodb://${cred}${replicaSetHosts}/`;
         this._replicaSet = replicaSet;
+        this._readPreference = readPreference;
         this._logger = logger;
         this._oplogNsRegExp = new RegExp(`^${database}\\.`);
         // oplog collection
@@ -35,27 +36,29 @@ class LogConsumer {
      * @return {undefined}
     */
     connectMongo(done) {
-        MongoClient.connect(this._mongoUrl, {
+        const client = new MongoClient(this._mongoUrl, {
             replicaSet: this._replicaSet,
             useNewUrlParser: true,
-        },
-        (err, client) => {
-            if (err) {
-                this._logger.error('Unable to connect to MongoDB',
-                    { error: err });
-                return done(err);
-            }
+            useUnifiedTopology: true,
+            readPreference: this._readPreference,
+        });
+
+        client.connect().then(client => {
             this._logger.info('connected to mongodb');
-            // 'local' is the database where MongoDB has oplog.rs
-            // capped collection
+            // 'local' is the database where MongoDB has oplog.rs capped collection
             const db = client.db('local', {
                 ignoreUndefined: true,
             });
             this._coll = db.collection('oplog.rs');
             return done();
+        })
+        .catch(err => {
+            this._logger.error('Unable to connect to MongoDB', { error: err });
+            return done(err);
         });
     }
 
+
     /**
      * Open a tailable cursor to mongo oplog and retrieve a stream of
      * records to read

lib/storage/metadata/mongoclient/MongoClientInterface.js

@@ -19,7 +19,7 @@ const BucketInfo = require('../../../models/BucketInfo').default;
 const ObjectMD = require('../../../models/ObjectMD').default;
 const jsutil = require('../../../jsutil');
 
-const MongoClient = require('mongodb').MongoClient;
+const { MongoClient } = require('mongodb');
 const Uuid = require('uuid');
 const diskusage = require('diskusage');
 
@@ -148,7 +148,9 @@ class MongoClientInterface {
             !Number.isNaN(process.env.MONGO_POOL_SIZE)) {
             options.poolSize = Number.parseInt(process.env.MONGO_POOL_SIZE, 10);
         }
-        return MongoClient.connect(this.mongoUrl, options)
+        const client = new MongoClient(this.mongoUrl, options);
+
+        return client.connect()
             .then(client => {
                 this.logger.info('connected to mongodb');
                 this.client = client;
@@ -477,6 +479,8 @@ class MongoClientInterface {
         const m = this.getCollection(METASTORE);
         m.findOneAndDelete({
             _id: bucketName,
+        } , {
+            includeResultMetadata: true
         }, {})
             .then(result => {
                 if (result.ok !== 1) {
@@ -1296,6 +1300,7 @@ class MongoClientInterface {
             _id: masterKey,
             value: objVal,
         }, {
+            includeResultMetadata: true,
             upsert: true,
         }).then(result => {
             if (result.ok !== 1) {
@@ -1641,6 +1646,7 @@ class MongoClientInterface {
                     'value.deleted': true,
                 },
             }, {
+                includeResultMetadata : true,
                 upsert: false,
             }).then(doc => {
                 if (!doc.value) {
@@ -2624,8 +2630,9 @@ class MongoClientInterface {
                     value: objVal,
                 },
             }, {
+                includeResultMetadata: true,
                 upsert: true,
-            }).then(res => {
+            },).then(res => {
                 if (res.ok !== 1) {
                     log.error('failed to update object', {
                         method,

package.json

@@ -43,7 +43,7 @@
     "joi": "^17.13.3",
     "level": "~5.0.1",
     "level-sublevel": "~6.6.5",
-    "mongodb": "^5.2.0",
+    "mongodb": "^6.11.0",
     "node-forge": "^1.3.1",
     "prom-client": "^15.1.3",
     "simple-glob": "^0.2.0",