feat: chat !!!

6 files changed, 85 insertions, 4 deletions

diff --git a/shared/src/main/java/kz/ilotterytea/frogartha/FrogarthaConstants.java b/shared/src/main/java/kz/ilotterytea/frogartha/FrogarthaConstants.java
index 84dc6b0..e205bf5 100644
--- a/shared/src/main/java/kz/ilotterytea/frogartha/FrogarthaConstants.java
+++ b/shared/src/main/java/kz/ilotterytea/frogartha/FrogarthaConstants.java
@@ -14,4 +14,9 @@ public class FrogarthaConstants {
     public static class Room {
         public static final int MAX_PLAYERS = 30;
     }
+
+    public static class Chat {
+        public static final int MAX_MESSAGE_LENGTH = 100;
+        public static final int MESSAGE_PER_MS = 500;
+    }
 }
diff --git a/shared/src/main/java/kz/ilotterytea/frogartha/domain/PlayerState.java b/shared/src/main/java/kz/ilotterytea/frogartha/domain/PlayerState.java
index 0aa89c5..c3db5a8 100644
--- a/shared/src/main/java/kz/ilotterytea/frogartha/domain/PlayerState.java
+++ b/shared/src/main/java/kz/ilotterytea/frogartha/domain/PlayerState.java
@@ -11,6 +11,7 @@ public class PlayerState implements Transferable<PlayerState> {
     private final Vector3 position;
     private final Vector2 direction;
     private float nextJumpTimestamp;
+    private long lastMessageTimestamp;
 
     public PlayerState() {
         this(new Vector3(), new Vector2());
@@ -42,6 +43,14 @@ public class PlayerState implements Transferable<PlayerState> {
         this.nextJumpTimestamp = nextJumpTimestamp;
     }
 
+    public long getLastMessageTimestamp() {
+        return lastMessageTimestamp;
+    }
+
+    public void setLastMessageTimestamp(long lastMessageTimestamp) {
+        this.lastMessageTimestamp = lastMessageTimestamp;
+    }
+
     public void setDirection(float x, float z) {
         this.direction.set(x, z);
     }
diff --git a/shared/src/main/java/kz/ilotterytea/frogartha/domain/actions/ChatMessageAction.java b/shared/src/main/java/kz/ilotterytea/frogartha/domain/actions/ChatMessageAction.java
new file mode 100644
index 0000000..465238a
--- /dev/null
+++ b/shared/src/main/java/kz/ilotterytea/frogartha/domain/actions/ChatMessageAction.java
@@ -0,0 +1,31 @@
+package kz.ilotterytea.frogartha.domain.actions;
+
+import com.github.czyzby.websocket.serialization.SerializationException;
+import com.github.czyzby.websocket.serialization.Transferable;
+import com.github.czyzby.websocket.serialization.impl.Deserializer;
+import com.github.czyzby.websocket.serialization.impl.Serializer;
+
+public class ChatMessageAction implements Transferable<ChatMessageAction> {
+    private String message;
+
+    public ChatMessageAction() {
+    }
+
+    public ChatMessageAction(String message) {
+        this.message = message;
+    }
+
+    public String getMessage() {
+        return message;
+    }
+
+    @Override
+    public void serialize(Serializer serializer) throws SerializationException {
+        serializer.serializeString(message);
+    }
+
+    @Override
+    public ChatMessageAction deserialize(Deserializer deserializer) throws SerializationException {
+        return new ChatMessageAction(deserializer.deserializeString());
+    }
+}
diff --git a/shared/src/main/java/kz/ilotterytea/frogartha/domain/events/ChatMessageEvent.java b/shared/src/main/java/kz/ilotterytea/frogartha/domain/events/ChatMessageEvent.java
new file mode 100644
index 0000000..7bd395e
--- /dev/null
+++ b/shared/src/main/java/kz/ilotterytea/frogartha/domain/events/ChatMessageEvent.java
@@ -0,0 +1,32 @@
+package kz.ilotterytea.frogartha.domain.events;
+
+import com.github.czyzby.websocket.serialization.SerializationException;
+import com.github.czyzby.websocket.serialization.Transferable;
+import com.github.czyzby.websocket.serialization.impl.Deserializer;
+import com.github.czyzby.websocket.serialization.impl.Serializer;
+
+public class ChatMessageEvent extends Event implements Transferable<ChatMessageEvent> {
+    private String message;
+
+    public ChatMessageEvent() {
+    }
+
+    public ChatMessageEvent(int playerId, String message) {
+        super(playerId);
+        this.message = message;
+    }
+
+    public String getMessage() {
+        return message;
+    }
+
+    @Override
+    public void serialize(Serializer serializer) throws SerializationException {
+        serializer.serializeInt(playerId).serializeString(message);
+    }
+
+    @Override
+    public ChatMessageEvent deserialize(Deserializer deserializer) throws SerializationException {
+        return new ChatMessageEvent(deserializer.deserializeInt(), deserializer.deserializeString());
+    }
+}
diff --git a/shared/src/main/java/kz/ilotterytea/frogartha/exceptions/PlayerKickException.java b/shared/src/main/java/kz/ilotterytea/frogartha/exceptions/PlayerKickException.java
index ad9c408..e24c633 100644
--- a/shared/src/main/java/kz/ilotterytea/frogartha/exceptions/PlayerKickException.java
+++ b/shared/src/main/java/kz/ilotterytea/frogartha/exceptions/PlayerKickException.java
@@ -33,6 +33,10 @@ public class PlayerKickException extends RuntimeException implements Transferabl
         return new PlayerKickException("You are not in room");
     }
 
+    public static PlayerKickException messageSpam() {
+        return new PlayerKickException("Kicked for spamming");
+    }
+
     @Override
     public void serialize(Serializer serializer) throws SerializationException {
         serializer.serializeString(getMessage());
diff --git a/shared/src/main/java/kz/ilotterytea/frogartha/utils/SerializerUtils.java b/shared/src/main/java/kz/ilotterytea/frogartha/utils/SerializerUtils.java
index e005937..3529968 100644
--- a/shared/src/main/java/kz/ilotterytea/frogartha/utils/SerializerUtils.java
+++ b/shared/src/main/java/kz/ilotterytea/frogartha/utils/SerializerUtils.java
@@ -2,10 +2,7 @@ package kz.ilotterytea.frogartha.utils;
 
 import com.github.czyzby.websocket.serialization.impl.ManualSerializer;
 import kz.ilotterytea.frogartha.domain.Identity;
-import kz.ilotterytea.frogartha.domain.actions.ChangedDirectionAction;
-import kz.ilotterytea.frogartha.domain.actions.JoinRoomAction;
-import kz.ilotterytea.frogartha.domain.actions.LeaveRoomAction;
-import kz.ilotterytea.frogartha.domain.actions.PlayerJumpAction;
+import kz.ilotterytea.frogartha.domain.actions.*;
 import kz.ilotterytea.frogartha.domain.events.*;
 import kz.ilotterytea.frogartha.exceptions.PlayerKickException;
 
@@ -26,5 +23,8 @@ public class SerializerUtils {
         serializer.register(new LeaveRoomAction());
         serializer.register(new PlayerLeftRoomEvent());
         serializer.register(new SenderLeftRoomEvent());
+
+        serializer.register(new ChatMessageAction());
+        serializer.register(new ChatMessageEvent());
     }
 }