fix: honor journal=true in connection string

lib/connection_string.js

@@ -427,7 +427,7 @@ function parseQueryString(query, options) {
 
   // special cases for known deprecated options
   if (result.wtimeout && result.wtimeoutms) {
-    delete result.wtimeout;
+    result.wtimeout = undefined;
     console.warn('Unsupported option `wtimeout` specified');
   }
 

lib/operations/connect.js

@@ -212,6 +212,12 @@ function connect(mongoClient, url, options, callback) {
       delete _finalOptions.db_options.auth;
     }
 
+    // `journal` should be translated to `j` for the driver
+    if (_finalOptions.journal != null) {
+      _finalOptions.j = _finalOptions.journal;
+      _finalOptions.journal = undefined;
+    }
+
     // resolve tls options if needed
     resolveTLSOptions(_finalOptions);
 

test/functional/shared.js

@@ -75,6 +75,13 @@ function makeCleanupFn(client) {
   };
 }
 
+/**
+ * Safely perform a test with provided MongoClient, ensuring client won't leak.
+ *
+ * @param {MongoClient} client
+ * @param {Function|Promise} operation
+ * @param {Function|Promise} [errorHandler]
+ */
 function withClient(client, operation, errorHandler) {
   const cleanup = makeCleanupFn(client);
 
@@ -192,13 +199,29 @@ class EventCollector {
   }
 }
 
-function withMonitoredClient(commands, callback) {
+/**
+ * Perform a test with a monitored MongoClient that will filter for certain commands.
+ *
+ * @param {string|Array} commands commands to filter for
+ * @param {object} [options] options to pass on to configuration.newClient
+ * @param {object} [options.dbOptions] connection string options
+ * @param {object} [options.serverOptions] MongoClient options
+ * @param {withMonitoredClientCallback} callback the test function
+ */
+function withMonitoredClient(commands, options, callback) {
+  if (arguments.length === 2) {
+    callback = options;
+    options = {};
+  }
   if (!Object.prototype.hasOwnProperty.call(callback, 'prototype')) {
     throw new Error('withMonitoredClient callback can not be arrow function');
   }
   return function(done) {
     const configuration = this.configuration;
-    const client = configuration.newClient({ monitorCommands: true });
+    const client = configuration.newClient(
+      Object.assign({ monitorCommands: true }, options.dbOptions),
+      Object.assign({}, options.serverOptions)
+    );
     const events = [];
     client.on('commandStarted', filterForCommands(commands, events));
     client.connect((err, client) => {
@@ -211,6 +234,13 @@ function withMonitoredClient(commands, callback) {
   };
 }
 
+/**
+ * @callback withMonitoredClientCallback
+ * @param {MongoClient} client monitored client
+ * @param {Array} events record of monitored commands
+ * @param {Function} done trigger end of test and cleanup
+ */
+
 module.exports = {
   connectToDb,
   setupDatabase,

test/functional/write_concern.test.js

@@ -1,8 +1,11 @@
 'use strict';
 
+const chai = require('chai');
+const expect = chai.expect;
 const TestRunnerContext = require('./spec-runner').TestRunnerContext;
 const generateTopologyTests = require('./spec-runner').generateTopologyTests;
 const loadSpecTests = require('../spec').loadSpecTests;
+const { withMonitoredClient } = require('./shared');
 
 describe('Write Concern', function() {
   describe('spec tests', function() {
@@ -16,4 +19,40 @@ describe('Write Concern', function() {
 
     generateTopologyTests(testSuites, testContext);
   });
+
+  // TODO - implement `read-write-concern/connection-string` spec tests
+  describe('test journal connection string option', function() {
+    const dbOptions = { journal: true };
+    const serverOptions = { j: true };
+    function writeConcernJournalOptionTest(client, events, done) {
+      expect(client).to.have.nested.property('s.options');
+      const clientOptions = client.s.options;
+      expect(clientOptions).to.containSubset({ j: true });
+      client
+        .db('test')
+        .collection('test')
+        .insertOne({ a: 1 }, (err, result) => {
+          expect(err).to.not.exist;
+          expect(result).to.exist;
+          expect(events)
+            .to.be.an('array')
+            .with.lengthOf(1);
+          expect(events[0]).to.containSubset({
+            commandName: 'insert',
+            command: {
+              writeConcern: { j: true }
+            }
+          });
+          done();
+        });
+    }
+    it(
+      'should set write concern with journal=true connection string option',
+      withMonitoredClient('insert', { dbOptions }, writeConcernJournalOptionTest)
+    );
+    it(
+      'should set write concern with j: true client option',
+      withMonitoredClient('insert', { serverOptions }, writeConcernJournalOptionTest)
+    );
+  });
 });