summaryrefslogtreecommitdiff
path: root/shared/src/main/java/kz/ilotterytea/frogartha/domain/events
diff options
context:
space:
mode:
authorilotterytea <iltsu@alright.party>2025-01-22 18:08:38 +0500
committerilotterytea <iltsu@alright.party>2025-01-22 18:08:38 +0500
commit9f1e7c6eaecc3f9c97b77163c5e2ba7a2cfde081 (patch)
treec0338e9c43174730d1d1a60ddf656903654ac071 /shared/src/main/java/kz/ilotterytea/frogartha/domain/events
parent7e2fa5847637b39c46493bb95d81d92dc5b2d603 (diff)
upd: pass id in PlayerData + other way to send an array of players
Diffstat (limited to 'shared/src/main/java/kz/ilotterytea/frogartha/domain/events')
-rw-r--r--shared/src/main/java/kz/ilotterytea/frogartha/domain/events/SenderJoinedRoomEvent.java21
1 files changed, 8 insertions, 13 deletions
diff --git a/shared/src/main/java/kz/ilotterytea/frogartha/domain/events/SenderJoinedRoomEvent.java b/shared/src/main/java/kz/ilotterytea/frogartha/domain/events/SenderJoinedRoomEvent.java
index b032c47..93caea0 100644
--- a/shared/src/main/java/kz/ilotterytea/frogartha/domain/events/SenderJoinedRoomEvent.java
+++ b/shared/src/main/java/kz/ilotterytea/frogartha/domain/events/SenderJoinedRoomEvent.java
@@ -9,23 +9,18 @@ import kz.ilotterytea.frogartha.domain.PlayerData;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
-import java.util.stream.Collectors;
public class SenderJoinedRoomEvent extends Event implements Transferable<SenderJoinedRoomEvent> {
- private List<Integer> ids;
private List<PlayerData> players;
+ private int playerCount;
public SenderJoinedRoomEvent() {
}
- public SenderJoinedRoomEvent(int playerId, List<Integer> ids, List<PlayerData> players) {
+ public SenderJoinedRoomEvent(int playerId, List<PlayerData> players) {
super(playerId);
- this.ids = ids;
this.players = players;
- }
-
- public List<Integer> getIds() {
- return ids;
+ this.playerCount = players.size();
}
public List<PlayerData> getPlayers() {
@@ -35,17 +30,17 @@ public class SenderJoinedRoomEvent extends Event implements Transferable<SenderJ
@Override
public void serialize(Serializer serializer) throws SerializationException {
serializer.serializeInt(playerId)
- .serializeIntArray(ids.stream().mapToInt(Integer::intValue).toArray())
+ .serializeInt(playerCount)
.serializeTransferableArray(players.toArray(new PlayerData[]{}));
}
@Override
public SenderJoinedRoomEvent deserialize(Deserializer deserializer) throws SerializationException {
- List<Integer> ids = Arrays.stream(deserializer.deserializeIntArray()).boxed().collect(Collectors.toList());
+ int id = deserializer.deserializeInt();
+ int playerCount = deserializer.deserializeInt();
return new SenderJoinedRoomEvent(
- deserializer.deserializeInt(),
- new ArrayList<>(ids),
- new ArrayList<>(Arrays.asList(deserializer.deserializeTransferableArray(new PlayerData(), size -> new PlayerData[ids.size()])))
+ id,
+ new ArrayList<>(Arrays.asList(deserializer.deserializeTransferableArray(new PlayerData(), size -> new PlayerData[playerCount])))
);
}
}