1 files changed, 126 insertions, 0 deletions
diff --git a/main.js b/main.js
new file mode 100755
index 0000000..b19143a
--- /dev/null
+++ b/main.js
@@ -0,0 +1,126 @@
+#!/usr/bin/env node
+
+const net = require("net");
+const util = require("util");
+
+if (process.argv.length != 4) {
+	console.log("Usage: ./main.js <hostname> <port>");
+	console.log("Pass address of doomrooms server as arguments.");
+	process.exit(1);
+}
+
+const GAME_ID = "tictactoe-tom";
+const GAME_NAME = "Tic Tac Toe";
+
+{
+	let id = 0;
+	function uniqid() {
+		return id++;
+	}
+}
+
+function lineReader(conn, lineCb) {
+	let buffer = "";
+	conn.on("data", (data) => {
+		buffer += data.toString();
+		let idx = buffer.indexOf("\n");
+		while (idx != -1) {
+			lineCb(buffer.slice(0, idx));
+			buffer = buffer.slice(idx + 1);
+			idx = buffer.indexOf("\n");
+		}
+	});
+}
+
+class Message {
+	constructor(/*...*/) {
+		if (typeof arguments[0] == "number") this.makeReply(...arguments);
+		else this.makeCommand(...arguments);
+	}
+
+	makeCommand(method, ...args) {
+		this.isCommand = true;
+		this.method = method;
+		this.args = args;
+		this.id = uniqid();
+	}
+
+	makeReply(id, res, err) {
+		this.isCommand = false;
+		this.id = id;
+		this.res = res;
+		this.err = err;
+	}
+
+	toJSON() {
+		if (this.isCommand) {
+			return JSON.stringify({
+				method: this.method,
+				args: this.args, 
+				id: this.id,
+			});
+		} else {
+			return JSON.stringify({
+				res: this.res,
+				err: this.err, 
+				id: this.id,
+			});
+		}
+	}
+}
+
+class Connection {
+	constructor(conn, msgCb) {
+		this.conn = conn;
+		lineReader(conn, (line) => {
+			let obj;
+			try {
+				obj = JSON.parse(line);
+			} catch (e) {
+				console.log("Invalid JSON received: " + line);
+				return;
+			}
+			if (obj.res || obj.err) {
+				const msg = new Message(obj.id, obj.res, obj.err);
+				if (this.replyHandlers[msg.id]) {
+					this.replyHandlers[msg.id](msg);
+					this.replyHandlers[msg.id] = null;
+				} else {
+					console.log("Reply for unexpected message id " + msg.id);
+				}
+			} else {
+				msgCb(new Message(obj.method, ...obj.args));
+			}
+		});
+
+		this.replyHandlers = {};
+	}
+
+	send(msg, replyCb) {
+		const data = msg.toJSON();
+		console.log("Writing to conn: " + data);
+		this.conn.write(data + "\n");
+		if (replyCb && msg.isCommand) {
+			this.replyHandlers[msg.id] = replyCb;
+		}
+	}
+}
+
+function messageHandler(msg) {
+	console.log("Message: " + util.inspect(msg));
+}
+
+const conn = new Connection(net.createConnection(+process.argv[3], process.argv[2]), messageHandler);
+conn.conn.on("connect", () => {
+	console.log("Connected to roomserver");
+
+	conn.conn.on("end", () => {
+		console.log("Connection with roomserver unexpectedly closed!");
+	});
+
+	setInterval(() => {
+		conn.send(new Message("ping"), (msg) => console.log("Ping reply: " + util.inspect(msg)));
+	}, 30000);
+
+	conn.send(new Message("make-game", GAME_ID, GAME_NAME), (msg) => console.log(msg));
+});