Compare commits
1 commit
5ec9b899f0
...
9b10902d2a
Author | SHA1 | Date | |
---|---|---|---|
9b10902d2a |
7 changed files with 64 additions and 65 deletions
|
@ -44,8 +44,7 @@ public class GameSession {
|
||||||
Player player,
|
Player player,
|
||||||
PlayerMoneyCallback moneyCallback,
|
PlayerMoneyCallback moneyCallback,
|
||||||
PlayerHitpointsCallback hitpointsCallback,
|
PlayerHitpointsCallback hitpointsCallback,
|
||||||
EnemiesChangedCallback enemyCallback
|
EnemiesChangedCallback enemyCallback) {
|
||||||
) {
|
|
||||||
this.player = player;
|
this.player = player;
|
||||||
this.moneyCallback = moneyCallback;
|
this.moneyCallback = moneyCallback;
|
||||||
this.hitpointsCallback = hitpointsCallback;
|
this.hitpointsCallback = hitpointsCallback;
|
||||||
|
@ -76,8 +75,7 @@ public class GameSession {
|
||||||
enemyCallback.call(
|
enemyCallback.call(
|
||||||
player,
|
player,
|
||||||
newEnemies.toArray(new Enemy[newEnemies.size()]),
|
newEnemies.toArray(new Enemy[newEnemies.size()]),
|
||||||
changedEnemies.toArray(new Enemy[changedEnemies.size()])
|
changedEnemies.toArray(new Enemy[changedEnemies.size()]));
|
||||||
);
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -92,12 +92,9 @@ public class AStar {
|
||||||
if (!walkable.call(pos)) {
|
if (!walkable.call(pos)) {
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
accumulator.add(
|
accumulator.add(new PathNode(
|
||||||
new PathNode(
|
|
||||||
right,
|
right,
|
||||||
nextCost,
|
nextCost,
|
||||||
right.gridDistance(target) + nextCost
|
right.gridDistance(target) + nextCost));
|
||||||
)
|
|
||||||
);
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
@ -55,8 +55,7 @@ public class Match {
|
||||||
Player player,
|
Player player,
|
||||||
PlayerMoneyCallback moneyCallback,
|
PlayerMoneyCallback moneyCallback,
|
||||||
PlayerHitpointsCallback hitpointsCallback,
|
PlayerHitpointsCallback hitpointsCallback,
|
||||||
EnemiesChangedCallback enemyCallback
|
EnemiesChangedCallback enemyCallback) {
|
||||||
) {
|
|
||||||
boolean isPlayer1 = player1.equals(player);
|
boolean isPlayer1 = player1.equals(player);
|
||||||
boolean isPlayer2 = player2.equals(player);
|
boolean isPlayer2 = player2.equals(player);
|
||||||
if (!isPlayer1 && !isPlayer2) {
|
if (!isPlayer1 && !isPlayer2) {
|
||||||
|
|
|
@ -61,8 +61,7 @@ public class MatchService {
|
||||||
Player player,
|
Player player,
|
||||||
PlayerMoneyCallback moneyCallback,
|
PlayerMoneyCallback moneyCallback,
|
||||||
PlayerHitpointsCallback hitpointsCallback,
|
PlayerHitpointsCallback hitpointsCallback,
|
||||||
EnemiesChangedCallback enemyCallback
|
EnemiesChangedCallback enemyCallback) {
|
||||||
) {
|
|
||||||
Match match = playerMatches.get(player);
|
Match match = playerMatches.get(player);
|
||||||
match.connectPlayer(player, moneyCallback, hitpointsCallback, enemyCallback);
|
match.connectPlayer(player, moneyCallback, hitpointsCallback, enemyCallback);
|
||||||
Optional<GameSession> optionalPlayerSession = match.getPlayerGameSession(player);
|
Optional<GameSession> optionalPlayerSession = match.getPlayerGameSession(player);
|
||||||
|
|
|
@ -1,6 +1,16 @@
|
||||||
package de.towerdefence.server.server.channels.match;
|
package de.towerdefence.server.server.channels.match;
|
||||||
|
|
||||||
|
import java.io.IOException;
|
||||||
|
import java.util.Map;
|
||||||
|
import java.util.Objects;
|
||||||
|
import java.util.concurrent.ConcurrentHashMap;
|
||||||
|
|
||||||
|
import org.springframework.web.socket.CloseStatus;
|
||||||
|
import org.springframework.web.socket.TextMessage;
|
||||||
|
import org.springframework.web.socket.WebSocketSession;
|
||||||
|
|
||||||
import com.fasterxml.jackson.databind.ObjectMapper;
|
import com.fasterxml.jackson.databind.ObjectMapper;
|
||||||
|
|
||||||
import de.towerdefence.server.game.Enemy;
|
import de.towerdefence.server.game.Enemy;
|
||||||
import de.towerdefence.server.game.exeptions.InvalidPlacementException;
|
import de.towerdefence.server.game.exeptions.InvalidPlacementException;
|
||||||
import de.towerdefence.server.match.MatchService;
|
import de.towerdefence.server.match.MatchService;
|
||||||
|
@ -16,13 +26,6 @@ import de.towerdefence.server.server.channels.match.placing.RequestTowerPlacingM
|
||||||
import de.towerdefence.server.server.channels.match.placing.TowerPlacedMessage;
|
import de.towerdefence.server.server.channels.match.placing.TowerPlacedMessage;
|
||||||
import de.towerdefence.server.session.Channel;
|
import de.towerdefence.server.session.Channel;
|
||||||
import de.towerdefence.server.session.SessionsService;
|
import de.towerdefence.server.session.SessionsService;
|
||||||
import java.io.IOException;
|
|
||||||
import java.util.Map;
|
|
||||||
import java.util.Objects;
|
|
||||||
import java.util.concurrent.ConcurrentHashMap;
|
|
||||||
import org.springframework.web.socket.CloseStatus;
|
|
||||||
import org.springframework.web.socket.TextMessage;
|
|
||||||
import org.springframework.web.socket.WebSocketSession;
|
|
||||||
|
|
||||||
public class MatchWebsocketHandler extends JsonWebsocketHandler {
|
public class MatchWebsocketHandler extends JsonWebsocketHandler {
|
||||||
|
|
||||||
|
@ -74,7 +77,7 @@ public class MatchWebsocketHandler extends JsonWebsocketHandler {
|
||||||
WebSocketSession session = playerSessions.get(player);
|
WebSocketSession session = playerSessions.get(player);
|
||||||
try {
|
try {
|
||||||
new EnemyUpdateMessage(newEnemies, changedEnemies).send(session);
|
new EnemyUpdateMessage(newEnemies, changedEnemies).send(session);
|
||||||
} catch (IOException ignored) {
|
}catch(IOException ignored){
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -92,16 +95,20 @@ public class MatchWebsocketHandler extends JsonWebsocketHandler {
|
||||||
} catch (IOException ignored) {
|
} catch (IOException ignored) {
|
||||||
this.closeSession(session, CloseStatus.BAD_DATA);
|
this.closeSession(session, CloseStatus.BAD_DATA);
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
private void handleRequestTowerPlacingMessage(WebSocketSession session, String payload)
|
private void handleRequestTowerPlacingMessage(
|
||||||
throws IOException {
|
WebSocketSession session,
|
||||||
RequestTowerPlacingMessage msg =
|
String payload) throws IOException {
|
||||||
objectMapper.readValue(payload, RequestTowerPlacingMessage.class);
|
RequestTowerPlacingMessage msg = objectMapper.readValue(payload, RequestTowerPlacingMessage.class);
|
||||||
Player opponent;
|
Player opponent;
|
||||||
try {
|
try {
|
||||||
opponent =
|
opponent = this.matchService.placeTower(
|
||||||
this.matchService.placeTower(this.sessionPlayers.get(session), msg.getX(), msg.getY());
|
this.sessionPlayers.get(session),
|
||||||
|
msg.getX(),
|
||||||
|
msg.getY()
|
||||||
|
);
|
||||||
} catch (InvalidPlacementException exception) {
|
} catch (InvalidPlacementException exception) {
|
||||||
new InvalidPlacementMessage(msg.getX(), msg.getY(), exception.getReason()).send(session);
|
new InvalidPlacementMessage(msg.getX(), msg.getY(), exception.getReason()).send(session);
|
||||||
return;
|
return;
|
||||||
|
|
|
@ -26,7 +26,6 @@ public class InvalidPlacementMessage extends JsonMessage {
|
||||||
return Map.of(
|
return Map.of(
|
||||||
"x", factory.numberNode(this.x),
|
"x", factory.numberNode(this.x),
|
||||||
"y", factory.numberNode(this.y),
|
"y", factory.numberNode(this.y),
|
||||||
"reason", factory.textNode(this.reason.getJsonName())
|
"reason", factory.textNode(this.reason.getJsonName()));
|
||||||
);
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
Loading…
Add table
Reference in a new issue