tcp-crypto.js
function Server (opts) { 
	let server = this;
	server.send = send;
	let isBusy = true;
	
	let queue = [];
	if (!!opts.dir) {
		try {
			fs.mkdirSync(opts.dir); // default './outbox'
		} catch(err) {
			if (err.code != 'EEXIST') 
				throw err;
		}	
	
		queue = fs.readdirSync(opts.dir)
			.map(function (f) { 
				return {
					id: f.split('.')[0], 
					event: f.split('.')[1], 
					data: fs.readFileSync(`${opts.dir}/${f}`)
				};
			})
			.map(function (msg) { 
				try { 
					msg.data = JSON.parse(msg.data);
				} catch (err) { 
					server.emit('error', 'Error on parse ${msg.id}: ' + err.message); 
					msg.data = ''
				}; 
				return msg;
			})
			.filter((msg) => !!msg.data);	
		queue.add = function (msg) {
			this.push(msg);
			fs.writeFileSync(`${opts.dir}/${msg.id}.${msg.event}`, JSON.stringify(msg.data), {'flags': 'a'});
		}

	} else {
		queue.add = function (msg) {
			this.push(msg);
		}
	}

	function send(event, data, id) {
		queue.add({event, data, id: id || genId()});
		if (server.next)
			server.next();
	}

	let netServer = net.createServer(function(socket){
		isBusy = false;
		server.next = next;
		server.emit('connection', opts.id);
		next();
		
		function next() {
			if (isBusy)
				return;

			isBusy = true;

			if (queue.length == 0) 
				return (isBusy = false);
	
			if (socket)
				socket.write((!!opts.cipher ? encode(JSON.stringify(queue[0]), opts.cipher, opts.password) : JSON.stringify(queue[0])) + '|', () => { 
					server.emit('send', queue[0]);
					queue.shift();
					isBusy = false; 
					next(); 
				});
		}
		
		let buffer = '';
		socket.on('data', function(chunk) {
			buffer += chunk;
			if (buffer.indexOf('|') == -1)
				return;
	
			let msgs = buffer.split('|');
			buffer = msgs.pop();

			msgs.forEach(function(packet){

				let msg;
				try { 
					msg = JSON.parse(!!opts.cipher ? decode(packet, opts.cipher, opts.password) : packet);
				} catch(err) { 
					return socket.emit('error', err);
				}	
				server.emit('receive', msg);
				
				if (msg.event == 'ACK' && !!opts.dir) {
					fs.unlink(`${opts.dir}/${msg.data.id}.${msg.data.event}`, (err) => err ? console.log(err) : null);
					return;
				}
		
				server.emit(msg.event, msg.data, msg.id);
			});	
		});
	
		socket.on('close', () => { 
			server.emit('disconnection', opts.id) 
			socket = undefined; 
		});
	
		socket.on('error', (err) => server.emit('error', err));
	});
	netServer.maxConnections = 1;
	netServer.listen(opts.port, (err) => console.log(err ? err : 'Listen on ' + opts.port));	
	netServer.on('close', () => process.exit(1));
}
function Server (opts) { 
	let server = this;
	server.send = send;
	let isBusy = true;
	
	let queue = [];
	if (!!opts.dir) {
		try {
			fs.mkdirSync(opts.dir); // default './outbox'
		} catch(err) {
			if (err.code != 'EEXIST') 
				throw err;
		}	
	
		queue = fs.readdirSync(opts.dir)
			.map(function (f) { 
				return {
					id: f.split('.')[0], 
					event: f.split('.')[1], 
					data: fs.readFileSync(`${opts.dir}/${f}`)
				};
			})
			.map(function (msg) { 
				try { 
					msg.data = JSON.parse(msg.data);
				} catch (err) { 
					server.emit('error', 'Error on parse ${msg.id}: ' + err.message); 
					msg.data = ''
				}; 
				return msg;
			})
			.filter((msg) => !!msg.data);	
		queue.add = function (msg) {
			this.push(msg);
			fs.writeFileSync(`${opts.dir}/${msg.id}.${msg.event}`, JSON.stringify(msg.data), {'flags': 'a'});
		}

	} else {
		queue.add = function (msg) {
			this.push(msg);
		}
	}

	function send(event, data, id) {
		queue.add({event, data, id: id || genId()});
		if (server.next)
			server.next();
	}

	let netServer = net.createServer(function(socket){
		isBusy = false;
		server.next = next;
		server.emit('connection', opts.id);
		next();
		
		function next() {
			if (isBusy)
				return;

			isBusy = true;

			if (queue.length == 0) 
				return (isBusy = false);
	
			if (socket)
				socket.write((!!opts.cipher ? encode(JSON.stringify(queue[0]), opts.cipher, opts.password) : JSON.stringify(queue[0])) + '|', () => { 
					server.emit('send', queue[0]);
					queue.shift();
					isBusy = false; 
					next(); 
				});
		}
		
		let buffer = '';
		socket.on('data', function(chunk) {
			buffer += chunk;
			if (buffer.indexOf('|') == -1)
				return;
	
			let msgs = buffer.split('|');
			buffer = msgs.pop();

			msgs.forEach(function(packet){

				let msg;
				try { 
					msg = JSON.parse(!!opts.cipher ? decode(packet, opts.cipher, opts.password) : packet);
				} catch(err) { 
					return socket.emit('error', err);
				}	
				server.emit('receive', msg);
				
				if (msg.event == 'ACK' && !!opts.dir) {
					fs.unlink(`${opts.dir}/${msg.data.id}.${msg.data.event}`, (err) => err ? console.log(err) : null);
					return;
				}
		
				server.emit(msg.event, msg.data, msg.id);
			});	
		});
	
		socket.on('close', () => { 
			server.emit('disconnection', opts.id) 
			socket = undefined; 
		});
	
		socket.on('error', (err) => server.emit('error', err));
	});
	netServer.maxConnections = 1;
	netServer.listen(opts.port, (err) => console.log(err ? err : 'Listen on ' + opts.port));	
	netServer.on('close', () => process.exit(1));
}
function Server ( opts ) { let server = this ; server . send = send ; let isBusy = true ; let queue = [ ] ; if ( ! ! opts . dir ) { try { fs . mkdirSync ( opts . dir ) ; // default './outbox' } catch ( err ) { if ( err . code != 'EEXIST' ) throw err ; } queue = fs . readdirSync ( opts . dir ) . map ( function ( f ) { return { id : f . split ( '.' ) [ 0 ] , event : f . split ( '.' ) [ 1 ] , data : fs . readFileSync ( ` ${ opts . dir } ${ f } ` ) } ; } ) . map ( function ( msg ) { try { msg . data = JSON . parse ( msg . data ) ; } catch ( err ) { server . emit ( 'error' , 'Error on parse ${msg.id}: ' + err . message ) ; msg . data = '' } ; return msg ; } ) . filter ( ( msg ) => ! ! msg . data ) ; queue . add = function ( msg ) { this . push ( msg ) ; fs . writeFileSync ( ` ${ opts . dir } ${ msg . id } ${ msg . event } ` , JSON . stringify ( msg . data ) , { 'flags' : 'a' } ) ; } } else { queue . add = function ( msg ) { this . push ( msg ) ; } } function send ( event , data , id ) { queue . add ( { event , data , id : id || genId ( ) } ) ; if ( server . next ) server . next ( ) ; } let netServer = net . createServer ( function ( socket ) { isBusy = false ; server . next = next ; server . emit ( 'connection' , opts . id ) ; next ( ) ; function next ( ) { if ( isBusy ) return ; isBusy = true ; if ( queue . length == 0 ) return ( isBusy = false ) ; if ( socket ) socket . write ( ( ! ! opts . cipher ? encode ( JSON . stringify ( queue [ 0 ] ) , opts . cipher , opts . password ) : JSON . stringify ( queue [ 0 ] ) ) + '|' , ( ) => { server . emit ( 'send' , queue [ 0 ] ) ; queue . shift ( ) ; isBusy = false ; next ( ) ; } ) ; } let buffer = '' ; socket . on ( 'data' , function ( chunk ) { buffer += chunk ; if ( buffer . indexOf ( '|' ) == - 1 ) return ; let msgs = buffer . split ( '|' ) ; buffer = msgs . pop ( ) ; msgs . forEach ( function ( packet ) { let msg ; try { msg = JSON . parse ( ! ! opts . cipher ? decode ( packet , opts . cipher , opts . password ) : packet ) ; } catch ( err ) { return socket . emit ( 'error' , err ) ; } server . emit ( 'receive' , msg ) ; if ( msg . event == 'ACK' && ! ! opts . dir ) { fs . unlink ( ` ${ opts . dir } ${ msg . data . id } ${ msg . data . event } ` , ( err ) => err ? console . log ( err ) : null ) ; return ; } server . emit ( msg . event , msg . data , msg . id ) ; } ) ; } ) ; socket . on ( 'close' , ( ) => { server . emit ( 'disconnection' , opts . id ) socket = undefined ; } ) ; socket . on ( 'error' , ( err ) => server . emit ( 'error' , err ) ) ; } ) ; netServer . maxConnections = 1 ; netServer . listen ( opts . port , ( err ) => console . log ( err ? err : 'Listen on ' + opts . port ) ) ; netServer . on ( 'close' , ( ) => process . exit ( 1 ) ) ; }
opts = {port, cipher, password, dir}
opts = { port cipher password dir }