1.0.14

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pushrocks/smartproxy",
-  "version": "1.0.4",
+  "version": "1.0.14",
   "private": false,
   "description": "a proxy for handling high workloads of proxying",
   "main": "dist/index.js",
@@ -17,14 +17,15 @@
     "@gitzone/tstest": "^1.0.15",
     "@pushrocks/tapbundle": "^3.0.7",
     "@types/node": "^12.7.2",
-    "tslint": "^5.11.0",
+    "tslint": "^5.19.0",
     "tslint-config-prettier": "^1.15.0"
   },
   "dependencies": {
-    "@types/express": "^4.17.1",
+    "@pushrocks/smartpromise": "^3.0.2",
-    "@types/http-proxy-middleware": "^0.19.3",
+    "@pushrocks/smartrequest": "^1.1.20",
-    "express": "^4.17.1",
+    "@tsclass/tsclass": "^2.0.3",
-    "http-proxy-middleware": "^0.19.1"
+    "@types/ws": "^6.0.2",
+    "ws": "^7.1.2"
   },
   "files": [
     "ts/*",

test/test.ts

@@ -1,8 +1,18 @@
 import { expect, tap } from '@pushrocks/tapbundle';
 import * as smartproxy from '../ts/index';
 
+let testProxy: smartproxy.SmartProxy;
+
 tap.test('first test', async () => {
-  console.log(smartproxy);
+  testProxy = new smartproxy.SmartProxy();
+});
+
+tap.test('should start the testproxy', async () => {
+  await testProxy.start();
+});
+
+tap.test('should close the testproxy', async () => {
+  await testProxy.stop();
 });
 
 tap.start();

ts/interfaces/index.ts

@@ -1,6 +1,6 @@
 export interface IHostConfig {
   hostName: string;
-  destination: string;
+  destinationIp: string;
   destinationPort: number;
   privateKey: string;
   publicKey: string;

ts/smartproxy.classes.proxyworker.ts

@@ -0,0 +1,5 @@
+import * as plugins from './smartproxy.plugins';
+
+export class ProxyWorker {
+
+}

ts/smartproxy.classes.router.ts

@@ -1,3 +1,8 @@
 import * as plugins from './smartproxy.plugins';
 
-export class SmartproxyRouter {}
+export class SmartproxyRouter {
+
+  public routeReq(req: plugins.http.IncomingMessage) {
+    return 'lossless.gmbh';
+  }
+}

ts/smartproxy.classes.smartproxy.ts

@@ -2,10 +2,10 @@ import * as plugins from './smartproxy.plugins';
 import * as interfaces from './interfaces';
 
 import { SmartproxyRouter } from './smartproxy.classes.router';
+import { Socket } from 'net';
 
 export class SmartProxy {
-  public expressInstance: plugins.express.Express;
+  public httpsServer: plugins.https.Server | plugins.http.Server;
-  public httpsServer: plugins.https.Server;
   public router = new SmartproxyRouter();
 
   public hostCandidates: interfaces.IHostConfig[] = [];
@@ -19,11 +19,71 @@ export class SmartProxy {
    * starts the proxyInstance
    */
   public async start() {
-    this.expressInstance = plugins.express();
+    this.httpsServer = plugins.http.createServer(async (req, res) => {
-    this.httpsServer = plugins.https.createServer(this.expressInstance);
+      req.headers.host = this.router.routeReq(req);
+      const response = await plugins.smartrequest.request(
+        `https://${req.headers.host}${req.url}`,
+        {
+          method: req.method,
+          headers: req.headers
+        },
+        true
+      );
+      res.statusCode = response.statusCode;
+      for (const header of Object.keys(response.headers)) {
+        res.setHeader(header, response.headers[header]);
+      }
+      response.on('data', data => {
+        res.write(data);
+      });
+      response.on('end', () => {
+        res.end();
+      });
+    });
+    for (const hostCandidate of this.hostCandidates) {
+      /* this.httpsServer.addContext(hostCandidate.hostName, {
+        cert: hostCandidate.publicKey,
+        key: hostCandidate.privateKey
+      }); */
+    }
+
+    // Enable websockets
+    const wss = new plugins.ws.Server({ server: this.httpsServer });
+    wss.on('connection', function connection(ws) {
+      const wscConnected = plugins.smartpromise.defer();
+      const wsc = new plugins.ws(`${ws.url}`);
+      wsc.on('open', () => {
+        wscConnected.resolve();
+      });
+
+      ws.on('message', async (message) => {
+        await wscConnected.promise;
+        wsc.emit('message', message);
+      });
+      wsc.on('message', (message) => {
+        ws.emit('message', message);
+      });
+
+      // handle closing
+      ws.on('close', (message) => {
+        wsc.close();
+      });
+      wsc.on('close', (message) => {
+        ws.close();
+      });
+    });
+
+    this.httpsServer.listen(3000);
   }
 
   public async update() {
     await this.start();
   }
+
+  public async stop() {
+    const done = plugins.smartpromise.defer();
+    this.httpsServer.close(() => {
+      done.resolve();
+    });
+  }
 }

ts/smartproxy.plugins.ts

@@ -1,10 +1,22 @@
 // node native scope
-import * as https from 'https';
+import crypto from 'crypto';
+import http from 'http';
+import https from 'https';
 
-export { https };
+export { crypto, http, https };
+
+// pushrocks scope
+import * as smartpromise from '@pushrocks/smartpromise';
+import * as smartrequest from '@pushrocks/smartrequest';
+
+export {
+  smartrequest,
+  smartpromise
+};
 
 // third party scope
-import express from 'express';
+import ws from 'ws';
-import * as httpProxyMiddleware from 'http-proxy-middleware';
 
-export { express, httpProxyMiddleware };
+export {
+  ws
+};