var net = require('net'); //network
const ws = require('ws'); //websocket

var dexter_ip = process.argv[2] || "192.168.1.142"

//socket server to accept websockets from the browser on port 3000
//and forward them out to DexRun as a raw socket
var browser = new ws.Server({ port:3000 });
var dexter = null; // open a new socket every time ._.

console.log("waiting for connection on localhost:3000")
console.log("Expecting Dexter on ",dexter_ip)

browser.on('connection', function connection(socket, req) {
	console.log(process.hrtime()[1], "browser connected");
	socket.on('message', function (data) {
		console.log(process.hrtime()[1], "browser says", data.toString());
		//Now as a client, open a raw socket to DexRun on localhost
		if (!dexter) {
			try {
				dexter = new net.Socket();
				dexter.connect(50000, dexter_ip);
			} catch (e) {
				console.log("Can't open connection to Dexter")
				//return;
			}
			console.log(process.hrtime()[1], "dexter connecting");
			dexter.on("connect", function () {
				console.log(process.hrtime()[1], "dexter connected");
			});
			dexter.on("data", function (data){
				console.log(process.hrtime()[1], "dexter says", data);
				if (socket) {
					socket.send(data, { binary: true });
					console.log(process.hrtime()[1], " fwed to browser ");
				}
			});
			dexter.on("close", function () {
				if (dexter) dexter.removeAllListeners();
				//or multiple connect/data/close events next time
				console.log(process.hrtime()[1], " dexter disconnect");
				if (socket) socket.close();
			});
			dexter.on("error", function(ex) {
				console.log("handled error");
				console.log(ex);
			  });
		}
        	try {
			dexter.write(data.toString());
		} catch (e) {}
	});
	socket.on('close', function (data) {
		console.log(process.hrtime()[1], " browser disconnected");
		if (dexter) {
			dexter.end();
			dexter.removeAllListeners();
			dexter = null;
		}
	});
});