#!/usr/bin/env node
const http = require("http");
const express = require("express");
const socketio = require("socket.io")

const PORT = 8080;

const app = express();
const server = http.Server(app);
const io = socketio(server);

// gameid -> {pl: [socket]*{1,2}, started: Bool, nextServe: Int, score: [Int, Int]}
const games = new Map();

function genId() {
	for (let i = 0; i < 10; i++) {
		// 2176782336 == 36^6
		const id = ("000000" + (2176782336 * Math.random() | 0).toString(36)).slice(-6);
		if (!games.has(id)) return id;
	}
	return "";
}

function validId(id) {
	return /^[0-9a-z]{6}$/.test(id);
}

app.get("/", (req, res) => {
	const gameid = genId();
	if (gameid == "") {
		res.sendStatus(500);
		return;
	}
	res.redirect("/game/" + gameid);
});

app.param("gameid", (req, res, next, gameid) => {
	if (!validId(gameid)) {
		res.sendStatus(404);
	} else {
		next();
	}
});

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

app.get("/game.css", (req, res) => res.sendFile(__dirname + "/game.css"));
app.get("/game.js", (req, res) => res.sendFile(__dirname + "/game.js"));

io.on("connection", (conn) => {
	let gameid, gameobj;
	conn.on("open", (id) => {
		console.log("open " + id);
		if (!validId(id)) {
			console.log("  invalid");
			conn.emit("redirect", "/");
			conn.disconnect(true);
			return;
		}
		gameobj = games.get(id);
		if (gameobj != undefined) {
			if (gameobj.pl.length == 1 && !gameobj.started) {
				console.log("  serve");
				gameid = id;
				gameobj.pl.push(conn);
				gameobj.pl[0].emit("status", "Get ready...");
				gameobj.pl[1].emit("status", "Get ready...");
				gameobj.pl[0].emit("serve", "left", 0.5, 0.5);
				gameobj.pl[1].emit("serve", "right", 0.5, 0.5);
				gameobj.started = true;
				setTimeout(() => {
					if (!gameobj || gameobj.pl.length != 2) return;
					gameobj.pl[0].emit("status", "");
					gameobj.pl[1].emit("status", "");
					gameobj.pl[0].emit(gameobj.nextServe == 0 ? "startBall" : "start");
					gameobj.pl[1].emit(gameobj.nextServe == 1 ? "startBall" : "start");
					gameobj.nextServe = 1 - gameobj.nextServe;
				}, 2000);
			} else {
				console.log("  full");
				gameobj = undefined;
				conn.emit("status", "Game full! Opening new game...");
				setTimeout(() => {
					conn.emit("redirect", "/");
					conn.disconnect(true);
				}, 2000);
			}
		} else {
			console.log("  new");
			gameid = id;
			gameobj = {pl: [conn], started: false, nextServe: 0, score: [0, 0]};
			games.set(gameid, gameobj);
			conn.emit("status", "Waiting for other player...");
		}
	});

	conn.on("disconnect", () => {
		if (gameobj == undefined) return;

		console.log("stop " + gameid);

		const newpl = [];
		for (const p of gameobj.pl) {
			if (p != conn) {
				p.emit("stop");
				p.emit("status", "Other player left.");
				setTimeout(() => {
					p.emit("redirect", "/");
					p.disconnect(true);
				}, 2000);
				newpl.push(p);
			}
		}

		if (newpl.length == 0) {
			console.log("  delete");
			games.delete(gameid);
		} else {
			gameobj.pl = newpl;
		}
	});

	conn.on("padvec", (pos, vel) => {
		if (!gameobj) return;
		for (const p of gameobj.pl) {
			if (p != conn) {
				p.emit("padvec", pos, vel);
			}
		}
	});

	conn.on("ballvec", (x, y, vx, vy) => {
		if (!gameobj) return;
		for (const p of gameobj.pl) {
			if (p != conn) {
				p.emit("ballvec", x, y, vx, vy);
			}
		}
	});

	conn.on("ballout", () => {
		if (!gameobj || gameobj.pl.length != 2) return;

		gameobj.pl[0].emit("stop");
		gameobj.pl[1].emit("stop");
		gameobj.pl[0].emit("status", "Ball out!");
		gameobj.pl[1].emit("status", "Ball out!");

		for (let i = 0; i < gameobj.pl.length; i++) {
			if (gameobj.pl[i] != conn) {
				gameobj.score[i]++;
			}
		}

		gameobj.pl[0].emit("score", gameobj.score);
		gameobj.pl[1].emit("score", gameobj.score);

		setTimeout(() => {
			if (!gameobj || gameobj.pl.length != 2) return;
			gameobj.pl[0].emit("status", "Get ready...");
			gameobj.pl[1].emit("status", "Get ready...");
			gameobj.pl[0].emit("serve", "left", 0.5, 0.5);
			gameobj.pl[1].emit("serve", "right", 0.5, 0.5);

			setTimeout(() => {
				if (!gameobj || gameobj.pl.length != 2) return;
				gameobj.pl[0].emit("status", "");
				gameobj.pl[1].emit("status", "");
				gameobj.pl[0].emit(gameobj.nextServe == 0 ? "startBall" : "start");
				gameobj.pl[1].emit(gameobj.nextServe == 1 ? "startBall" : "start");
				gameobj.nextServe = 1 - gameobj.nextServe;
			}, 2000);
		}, 2000);
	});
});

server.listen(PORT, () => console.log("Listening on port " + PORT));