fix: IPv6 is not supported when using dns service discovery

Both server class and monitoring class split the address string on ":" and
assumed it would return address and port tuple. To handle IPv6 addresses
we need to use the number at the end of the address and keep the IPv6
address from being split. This consolidates the logic into ServerDescription
getters.

NODE-2671

Author: nbbeeken

lib/core/sdam/monitor.js

@@ -69,12 +69,11 @@ class Monitor extends EventEmitter {
     });
 
     // TODO: refactor this to pull it directly from the pool, requires new ConnectionPool integration
-    const addressParts = server.description.address.split(':');
     const connectOptions = Object.assign(
       {
         id: '<monitor>',
-        host: addressParts[0],
-        port: parseInt(addressParts[1], 10),
+        host: server.description.host,
+        port: server.description.port,
         bson: server.s.bson,
         connectionType: Connection
       },

lib/core/sdam/server.js

@@ -115,9 +115,8 @@ class Server extends EventEmitter {
 
     // create the connection pool
     // NOTE: this used to happen in `connect`, we supported overriding pool options there
-    const addressParts = this.description.address.split(':');
     const poolOptions = Object.assign(
-      { host: addressParts[0], port: parseInt(addressParts[1], 10), bson: this.s.bson },
+      { host: this.description.host, port: this.description.port, bson: this.s.bson },
       options
     );
 

lib/core/sdam/server_description.js

@@ -116,6 +116,16 @@ class ServerDescription {
     return WRITABLE_SERVER_TYPES.has(this.type);
   }
 
+  get host() {
+    const chopLength = `:${this.port}`.length;
+    return this.address.slice(0, -chopLength);
+  }
+
+  get port() {
+    const port = this.address.split(':').pop();
+    return port ? Number.parseInt(port, 10) : port;
+  }
+
   /**
    * Determines if another `ServerDescription` is equal to this one per the rules defined
    * in the {@link https://github.com/mongodb/specifications/blob/master/source/server-discovery-and-monitoring/server-discovery-and-monitoring.rst#serverdescription|SDAM spec}

test/unit/sdam/monitoring.test.js

@@ -4,6 +4,7 @@ const BSON = require('bson');
 const Topology = require('../../../lib/core/sdam/topology').Topology;
 const Monitor = require('../../../lib/core/sdam/monitor').Monitor;
 const ServerType = require('../../../lib/core/sdam/common').ServerType;
+const ServerDescription = require('../../../lib/core/sdam/server_description').ServerDescription;
 const expect = require('chai').expect;
 
 class MockServer {
@@ -12,10 +13,8 @@ class MockServer {
       bson: new BSON()
     };
 
-    this.description = {
-      type: ServerType.Unknown,
-      address: `${options.host}:${options.port}`
-    };
+    this.description = new ServerDescription(`${options.host}:${options.port}`);
+    this.description.type = ServerType.Unknown;
   }
 }
 

test/unit/sdam/server_description.test.js

@@ -41,4 +41,10 @@ describe('ServerDescription', function() {
       });
     });
   });
+
+  it('should sensibly parse an ipv6 address', function() {
+    const description = new ServerDescription('abcd:f::abcd:abcd:abcd:abcd:27017');
+    expect(description.host).to.equal('abcd:f::abcd:abcd:abcd:abcd');
+    expect(description.port).to.equal(27017);
+  });
 });