Support for publish_address as hostname/ip:port (#804)

lib/ConnectionPool.js

@@ -332,18 +332,33 @@ class ConnectionPool {
    * @param {object} nodes
    * @returns {array} hosts
    */
-  nodesToHost (nodes) {
+  nodesToHost (nodes, protocol) {
     const ids = Object.keys(nodes)
     const hosts = []
 
     for (var i = 0, len = ids.length; i < len; i++) {
       const node = nodes[ids[i]]
       // If there is no protocol in
-      // the `publish_address` new URL wil throw
+      // the `publish_address` new URL will throw
+      // the publish_address can have two forms:
+      //   - ip:port
+      //   - hostname/ip:port
+      // if we encounter the second case, we should
+      // use the hostname instead of the ip
       var address = node.http.publish_address
+      const hostAndIpRegex = /^[a-z0-9_.-]*\/\b\d{1,3}\.\d{1,3}\.\d{1,3}\.\d{1,3}\b/gi
+      const match = address.match(hostAndIpRegex)
+      if (match !== null) {
+        const ipRegex = /\b\d{1,3}\.\d{1,3}\.\d{1,3}\.\d{1,3}\b/
+        const ip = address.match(ipRegex)[0]
+        // extract the hostname, the -1 at the end removes the final /
+        const hostname = address.slice(0, address.indexOf(ip) - 1)
+        const port = address.split(':')[1]
+        address = `${hostname}:${port}`
+      }
       address = address.slice(0, 4) === 'http'
         ? address
-        : 'http://' + address
+        : `${protocol}//${address}`
       const roles = node.roles.reduce((acc, role) => {
         acc[role] = true
         return acc