80 lines
2.2 KiB
JavaScript
80 lines
2.2 KiB
JavaScript
'use strict';
|
|
|
|
var net = require('net');
|
|
var tls = require('tls');
|
|
|
|
function listenForConns(emitter, opts) {
|
|
function pipeConn(c, out) {
|
|
var sclient = tls.connect({
|
|
servername: opts.remoteAddr, host: opts.remoteAddr, port: opts.remotePort
|
|
, rejectUnauthorized: opts.rejectUnauthorized
|
|
}, function () {
|
|
console.info('[connect] ' + sclient.localAddress.replace('::1', 'localhost') + ":" + sclient.localPort
|
|
+ " => " + opts.remoteAddr + ":" + opts.remotePort);
|
|
c.pipe(sclient);
|
|
sclient.pipe(out || c);
|
|
});
|
|
sclient.on('error', function (err) {
|
|
console.error('[error] (remote) ' + err.toString());
|
|
});
|
|
c.on('error', function (err) {
|
|
console.error('[error] (local) ' + err.toString());
|
|
});
|
|
if (out) {
|
|
out.on('error', function (err) {
|
|
console.error('[error] (local) ' + err.toString());
|
|
});
|
|
}
|
|
}
|
|
|
|
if ('-' === opts.localAddress || '|' === opts.localAddress) {
|
|
pipeConn(opts.stdin, opts.stdout);
|
|
return;
|
|
}
|
|
|
|
var server = net.createServer(pipeConn);
|
|
server.on('error', function (err) {
|
|
console.error('[error] ' + err.toString());
|
|
});
|
|
server.listen({
|
|
host: opts.localAddress
|
|
, port: opts.localPort
|
|
}, function () {
|
|
opts.localPort = this.address().port;
|
|
opts.server = this;
|
|
emitter.emit('listening', opts);
|
|
});
|
|
}
|
|
|
|
function testConn(opts) {
|
|
var emitter = new (require('events').EventEmitter)();
|
|
|
|
// Test connection first
|
|
var tlsOpts = {
|
|
host: opts.remoteAddr, port: opts.remotePort
|
|
, rejectUnauthorized: opts.rejectUnauthorized
|
|
};
|
|
if (opts.servername) {
|
|
tlsOpts.servername = opts.servername;
|
|
} else if (/^[\w\.\-]+\.[a-z]{2,}$/i.test(opts.remoteAddr)) {
|
|
tlsOpts.servername = opts.remoteAddr.toLowerCase();
|
|
}
|
|
if (opts.alpn) {
|
|
tlsOpts.ALPNProtocols = [ 'http', 'h2' ];
|
|
}
|
|
var tlsSock = tls.connect(tlsOpts, function () {
|
|
setTimeout(function () {
|
|
tlsSock.end();
|
|
listenForConns(emitter, opts);
|
|
}, 200);
|
|
});
|
|
tlsSock.on('error', function (err) {
|
|
console.warn("[warn] '" + opts.remoteAddr + ":" + opts.remotePort + "' may not be accepting connections: ", err.toString(), '\n');
|
|
listenForConns(emitter, opts);
|
|
});
|
|
|
|
return emitter;
|
|
}
|
|
|
|
module.exports = testConn;
|