From 1e03714a508bbebd6ca12d6cf98ba22c7d3eb276 Mon Sep 17 00:00:00 2001
From: Paul Shippy <paul.shippy@soleranetwork.com>
Date: Tue, 19 Feb 2019 10:45:05 -0700
Subject: [PATCH] update mongo methods to non-deprecated versions

---
 lib/databases/mongodb.js | 24 ++++++++++++------------
 1 file changed, 12 insertions(+), 12 deletions(-)

diff --git a/lib/databases/mongodb.js b/lib/databases/mongodb.js
index 6f77ffd1..4db4b506 100644
--- a/lib/databases/mongodb.js
+++ b/lib/databases/mongodb.js
@@ -263,18 +263,18 @@ _.extend(Mongo.prototype, {
     var self = this;
     async.parallel([
       function (callback) {
-        self.events.remove({}, callback);
+        self.events.deleteOne({}, callback);
       },
       function (callback) {
-        self.snapshots.remove({}, callback);
+        self.snapshots.deleteOne({}, callback);
       },
       function (callback) {
-        self.transactions.remove({}, callback);
+        self.transactions.deleteOne({}, callback);
       },
       function (callback) {
         if (!self.positions)
           return callback(null);
-        self.positions.remove({}, callback);
+        self.positions.deleteOne({}, callback);
       }
     ], function (err) {
       if (err) {
@@ -351,7 +351,7 @@ _.extend(Mongo.prototype, {
       }
 
       if (events.length === 1) {
-        return self.events.insert(events, callback);
+        return self.events.insertOne(events[0], callback);
       }
 
       var tx = {
@@ -362,14 +362,14 @@ _.extend(Mongo.prototype, {
         context: events[0].context
       };
 
-      self.transactions.insert(tx, function (err) {
+      self.transactions.insertOne(tx, function (err) {
         if (err) {
           debug(err);
           if (callback) callback(err);
           return;
         }
 
-        self.events.insert(events, function (err) {
+        self.events.insertMany(events, function (err) {
           if (err) {
             debug(err);
             if (callback) callback(err);
@@ -546,7 +546,7 @@ _.extend(Mongo.prototype, {
 
   setEventToDispatched: function (id, callback) {
     var updateCommand = { '$unset' : { 'dispatched': null } };
-    this.events.update({'_id' : id}, updateCommand, callback);
+    this.events.updateOne({'_id' : id}, updateCommand, callback);
   },
 
   addSnapshot: function(snap, callback) {
@@ -558,7 +558,7 @@ _.extend(Mongo.prototype, {
     }
 
     snap._id = snap.id;
-    this.snapshots.insert(snap, callback);
+    this.snapshots.insertOne(snap, callback);
   },
 
   cleanSnapshots: function (query, callback) {
@@ -634,7 +634,7 @@ _.extend(Mongo.prototype, {
     }
 
     // the following is usually unnecessary
-    this.transactions.remove(findStatement, function (err) {
+    this.transactions.deleteMany(findStatement, function (err) {
       if (err) {
         debug(err);
       }
@@ -677,7 +677,7 @@ _.extend(Mongo.prototype, {
             return clb(null);
           }
           
-          self.transactions.remove({ _id: tx._id }, clb);
+          self.transactions.deleteOne({ _id: tx._id }, clb);
         });
       }, function (err) {
         if (err) {
@@ -742,7 +742,7 @@ _.extend(Mongo.prototype, {
 
       var missingEvts = tx.events.slice(tx.events.length - lastEvt.restInCommitStream);
 
-      self.events.insert(missingEvts, function (err) {
+      self.events.insertMany(missingEvts, function (err) {
         if (err) {
           debug(err);
           return callback(err);