package jrummikub.control.network; import java.util.Date; import jrummikub.control.RoundControl; import jrummikub.control.turn.ITurnControl; import jrummikub.model.IRoundState; import jrummikub.model.ITable; import jrummikub.model.PlayerSettings.Type; import jrummikub.util.IListener; import jrummikub.util.IListener1; import jrummikub.view.IView; public class NetworkRoundControl extends RoundControl { private IConnectionControl connectionControl; private boolean currentlyActive; public NetworkRoundControl(IRoundState roundState, IView view, final IConnectionControl connectionControl, boolean startActive) { super(roundState, view); this.connectionControl = connectionControl; currentlyActive = startActive; connections.add(connectionControl.getRoundStateUpdateEvent().add( new IListener1() { @Override public void handle(IRoundState state) { NetworkControl.fixGameSettings(state.getGameSettings(), connectionControl.getNickname()); setRoundState(state); } })); connections.add(connectionControl.getTurnStartEvent().add(new IListener() { @Override public void handle() { System.err.println(new Date() + ": Received startTurn"); startTurn(); } })); connections.add(connectionControl.getNextPlayerEvent().add(new IListener() { @Override public void handle() { System.err.println(new Date() + ": Received nextPlayer"); NetworkRoundControl.super.nextPlayer(); } })); } @Override protected void addTurnControlListeners(ITurnControl turnControl) { turnControl.getTableUpdateEvent().add(new IListener1() { @Override public void handle(ITable table) { connectionControl.updateTable(table); } }); } @Override protected ITurnControl createTurnControl(Type type) { switch (type) { case HUMAN: currentlyActive = true; break; case NETWORK: currentlyActive = false; break; } System.err.println("Creating a " + (currentlyActive ? "normal" : "network") + " turn control for a " + type); if (!currentlyActive) { return new NetworkTurnControl(connectionControl); } return super.createTurnControl(type); } @Override protected void prepareTurn() { if (currentlyActive) { System.err.println(new Date() + ": Sending startTurn"); connectionControl.startTurn(); } doPrepareTurn(); } @Override protected void deal() { super.deal(); if (currentlyActive) { connectionControl.updateRoundState(roundState); } } @Override protected void nextPlayer() { if (currentlyActive) { System.err.println(new Date() + ": Sending nextPlayer"); connectionControl.nextPlayer(); } } @Override protected void endOfTurn(InvalidTurnInfo invalidTurnInfo) { if (currentlyActive) { System.err.println(new Date() + ": Sending endTurn"); connectionControl.endTurn(roundState, invalidTurnInfo); } super.endOfTurn(invalidTurnInfo); } }