main.js

var express = require("express");
var app = express();
var http = require("http").createServer(app);
var io = require("socket.io")(http);
var net = require("net");

var ip = process.argv.length > 2 ? process.argv[2] : "127.0.0.1";
if(!ip.includes(":")) ip += ":8003";

var port = process.argv.length > 3 ? parseInt(process.argv[3]) : 8080;

var buffer = [];

var options = {
	port: ip.split(':')[1],
	host: ip.split(':')[0]
};

var socket = net.connect(options, () => {
	console.log("connected to server");
});

function onErr() {
	setTimeout(attemptReconnect, 5000);
}

const allowedEvents = ["begin", "end", "player"];
function onDat(data) {
	console.log(data.toString());
	var lines = data.toString().split('\n');
	lines.forEach(line => {
		if (line.length < 1) return;
		var tokens = line.split(' ');
		if (tokens.length < 1) return;

		var event = tokens[0];
		if (allowedEvents.includes(event)) {
			buffer.push(line);
		}
	});

	if (buffer.includes("end")) {
		console.log(buffer);
		io.emit("addr", ip);
		io.emit("payload", buffer);
		buffer = [];
	}
}

function onEnd() {
	console.log("disconnected from server");
	io.emit("dc");
	setTimeout(attemptReconnect, 5000);
}

socket.on("data", onDat);
socket.on("end", onEnd);

function attemptReconnect() {
	console.log("attempting to reconnect...");
	io.emit("dc");
	socket = net.connect(options, () => {
		console.log("reconnected to server");
	});
	socket.on("error", onErr);
	socket.on("data", onDat);
	socket.on("end", onEnd);
}

app.get("/", (req, res) => {
	res.sendFile(__dirname + "/index.html");
});

app.use("/res", express.static("res"));

http.listen(port, () => {
	console.log("listening to " + ip + " on *:" + port);
});