/back/src/Game.ts at 8cf4626e99c75e00a14169a549d58e42fd5cbab2

import {Card, Suit} from 'bsx-core';

import Client from './Client';
import logSocket from './logSocket';
import Room from './Room';
import server from './server';

class Player {
	game: Game;
	client: Client;
	cards: Card[] = [];
	stack: Card[] = [];
	flipped: Card[] = [];
	disconnected = false;
	disconnectListener?: () => void;
	rank = 0;
	constructor(game: Game, client: Client) {
		this.game = game;
		this.client = client;
	}
	sendGameState() {
		const i = this.game.players.indexOf(this);
		this.client.socket.emit('gameState', {
			cards: this.cards,
			rank: this.rank,
			players: this.game.players.map((p: Player) => ({
				username: p.client.username,
				numCards: p.cards.length,
				stackSize: p.stack.length,
				flipped: p.flipped,
				rank: p.rank,
			})),
			phase: this.game.phase,
			lastPlayed: this.game.lastPlayed,
			lastPlayedPlayer: this.game.lastPlayedPlayer < 0 ? null : this.game.players[this.game.lastPlayedPlayer].client.username,
			playerTurn: this.game.players[this.game.playerTurn].client.username
		});
	}
}

export default class Game {
	room: Room;
	players: Player[] = [];
	phase = 0;
	lastPlayed = 0;
	lastPlayedPlayer = -1;
	playerTurn = 0;
	playersFinished = 0;
	constructor(room: Room) {
		this.room = room;
		this.start();
	}
	async start() {
		const cards = [];
		for (let i = 1; i <= 13; ++i)
			for (let j = 0; j < 4; ++j)
				cards.push({rank: i, suit: j});
		// Shuffle cards
		for (let i = 0; i < 52; ++i) {
			const j = Math.floor(Math.random() * (i+1));
			[cards[i], cards[j]] = [cards[j], cards[i]];
		}
		const handSize = 5; // 5 - this.room.clients.length/7;
		for (let i = 0; i < this.room.clients.length; ++i) {
			this.players.push(new Player(this, this.room.clients[i]));
			this.players[i].cards = cards.slice(i * handSize, (i + 1) * handSize);
		}
		const startingPlayer = this.players[0]; // Pick a random starting player instead??
		this.playerTurn = this.players.indexOf(startingPlayer);
		while (true) {
			// Check if game ended
			// Rewrite
			const playersLeft: Player[] = [];
			this.players.forEach((p: Player) => {
				if (!p.rank && !p.disconnected)
					playersLeft.push(p);
			});
			if (playersLeft.length < 2) {
				if (playersLeft.length === 1)
					playersLeft[0].rank = ++this.playersFinished; // rank is reversed, fix later
				break;
			}
			await this.round();
		}
		this.broadcastGameState();
		setTimeout(() => {
			server.to(this.room.name).emit('endGame');
			this.room.host.once('startGame', () => this.room.startGame());
			this.room.game = null;
		}, 5000);
	}
	broadcastGameState() {
		this.players.forEach((p: Player) => p.sendGameState());
	}
	async round() {
		this.phase = 0;
		await this.prepare(); // Phase 0
		this.phase = 1;
		this.lastPlayed = 0;
		while (true) { // Phase 1
			const p = this.players[this.playerTurn];
			if (p.rank || p.disconnected) {
				this.playerTurn = (this.playerTurn + 1) % this.players.length;
				continue;
			}
			await this.turn();
			if (this.phase === 2) break; // Called BS!
			this.lastPlayedPlayer = this.playerTurn;
			this.playerTurn = (this.playerTurn + 1) % this.players.length;
		}
		while (this.lastPlayed > 0) { // Phase 2
			await this.flip();
			this.lastPlayed--;
			if (this.phase === 3 as number) { // Oops, flipped over a red card!
				await this.giveup(); // The player who called BS won and now the challenged player must give up a card!
				return;
			}
		}
		this.phase = 3;
		await this.giveup(); // The player who called BS won and now they must give up a card!
	}
	async prepare() { // Players prepare their hand for this round
		this.broadcastGameState();
		const playerPromises = [];
		for (let i = 0; i < this.room.clients.length; ++i) {
			const p = this.players[i];
			if (p.rank || p.disconnected) continue;
			playerPromises.push(new Promise<void>(resolve => {
				p.client.once('prepare', stack => {
					delete p.disconnectListener;
					(() => {
						p.stack = stack;
						p.cards = [...stack];
						p.flipped = [];
						return;
					})();
					resolve();
				});
				p.disconnectListener = () => {
					delete p.disconnectListener;
					p.client.removeAllListeners('prepare');
					resolve();
				};
			}));
		}
		await Promise.all(playerPromises);
	}
	async turn() { // Do a turn
		const p = this.players[this.playerTurn];
		this.broadcastGameState();
		await new Promise<void>(resolve => {
			p.client.once('turn', num => {
				delete p.disconnectListener;
				(() => {
					if (num === -1) {
						this.phase = 2; // Called BS, move on to the next phase!
						return;
					}
					if (num > this.lastPlayed) {
						this.lastPlayed = num;
						return;
					}
					p.client.socket.disconnect();
					logSocket(p.client.socket, 'Bad cards argument on turn');
				})();
				resolve();
			});
			p.disconnectListener = () => {
				delete p.disconnectListener;
				p.client.removeAllListeners('turn');
				resolve();
			};
		});
	}
	async flip() { // Someone called BS and now the challenged player must flip over a card
		const p = this.players[this.lastPlayedPlayer];
		this.broadcastGameState();
		await new Promise<void>(resolve => {
			p.client.once('flip', selectedPlayer => {
				delete p.disconnectListener;
				(() => {
					if (this.players[selectedPlayer].stack.length > 0) {
						if (this.players[selectedPlayer].stack[0].suit === Suit.Diamonds ||
							this.players[selectedPlayer].stack[0].suit === Suit.Hearts) this.phase = 3; // Red card
						this.players[selectedPlayer].flipped.push(this.players[selectedPlayer].stack[0]);
						this.players[selectedPlayer].stack.splice(0, 1);
						return;
					}
					p.client.socket.disconnect();
					logSocket(p.client.socket, 'Bad cards argument on turn');
				})();
				resolve();
			});
			p.disconnectListener = () => {
				delete p.disconnectListener;
				p.client.removeAllListeners('flip');
				resolve();
			};
		});
	}
	async giveup() { // Give up a card
		const p = this.players[this.lastPlayed > 0 ? this.lastPlayedPlayer : this.playerTurn];
		this.broadcastGameState();
		await new Promise<void>(resolve => {
			p.client.once('giveup', card => {
				delete p.disconnectListener;
				(() => {
					p.cards.splice(card, 1);
					return;
				})();
				resolve();
			});
			p.disconnectListener = () => {
				delete p.disconnectListener;
				p.client.removeAllListeners('giveup');
				resolve();
			};
		});
	}
	updateSocket(client: Client) {
		this.players.find((p: Player) => p.client === client)!.sendGameState();
	}
	remove(client: Client) {
		const p = this.players.find((p: Player) => p.client === client)!;
		p.disconnected = true;
		if (p.disconnectListener)
			p.disconnectListener();
	}
};