Merge pull request #43 from seanstern/fix-monogodb-vulnerability

Update mongodb dependency to ^3.2.7

Author: danielgerlag

providers/workflow-es-mongodb/package.json

@@ -1,6 +1,6 @@
 {
   "name": "workflow-es-mongodb",
-  "version": "2.1.0",
+  "version": "2.1.1",
   "description": "MongoDB provider for Workflow ES",
   "main": "./build/src/index.js",
   "typings": "./build/src/index.d.ts",
@@ -29,7 +29,7 @@
   "dependencies": {
     "inversify": "^4.1.0",
     "json-stable-stringify": "^1.0.1",
-    "mongodb": "^2.2.11",
+    "mongodb": "^3.2.7",
     "reflect-metadata": "^0.1.10",
     "workflow-es": "^2.1.0"
   },

providers/workflow-es-mongodb/src/mongodb-provider.ts

@@ -4,7 +4,7 @@ import { MongoClient, ObjectID } from "mongodb";
 export class MongoDBPersistence implements IPersistenceProvider {
 
     public connect: Promise<void>;
-    private db: any;
+    private client: any;
     private workflowCollection: any;
     private subscriptionCollection: any;
     private eventCollection: any;
@@ -13,14 +13,16 @@ export class MongoDBPersistence implements IPersistenceProvider {
 
     constructor(connectionString: string) {
         var self = this;
-        this.connect = new Promise<void>((resolve, reject) => {            
-            MongoClient.connect(connectionString, (err, db) => {
+        this.connect = new Promise<void>((resolve, reject) => {  
+            const options =  { useNewUrlParser: true,  useUnifiedTopology: true };
+            MongoClient.connect(connectionString, options, (err, client) => {
                 if (err)
                     reject(err);
-                self.db = db;
-                self.workflowCollection = self.db.collection("workflows");
-                self.subscriptionCollection = self.db.collection("subscriptions");
-                self.eventCollection = self.db.collection("events");
+                self.client = client;
+                const db = self.client.db();
+                self.workflowCollection = db.collection("workflows");
+                self.subscriptionCollection = db.collection("subscriptions");
+                self.eventCollection = db.collection("events");
                 resolve();
             });
         });