5 Commits

Author SHA1 Message Date
Bas de Jong
9c01aabbe1 Fixed merge mistakes 2026-01-07 23:46:21 +01:00
Bas Antonius de Jong
0cb52b042f Merge branch 'Development' into 289-server 2026-01-07 23:44:13 +01:00
Bas de Jong
56a8d12e46 Logging and fixed user input getting stuck 2026-01-07 23:38:53 +01:00
65220d9649 Hotfix for stuff 2026-01-07 17:16:45 +01:00
Bas Antonius de Jong
c64a2e2c65 Server update with new dev changes (#305)
* merge widgets with development

* readd previous game thread code

* Revert "readd previous game thread code"

This reverts commit d24feef73e.

* Revert "Merge remote-tracking branch 'origin/Development' into Development"

This reverts commit 59d46cb73c, reversing
changes made to 38681c5db0.

* Revert "merge widgets with development"

This reverts commit 38681c5db0.

* Merge 292 into development (#293)

Applied template method pattern to abstract player

* Added documentation to player classes and improved method names (#295)

* mcts v1

* bitboard optimization

* bitboard fix & mcts v2 & mcts v3. v3 still in progress and v4 coming soon

* main

---------

Co-authored-by: ramollia <>
Co-authored-by: Stef <stbuwalda@gmail.com>
Co-authored-by: Stef <48526421+StefBuwalda@users.noreply.github.com>
2026-01-07 16:15:49 +01:00
9 changed files with 87 additions and 50 deletions

View File

@@ -19,7 +19,7 @@ import org.toop.framework.networking.connection.clients.TournamentNetworkingClie
import org.toop.framework.networking.connection.events.NetworkEvents; import org.toop.framework.networking.connection.events.NetworkEvents;
import org.toop.framework.networking.connection.types.NetworkingConnector; import org.toop.framework.networking.connection.types.NetworkingConnector;
import org.toop.framework.networking.server.gateway.NettyGatewayServer; import org.toop.framework.networking.server.gateway.NettyGatewayServer;
import org.toop.game.players.LocalPlayer; import org.toop.framework.game.players.LocalPlayer;
import org.toop.local.AppContext; import org.toop.local.AppContext;
import java.util.List; import java.util.List;
@@ -196,30 +196,21 @@ public final class Server {
return; return;
} }
final int myTurn = response.playerToMove().equalsIgnoreCase(response.opponent()) ? 1 : 0; final String startingPlayer = response.playerToMove();
final int userStartingTurn = startingPlayer.equalsIgnoreCase(user) ? 0 : 1;
final int opponentStartingTurn = 1 - userStartingTurn;
final GameInformation information = new GameInformation(type); final GameInformation information = new GameInformation(type);
//information.players[0] = playerInformation; information.players[userStartingTurn].name = user;
information.players[0].name = user; information.players[opponentStartingTurn].name = response.opponent();
information.players[0].isHuman = true; // Make false and uncomment/comment code at lines HERE To make use of AI.
// information.players[0].computerDifficulty = 5; // HERE Player[] players = new Player[2];
// information.players[0].computerThinkTime = 1; // HERE players[userStartingTurn] = new LocalPlayer(user);
information.players[1].name = response.opponent(); players[opponentStartingTurn] = new OnlinePlayer(response.opponent());
switch (type) { switch (type) {
case TICTACTOE -> { case TICTACTOE -> gameController = new TicTacToeBitController(players);
Player[] players = new Player[2]; case REVERSI -> gameController = new ReversiBitController(players);
players[Math.abs(myTurn-1)] = new OnlinePlayer(response.opponent());
players[myTurn] = new LocalPlayer(user); // HERE
// players[myTurn] = new ArtificialPlayer(new RandomAI(), user); // HERE
gameController = new TicTacToeBitController(players);
}
case REVERSI -> {
Player[] players = new Player[2];
players[Math.abs(myTurn-1)] = new OnlinePlayer(response.opponent());
players[myTurn] = new LocalPlayer(user); // HERE
// players[myTurn] = new ArtificialPlayer(new RandomAI(), user); // HERE
gameController = new ReversiBitController(players);}
default -> new ErrorPopup("Unsupported game type."); default -> new ErrorPopup("Unsupported game type.");
} }

View File

@@ -78,6 +78,7 @@ public abstract class BitGameCanvas implements GameCanvas {
} }
canvas.setOnMouseClicked(event -> { canvas.setOnMouseClicked(event -> {
if (event.getButton() != MouseButton.PRIMARY) { if (event.getButton() != MouseButton.PRIMARY) {
return; return;
} }
@@ -93,9 +94,6 @@ public abstract class BitGameCanvas implements GameCanvas {
} }
}); });
render(); render();
} }

View File

@@ -16,7 +16,7 @@ import org.toop.framework.gameFramework.model.game.threadBehaviour.ThreadBehavio
import org.toop.framework.gameFramework.model.player.Player; import org.toop.framework.gameFramework.model.player.Player;
import org.toop.framework.gameFramework.view.GUIEvents; import org.toop.framework.gameFramework.view.GUIEvents;
import org.toop.framework.networking.connection.events.NetworkEvents; import org.toop.framework.networking.connection.events.NetworkEvents;
import org.toop.game.players.LocalPlayer; import org.toop.framework.game.players.LocalPlayer;
public class GenericGameController implements GameController { public class GenericGameController implements GameController {
protected final EventFlow eventFlow = new EventFlow(); protected final EventFlow eventFlow = new EventFlow();
@@ -35,14 +35,16 @@ public class GenericGameController implements GameController {
// TODO: Change gameType to automatically happen with either dependency injection or something else. // TODO: Change gameType to automatically happen with either dependency injection or something else.
public GenericGameController(GameCanvas canvas, TurnBasedGame game, ThreadBehaviour gameThreadBehaviour, String gameType) { public GenericGameController(GameCanvas canvas, TurnBasedGame game, ThreadBehaviour gameThreadBehaviour, String gameType) {
logger.info("Creating: " + this.getClass()); logger.info("Creating: {}", this.getClass());
this.canvas = canvas; this.canvas = canvas;
this.game = game; this.game = game;
this.gameThreadBehaviour = gameThreadBehaviour; this.gameThreadBehaviour = gameThreadBehaviour;
// Tell thread how to send moves // Tell thread how to send moves
this.gameThreadBehaviour.setOnSendMove((id, m) -> GlobalEventBus.get().post(new NetworkEvents.SendMove(id, (short)translateMove(m)))); this.gameThreadBehaviour.setOnSendMove(
(id, m) -> GlobalEventBus.get().post(new NetworkEvents.SendMove(id, (short)translateMove(m)))
);
// Tell thread how to update UI // Tell thread how to update UI
this.gameThreadBehaviour.setOnUpdateUI(() -> Platform.runLater(this::updateUI)); this.gameThreadBehaviour.setOnUpdateUI(() -> Platform.runLater(this::updateUI));
@@ -53,21 +55,37 @@ public class GenericGameController implements GameController {
WidgetContainer.getCurrentView().transitionNext(gameView, true); WidgetContainer.getCurrentView().transitionNext(gameView, true);
// Listen to updates // Listen to updates
logger.info("Game controller started listening");
eventFlow eventFlow
.listen(GUIEvents.GameEnded.class, this::onGameFinish, false) .listen(GUIEvents.GameEnded.class, this::onGameFinish, false)
.listen(GUIEvents.PlayerAttemptedMove.class, event -> {if (getCurrentPlayer() instanceof LocalPlayer lp){lp.setLastMove(event.move());}}, false); .listen(GUIEvents.PlayerAttemptedMove.class, event -> {
logger.info("User attempting move {}", event.move());
logger.info("Current player's turn {}", getCurrentPlayer().getName());
logger.info("First player {}", game.getPlayer(0).getName());
logger.info("Username {}", getCurrentPlayer().getName());
logger.info("User is class {}, {}", getCurrentPlayer().getClass(), getCurrentPlayer() instanceof LocalPlayer);
if (getCurrentPlayer() instanceof LocalPlayer lp) {
try {
lp.setLastMove(event.move());
} catch (Exception e) {
IO.println(e);
}
}
}, false);
} }
public void start(){ public void start(){
logger.info("Starting GameManager"); logger.info("Starting GameManager");
updateUI(); updateUI();
gameThreadBehaviour.start(); gameThreadBehaviour.start();
logger.info("GameManager started");
} }
public void stop(){ public void stop(){
logger.info("Stopping GameManager"); logger.info("Stopping GameManager");
removeListeners(); removeListeners();
gameThreadBehaviour.stop(); gameThreadBehaviour.stop();
logger.info("GameManager stopped");
} }
public Player getCurrentPlayer(){ public Player getCurrentPlayer(){
@@ -98,7 +116,7 @@ public class GenericGameController implements GameController {
} }
public Player getPlayer(int player){ public Player getPlayer(int player){
if (player < 0 || player >= 2){ // TODO: Make game turn player count if (player < 0 || player > game.getPlayerCount()-1){ // TODO: Make game turn player count
logger.error("Invalid player index"); logger.error("Invalid player index");
throw new IllegalArgumentException("player out of range"); throw new IllegalArgumentException("player out of range");
} }

View File

@@ -7,7 +7,6 @@ import org.toop.framework.game.gameThreads.LocalThreadBehaviour;
import org.toop.framework.game.gameThreads.OnlineThreadBehaviour; import org.toop.framework.game.gameThreads.OnlineThreadBehaviour;
import org.toop.framework.game.games.tictactoe.BitboardTicTacToe; import org.toop.framework.game.games.tictactoe.BitboardTicTacToe;
import org.toop.framework.game.players.OnlinePlayer; import org.toop.framework.game.players.OnlinePlayer;
import org.toop.framework.networking.server.OnlineGame;
import java.util.Arrays; import java.util.Arrays;

View File

@@ -12,7 +12,7 @@ import org.toop.app.widget.complex.PlayerInfoWidget;
import org.toop.app.widget.complex.ViewWidget; import org.toop.app.widget.complex.ViewWidget;
import org.toop.app.widget.popup.ErrorPopup; import org.toop.app.widget.popup.ErrorPopup;
import org.toop.app.widget.tutorial.*; import org.toop.app.widget.tutorial.*;
import org.toop.game.players.LocalPlayer; import org.toop.framework.game.players.LocalPlayer;
import org.toop.game.players.ai.MCTSAI; import org.toop.game.players.ai.MCTSAI;
import org.toop.game.players.ai.MCTSAI2; import org.toop.game.players.ai.MCTSAI2;
import org.toop.game.players.ai.MCTSAI3; import org.toop.game.players.ai.MCTSAI3;

View File

@@ -47,9 +47,11 @@ public abstract class BitboardGame implements TurnBasedGame {
this.playerBitboard = other.playerBitboard.clone(); this.playerBitboard = other.playerBitboard.clone();
this.currentTurn = other.currentTurn; this.currentTurn = other.currentTurn;
this.players = Arrays.stream(other.players) this.players = other.players;
.map(Player::deepCopy) // TODO: Players are not deep copied, which is bad. I don't know why but deepcopying breaks it. Fix it
.toArray(Player[]::new); //this.players = Arrays.stream(other.players)
// .map(Player::deepCopy)
// .toArray(Player[]::new);
} }
public int getColumnSize() { public int getColumnSize() {

View File

@@ -8,6 +8,9 @@ import org.toop.framework.gameFramework.model.game.threadBehaviour.SupportsOnlin
import org.toop.framework.gameFramework.model.player.Player; import org.toop.framework.gameFramework.model.player.Player;
import org.toop.framework.game.players.OnlinePlayer; import org.toop.framework.game.players.OnlinePlayer;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
/** /**
* Handles online multiplayer game logic. * Handles online multiplayer game logic.
* <p> * <p>
@@ -15,6 +18,9 @@ import org.toop.framework.game.players.OnlinePlayer;
* for the local player while receiving moves from other players. * for the local player while receiving moves from other players.
*/ */
public class OnlineThreadBehaviour extends AbstractThreadBehaviour implements SupportsOnlinePlay { public class OnlineThreadBehaviour extends AbstractThreadBehaviour implements SupportsOnlinePlay {
private ExecutorService moveExecutor = Executors.newSingleThreadExecutor();
/** /**
* Creates behaviour and sets the first local player * Creates behaviour and sets the first local player
* (non-online player) from the given array. * (non-online player) from the given array.
@@ -51,9 +57,33 @@ public class OnlineThreadBehaviour extends AbstractThreadBehaviour implements Su
*/ */
@Override @Override
public void onYourTurn(long clientId) { public void onYourTurn(long clientId) {
if (!isRunning.get()) return; logger.info("Yourturn");
long move = game.getPlayer(game.getCurrentTurn()).getMove(game.deepCopy()); if (!isRunning.get()) {
logger.warn("Game is not running!");
return;
}
TurnBasedGame gameCopy = game.deepCopy();
if (gameCopy == null) {
logger.error("Could not deep copy game");
return;
}
logger.info("Successfully collected game copy");
Player player = gameCopy.getPlayer(game.getCurrentTurn());
if (player == null) {
logger.error("Could not find current turn's player");
return;
}
logger.info("Successfully collected current turn's player");
moveExecutor.submit(() -> {
long move = player.getMove(gameCopy);
logger.info("Move set: {}", move);
logger.info("Completed onYourTurn");
sendMove(clientId, move); sendMove(clientId, move);
});
} }
/** /**

View File

@@ -1,4 +1,4 @@
package org.toop.game.players; package org.toop.framework.game.players;
import org.toop.framework.gameFramework.model.game.TurnBasedGame; import org.toop.framework.gameFramework.model.game.TurnBasedGame;
import org.toop.framework.gameFramework.model.player.AbstractPlayer; import org.toop.framework.gameFramework.model.player.AbstractPlayer;
@@ -45,11 +45,16 @@ public class LocalPlayer extends AbstractPlayer {
long legalMoves = gameCopy.getLegalMoves(); long legalMoves = gameCopy.getLegalMoves();
long move; long move;
try {
do { do {
move = getLastMove(); move = getLastMove();
IO.println("GETTING MOVE");
} while ((legalMoves & move) == 0); } while ((legalMoves & move) == 0);
return move; return move;
} catch (Exception e) {
IO.println(e);
}
return -1;
} }
/** /**

View File

@@ -11,8 +11,6 @@ import org.toop.framework.networking.server.Server;
import org.toop.framework.networking.server.client.Client; import org.toop.framework.networking.server.client.Client;
import org.toop.framework.networking.server.parsing.Parser; import org.toop.framework.networking.server.parsing.Parser;
import java.util.Arrays;
public class NettyClientSession extends SimpleChannelInboundHandler<String> implements ClientSession<OnlineTurnBasedGame, ServerPlayer> { public class NettyClientSession extends SimpleChannelInboundHandler<String> implements ClientSession<OnlineTurnBasedGame, ServerPlayer> {
private final NettyClient client; private final NettyClient client;
@@ -41,13 +39,9 @@ public class NettyClientSession extends SimpleChannelInboundHandler<String> impl
@Override @Override
protected void channelRead0(ChannelHandlerContext ctx, String msg) { protected void channelRead0(ChannelHandlerContext ctx, String msg) {
IO.println(msg);
ParsedMessage p = Parser.parse(msg); ParsedMessage p = Parser.parse(msg);
if (p == null) return; if (p == null) return;
IO.println(p.command() + " " + Arrays.toString(p.args()));
handler.handle(p); handler.handle(p);
} }