added more logic for the server state diagram

This commit is contained in:
Daniel Grigencha
2024-11-22 09:37:49 +01:00
parent 04501de11c
commit 89232901a7
21 changed files with 570 additions and 251 deletions

View File

@@ -301,7 +301,6 @@ public Boolean getGameHasStarted() {
*/ */
public void setGameHasStarted(Boolean gameHasStarted) { public void setGameHasStarted(Boolean gameHasStarted) {
this.gameHasStarted = gameHasStarted; this.gameHasStarted = gameHasStarted;
if (gameHasStarted) notifyObservers();
} }
/** /**

View File

@@ -1,6 +1,7 @@
package pp.mdga.server; package pp.mdga.server;
import pp.mdga.message.client.AnimationEnd; import pp.mdga.message.client.AnimationEnd;
import pp.mdga.message.server.DiceNow;
public class Animation extends ServerState { public class Animation extends ServerState {
public Animation(ServerState parent, ServerGameLogic logic) { public Animation(ServerState parent, ServerGameLogic logic) {
@@ -8,7 +9,8 @@ public Animation(ServerState parent, ServerGameLogic logic) {
} }
@Override @Override
public void receivedAnimationEnd(AnimationEnd msg) { public void receivedAnimationEnd(AnimationEnd msg, int from) {
logic.send(logic.getGame().getStartPlayer(), new DiceNow());
parent.gotoState(new Turn(parent, logic)); parent.gotoState(new Turn(parent, logic));
} }
} }

View File

@@ -2,41 +2,43 @@
import pp.mdga.game.Player; import pp.mdga.game.Player;
import pp.mdga.message.client.RequestDice; import pp.mdga.message.client.RequestDice;
import pp.mdga.message.server.DiceNow; import pp.mdga.message.server.*;
import pp.mdga.message.server.RankingRollAgain;
import java.util.ArrayList;
import java.util.List;
public class DetermineStartPlayer extends ServerState { public class DetermineStartPlayer extends ServerState {
private final List<Player> player = new ArrayList<>();
public DetermineStartPlayer(ServerState parent, ServerGameLogic logic) { public DetermineStartPlayer(ServerState parent, ServerGameLogic logic) {
super(parent, logic); super(parent, logic);
logic.getGame().addObserver(this); logic.getGame().addObserver(this);
} }
@Override @Override
public void receivedRequestDice(RequestDice msg) { public void receivedRequestDice(RequestDice msg, int from) {
// todo: implement logic.send();
}
// todo: msg?, sent to everyone? broadcastUpdate(new Dice());
@Override
public void sentRankingResponse() {
// todo: implemtent
} }
@Override @Override
public void update() { public void update() {
if (logic.getGame().allRanked()) { if (Boolean.TRUE.equals(logic.getGame().allRanked())) {
if (logic.getGame().getStartPlayer() == null) { broadcastUpdate(new RankingResponce());
// todo: send it to everyone? or player with the same dice value? save the players with the same value? if (logic.getGame().getOrder().isEmpty()) {
logic.send(new Player(1), new RankingRollAgain()); // todo: save the players with the same value?
broadcastUpdate(new RankingRollAgain());
broadcastUpdate(new EndOfTurn());
} else { } else {
// todo: set start player // todo: set start player
Player startPlayer = new Player(1); Player startPlayer = new Player(1);
logic.getGame().setStartPlayer(startPlayer); logic.getGame().setStartPlayer(startPlayer);
logic.send(startPlayer, new DiceNow()); logic.send(startPlayer, new DiceNow());
broadcastUpdate(new EndOfTurn());
parent.gotoState(new Animation(parent, logic)); parent.gotoState(new Animation(parent, logic));
logic.getGame().removeObserver(this); logic.getGame().removeObserver(this);
} }
} }
} }
} }

View File

@@ -1,9 +1,6 @@
package pp.mdga.server; package pp.mdga.server;
import pp.mdga.game.Player;
import pp.mdga.message.client.RequestDice; import pp.mdga.message.client.RequestDice;
import pp.mdga.message.server.Dice;
import pp.mdga.message.server.DiceAgain;
public class FirstRoll extends ServerState { public class FirstRoll extends ServerState {
public FirstRoll(ServerState parent, ServerGameLogic logic) { public FirstRoll(ServerState parent, ServerGameLogic logic) {
@@ -11,21 +8,21 @@ public FirstRoll(ServerState parent, ServerGameLogic logic) {
} }
@Override @Override
public void receivedRequestDice(RequestDice msg) { public void receivedRequestDice(RequestDice msg, int from) {
// todo: implement player.hasMovablePieces() // todo: implement player.hasMovablePieces()
if (player.hasMovablePieces()) { // if (player.hasMovablePieces()) {
// todo: goto ChoosePiece // // todo: goto ChoosePiece
} else { // } else {
// todo: implement roll // // todo: implement roll
if (roll == 6) { // if (roll == 6) {
// todo: send to everyone? or one player? // // todo: send to everyone? or one player?
logic.send(new Player(1), new Dice()); // logic.send(new Player(1), new Dice());
// todo: goto ChoosePiece // // todo: goto ChoosePiece
} else { // } else {
// todo: send to everyone? or one player? // // todo: send to everyone? or one player?
logic.send(new Player(1), new DiceAgain()); // logic.send(new Player(1), new DiceAgain());
parent.gotoState(new SecondRoll(parent, logic)); // parent.gotoState(new SecondRoll(parent, logic));
} // }
} // }
} }
} }

View File

@@ -1,8 +1,9 @@
package pp.mdga.server; package pp.mdga.server;
import pp.mdga.game.Piece;
import pp.mdga.message.client.*; import pp.mdga.message.client.*;
import pp.mdga.message.server.PauseGame;
import pp.mdga.message.server.PossibleCard; import pp.mdga.message.server.PossibleCard;
import pp.mdga.message.server.RankingResponce;
public class GameState extends ServerState { public class GameState extends ServerState {
private final GameStateMachine gameStateMachine = new GameStateMachine(this, logic); private final GameStateMachine gameStateMachine = new GameStateMachine(this, logic);
@@ -18,58 +19,50 @@ public void entry() {
} }
@Override @Override
public void receivedAnimationEnd(AnimationEnd msg) { public void exit() {
gameStateMachine.receivedAnimationEnd(msg); parent.gotoState(new Ceremony(parent, logic));
}
// todo piece?
@Override
public void receivedConfirmPiece(Piece piece) {
gameStateMachine.receivedConfirmPiece(piece);
} }
@Override @Override
public void receivedNoPowerCard(NoPowerCard msg) { public void receivedAnimationEnd(AnimationEnd msg, int from) {
gameStateMachine.receivedNoPowerCard(msg); gameStateMachine.receivedAnimationEnd(msg, from);
} }
@Override @Override
public void receivedSelectCard(SelectCard msg) { public void receivedNoPowerCard(NoPowerCard msg, int from) {
gameStateMachine.receivedSelectCard(msg); gameStateMachine.receivedNoPowerCard(msg, from);
} }
@Override @Override
public void receivedRequestDice(RequestDice msg) { public void receivedSelectCard(SelectCard msg, int from) {
gameStateMachine.receivedRequestDice(msg); gameStateMachine.receivedSelectCard(msg, from);
}
// todo msg?
@Override
public void receivedRollRankingDice() {
gameStateMachine.receivedRollRankingDice();
} }
@Override @Override
public void receivedSelectedPieces(SelectedPieces msg) { public void receivedRequestDice(RequestDice msg, int from) {
gameStateMachine.receivedSelectedPieces(msg); gameStateMachine.receivedRequestDice(msg, from);
} }
@Override @Override
public void sentPossibleCard(PossibleCard msg) { public void receivedSelectedPieces(SelectedPieces msg, int from) {
gameStateMachine.sentPossibleCard(msg); gameStateMachine.receivedSelectedPieces(msg, from);
} }
// todo msg?, sent to everyone?
@Override @Override
public void sentRankingResponse() { public void sentPossibleCard(PossibleCard msg, int from) {
gameStateMachine.sentRankingResponse(); gameStateMachine.sentPossibleCard(msg, from);
}
@Override
public void sentRankingResponse(RankingResponce msg, int from) {
gameStateMachine.sentRankingResponse(msg, from);
} }
@Override @Override
public void update() { public void update() {
if (logic.getGame().playerHasDisconnected()) { if (Boolean.TRUE.equals(logic.getGame().playerHasDisconnected())) {
parent.gotoState(new Interrupt(parent, logic)); broadcastUpdate(new PauseGame());
// todo: change to interrupt, save the last state of gamestatemachine, change from interrupt to gamestate has to restore the last state parent.gotoState(new Interrupt(parent, logic, this));
logic.getGame().removeObserver(this); logic.getGame().removeObserver(this);
} }
} }

View File

@@ -1,10 +1,24 @@
package pp.mdga.server; package pp.mdga.server;
public class GameStateMachine extends ServerStateMachine{ /**
* The GameStateMachine class represents the state machine for the game state.
*/
public class GameStateMachine extends ServerStateMachine {
/**
* Constructs a new GameStateMachine with the specified parent state and game logic.
*
* @param parent the parent state
* @param logic the server game logic
*/
public GameStateMachine(ServerState parent, ServerGameLogic logic) { public GameStateMachine(ServerState parent, ServerGameLogic logic) {
super(parent, logic); super(parent, logic);
} }
/**
* Returns the initial state of the state machine, which is DetermineStartPlayer.
*
* @return the initial state
*/
@Override @Override
public DetermineStartPlayer initialState() { public DetermineStartPlayer initialState() {
return new DetermineStartPlayer(this, logic); return new DetermineStartPlayer(this, logic);

View File

@@ -1,15 +1,21 @@
package pp.mdga.server; package pp.mdga.server;
import pp.mdga.message.server.ResumeGame;
public class Interrupt extends ServerState { public class Interrupt extends ServerState {
public Interrupt(ServerState parent, ServerGameLogic logic) { private final GameState lastState;
public Interrupt(ServerState parent, ServerGameLogic logic, GameState lastState) {
super(parent, logic); super(parent, logic);
this.lastState = lastState;
logic.getGame().addObserver(this); logic.getGame().addObserver(this);
} }
@Override @Override
public void update() { public void update() {
if (!logic.getGame().gameIsInterrupted()) { if (Boolean.FALSE.equals(logic.getGame().gameIsInterrupted())) {
parent.gotoState(new GameState(parent, logic)); broadcastUpdate(new ResumeGame());
parent.gotoState(lastState);
logic.getGame().removeObserver(this); logic.getGame().removeObserver(this);
} }
} }

View File

@@ -1,52 +1,74 @@
package pp.mdga.server; package pp.mdga.server;
import pp.mdga.message.client.*; import pp.mdga.message.client.*;
import pp.mdga.message.server.ServerMessage; import pp.mdga.message.server.ServerStartGame;
import pp.mdga.message.server.UpdateReady; import pp.mdga.message.server.UpdateReady;
import pp.mdga.message.server.UpdateTSK; import pp.mdga.message.server.UpdateTSK;
/**
* Represents the lobby state of the server.
*/
public class Lobby extends ServerState { public class Lobby extends ServerState {
/**
* Constructs a new Lobby state.
*
* @param parent the parent state
* @param logic the server game logic
*/
public Lobby(ServerState parent, ServerGameLogic logic) { public Lobby(ServerState parent, ServerGameLogic logic) {
super(parent, logic); super(parent, logic);
logic.getGame().addObserver(this);
} }
/**
* Handles the DeselectTSK message.
*
* @param msg the DeselectTSK message
*/
@Override @Override
public void receivedDeselectTSK(DeselectTSK msg) { public void receivedDeselectTSK(DeselectTSK msg, int from) {
broadcastUpdate(new UpdateTSK()); broadcastUpdate(new UpdateTSK());
} }
/**
* Handles the LobbyNotReady message.
*
* @param msg the LobbyNotReady message
*/
@Override @Override
public void receivedNotReady(LobbyNotReady msg) { public void receivedNotReady(LobbyNotReady msg, int from) {
broadcastUpdate(new UpdateReady()); broadcastUpdate(new UpdateReady());
} }
/**
* Handles the LobbyReady message.
*
* @param msg the LobbyReady message
*/
@Override @Override
public void receivedReady(LobbyReady msg) { public void receivedReady(LobbyReady msg, int from) {
broadcastUpdate(new UpdateReady()); broadcastUpdate(new UpdateReady());
} }
/**
* Handles the SelectTSK message.
*
* @param msg the SelectTSK message
*/
@Override @Override
public void receivedSelectTSK(SelectTSK msg) { public void receivedSelectTSK(SelectTSK msg, int from) {
broadcastUpdate(new UpdateTSK()); broadcastUpdate(new UpdateTSK());
} }
private void broadcastUpdate(ServerMessage updateMessage) { /**
for (var entry : logic.getGame().getPlayers().entrySet()) { * Handles the ClientStartGame message.
logic.send(entry.getValue(), updateMessage); *
} * @param msg the ClientStartGame message
} */
@Override @Override
public void receivedStartGame(ClientStartGame msg) { public void receivedStartGame(ClientStartGame msg, int from) {
// todo: implement?? if (Boolean.TRUE.equals(logic.getGame().allRanked())) {
} broadcastUpdate(new ServerStartGame());
@Override
public void update() {
if (logic.getGame().getGameHasStarted()) {
parent.gotoState(new GameState(parent, logic)); parent.gotoState(new GameState(parent, logic));
logic.getGame().removeObserver(this);
} }
} }
} }

View File

@@ -11,45 +11,45 @@ public NoPiece(ServerState parent, ServerGameLogic logic) {
@Override @Override
public void entry() { public void entry() {
if (hasTurbo() || turbo == 0) { // if (hasTurbo() || turbo == 0) {
if (roll == 6 && // if (roll == 6 &&
logic.getGame().getBoard().getPlayerData().getWaitingArea().hasPieces() && // logic.getGame().getBoard().getPlayerData().getWaitingArea().hasPieces() &&
logic.getGame().getBoard().getNodes().getStartNode(Color).isOccupied()) { // logic.getGame().getBoard().getNodes().getStartNode(Color).isOccupied()) {
parent.gotoState(new WaitingPiece(parent, logic)); // parent.gotoState(new WaitingPiece(parent, logic));
} else { // } else {
parent.gotoState(new NoTurn(parent, logic)); // parent.gotoState(new NoTurn(parent, logic));
} // }
} else { // } else {
validateHasPieces(); // validateHasPieces();
} // }
} }
private void validateHasPieces() { private void validateHasPieces() {
if (logic.getGame().getBoard().getPlayerData().getWaitingArea().hasPieces()) { // if (logic.getGame().getBoard().getPlayerData().getWaitingArea().hasPieces()) {
if (logic.getGame().getBoard().getNodes().getStartNode(Color).isOccupied()) { // if (logic.getGame().getBoard().getNodes().getStartNode(Color).isOccupied()) {
if (roll == 6) { // if (roll == 6) {
logic.send(new Player(1), new WaitPiece()); // logic.send(new Player(1), new WaitPiece());
} else { // } else {
validateMove(); // validateMove();
} // }
} else { // } else {
if (logic.getGame().getBoard().getNodes().getStartNode(Color).getPiece().canMove()) { // if (logic.getGame().getBoard().getNodes().getStartNode(Color).getPiece().canMove()) {
logic.send(new Player(1), new WaitPiece()); // logic.send(new Player(1), new WaitPiece());
parent.gotoState(new StartPiece(parent, logic)); // parent.gotoState(new StartPiece(parent, logic));
} else { // } else {
validateMove(); // validateMove();
} // }
} // }
} else { // } else {
validateMove(); // validateMove();
} // }
} }
private void validateMove() { private void validateMove() {
if (player.canMove()) { // if (player.canMove()) {
parent.gotoState(new NoTurn(parent, logic)); // parent.gotoState(new NoTurn(parent, logic));
} else { // } else {
logic.send(new Player(1), new SelectPiece()); // logic.send(new Player(1), new SelectPiece());
} // }
} }
} }

View File

@@ -8,7 +8,7 @@ public NoTurn(ServerState parent, ServerGameLogic logic) {
} }
@Override @Override
public void sentEndOfTurn(EndOfTurn msg) { public void sentEndOfTurn(EndOfTurn msg, int from) {
// todo: goto end of turn // todo: goto end of turn
} }
} }

View File

@@ -14,7 +14,7 @@ public PowerCard(ServerState parent, ServerGameLogic logic) {
} }
@Override @Override
public void receivedNoPowerCard(NoPowerCard msg) { public void receivedNoPowerCard(NoPowerCard msg, int from) {
// todo: send to everyone? or one player? // todo: send to everyone? or one player?
// todo: right msg? // todo: right msg?
logic.send(new Player(1), new DiceNow()); logic.send(new Player(1), new DiceNow());
@@ -22,29 +22,29 @@ public void receivedNoPowerCard(NoPowerCard msg) {
} }
@Override @Override
public void receivedSelectCard(SelectCard msg) { public void receivedSelectCard(SelectCard msg, int from) {
// todo: send to everyone? or one player? // todo: send to everyone? or one player?
logic.send(new Player(1), new PossibleCard()); logic.send(new Player(1), new PossibleCard());
} }
@Override @Override
public void receivedSelectedPieces(SelectedPieces msg) { public void receivedSelectedPieces(SelectedPieces msg, int from) {
if (verifySelectedPieces()) { // if (verifySelectedPieces()) {
// todo: send to everyone? or one player? // // todo: send to everyone? or one player?
// todo: msg PowerCardAnimation? // // todo: msg PowerCardAnimation?
logic.send(new Player(1), new PowerCardAnimation()); // logic.send(new Player(1), new PowerCardAnimation());
parent.gotoState(new PlayPowerCard(parent, logic)); // parent.gotoState(new PlayPowerCard(parent, logic));
} // }
} }
@Override @Override
public void sentPossibleCard(PossibleCard msg) { public void sentPossibleCard(PossibleCard msg, int from) {
// todo: implement // todo: implement
} }
@Override @Override
public void update() { public void update() {
if (!logic.getGame().getMovablePieces()) { if (!super.getMoveablePieces(logic.getGame().getActiveColor()).isEmpty()) {
// todo: send to everyone? or one player? // todo: send to everyone? or one player?
// todo: right msg? // todo: right msg?
logic.send(new Player(1), new DiceNow()); logic.send(new Player(1), new DiceNow());

View File

@@ -11,15 +11,15 @@ public SecondRoll(ServerState parent, ServerGameLogic logic) {
} }
@Override @Override
public void receivedRequestDice(RequestDice msg) { public void receivedRequestDice(RequestDice msg, int from) {
if (roll == 6) { // if (roll == 6) {
// todo: send to everyone? or one player? // // todo: send to everyone? or one player?
logic.send(new Player(1), new Dice()); // logic.send(new Player(1), new Dice());
// todo: goto ChoosePiece // // todo: goto ChoosePiece
} else { // } else {
// todo: send to everyone? or one player? // // todo: send to everyone? or one player?
logic.send(new Player(1), new DiceAgain()); // logic.send(new Player(1), new DiceAgain());
parent.gotoState(new ThirdRoll(parent, logic)); // parent.gotoState(new ThirdRoll(parent, logic));
} // }
} }
} }

View File

@@ -2,6 +2,7 @@
import pp.mdga.game.Piece; import pp.mdga.game.Piece;
import pp.mdga.game.Player; import pp.mdga.game.Player;
import pp.mdga.message.client.RequestMove;
import pp.mdga.message.server.StartPiece; import pp.mdga.message.server.StartPiece;
public class SelectPiece extends ServerState { public class SelectPiece extends ServerState {
@@ -10,12 +11,12 @@ public SelectPiece(ServerState parent, ServerGameLogic logic) {
} }
@Override @Override
public void receivedConfirmPiece(Piece p) { public void receivedRequestMove(RequestMove msg, int from) {
if (verifyPiece(p)) { // if (verifyPiece(p)) {
logic.send(new Player(1), new Animation()); // logic.send(new Player(1), new Animation());
// todo: goto state // // todo: goto state
} else { // } else {
logic.send(new Player(1), new StartPiece()); // logic.send(new Player(1), new StartPiece());
} // }
} }
} }

View File

@@ -1,11 +1,25 @@
package pp.mdga.server; package pp.mdga.server;
/**
* The ServerAutomaton class represents the top-level state machine for the server.
* It initializes the state machine and sets the initial state to Lobby.
*/
public class ServerAutomaton extends ServerStateMachine { public class ServerAutomaton extends ServerStateMachine {
/**
* Constructs a new ServerAutomaton with the specified game logic.
*
* @param logic the server game logic
*/
public ServerAutomaton(ServerGameLogic logic) { public ServerAutomaton(ServerGameLogic logic) {
super(null, logic); super(null, logic);
entry(); entry();
} }
/**
* Returns the initial state of the state machine, which is Lobby.
*
* @return the initial state
*/
@Override @Override
public Lobby initialState() { public Lobby initialState() {
return new Lobby(this, logic); return new Lobby(this, logic);

View File

@@ -125,7 +125,6 @@ public Game getGame() {
return game; return game;
} }
// todo: remove
public ServerState getState() { public ServerState getState() {
return state; return state;
} }

View File

@@ -8,64 +8,175 @@
import pp.mdga.message.client.*; import pp.mdga.message.client.*;
import pp.mdga.message.server.EndOfTurn; import pp.mdga.message.server.EndOfTurn;
import pp.mdga.message.server.PossibleCard; import pp.mdga.message.server.PossibleCard;
import pp.mdga.message.server.RankingResponce;
import pp.mdga.message.server.ServerMessage;
import java.lang.System.Logger; import java.lang.System.Logger;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.Arrays;
import java.util.List; import java.util.List;
/**
* Abstract class representing a state in the server's state machine.
* Implements the Observer pattern to observe changes in the game state.
*/
public abstract class ServerState implements Observer { public abstract class ServerState implements Observer {
/**
* Logger for logging messages within the application.
*/
protected static final Logger LOGGER = System.getLogger(ServerState.class.getName()); protected static final Logger LOGGER = System.getLogger(ServerState.class.getName());
/**
* The parent state of the current state.
*/
protected ServerState parent; protected ServerState parent;
/**
* The game logic associated with the server state.
*/
protected ServerGameLogic logic; protected ServerGameLogic logic;
public ServerState(ServerState parent, ServerGameLogic logic) { /**
* Constructs a new ServerState with the specified parent state and game logic.
*
* @param parent the parent state of the current state
* @param logic the game logic associated with the server state
*/
protected ServerState(ServerState parent, ServerGameLogic logic) {
this.parent = parent; this.parent = parent;
this.logic = logic; this.logic = logic;
} }
/**
* This method is called when the state is entered.
*/
public void entry() { /* do nothing */ } public void entry() { /* do nothing */ }
public void receivedAnimationEnd(AnimationEnd msg) { /* do nothing */ } /**
* This method is called when the state is exited.
*/
public void exit() { /* do nothing */ }
// todo piece? /**
public void receivedConfirmPiece(Piece piece) { /* do nothing */ } * This method is called when an animation ends.
*
* @param msg the animation end message
*/
public void receivedAnimationEnd(AnimationEnd msg, int from) { /* do nothing */ }
public void receivedDeselectTSK(DeselectTSK msg) { /* do nothing */ } /**
* This method is called when a TSK is deselected.
*
* @param msg the deselect TSK message
*/
public void receivedDeselectTSK(DeselectTSK msg, int from) { /* do nothing */ }
public void receivedNoPowerCard(NoPowerCard msg) { /* do nothing */ } /**
* This method is called when a NoPowerCard message is received.
*
* @param msg the NoPowerCard message
*/
public void receivedNoPowerCard(NoPowerCard msg, int from) { /* do nothing */ }
public void receivedNotReady(LobbyNotReady msg) { /* do nothing */ } /**
* This method is called when a LobbyNotReady message is received.
*
* @param msg the LobbyNotReady message
*/
public void receivedNotReady(LobbyNotReady msg, int from) { /* do nothing */ }
public void receivedReady(LobbyReady msg) { /* do nothing */ } /**
* This method is called when a LobbyReady message is received.
*
* @param msg the LobbyReady message
*/
public void receivedReady(LobbyReady msg, int from) { /* do nothing */ }
public void receivedRequestDice(RequestDice msg) { /* do nothing */ } /**
* This method is called when a RequestDice message is received.
*
* @param msg the RequestDice message
*/
public void receivedRequestDice(RequestDice msg, int from) { /* do nothing */ }
// todo msg? /**
public void receivedRollRankingDice() { /* do nothing */ } * This method is called when a RequestMove message is received.
*
* @param msg the RequestMove message
*/
public void receivedRequestMove(RequestMove msg, int from) { /* do nothing */ }
public void receivedSelectCard(SelectCard msg) { /* do nothing */ } /**
* This method is called when a SelectCard message is received.
*
* @param msg the SelectCard message
*/
public void receivedSelectCard(SelectCard msg, int from) { /* do nothing */ }
public void receivedSelectTSK(SelectTSK msg) { /* do nothing */ } /**
* This method is called when a SelectTSK message is received.
*
* @param msg the SelectTSK message
*/
public void receivedSelectTSK(SelectTSK msg, int from) { /* do nothing */ }
public void receivedSelectedPieces(SelectedPieces msg) { /* do nothing */ } /**
* This method is called when a SelectedPieces message is received.
*
* @param msg the SelectedPieces message
*/
public void receivedSelectedPieces(SelectedPieces msg, int from) { /* do nothing */ }
public void receivedStartGame(ClientStartGame msg) { /* do nothing */ } /**
* This method is called when a StartGame message is received.
*
* @param msg the StartGame message
*/
public void receivedStartGame(ClientStartGame msg, int from) { /* do nothing */ }
public void sentEndOfTurn(EndOfTurn msg) { /* do nothing */ } /**
* This method is called when an EndOfTurn message is sent.
*
* @param msg the EndOfTurn message
*/
public void sentEndOfTurn(EndOfTurn msg, int from) { /* do nothing */ }
public void sentPossibleCard(PossibleCard msg) { /* do nothing */ } /**
* This method is called when a PossibleCard message is sent.
*
* @param msg the PossibleCard message
*/
public void sentPossibleCard(PossibleCard msg, int from) { /* do nothing */ }
// todo msg?, sent to everyone? /**
public void sentRankingResponse() { /* do nothing */ } * This method is called when a RankingResponce message is sent.
*
* @param msg the RankingResponce message
*/
public void sentRankingResponse(RankingResponce msg, int from) { /* do nothing */ }
/**
* This method transitions to a new state.
*
* @param state the new state to transition to
* @throws IllegalStateException if called outside a state machine
*/
public void gotoState(ServerState state) { public void gotoState(ServerState state) {
throw new IllegalStateException("not in a statemachine"); throw new IllegalStateException("not in a statemachine");
} }
/**
* Returns the parent state of the current state.
*
* @return the parent state
*/
public ServerState getParent() { public ServerState getParent() {
return parent; return parent;
} }
/**
* This method is called when the observed object is changed.
* It is part of the Observer pattern implementation.
*/
public void update() { /* do nothing */ } public void update() { /* do nothing */ }
/** /**
@@ -73,7 +184,7 @@ public void update() { /* do nothing */ }
* *
* @return the steps a piece can move * @return the steps a piece can move
*/ */
private int calculateSteps(){ private int calculateSteps() {
return logic.getGame().getDiceEyes() * logic.getGame().getDiceModifier(); return logic.getGame().getDiceEyes() * logic.getGame().getDiceModifier();
} }
@@ -84,14 +195,15 @@ private int calculateSteps(){
* @return true if the piece can be moved, false otherwise * @return true if the piece can be moved, false otherwise
*/ */
protected boolean tryMove(Piece piece) { protected boolean tryMove(Piece piece) {
if (piece.getState() == PieceState.HOME){ int steps = calculateSteps();
return tryHomeMove(piece, calculateSteps()); if (piece.getState() == PieceState.HOME) {
return tryHomeMove(piece, steps);
} else { } else {
int homeMoves = getHomeMoves(piece, calculateSteps()); int homeMoves = getHomeMoves(piece, steps);
if (homeMoves > 0){ if (homeMoves > 0) {
return tryHomeMove(piece, homeMoves); return tryHomeMove(piece, homeMoves);
} else { } else {
return tryInfieldMove(piece, calculateSteps()); return tryInfieldMove(piece, steps);
} }
} }
} }
@@ -108,12 +220,12 @@ protected int getHomeMoves(Piece piece, int steps) {
Color col = piece.getColor(); Color col = piece.getColor();
int startIndex = logic.getGame().getBoard().getPlayerData().get(col).getStartNodeIndex(); int startIndex = logic.getGame().getBoard().getPlayerData().get(col).getStartNodeIndex();
int moveIndex = startIndex + steps; int moveIndex = startIndex + steps;
if (moveIndex > logic.getGame().getBoard().getInfield().length){ if (moveIndex > logic.getGame().getBoard().getInfield().length) {
moveIndex %= logic.getGame().getBoard().getInfield().length; moveIndex %= logic.getGame().getBoard().getInfield().length;
if(moveIndex >= startIndex){ if (moveIndex >= startIndex) {
return moveIndex - startIndex + 1; return moveIndex - startIndex + 1;
} }
} else if (figureIndex < startIndex && moveIndex >= startIndex){ } else if (figureIndex < startIndex && moveIndex >= startIndex) {
return moveIndex - startIndex + 1; return moveIndex - startIndex + 1;
} }
return 0; return 0;
@@ -126,11 +238,11 @@ protected int getHomeMoves(Piece piece, int steps) {
* @param steps the steps the piece would move * @param steps the steps the piece would move
* @return true if the piece can move in the infield, false otherwise * @return true if the piece can move in the infield, false otherwise
*/ */
protected boolean tryInfieldMove(Piece piece, int steps){ protected boolean tryInfieldMove(Piece piece, int steps) {
int figureIndex = logic.getGame().getBoard().getInfieldIndexOfPiece(piece); int figureIndex = logic.getGame().getBoard().getInfieldIndexOfPiece(piece);
int moveIndex = (figureIndex + steps) % logic.getGame().getBoard().getInfield().length; int moveIndex = (figureIndex + steps) % logic.getGame().getBoard().getInfield().length;
Piece occupant = logic.getGame().getBoard().getInfield()[moveIndex].getOccupant(); Piece occupant = logic.getGame().getBoard().getInfield()[moveIndex].getOccupant();
if(occupant != null){ if (occupant != null) {
return occupant.getColor() != piece.getColor(); return occupant.getColor() != piece.getColor();
} }
return true; return true;
@@ -143,22 +255,23 @@ protected boolean tryInfieldMove(Piece piece, int steps){
* @param steps the steps the piece would move * @param steps the steps the piece would move
* @return true if the piece can move into the home area, false otherwise * @return true if the piece can move into the home area, false otherwise
*/ */
protected boolean tryHomeMove(Piece piece, int steps){ protected boolean tryHomeMove(Piece piece, int steps) {
Color col = piece.getColor(); Color col = piece.getColor();
PlayerData playerData = logic.getGame().getBoard().getPlayerData().get(col); PlayerData playerData = logic.getGame().getBoard().getPlayerData().get(col);
Node[] homeNodes = playerData.getHomeNodes(); Node[] homeNodes = playerData.getHomeNodes();
int index; int index;
if (playerData.homeIncludes(piece)){ if (playerData.homeIncludes(piece)) {
index = playerData.getIndexInHome(piece); index = playerData.getIndexInHome(piece);
} else { } else {
index = 0; index = 0;
} }
if(index + steps >= homeNodes.length){
if (index + steps >= homeNodes.length) {
return false; return false;
} else { } else {
for(int i = index; i <= index + steps; i++){ for (int i = index; i <= index + steps; i++) {
if(homeNodes[i].getOccupant() != null){ if (homeNodes[i].getOccupant() != null) {
return false; return false;
} }
} }
@@ -176,7 +289,7 @@ protected List<Piece> getMoveablePieces(Color color) {
ArrayList<Piece> moveablePieces = new ArrayList<>(); ArrayList<Piece> moveablePieces = new ArrayList<>();
ArrayList<Piece> pieces = new ArrayList<>(); ArrayList<Piece> pieces = new ArrayList<>();
for (Piece piece : logic.getGame().getBoard().getPlayerData().get(color).getPieces()) { for (Piece piece : logic.getGame().getBoard().getPlayerData().get(color).getPieces()) {
if(piece.getState() == PieceState.ACTIVE || piece.getState() == PieceState.HOME){ if (piece.getState() == PieceState.ACTIVE || piece.getState() == PieceState.HOME) {
pieces.add(piece); pieces.add(piece);
} }
} }
@@ -188,6 +301,22 @@ protected List<Piece> getMoveablePieces(Color color) {
return moveablePieces; return moveablePieces;
} }
/**
* Broadcasts an update message to all players.
*
* @param updateMessage the update message to be sent
*/
protected void broadcastUpdate(ServerMessage updateMessage) {
for (var entry : logic.getGame().getPlayers().entrySet()) {
logic.send(entry.getValue(), updateMessage);
}
}
/**
* Returns a string representation of the object.
*
* @return the simple name of the class
*/
@Override @Override
public String toString() { public String toString() {
return getClass().getSimpleName(); return getClass().getSimpleName();

View File

@@ -1,26 +1,50 @@
package pp.mdga.server; package pp.mdga.server;
import pp.mdga.game.Piece;
import pp.mdga.message.client.*; import pp.mdga.message.client.*;
import pp.mdga.message.server.EndOfTurn; import pp.mdga.message.server.EndOfTurn;
import pp.mdga.message.server.PossibleCard; import pp.mdga.message.server.PossibleCard;
import pp.mdga.message.server.RankingResponce;
/**
* Abstract class representing a state machine for the server.
* It manages the transitions between different states and delegates
* the handling of messages to the current state.
*/
public abstract class ServerStateMachine extends ServerState { public abstract class ServerStateMachine extends ServerState {
/**
* The current state of the state machine.
*/
private ServerState state; private ServerState state;
public ServerStateMachine(ServerState parent, ServerGameLogic logic) { /**
* Constructs a new instance of ServerStateMachine.
*
* @param parent the parent state
* @param logic the server game logic
*/
protected ServerStateMachine(ServerState parent, ServerGameLogic logic) {
super(parent, logic); super(parent, logic);
} }
/**
* Creates the initial state of a state machine.
*/
public abstract ServerState initialState(); public abstract ServerState initialState();
/**
* Transitions to a new state.
*
* @param newState the new state to transition to
*/
@Override @Override
public void gotoState(ServerState newState) { public void gotoState(ServerState newState) {
LOGGER.log(System.Logger.Level.DEBUG, "{0}: {1} --> {2}", this, state, newState); LOGGER.log(System.Logger.Level.DEBUG, "{0}: {1} --> {2}", this, state, newState);
enter(newState); enter(newState);
} }
/**
* This method is called when the state is entered.
*/
@Override @Override
public void entry() { public void entry() {
final ServerState newState = initialState(); final ServerState newState = initialState();
@@ -28,6 +52,12 @@ public void entry() {
enter(newState); enter(newState);
} }
/**
* Enters a new state.
*
* @param newState the new state to enter
* @throws IllegalArgumentException if the new state does not belong to this state machine
*/
private void enter(ServerState newState) { private void enter(ServerState newState) {
if (newState.parent != this) if (newState.parent != this)
throw new IllegalArgumentException("Wrong state: " + newState + " belongs to " + newState.parent + " instead of " + this); throw new IllegalArgumentException("Wrong state: " + newState + " belongs to " + newState.parent + " instead of " + this);
@@ -35,86 +65,170 @@ private void enter(ServerState newState) {
state.entry(); state.entry();
} }
/**
* This method is called when the state is exited.
*/
@Override @Override
public void receivedAnimationEnd(AnimationEnd msg) { public void exit() {
state.receivedAnimationEnd(msg); state.exit();
} }
// todo piece? /**
* This method is called when an animation ends.
*
* @param msg the animation end message
*/
@Override @Override
public void receivedConfirmPiece(Piece piece) { public void receivedAnimationEnd(AnimationEnd msg, int from) {
state.receivedConfirmPiece(piece); state.receivedAnimationEnd(msg, from);
} }
/**
* This method is called when a TSK is deselected.
*
* @param msg the deselect TSK message
*/
@Override @Override
public void receivedDeselectTSK(DeselectTSK msg) { public void receivedDeselectTSK(DeselectTSK msg, int from) {
state.receivedDeselectTSK(msg); state.receivedDeselectTSK(msg, from);
} }
/**
* This method is called when a NoPowerCard message is received.
*
* @param msg the NoPowerCard message
*/
@Override @Override
public void receivedNoPowerCard(NoPowerCard msg) { public void receivedNoPowerCard(NoPowerCard msg, int from) {
state.receivedNoPowerCard(msg); state.receivedNoPowerCard(msg, from);
} }
/**
* This method is called when a LobbyNotReady message is received.
*
* @param msg the LobbyNotReady message
*/
@Override @Override
public void receivedNotReady(LobbyNotReady msg) { public void receivedNotReady(LobbyNotReady msg, int from) {
state.receivedNotReady(msg); state.receivedNotReady(msg, from);
} }
/**
* This method is called when a LobbyReady message is received.
*
* @param msg the LobbyReady message
*/
@Override @Override
public void receivedSelectCard(SelectCard msg) { public void receivedReady(LobbyReady msg, int from) {
state.receivedSelectCard(msg); state.receivedReady(msg, from);
} }
/**
* This method is called when a RequestDice message is received.
*
* @param msg the RequestDice message
*/
@Override @Override
public void receivedReady(LobbyReady msg) { public void receivedRequestDice(RequestDice msg, int from) {
state.receivedReady(msg); state.receivedRequestDice(msg, from);
} }
/**
* This method is called when a RequestMove message is received.
*
* @param msg the RequestMove message
*/
@Override @Override
public void receivedRequestDice(RequestDice msg) { public void receivedRequestMove(RequestMove msg, int from) {
state.receivedRequestDice(msg); state.receivedRequestMove(msg, from);
} }
// todo msg? /**
* This method is called when a SelectCard message is received.
*
* @param msg the SelectCard message
*/
@Override @Override
public void receivedRollRankingDice() { public void receivedSelectCard(SelectCard msg, int from) {
state.receivedRollRankingDice(); state.receivedSelectCard(msg, from);
} }
/**
* This method is called when a SelectTSK message is received.
*
* @param msg the SelectTSK message
*/
@Override @Override
public void receivedSelectTSK(SelectTSK msg) { public void receivedSelectTSK(SelectTSK msg, int from) {
state.receivedSelectTSK(msg); state.receivedSelectTSK(msg, from);
} }
/**
* This method is called when a SelectedPieces message is received.
*
* @param msg the SelectedPieces message
*/
@Override @Override
public void receivedSelectedPieces(SelectedPieces msg) { public void receivedSelectedPieces(SelectedPieces msg, int from) {
state.receivedSelectedPieces(msg); state.receivedSelectedPieces(msg, from);
} }
/**
* This method is called when a StartGame message is received.
*
* @param msg the StartGame message
*/
@Override @Override
public void receivedStartGame(ClientStartGame msg) { public void receivedStartGame(ClientStartGame msg, int from) {
state.receivedStartGame(msg); state.receivedStartGame(msg, from);
} }
/**
* This method is called when an EndOfTurn message is sent.
*
* @param msg the EndOfTurn message
*/
@Override @Override
public void sentEndOfTurn(EndOfTurn msg) { public void sentEndOfTurn(EndOfTurn msg, int from) {
state.sentEndOfTurn(msg); state.sentEndOfTurn(msg, from);
} }
/**
* This method is called when a PossibleCard message is sent.
*
* @param msg the PossibleCard message
*/
@Override @Override
public void sentPossibleCard(PossibleCard msg) { public void sentPossibleCard(PossibleCard msg, int from) {
state.sentPossibleCard(msg); state.sentPossibleCard(msg, from);
} }
// todo msg?, sent to everyone? /**
* This method is called when a RankingResponce message is sent.
*
* @param msg the RankingResponce message
*/
@Override @Override
public void sentRankingResponse() { public void sentRankingResponse(RankingResponce msg, int from) {
state.sentRankingResponse(); state.sentRankingResponse(msg, from);
} }
/**
* Returns a string representation of the object, including the current state.
*
* @return the string representation of the object
*/
@Override @Override
public String toString() { public String toString() {
return super.toString() + "(in " + state + ")"; return super.toString() + "(in " + state + ")";
} }
/**
* Returns the current state.
*
* @return the current state
*/
public ServerState getState() {
return state;
}
} }

View File

@@ -2,6 +2,7 @@
import pp.mdga.game.Piece; import pp.mdga.game.Piece;
import pp.mdga.game.Player; import pp.mdga.game.Player;
import pp.mdga.message.client.RequestMove;
public class StartPiece extends ServerState { public class StartPiece extends ServerState {
public StartPiece(ServerState parent, ServerGameLogic logic) { public StartPiece(ServerState parent, ServerGameLogic logic) {
@@ -9,12 +10,12 @@ public StartPiece(ServerState parent, ServerGameLogic logic) {
} }
@Override @Override
public void receivedConfirmPiece(Piece p) { public void receivedRequestMove(RequestMove msg, int from) {
if (verifyPiece(p)) { // if (verifyPiece(p)) {
logic.send(new Player(1), new Animation()); // logic.send(new Player(1), new Animation());
// todo: goto state // // todo: goto state
} else { // } else {
logic.send(new Player(1), new pp.mdga.message.server.StartPiece()); // logic.send(new Player(1), new pp.mdga.message.server.StartPiece());
} // }
} }
} }

View File

@@ -11,15 +11,15 @@ public ThirdRoll(ServerState parent, ServerGameLogic logic) {
} }
@Override @Override
public void receivedRequestDice(RequestDice msg) { public void receivedRequestDice(RequestDice msg, int from) {
if (roll == 6) { // if (roll == 6) {
// todo: send to everyone? or one player? // // todo: send to everyone? or one player?
logic.send(new Player(1), new Dice()); // logic.send(new Player(1), new Dice());
// todo: goto ChoosePiece // // todo: goto ChoosePiece
} else { // } else {
// todo: send to everyone? or one player? // // todo: send to everyone? or one player?
logic.send(new Player(1), new DiceAgain()); // logic.send(new Player(1), new DiceAgain());
// todo: goto End from Turn // // todo: goto End from Turn
} // }
} }
} }

View File

@@ -1,5 +1,11 @@
package pp.mdga.server; package pp.mdga.server;
import pp.mdga.client.Spectator;
import pp.mdga.game.Player;
import pp.mdga.message.server.ActivePlayer;
import pp.mdga.message.server.Ceremony;
import pp.mdga.message.server.EndOfTurn;
public class Turn extends ServerState { public class Turn extends ServerState {
private final TurnStateMachine turnStateMachine = new TurnStateMachine(this, logic); private final TurnStateMachine turnStateMachine = new TurnStateMachine(this, logic);
@@ -8,4 +14,23 @@ public Turn(ServerState parent, ServerGameLogic logic) {
} }
// todo: when TurnStateMachine is in the end state, and then? // todo: when TurnStateMachine is in the end state, and then?
@Override
public void exit() {
Player player = logic.getGame().getStartPlayer();
// if (player.isFinished()) {
// logic.send(player, new Spectator());
// } else {
// logic.send(player, new EndOfTurn());
// }
if (logic.getGame().getPlayers().size() == 1) {
broadcastUpdate(new Ceremony());
this.getParent().getParent().exit();
} else {
// todo: next player
broadcastUpdate(new ActivePlayer());
parent.gotoState(new Animation(parent, logic));
}
}
} }

View File

@@ -2,7 +2,8 @@
import pp.mdga.game.Piece; import pp.mdga.game.Piece;
import pp.mdga.game.Player; import pp.mdga.game.Player;
import pp.mdga.message.client.AnimationEnd; import pp.mdga.message.client.RequestDice;
import pp.mdga.message.client.RequestMove;
import pp.mdga.message.server.StartPiece; import pp.mdga.message.server.StartPiece;
public class WaitingPiece extends ServerState { public class WaitingPiece extends ServerState {
@@ -11,12 +12,12 @@ public WaitingPiece(ServerState parent, ServerGameLogic logic) {
} }
@Override @Override
public void receivedConfirmPiece(Piece p) { public void receivedRequestMove(RequestMove msg, int from) {
if (verifyPiece(p)) { // if (verifyPiece(p)) {
logic.send(new Player(1), new Animation()); // logic.send(new Player(1), new Animation());
// todo: goto state // // todo: goto state
} else { // } else {
logic.send(new Player(1), new StartPiece()); // logic.send(new Player(1), new StartPiece());
} // }
} }
} }