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 0@39.yt (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;