node-http-proxy/index.js

var net = require('net');
var http = require('http');
var fs = require('fs');

class HttpRequest {
    constructor({attrs}) {
        this.attrs = attrs;

        this.logSomething = this.logSomething.bind(this);
    }

    // TODO - not working yet. will come back to this.
    logSomething() {
        fs.appendFile("proxy.log", this.attrs, (err) => {
            console.log("Got an error.");
        })
    }
}

/**
 * Parse an HTTP request.
 * @param {String} bytes 
 */
function parseHttpRequest(bytes) {
    let httpRequestAttrs = {headers: ""};

    bytes.split("\r\n").map((row) => {
        // Match against HTTP verbs from the first row.
        if (row.match('GET|POST|PUT|PATCH|UPDATE|DELETE')) {
            console.log("FIRST ROW");
            console.log(row);
            let typeInfo = row.split(" ");

            if (typeInfo.length !== 3) {
                console.log("Bad HTTP request");
                return null;
            }

            httpRequestAttrs["type"] = typeInfo[0];
            httpRequestAttrs["path"] = typeInfo[1];
            httpRequestAttrs["httpVersion"] = typeInfo[2];
        } else {
            httpRequestAttrs.headers = httpRequestAttrs.headers.concat(row + "\r\n");
        }
    });

    return new HttpRequest(httpRequestAttrs);
}

/**
 * Log the request and forward it.
 * @param {String} bytes 
 */
async function logAndSend(bytes) {
    console.log(bytes)
}

var server = net.createServer((socket) => {
    socket.on('end', (c) => {
        console.log("Client disconnected");
    });
    socket.on("data", (c) => {
        parseHttpRequest(c.toString()).log();
    });
})

server.on('connection', (c) => {
    console.log("Client connected!" + c.read(10));
});

server.on("listening", (c) => {
    console.log("LISTENING");
})

server.listen(8124, () => {
    console.log("Server bound.");
})

module.exports = [parseHttpRequest];