146 lines
4.0 KiB
JavaScript
146 lines
4.0 KiB
JavaScript
import { generate_keypair, generate_rsa_keypair } from "../crypto/main.js";
|
|
import { Random } from "./random.js";
|
|
import { Barrier } from "./barrier.js";
|
|
import { Packet } from "./packet.js";
|
|
import { Game } from "./game.js";
|
|
import "./dom.js";
|
|
|
|
export const ID = window.crypto.randomUUID();
|
|
export const game = new Game();
|
|
export let socket;
|
|
let random;
|
|
let barrier;
|
|
window.paillier = generate_keypair();
|
|
window.rsa = generate_rsa_keypair();
|
|
|
|
// Not totally reliable but better than nothing.
|
|
window.addEventListener("beforeunload", () => {
|
|
socket.emit("message", Packet.createDisconnect());
|
|
});
|
|
|
|
document.addEventListener("DOMContentLoaded", () => {
|
|
socket = io();
|
|
random = new Random();
|
|
barrier = new Barrier();
|
|
|
|
socket.on("connect", () => {
|
|
window.console.log("Connected!");
|
|
window.console.log(`We are: ${ID}`);
|
|
socket.emit("message", Packet.createAnnounce());
|
|
game.addPlayer(ID, true);
|
|
});
|
|
|
|
socket.on("message", async (data) => {
|
|
window.console.log(data);
|
|
|
|
// todo validate signature
|
|
|
|
switch (data.type) {
|
|
case "RANDOM":
|
|
if (data.author === ID) {
|
|
return;
|
|
}
|
|
await random.processCooperativeRandom(data);
|
|
break;
|
|
|
|
case "BARRIER":
|
|
if (data.author === ID) {
|
|
return;
|
|
}
|
|
barrier.resolve(data);
|
|
break;
|
|
|
|
default:
|
|
const event = new CustomEvent(data.type, { detail: data });
|
|
document.dispatchEvent(event);
|
|
break;
|
|
}
|
|
});
|
|
});
|
|
|
|
/**
|
|
* Process player connect packets: these inform that a new player has joined.
|
|
*
|
|
* @param data Packet received
|
|
*/
|
|
document.addEventListener("ANNOUNCE", (ev) => {
|
|
const data = ev.detail;
|
|
if (data.author === ID) return;
|
|
|
|
let is_new = game.addPlayer(data.author, false);
|
|
|
|
// When a new player is seen, all announce to ensure they know all players.
|
|
if (is_new) {
|
|
socket.emit("message", Packet.createAnnounce());
|
|
}
|
|
});
|
|
|
|
document.addEventListener("DISCONNECT", (ev) => {
|
|
const data = ev.detail;
|
|
game.removePlayer(data.author);
|
|
});
|
|
|
|
/**
|
|
* Process keep-alive packets: these are packets that check players are still online.
|
|
*
|
|
* @param data Packet received
|
|
*/
|
|
document.addEventListener("KEEPALIVE", (ev) => {
|
|
const data = ev.detail;
|
|
game.keepAlive(data.author);
|
|
});
|
|
|
|
document.addEventListener("ACT", async (ev) => {
|
|
const data = ev.detail;
|
|
|
|
if (game.isWaiting()) {
|
|
game.setReady(data.author, data.ready);
|
|
} else {
|
|
if (data.author !== game.currentPlayer().id) {
|
|
if (data.action === "DEFENSE") {
|
|
await game.players[data.author].setDefense(data.amount);
|
|
}
|
|
|
|
return;
|
|
}
|
|
|
|
if (game.isPregame()) {
|
|
if (!Region.allRegionsClaimed()) {
|
|
// Claim a region in the pregame.
|
|
if (game.currentPlayer().claim(data)) {
|
|
// Increment to next player.
|
|
game.currentPlayer().endTurn();
|
|
}
|
|
} else if (!Region.allReinforcementsPlaced()) {
|
|
if (game.currentPlayer().reinforce(data)) {
|
|
game.currentPlayer().endTurn();
|
|
}
|
|
}
|
|
|
|
if (Region.allReinforcementsPlaced()) {
|
|
game.incrementState();
|
|
}
|
|
} else {
|
|
if (await game.currentPlayer().act(data)) {
|
|
game.currentPlayer().endTurn();
|
|
}
|
|
}
|
|
}
|
|
});
|
|
|
|
document.addEventListener("gameStateUpdate", async () => {
|
|
if (game.isPregame()) {
|
|
let firstPlayerIndex = await random.get(
|
|
Object.keys(game.players).length,
|
|
"first-player"
|
|
);
|
|
|
|
let firstPlayer = Object.values(game.players).sort((a, b) =>
|
|
a.id < b.id ? -1 : 1
|
|
)[firstPlayerIndex];
|
|
|
|
firstPlayer.isPlaying = true;
|
|
await barrier.wait();
|
|
}
|
|
});
|