wip - intercepting json

.gitignore

@@ -5,3 +5,4 @@ _*
 Thumbs.db
 *.log
 node_modules
+.idea

examples/config-file-watcher/config.json

@@ -3,6 +3,6 @@
     {
         "name": "app-1",
         "hostnames": [ "localhost" ],
-        "endpoint": { "host": "127.0.0.1", "port": 3001 }
+        "endpoint": { "host": "www.bbc.co.uk", "port": 443 }
     }
 ]

examples/config-file-watcher/index.js

@@ -1,28 +1,52 @@
-
-'use strict';
-
-const fs = require('fs');
-const upstreamProxy = require('upstream-proxy');
-const chokidar = require('chokidar');
+"use strict";
+const HTTPParser = require("http-parser-js").HTTPParser;
+const fs = require("fs");
+const upstreamProxy = require("@markhigham/upstream-proxy");
+const chokidar = require("chokidar");
 
 const PORT = 3000;
-const configFile = './config.json';
+const configFile = "./config.json";
 
 let proxy = new upstreamProxy();
 
 let setConfigFromFile = () => {
-  fs.readFile(configFile, 'utf8', (err, data) => {
+  fs.readFile(configFile, "utf8", (err, data) => {
     if (err) throw err;
-    let result = proxy.setConfig( JSON.parse(data) );
-    console.log( `Config set: ${result}` );
+    const config = JSON.parse(data);
+    console.log(config);
+    let result = proxy.setConfig(config);
+    console.log(`Config set: ${result}`);
   });
-}
+};
 
-proxy.listen(PORT, () => {
-  console.log( `\nWebserver (USP) ist listening on port ${PORT}.` );
-  setConfigFromFile();
-}).start();
+proxy
+  .listen(PORT, () => {
+    console.log(`\nWebserver (USP) is listening on port ${PORT}.`);
+    setConfigFromFile();
+  })
+  .start();
 
-chokidar.watch(configFile).on('change', (event, path) => {
+chokidar.watch(configFile).on("change", (event, path) => {
   setConfigFromFile();
 });
+
+proxy.on("data", (data) => {
+  const parser = new HTTPParser(HTTPParser.RESPONSE);
+  parser.onHeadersComplete = (res) => {
+    // console.log(res.headers);
+  };
+
+  parser.onBody = (chunk, start, len) => {
+    console.log(`${chunk.toString("utf8", start, start + len)}`);
+  };
+
+  parser.onMessageComplete = () => {
+    // console.log('\nDone');
+  };
+
+  try {
+    parser.execute(data, 0, data.length);
+  } catch (e) {
+    console.log(e);
+  }
+});