index.js

var http = require('http');
var https = require('https');
var fs = require('fs');
var net = require('net');
var url = require('url');
var path = require('path');
var multiparty = require('multiparty');

var uuid = require('uuid');

var log4js = require('log4js');
log4js.configure('log4js.json', { cwd: path.resolve(__dirname, '.') });

var user = require('./app/user');
var app = require('./app/app');

var logger = log4js.getLogger();

function request(req, resp) {
    var u = url.parse(req.url);

    var options = {
        hostname: u.hostname,
        port: u.port || 80,
        path: u.path,
        method: req.method,
        headers: req.headers
    };

    logger.debug("%s %s %s:%s%s", req.connection.remoteAddress, options.method, options.hostname, options.port, options.path);

    var header=req.headers['authorization']||'',        // get the header
        token=header.split(/\s+/).pop()||'',            // and the encoded auth token
        auth=new Buffer(token, 'base64').toString(),    // convert from base64
        parts=auth.split(/:/),                          // split on colon
        username=parts[0],
        password=parts[1];

    if(u.hostname == null){ // Non Proxy Request
        app(req, resp);
    } else { // Proxy Request
        resp.end();
        return;

        var forwardReq = http.request(options, function (forwardResp) {
            resp.writeHead(forwardResp.statusCode, forwardResp.headers);
            forwardResp.pipe(resp);
        }).on('error', function (e) {
            resp.end();
        });

        req.pipe(forwardReq);
    }
}

function connect(req, socket, headers) {
    var correlationId = uuid.v4();

    var u = url.parse('http://' + req.url);

    var options = {
        hostname : u.hostname,
        port     : u.port
    };

    logger.debug("%s %s %s %s:%s", correlationId , req.connection.remoteAddress, "CONNECT", options.hostname, options.port);

    if(!user.inWhiteList(req.connection.remoteAddress)){
        socket.end();
    }else{
        var forwardSocket = net.connect(options.port, options.hostname, function() {
            socket.write('HTTP/1.1 200 Connection Established\r\n\r\n');
            forwardSocket.pipe(socket);
        }).on('error', function(e) {
            logger.error("%s", correlationId, e);
            socket.end();
        }).on('close', function(had_error){
            logger.error("%s had_error", correlationId, had_error);
            forwardSocket.end();
        });
        socket.pipe(forwardSocket);
    }
}

var options = {
    //key: fs.readFileSync('./certs/privkey.pem'),
    //cert: fs.readFileSync('./certs/fullchain.pem')
    key: fs.readFileSync('./certs/privkey.pem'),
    cert: fs.readFileSync('./certs/fullchain.pem')
};

http.createServer()
    .on('request', request)
    .on('connect', connect)
    .listen(8080, '0.0.0.0', function(){
        logger.info("8080 listen");
    });

https.createServer(options)
    .on('request', request)
    .on('connect', connect)
    .listen(8443, '0.0.0.0', function(){
        logger.info("8443 listen");

        // var cookie = 'something=anything'
        //
        // // make a request to a tunneling proxy
        // var options = {
        //     port: 8443,
        //     hostname: '127.0.0.1',
        //     method: 'CONNECT',
        //     path: 'www.baidu.com:80',
        //     rejectUnauthorized: false
        // };
        //
        // var req = https.request(options);
        // req.setHeader("abc", "abc");
        // req.setHeader("Cookie", cookie);
        // req.end();
        //
        // req.on('connect', function(res, socket, head){
        //     logger.debug('got connected!');
        //
        //     // make a request over an HTTP tunnel
        //     socket.write('GET / HTTP/1.1\r\n' +
        //         'Host: www.baidu.com:80\r\n' +
        //         'Connection: close\r\n' +
        //         '\r\n');
        //     socket.on('data', function(chunk){
        //         logger.debug(chunk.toString());
        //     });
        //     socket.on('end', function(){
        //         //proxy.close();
        //     });
        // });
    });