Bump mongodb to 6.5.0

README.md

@@ -57,7 +57,7 @@ The MongoDB transport takes the following options. Only option `db` is required:
 | ------ | :----------------------------------------------- |
 | db     | **REQUIRED**. MongoDB connection uri, pre-connected `MongoClient` object or promise which resolves to a pre-connected `MongoClient` object. |
 | dbname | The database name to connect to, defaults to DB name based on connection URI if not provided, ignored if using a pre-connected connection. |
-| options| MongoDB connection parameters.<br/>Defaults to `{poolSize: 2, autoReconnect: true, useNewUrlParser: true}`). |
+| options| MongoDB connection parameters.<br/>Defaults to `{maxPoolSize: 2}`). |
 | collection | The name of the collection you want to store log messages in.<br/>Defaults to `log`. |
 | level  | Level of messages that this transport should log.<br/>Defaults to `info`. |
 | silent | Boolean flag indicating whether to suppress output.<br/>Defaults to `false`. |

lib/helpers.js

@@ -5,7 +5,7 @@
  * @author [email protected] (Yurij Mikhalevich)
  */
 'use strict';
-const ObjectID = require('mongodb').ObjectID;
+const ObjectId = require('mongodb').ObjectId;
 
 
 /**
@@ -26,9 +26,9 @@
  * @param {Array} optParents Object's parents
  * @returns {Object} Adjusted clone of object
  */
 function cloneMeta(node, optParents) {
   if (!((node !== null && typeof node === 'object') || typeof node === 'function')
-      || (node instanceof ObjectID) || (node instanceof Buffer)) {
+      || (node instanceof ObjectId) || (node instanceof Buffer)) {
     return node;
   }
   let copy = Array.isArray(node) ? [] : {};
@@ -42,7 +42,7 @@
   optParents.push(node);
   for (const key in node) {
     if (!Object.prototype.hasOwnProperty.call(node, key)) {
       continue;
     }
     const value = node[key];
     let newKey = key;

lib/winston-mongodb.js

@@ -54,7 +54,7 @@
  * @param {number} options.expireAfterSeconds Seconds before the entry is removed.
  * Do not use if capped is set.
  */
 const MongoDB = exports.MongoDB = function (options) {
   Transport.call(this, options);
   options = (options || {});
   if (!options.db) {
@@ -66,9 +66,7 @@
   this.options = options.options;
   if (!this.options) {
     this.options = {
-      poolSize: 2,
-      autoReconnect: true,
-      useNewUrlParser: true
+      maxPoolSize: 2
     };
   }
   this.collection = (options.collection || 'log');
@@ -90,7 +88,7 @@
   const self = this;
 
   function setupDatabaseAndEmptyQueue(db) {
     return createCollection(db).then(db => {
       self.logDb = db;
       processOpQueue();
     }, err => {
@@ -289,7 +287,7 @@
  * @param {Stream} stream Pass in a pre-existing stream.
  * @returns {Stream} Log stream for the transport
  */
 MongoDB.prototype.stream = function (options, stream) {
   options = options || {};
   stream = stream || new Stream();
   let start = options.start;