tor-router/src/HTTPServer.js

const http = require('http');
const Server = http.Server;
const domain = require('domain');
const socks = require('socksv5');
const URL = require('url');
const SocksProxyAgent = require('socks-proxy-agent');

class HTTPServer extends Server {
	constructor(tor_pool, logger) {
		let handle_http_connections = (req, res) => {
			let d = domain.create();
			d.on('error', (error) => {
				this.logger.error(`[http-proxy]: an error occured: ${error.message}`)
				res.end();
			});
			d.add(req);
			d.add(res);

			let url = URL.parse(req.url); 
			url.port = url.port || 80;

			var buffer = [];

			function onIncomingData(chunk) {
				buffer.push(chunk);
			}

			function preConnectClosed() {
				req.finished = true;
			}

			req.on('data', onIncomingData);
			req.on('end', preConnectClosed);
			

			let connect = (tor_instance) => {
				let socks_port = tor_instance.socks_port;
				logger && logger.verbose(`[http-proxy]: ${req.connection.remoteAddress}:${req.connection.remotePort} → 127.0.0.1:${socks_port} → ${url.hostname}:${url.port}`);

				d.run(() => {
					let proxy_req = http.request({
						method: req.method,
						hostname: url.hostname, 
						port: url.port,
						path: url.path,
						headers: req.headers,
						agent: new SocksProxyAgent(`socks://127.0.0.1:${socks_port}`)
					}, (proxy_res) => {
						d.add(proxy_res);
						proxy_res.on('data', (chunk) => {
							res.write(chunk);
						});

						proxy_res.on('end', () => {
							res.end();
						});

						res.writeHead(proxy_res.statusCode, proxy_res.headers);
					});

					req.removeListener('data', onIncomingData);

					req.on('data', (chunk) => {
						proxy_req.write(chunk);
					})

					req.on('end', () => {
						proxy_req.end();
					})

					while (buffer.length) {
						proxy_req.write(buffer.shift());
					}

					if (req.finished) 
						proxy_req.end();

					d.add(proxy_req);
				});
			};
			if (tor_pool.instances.length) {
				connect(tor_pool.next());
			} else {
				logger.debug(`[http-proxy]: a connection has been attempted, but no tor instances are live... waiting for an instance to come online`);
				tor_pool.once('instance_created', connect);
			}
		};

		let handle_connect_connections = (req, inbound_socket, head) => {
			let d = domain.create();

			d.add(inbound_socket);

			let hostname = req.url.split(':').shift();
			let port = Number(req.url.split(':').pop());

			let connect = (tor_instance) => {
				let socks_port = tor_instance.socks_port;
				logger && logger.verbose(`[http-connect]: ${req.connection.remoteAddress}:${req.connection.remotePort} → 127.0.0.1:${socks_port} → ${hostname}:${port}`)
				var outbound_socket;

				let onClose = (error) => {
					inbound_socket && inbound_socket.end();
					outbound_socket && outbound_socket.end();

					inbound_socket = outbound_socket = buffer = void(0);

					if (error)
						this.logger.error(`[http-connect]: an error occured: ${error.message}`)

					d.exit();
				};

				d.on('error', onClose);

				d.add(inbound_socket);

				var buffer = [head];
				let onInboundData = function (data) {
					buffer.push(data);
				};

				d.run(() => {
					socks.connect({
						host: hostname,
						port: port,
						proxyHost: '127.0.0.1',
						proxyPort: socks_port,
						localDNS: false,
						auths: [ socks.auth.None() ]
					}, ($outbound_socket) => {
						outbound_socket = $outbound_socket;
						d.add(outbound_socket);
						outbound_socket && outbound_socket.on('close', onClose);
						outbound_socket && outbound_socket.on('error', onClose);

						inbound_socket.write('HTTP/1.1 200 Connection Established\r\n'+'Proxy-agent: tor-router\r\n' +'\r\n');
						outbound_socket.write(head);

						outbound_socket.pipe(inbound_socket);
						inbound_socket.pipe(outbound_socket);
					})
				});
			};
			if (tor_pool.instances.length) {
				connect(tor_pool.next());
			} else {
				logger.debug(`[http-connect]: a connection has been attempted, but no tor instances are live... waiting for an instance to come online`);
				tor_pool.once('instance_created', connect);
			}
		};

		super(handle_http_connections);
		this.on('connect', handle_connect_connections);

		this.logger = logger;
		this.tor_pool = tor_pool;
	}
};

module.exports = HTTPServer;