diff --git a/.idea/workspace.xml b/.idea/workspace.xml index a7fb959..7e0b642 100644 --- a/.idea/workspace.xml +++ b/.idea/workspace.xml @@ -6,6 +6,11 @@ + + + + + diff --git a/src/main/java/org/toop/Main.java b/src/main/java/org/toop/Main.java index 5ba1913..b22f187 100644 --- a/src/main/java/org/toop/Main.java +++ b/src/main/java/org/toop/Main.java @@ -13,6 +13,7 @@ import org.apache.logging.log4j.Logger; import org.apache.logging.log4j.LogManager; import java.io.IOException; +import java.util.Objects; import java.util.concurrent.CompletableFuture; import java.util.concurrent.ExecutionException; @@ -35,6 +36,13 @@ public class Main { GlobalEventBus.post(new Events.ServerEvents.CreateTicTacToeGameRequest(serverId, "J", "P", ticTacToeGame)); String ticTacToeGameId = ticTacToeGame.get(); GlobalEventBus.post(new Events.ServerEvents.RunTicTacToeGame(serverId, ticTacToeGameId)); + GlobalEventBus.subscribeAndRegister(Events.ServerEvents.ReceivedMessage.class, + event -> { + if (Objects.equals(event.ConnectionUuid(), connectionId)) { + logger.info("Received '{}'", event.message()); + } + } + ); GlobalEventBus.post(new Events.ServerEvents.SendCommand( connectionId, diff --git a/src/main/java/org/toop/game/tictactoe/TicTacToe.java b/src/main/java/org/toop/game/tictactoe/TicTacToe.java index 576731d..127f535 100644 --- a/src/main/java/org/toop/game/tictactoe/TicTacToe.java +++ b/src/main/java/org/toop/game/tictactoe/TicTacToe.java @@ -34,6 +34,7 @@ public class TicTacToe extends GameBase implements Runnable { */ public TicTacToe(String player1, String player2, String gameId) { super(3, new Player(player1, 'X'), new Player(player2, 'O')); + this.gameId = gameId; movesLeft = size * size; } @@ -59,7 +60,7 @@ public class TicTacToe extends GameBase implements Runnable { // if (command == null) { continue; } try { ParsedCommand cmd = this.commandQueue.take(); - logger.info("Game {}, took command: {}", this.gameId, cmd.originalCommand); // TODO: Fix null gameid + logger.info("Game {}, took command: {}", this.gameId, cmd.originalCommand); this.addSendToQueue("OK"); } catch (InterruptedException e) { logger.error("Game {} has crashed.", this.gameId); diff --git a/src/main/java/org/toop/server/backend/tictactoe/TicTacToeServer.java b/src/main/java/org/toop/server/backend/tictactoe/TicTacToeServer.java index e887003..9e1df12 100644 --- a/src/main/java/org/toop/server/backend/tictactoe/TicTacToeServer.java +++ b/src/main/java/org/toop/server/backend/tictactoe/TicTacToeServer.java @@ -114,7 +114,7 @@ public class TicTacToeServer extends TcpServer { try { while (isRunning()) { String msg = game.sendQueue.take(); // blocks until a message is added to the queue - logger.info("Adding: {} to the send queue", msg); + logger.info("Games: {}, Adding: {} to the send queue", game.gameId, msg); this.sendQueue.put(msg); // push to network layer } } catch (InterruptedException e) { diff --git a/src/main/java/org/toop/server/frontend/ServerConnection.java b/src/main/java/org/toop/server/frontend/ServerConnection.java index 5413e20..2f8a99f 100644 --- a/src/main/java/org/toop/server/frontend/ServerConnection.java +++ b/src/main/java/org/toop/server/frontend/ServerConnection.java @@ -108,7 +108,7 @@ public final class ServerConnection implements Runnable { while (running) { String received = tcpClient.readLine(); // blocks if (received != null) { - logger.info("Received: '{}'", received); + logger.info("Connection: {} received: '{}'", this.uuid, received); GlobalEventBus.post(new Events.ServerEvents.ReceivedMessage(this.uuid, received)); } else { break;