Created
September 22, 2016 20:44
-
-
Save rrva/22de896bda8a0dd55e360d20fad3b39c to your computer and use it in GitHub Desktop.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| var bunyan = require('bunyan'); | |
| var log = bunyan.createLogger({name: "sandbox"}]}); | |
| var net = require('net'); | |
| var fs = require('fs'); | |
| var Muxer = module.exports = function Muxer(options) { | |
| if (this.constructor.name !== 'Muxer') | |
| return new Muxer(options); | |
| this.services = []; | |
| return this; | |
| }; | |
| Muxer.prototype.addRule = Muxer.prototype.add = function(matcher, handler, callback) { | |
| var type = matcher.constructor.name; | |
| // Process matcher. | |
| if (type === 'RegExp') { | |
| var regex = matcher; | |
| matcher = function(chunk) { | |
| return regex.test(chunk.toString()); | |
| }; | |
| } else if (type === 'String') { | |
| var value = matcher; | |
| matcher = function(chunk) { | |
| return value === chunk.toString().substring(0, value.length); | |
| }; | |
| } else if (type !== 'Function') { | |
| throw new Error('Unknown handler type (can handle functions, regex and strings)'); | |
| } | |
| // Process handler (either a path or '[ADDRESS:]PORT'). | |
| if (fs.existsSync(handler)) { | |
| // make sure it's a socket | |
| var stat = fs.statSync(handler); | |
| if (! stat.isSocket()) | |
| throw new Error('Handler is a file, but not a socket'); | |
| handler = { file : handler }; | |
| } else { | |
| var address = '127.0.0.1'; | |
| var port = null; | |
| var s = String(handler).split(':'); | |
| if (s.length === 1) { | |
| port = s[0]; | |
| } else if (s.length === 2) { | |
| address = s[0] || address; | |
| port = s[1]; | |
| } | |
| if (port === null) | |
| throw new Error('Invalid handler address (should be "[ADDRESS:]PORT")'); | |
| handler = { | |
| address : address, | |
| port : port | |
| }; | |
| } | |
| // Add to list of services. | |
| this.services.push({ | |
| matcher : matcher, | |
| handler : handler, | |
| callback : callback | |
| }); | |
| // Done. | |
| return this; | |
| }; | |
| var timeouts = {}; | |
| var debugconns = {}; | |
| function socketKey(conn) { | |
| return conn.remoteAddress + ':' + conn.remotePort; | |
| } | |
| Muxer.prototype.listen = function() { | |
| var services = this.services; | |
| var server = this.server = net.createServer(function(conn) { | |
| var proxy = null; | |
| log.info("Received connection. Lets see what they want."); | |
| timeoutId = setTimeout(debugbanner, 1000, conn); | |
| timeouts[socketKey(conn)] = timeoutId; | |
| // Handle errors on connection. | |
| conn.on('error', function(e) { | |
| conn.destroy(); | |
| if (proxy) | |
| proxy.destroy(); | |
| // XXX: propagate to server? not for now. | |
| // server.emit('error', e); | |
| }); | |
| function debugbanner(conn) { | |
| log.info("We got a mute one, lets connect it to service 0"); | |
| var service = services[0]; | |
| proxy = net.connect(service.handler.port, service.handler.address); | |
| debugconns[socketKey(conn)] = proxy; | |
| // Wait for 'connect' event before we continue. | |
| proxy.once('connect', function() { | |
| // If rule has a callback, call it. | |
| if (typeof service.callback === 'function') { | |
| service.callback(proxy, conn, service); | |
| } | |
| // Pipe connection to proxy and vice versa. | |
| conn.pipe(proxy); | |
| proxy.pipe(conn); | |
| }); | |
| // Handle errors on proxy stream. | |
| proxy.on('error', function(e) { | |
| proxy.destroy(); | |
| conn.destroy(); | |
| // XXX: propagate to server? not for now. | |
| // server.emit('error', e); | |
| }); | |
| } | |
| // Wait for the first data event. | |
| conn.once('data', function(chunk) { | |
| if(typeof(debugconns[socketKey(conn)]) !== 'undefined') { | |
| return | |
| } | |
| log.info('data', chunk.toString()); | |
| timeoutId = timeouts[socketKey(conn)]; | |
| log.info("Found timeoutId, clearing it: ", socketKey(conn)); | |
| clearTimeout(timeoutId); | |
| // Find a matching service for this chunk. | |
| for (var i = 0, len = services.length; i < len; i++) { | |
| var service = services[i]; | |
| if (service.matcher(chunk) === true) { | |
| // Found one: create a connection to it. | |
| if (service.handler.file) { | |
| proxy = net.connect(service.handler.file); | |
| } else { | |
| proxy = net.connect(service.handler.port, service.handler.address); | |
| } | |
| // Wait for 'connect' event before we continue. | |
| proxy.once('connect', function() { | |
| // If rule has a callback, call it. | |
| if (typeof service.callback === 'function') { | |
| service.callback(proxy, conn, service); | |
| } | |
| // Write the first chunk of data. | |
| proxy.write(chunk); | |
| // Pipe connection to proxy and vice versa. | |
| conn.pipe(proxy); | |
| proxy.pipe(conn); | |
| }); | |
| // Handle errors on proxy stream. | |
| proxy.on('error', function(e) { | |
| proxy.destroy(); | |
| conn.destroy(); | |
| // XXX: propagate to server? not for now. | |
| // server.emit('error', e); | |
| }); | |
| // Done. | |
| return; | |
| } | |
| } | |
| // No matcher found: destroy connection. | |
| return conn.destroy(); | |
| }); | |
| }); | |
| // Start listening. | |
| this.server.listen.apply(this.server, arguments); | |
| // Done. | |
| return this.server; | |
| }; |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment