mchess-server/chess/game.go

package chess

import (
	"context"
	"log"
	"math/rand"
	"mchess_server/api"
	"mchess_server/types"

	"github.com/google/uuid"
	gorillaws "github.com/gorilla/websocket"
)

type Game struct {
	id                uuid.UUID
	board             Board
	players           []*Player
	currentTurnPlayer *Player
	gameState         int
	isBeingHandled    bool
}

const (
	Init = iota
	Prepare
	PlayerToMove
	CheckMove
	CheckPlayerChange
	GameEnded
)

func NewGame() *Game {
	var game = Game{
		id:        uuid.New(),
		board:     newBoard(),
		gameState: Init,
	}
	game.board.Init()

	return &game
}

func (game Game) GetPlayers() []*Player {
	return game.players
}

func (game Game) GetPlayer1() *Player {
	return game.players[0]
}

func (game Game) GetRandomPlayer() *Player {
	index := rand.Int() % 2
	return game.players[index]
}

func (game Game) GetPlayer2() *Player {
	return game.players[1]
}

func (game *Game) prepare() {
	game.players[0].SetColor(types.White)
	game.players[1].SetColor(types.Black)

	game.currentTurnPlayer = game.GetPlayer1()

	game.players[0].SetDisconnectCallback(game.playerDisconnected)
	game.players[1].SetDisconnectCallback(game.playerDisconnected)

	err := game.notifyPlayersAboutGameStart()
	if err != nil {
		return
	}
}

func (game *Game) StartHandling() {
	if game.isBeingHandled {
		return
	}

	game.isBeingHandled = true
	go game.Handle()
}

func (game *Game) Handle() {
	defer game.killGame()

	var receivedMove types.Move
	var gameEndReason GameEndedReason
	var err error

	for {
		switch game.gameState {
		case Init:
			// Todo: Randomize which player will play white
			game.gameState = Prepare

		case Prepare:
			game.prepare()
			game.gameState = PlayerToMove

		case PlayerToMove:
			log.Println("with ", game.currentTurnPlayer.GetColor(), " to move")
			receivedMove, err = game.currentTurnPlayer.ReadMove()
			if err != nil {
				log.Println("Error while reading message:", err)
				return
			}
			log.Println("Player ", game.currentTurnPlayer.color.String(), " moved:\n", receivedMove)

			game.gameState = CheckMove
		case CheckMove:
			valid, ruleViolation := game.board.CheckAndPlay(&receivedMove)

			if !valid {
				invalidMoveMessage, err := api.GetInvalidMoveMessage(receivedMove, ruleViolation.String())
				if err != nil {
					log.Println("Error marshalling 'colorDetermined' message for player 1", err)
					return
				}
				game.currentTurnPlayer.writeMessage(string(invalidMoveMessage))
				game.gameState = PlayerToMove
				continue
			}

			game.gameState = CheckPlayerChange

		case CheckPlayerChange:
			if game.currentTurnPlayer.Uuid == game.players[0].Uuid {
				game.currentTurnPlayer = game.players[1]
			} else {
				game.currentTurnPlayer = game.players[0]
			}

			err := game.broadcastMove(receivedMove)
			if err != nil {
				log.Println("Error broadcasting move ", err)
				return
			}

			if gameEnded, reason := game.board.HasGameEnded(receivedMove); gameEnded {
				gameEndReason = reason
				game.gameState = GameEnded
				continue
			}

			game.gameState = PlayerToMove

		case GameEnded:
			game.broadcastGameEnd(gameEndReason)
			return
		}
		log.Println("GameState = ", game.gameState)
	}
}

func (game *Game) AddPlayersToGame(player *Player) {
	game.players = append(game.players, player)
}

func (game *Game) AreBothPlayersConnected() bool {
	if len(game.GetPlayers()) < 2 {
		return false
	}

	return game.players[0].hasWebsocketConnection() && game.players[1].hasWebsocketConnection()
}

func (game *Game) killGame() {
	log.Println("Game should be killed")
}

func (game Game) notifyPlayersAboutGameStart() error {
	colorDeterminedPlayer1, err := api.GetColorDeterminedMessage(types.White)
	if err != nil {
		log.Println("Error marshalling 'colorDetermined' message for player 1", err)
		return err
	}
	colorDeterminedPlayer2, err := api.GetColorDeterminedMessage(types.Black)
	if err != nil {
		log.Println("Error marshalling 'colorDetermined' message for player 2", err)
		return err
	}

	game.GetPlayer1().writeMessage(string(colorDeterminedPlayer1))
	game.GetPlayer1().SendBoardState(types.Move{}, game.board.PGN(), types.White)

	game.GetPlayer2().writeMessage(string(colorDeterminedPlayer2))
	game.GetPlayer2().SendBoardState(types.Move{}, game.board.PGN(), types.White)
	return nil
}

func (game Game) broadcastMove(move types.Move) error {
	log.Println("broadcast move")
	err := game.GetPlayer1().SendBoardState(move, game.board.PGN(), game.currentTurnPlayer.GetColor())
	if err != nil {
		return err
	}

	err = game.GetPlayer2().SendBoardState(move, game.board.PGN(), game.currentTurnPlayer.GetColor())
	if err != nil {
		return err
	}
	return nil
}

func (game Game) broadcastGameEnd(reason GameEndedReason) error {
	err := game.GetPlayer1().SendGameEnded(reason)
	if err != nil {
		return err
	}

	err = game.GetPlayer2().SendGameEnded(reason)
	if err != nil {
		return err
	}

	return nil
}

func (game *Game) playerDisconnected(p *Player) {
}

func (game *Game) SetWebsocketConnectionFor(ctx context.Context, p *Player, ws *gorillaws.Conn) {
	p.SetWebsocketConnectionAndSendBoardState(ctx, ws, &game.board)
}

func (game *Game) SendBoardStateTo(p *Player) {
	p.SendBoardState(game.board.getLastMove(), game.board.PGN(), game.board.colorToMove)
}