Add support for unix domain sockets

Author: jondubois

lib/clientsocket.js

@@ -26,6 +26,8 @@ function AGClientSocket(socketOptions) {
   let defaultOptions = {
     path: '/socketcluster/',
     secure: false,
+    protocolScheme: null,
+    socketPath: null,
     autoConnect: true,
     autoReconnect: true,
     autoSubscribeOnConnect: true,

lib/transport.js

@@ -129,7 +129,12 @@ AGTransport.CLOSED = AGTransport.prototype.CLOSED = 'closed';
 
 AGTransport.prototype.uri = function () {
   let query = this.options.query || {};
-  let schema = this.options.secure ? 'wss' : 'ws';
+  let scheme;
+  if (this.options.protocolScheme == null) {
+    scheme = this.options.secure ? 'wss' : 'ws';
+  } else {
+    scheme = this.options.protocolScheme;
+  }
 
   if (this.options.timestampRequests) {
     query[this.options.timestampParam] = (new Date()).getTime();
@@ -142,19 +147,25 @@ AGTransport.prototype.uri = function () {
   }
 
   let host;
-  if (this.options.host) {
-    host = this.options.host;
-  } else {
-    let port = '';
+  let path;
+  if (this.options.socketPath == null) {
+    if (this.options.host) {
+      host = this.options.host;
+    } else {
+      let port = '';
 
-    if (this.options.port && ((schema === 'wss' && this.options.port !== 443)
-      || (schema === 'ws' && this.options.port !== 80))) {
-      port = ':' + this.options.port;
+      if (this.options.port && ((scheme === 'wss' && this.options.port !== 443)
+        || (scheme === 'ws' && this.options.port !== 80))) {
+        port = ':' + this.options.port;
+      }
+      host = this.options.hostname + port;
     }
-    host = this.options.hostname + port;
+    path = this.options.path;
+  } else {
+    host = this.options.socketPath;
+    path = `:${this.options.path}`;
   }
-
-  return schema + '://' + host + this.options.path + query;
+  return scheme + '://' + host + path + query;
 };
 
 AGTransport.prototype._onOpen = async function () {