feat: make timer stop game (Fixes #15)

app/src/main/java/network/client/Client.java

@@ -4,6 +4,7 @@ import java.io.IOException;
 import java.net.UnknownHostException;
 import java.util.Random;
 
+import common.ConsumerSignal;
 import common.Signal;
 import game.Game;
 import game.Player;
@@ -21,6 +22,7 @@ public class Client {
 	public final Signal onDisconnect = new Signal();
 	public final Signal onClosed = new Signal();
 	public final Signal onGameStarted = new Signal();
+	public final ConsumerSignal<Player> onGameEnd = new ConsumerSignal<>();
 
 	Player player;
 

app/src/main/java/network/client/ClientConnexion.java

@@ -78,8 +78,9 @@ public class ClientConnexion extends Connexion {
 
 	@Override
 	public void visitPacket(EndGamePacket packet) {
-		// TODO Auto-generated method stub
-		throw new UnsupportedOperationException("Unimplemented method 'visitPacket'");
+		Player winner = this.client.getGame().getLeaderboard().getFirst();
+		this.client.getGame().stopGame();
+		this.client.onGameEnd.emit(winner);
 	}
 
 	@Override

app/src/main/java/network/server/Server.java

@@ -8,7 +8,9 @@ import java.util.List;
 
 import game.Game;
 import game.Player;
+import game.Game.GameState;
 import network.protocol.Packet;
+import network.protocol.packets.EndGamePacket;
 import network.protocol.packets.StartGamePacket;
 import sudoku.io.SudokuSerializer;
 import sudoku.structure.MultiDoku;
@@ -38,7 +40,16 @@ public class Server {
 		}
 	}
 
-	public void update() {
+	private void checkTimer() {
+		if (getGame() == null || getGame().getGameState() != GameState.GameGoing)
+			return;
+		long now = Instant.now().getEpochSecond();
+		long end = getGame().getStartTime().getEpochSecond() + getGame().getGameDuration();
+		if (now > end)
+			stopGame();
+	}
+
+	private void checkConnexions() {
 		for (var it = connexions.iterator(); it.hasNext();) {
 			ServerConnexion connexion = it.next();
 			if (!connexion.update()) {
@@ -49,6 +60,11 @@ public class Server {
 		}
 	}
 
+	public void update() {
+		checkTimer();
+		checkConnexions();
+	}
+
 	public void stop() {
 		this.acceptThread.cancel();
 		this.logicThread.cancel();
@@ -78,4 +94,10 @@ public class Server {
 		broadcastPacket(new StartGamePacket(SudokuSerializer.serializeSudoku(doku).toString(), now, gameDuration));
 	}
 
+	public void stopGame() {
+		// we don't need to specify the winner since it has to be the first
+		broadcastPacket(new EndGamePacket());
+		getGame().stopGame();
+	}
+
 }

app/src/main/java/network/server/ServerConnexion.java

@@ -153,9 +153,7 @@ public class ServerConnexion extends Connexion {
 
 	private void checkWin() {
 		if (this.player.getRemainingCells() == 0) {
-			// we don't need to specify the winner since it has to be the first
-			this.server.broadcastPacket(new EndGamePacket());
-			this.server.getGame().stopGame();
+			this.server.stopGame();
 		}
 	}
 

app/src/main/java/network/server/ServerLogicThread.java

@@ -19,7 +19,7 @@ public class ServerLogicThread extends Thread {
 			try {
 				Thread.sleep(50);
 			} catch (InterruptedException e) {
-				// e.printStackTrace();
+				e.printStackTrace();
 				break;
 			}
 		}