1.0.30

package-lock.json

@@ -1,6 +1,6 @@
 {
   "name": "@pushrocks/smartproxy",
-  "version": "1.0.28",
+  "version": "1.0.30",
   "lockfileVersion": 1,
   "requires": true,
   "dependencies": {

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pushrocks/smartproxy",
-  "version": "1.0.28",
+  "version": "1.0.30",
   "private": false,
   "description": "a proxy for handling high workloads of proxying",
   "main": "dist/index.js",

ts/smartproxy.classes.proxyworker.ts

@@ -126,15 +126,17 @@ JNj2Dr5H0XoLFFnvuvzcRbhlJ9J67JzR+7g=
       });
     });
 
-    const Websocket = await import('ws');
-
     // Enable websockets
     const wss = new plugins.ws.Server({ server: this.httpsServer });
-    wss.on('connection', function connection(ws) {
+    wss.on('connection', (ws: plugins.ws) => {
       console.log('got connection for wsc');
       const wscConnected = plugins.smartpromise.defer();
 
-      const wsc = new Websocket.default(`${ws.url}`);
+      const wsc = new plugins.ws(this.router.routeWs(ws), {
+        headers: {
+          Host: ws.url
+        }
+      });
       wsc.on('open', () => {
         wscConnected.resolve();
       });

ts/smartproxy.classes.router.ts

@@ -21,4 +21,12 @@ export class SmartproxyRouter {
     });
     return correspodingReverseProxyConfig;
   }
+
+  public routeWs(ws: plugins.ws) {
+    const originalHost = plugins.url.parse(ws.url).host;
+    const correspodingReverseProxyConfig = this.reverseProxyConfigs.find(reverseConfig => {
+      return reverseConfig.hostName === originalHost;
+    });
+    return correspodingReverseProxyConfig.destinationIp;
+  }
 }

ts/smartproxy.plugins.ts

@@ -1,8 +1,9 @@
 // node native scope
 import * as http from 'http';
 import * as https from 'https';
+import * as url from 'url';
 
-export { http, https };
+export { http, https, url };
 
 // tsclass scope
 import * as tsclass from '@tsclass/tsclass';
@@ -18,6 +19,6 @@ import * as smartsystem from '@pushrocks/smartsystem';
 export { smartrequest, smartpromise, smartspawn, smartsystem };
 
 // third party scope
-import * as ws from 'ws';
+import ws from 'ws';
 
 export { ws };