fix: add host/port to cmap connection

NODE-2731

Author: emadum

.evergreen/config.yml

@@ -179,7 +179,7 @@ functions:
         working_dir: src
         script: |
           KRB5_KEYTAB='${gssapi_auth_keytab_base64}' KRB5_PRINCIPAL='${gssapi_auth_principal}' \
-          MONGODB_URI='${gssapi_auth_mongodb_uri}' \
+          MONGODB_URI='${gssapi_auth_mongodb_uri}' UNIFIED=${UNIFIED} \
           NODE_LTS_NAME='${NODE_LTS_NAME}' bash ${PROJECT_DIRECTORY}/.evergreen/run-kerberos-tests.sh
   run ldap tests:
     - command: shell.exec
@@ -1074,13 +1074,26 @@ tasks:
     commands:
       - func: install dependencies
       - func: run atlas tests
-  - name: test-auth-kerberos
+  - name: test-auth-kerberos-legacy
     tags:
       - auth
       - kerberos
+      - legacy
     commands:
       - func: install dependencies
       - func: run kerberos tests
+        vars:
+          UNIFIED: 0
+  - name: test-auth-kerberos-unified
+    tags:
+      - auth
+      - kerberos
+      - unified
+    commands:
+      - func: install dependencies
+      - func: run kerberos tests
+        vars:
+          UNIFIED: 1
   - name: test-auth-ldap
     tags:
       - auth
@@ -1393,7 +1406,8 @@ buildvariants:
       - test-2.6-replica_set-unified
       - test-2.6-sharded_cluster-unified
       - test-atlas-connectivity
-      - test-auth-kerberos
+      - test-auth-kerberos-legacy
+      - test-auth-kerberos-unified
       - test-auth-ldap
       - test-tls-support
       - test-latest-ocsp-valid-cert-server-staples
@@ -1507,7 +1521,8 @@ buildvariants:
       - test-2.6-replica_set-unified
       - test-2.6-sharded_cluster-unified
       - test-atlas-connectivity
-      - test-auth-kerberos
+      - test-auth-kerberos-legacy
+      - test-auth-kerberos-unified
       - test-auth-ldap
   - name: ubuntu-14.04-dubnium
     display_name: Ubuntu 14.04 Node Dubnium
@@ -1583,7 +1598,8 @@ buildvariants:
       - test-3.2-replica_set-unified
       - test-3.2-sharded_cluster-unified
       - test-atlas-connectivity
-      - test-auth-kerberos
+      - test-auth-kerberos-legacy
+      - test-auth-kerberos-unified
       - test-auth-ldap
       - test-tls-support
       - test-latest-ocsp-valid-cert-server-staples

.evergreen/config.yml.in

@@ -218,7 +218,7 @@ functions:
         working_dir: src
         script: |
           KRB5_KEYTAB='${gssapi_auth_keytab_base64}' KRB5_PRINCIPAL='${gssapi_auth_principal}' \
-          MONGODB_URI='${gssapi_auth_mongodb_uri}' \
+          MONGODB_URI='${gssapi_auth_mongodb_uri}' UNIFIED=${UNIFIED} \
           NODE_LTS_NAME='${NODE_LTS_NAME}' bash ${PROJECT_DIRECTORY}/.evergreen/run-kerberos-tests.sh
 
   "run ldap tests":

.evergreen/generate_evergreen_tasks.js

@@ -109,11 +109,27 @@ TASKS.push(
     commands: [{ func: 'install dependencies' }, { func: 'run atlas tests' }]
   },
   {
-    name: 'test-auth-kerberos',
-    tags: ['auth', 'kerberos'],
+    name: 'test-auth-kerberos-legacy',
+    tags: ['auth', 'kerberos', 'legacy'],
     commands: [
       { func: 'install dependencies' },
-      { func: 'run kerberos tests' }
+      { func: 'run kerberos tests',
+        vars: {
+          UNIFIED: 0
+        }
+      }
+    ]
+  },
+  {
+    name: 'test-auth-kerberos-unified',
+    tags: ['auth', 'kerberos', 'unified'],
+    commands: [
+      { func: 'install dependencies' },
+      { func: 'run kerberos tests',
+        vars: {
+          UNIFIED: 1
+        }
+      }
     ]
   },
   {
@@ -311,6 +327,11 @@ const getTaskList = (() => {
         return true;
       }
 
+      // kerberos tests don't require mongo orchestration
+      if (task.tags.filter(tag => tag === 'kerberos').length) {
+        return true;
+      }
+
       const { VERSION } = tasksWithVars[0].vars || {};
       if (VERSION === 'latest') {
         return semver.satisfies(semver.coerce(LATEST_EFFECTIVE_VERSION), mongoVersion);

lib/cmap/connection.js

@@ -33,6 +33,8 @@ class Connection extends EventEmitter {
     this.address = streamIdentifier(stream);
     this.bson = options.bson;
     this.socketTimeout = typeof options.socketTimeout === 'number' ? options.socketTimeout : 360000;
+    this.host = options.host || 'localhost';
+    this.port = options.port || 27017;
     this.monitorCommands =
       typeof options.monitorCommands === 'boolean' ? options.monitorCommands : false;
     this.closed = false;

package.json

@@ -65,7 +65,7 @@
   },
   "scripts": {
     "atlas": "mocha --opts '{}' ./test/manual/atlas_connectivity.test.js",
-    "check:kerberos": "mocha --opts '{}' test/manual/kerberos.test.js",
+    "check:kerberos": "mocha --opts '{}' -t 60000 test/manual/kerberos.test.js",
     "check:ldap": "mocha --opts '{}' test/manual/ldap.test.js",
     "check:tls": "mocha --opts '{}' test/manual/tls_support.test.js",
     "test": "npm run lint && mocha --recursive test/functional test/unit test/core",

test/manual/kerberos.test.js

@@ -3,6 +3,8 @@ const MongoClient = require('../..').MongoClient;
 const chai = require('chai');
 const expect = chai.expect;
 
+const clientOptions = parseInt(process.env.UNIFIED) ? { useUnifiedTopology: true } : {};
+
 describe('Kerberos', function() {
   if (process.env.MONGODB_URI == null) {
     console.log('skipping Kerberos tests, MONGODB_URI environment variable is not defined');
@@ -19,7 +21,7 @@ describe('Kerberos', function() {
   }
 
   it('should authenticate with original uri', function(done) {
-    const client = new MongoClient(krb5Uri);
+    const client = new MongoClient(krb5Uri, clientOptions);
     client.connect(function(err, client) {
       expect(err).to.not.exist;
       client
@@ -37,7 +39,8 @@ describe('Kerberos', function() {
 
   it('validate that SERVICE_REALM and CANONICALIZE_HOST_NAME can be passed in', function(done) {
     const client = new MongoClient(
-      `${krb5Uri}&authMechanismProperties=SERVICE_NAME:mongodb,CANONICALIZE_HOST_NAME:false,SERVICE_REALM:windows&maxPoolSize=1`
+      `${krb5Uri}&authMechanismProperties=SERVICE_NAME:mongodb,CANONICALIZE_HOST_NAME:false,SERVICE_REALM:windows&maxPoolSize=1`,
+      clientOptions
     );
     client.connect(function(err, client) {
       expect(err).to.not.exist;
@@ -56,7 +59,8 @@ describe('Kerberos', function() {
 
   it('should authenticate with additional authentication properties', function(done) {
     const client = new MongoClient(
-      `${krb5Uri}&authMechanismProperties=SERVICE_NAME:mongodb,CANONICALIZE_HOST_NAME:false&maxPoolSize=1`
+      `${krb5Uri}&authMechanismProperties=SERVICE_NAME:mongodb,CANONICALIZE_HOST_NAME:false&maxPoolSize=1`,
+      clientOptions
     );
     client.connect(function(err, client) {
       expect(err).to.not.exist;
@@ -75,11 +79,13 @@ describe('Kerberos', function() {
 
   it('should fail to authenticate with bad credentials', function(done) {
     const client = new MongoClient(
-      krb5Uri.replace(encodeURIComponent(process.env.KRB5_PRINCIPAL), 'bad%40creds.cc')
+      krb5Uri.replace(encodeURIComponent(process.env.KRB5_PRINCIPAL), 'bad%40creds.cc'),
+      clientOptions
     );
     client.connect(function(err) {
       expect(err).to.exist;
       expect(err.message).to.match(/Authentication failed/);
+      expect(client.isConnected()).to.be.false;
       done();
     });
   });