Yandrik/Server
1
0
Fork 0
Code Issues Pull Requests Projects Releases 1 Wiki Activity

fix: send GameStructure on reconnect

Browse Source
This commit is contained in:
punchready 2021-06-07 09:04:18 +02:00
parent efa5ce3848
commit 3be518f13b
2 changed files with 26 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
Server/src/main/java/uulm/teamname/marvelous/server/lobbymanager/LobbyConnection.java
View File

@ -119,14 +119,15 @@ public class LobbyConnection implements Runnable {
public void handleDisconnect(Participant participant) {
participant.disconnected = true;
if(lobby != null) {
if(state == LobbyConnectionState.Started) {
lobby.handleDisconnect(participant);
}
}
public void handleReconnect(Participant participant) {
participant.disconnected = false;
if(lobby != null) {
if(state == LobbyConnectionState.Started) {
sendGameStructure(participant.equals(player1), participant.equals(player2), false);
lobby.handleReconnect(participant);
}
}
@ -144,7 +145,7 @@ public class LobbyConnection implements Runnable {
Logger.info("Starting Lobby thread for lobby '{}'", gameID);
sendGameStructure();
sendGameStructure(true, true, true);
this.lobby = new Lobby(
gameID,
@ -170,7 +171,7 @@ public class LobbyConnection implements Runnable {
}
private void sendGameStructure() {
private void sendGameStructure(boolean p1, boolean p2, boolean spectators) {
GameStructureMessage gameStructureMessage = new GameStructureMessage();
gameStructureMessage.playerOneName = player1.id.getName();
gameStructureMessage.playerTwoName = player2.id.getName();
@ -190,15 +191,21 @@ public class LobbyConnection implements Runnable {
gameStructureMessage.scenarioconfig = Server.getScenarioConfig();
// Sending GameStructure message with fitting assignment
if(p1) {
gameStructureMessage.assignment = ParticipantType.PlayerOne;
player1.sendMessage(gameStructureMessage);
}
if(p2) {
gameStructureMessage.assignment = ParticipantType.PlayerTwo;
player2.sendMessage(gameStructureMessage);
}
if(spectators) {
gameStructureMessage.assignment = ParticipantType.Spectator;
broadcastToSpectators(gameStructureMessage);
}
}
private Tuple<Participant, Request[]> pollQueueAsync() {
Tuple<Participant, Request[]> current = null;

9
Server/src/main/java/uulm/teamname/marvelous/server/lobbymanager/Participant.java
View File

@ -2,6 +2,7 @@ package uulm.teamname.marvelous.server.lobbymanager;
import uulm.teamname.marvelous.gamelibrary.messages.BasicMessage;
import uulm.teamname.marvelous.gamelibrary.messages.ParticipantType;
import uulm.teamname.marvelous.server.lobby.Lobby;
import uulm.teamname.marvelous.server.netconnector.Client;
import uulm.teamname.marvelous.server.netconnector.SUID;
@ -41,4 +42,12 @@ public class Participant {
}
return client.sendMessage(message);
}
@Override
public boolean equals(Object o) {
if (this == o) return true;
if (o == null || getClass() != o.getClass()) return false;
Participant other = (Participant) o;
return other.id.equals(id);
}
}