fix: Wait for the tunnel to close before finishing client close COMPA…

…SS-4474 (#352)

* fix: Wait for the tunnel to close before finishing client close

* fix: Update ssh-tunnel mock to match new implementation

* fix: Only pick up errors that originated in ssh-client

* fix: Increase the timeout to make sure tunnel has a chance to start (and fail) before server stops trying

* refactor: Async-ify create tunnel and connect tasks; Expose tunnel through connect instead of overriding client.close method

* refactor: Pass tunnel as function parameter

* fix: Bump ssh-tunnel version once more

* refactor: Asyncify awaiting on tunnel error

Co-authored-by: Anna Henningsen <anna@addaleax.net>

* fix: Change spied close method

Co-authored-by: Anna Henningsen <anna@addaleax.net>

.vscode/settings.json

@@ -1,5 +1,5 @@
 {
-  "editor.formatOnSave": true,
+  "editor.formatOnSave": false,
   "editor.tabSize": 2,
   "editor.insertSpaces": true,
   "files.trimTrailingWhitespace": true,

lib/connect.js

@@ -1,4 +1,4 @@
-const { EventEmitter } = require('events');
+const { EventEmitter, once } = require('events');
 const fs = require('fs');
 const async = require('async');
 const {
@@ -12,7 +12,7 @@ const {
 const { MongoClient } = require('mongodb');
 const { parseConnectionString } = require('mongodb/lib/core');
 const Connection = require('./extended-model');
-const createSSHTunnel = require('./ssh-tunnel');
+const { default: SSHTunnel } = require('@mongodb-js/ssh-tunnel');
 
 const debug = require('debug')('mongodb-connection-model:connect');
 
@@ -125,8 +125,9 @@ const getTasks = (model, setupListeners) => {
   const tasks = {};
   const _statuses = {};
   let options = {};
-  let tunnel;
-  let client;
+  /** @type {SSHTunnel} */
+  let tunnel = null;
+  let client = null;
 
   const status = (message, cb) => {
     if (_statuses[message]) {
@@ -189,19 +190,27 @@ const getTasks = (model, setupListeners) => {
   });
 
   assign(tasks, {
-    [Tasks.CreateSSHTunnel]: (cb) => {
-      const ctx = status('Create SSH Tunnel', cb);
+    [Tasks.CreateSSHTunnel]: async() => {
+      const ctx = status('Create SSH Tunnel');
 
       if (model.sshTunnel === 'NONE') {
         return ctx.skip('The selected SSH Tunnel mode is NONE.');
       }
 
-      tunnel = createSSHTunnel(model, ctx);
+      tunnel = new SSHTunnel(model.sshTunnelOptions);
+
+      try {
+        await tunnel.listen();
+        ctx(null);
+      } catch (err) {
+        ctx(err);
+        throw err;
+      }
     }
   });
 
   assign(tasks, {
-    [Tasks.ConnectToMongoDB]: (cb) => {
+    [Tasks.ConnectToMongoDB]: async() => {
       const ctx = status('Connect to MongoDB');
 
       // @note: Durran:
@@ -215,6 +224,7 @@ const getTasks = (model, setupListeners) => {
 
       validOptions.useNewUrlParser = true;
       validOptions.useUnifiedTopology = true;
+
       if (
         model.directConnection === undefined &&
         model.hosts.length === 1 &&
@@ -234,29 +244,37 @@ const getTasks = (model, setupListeners) => {
         setupListeners(mongoClient);
       }
 
-      mongoClient.connect((err, _client) => {
-        ctx(err);
-
-        if (err) {
-          if (tunnel) {
-            debug('data-service connection error, shutting down ssh tunnel');
-            tunnel.close();
+      /** @type {Promise<never>} */
+      const waitForTunnelError = (async() => {
+        const [error] = await once(tunnel || new EventEmitter(), 'error');
+        throw error;
+      })();
+
+      const closeTunnelOnError = async(tunnelToClose) => {
+        if (tunnelToClose) {
+          debug('data-service connection error, shutting down ssh tunnel');
+          try {
+            await tunnelToClose.close();
+            debug('ssh tunnel stopped');
+          } catch (err) {
+            debug('ssh tunnel stopped with error: %s', err.message);
           }
-
-          return cb(err);
         }
+      };
 
+      try {
+        const _client = await Promise.race([
+          mongoClient.connect(),
+          waitForTunnelError
+        ]);
         client = _client;
-
-        if (tunnel) {
-          client.on('close', () => {
-            debug('data-service disconnected. shutting down ssh tunnel');
-            tunnel.close();
-          });
-        }
-
-        cb(null, { url: model.driverUrlWithSsh, options: validOptions });
-      });
+        ctx(null);
+        return { url: model.driverUrlWithSsh, options: validOptions };
+      } catch (err) {
+        await closeTunnelOnError(tunnel);
+        ctx(err);
+        throw err;
+      }
     }
   });
 
@@ -332,7 +350,7 @@ const connect = (model, setupListeners, done) => {
 
     logTaskStatus('Successfully connected');
 
-    return done(null, tasks.client, connectionOptions);
+    return done(null, tasks.client, tasks.tunnel, connectionOptions);
   });
 
   return tasks.state;

package.json

@@ -16,13 +16,14 @@
   "scripts": {
     "ci": "npm run check && npm test",
     "pretest": "mongodb-runner install",
-    "test": "mocha",
+    "test": "mocha --timeout 15000",
     "check": "mongodb-js-precommit"
   },
   "peerDependencies": {
     "mongodb": "3.x"
   },
   "dependencies": {
+    "@mongodb-js/ssh-tunnel": "^1.2.0",
     "ampersand-model": "^8.0.0",
     "ampersand-rest-collection": "^6.0.0",
     "async": "^3.1.0",