feat(punishment): add query protocol objects for punishment service

Add GetActivePunishmentProtocolObject and GetAllBannedIdsProtocolObject
so proxy and game servers can query the punishment service instead of
accessing PunishmentRedis directly.

Author: Swofty-Developments

commons/src/main/java/net/swofty/commons/protocol/objects/punishment/GetActivePunishmentProtocolObject.java

@@ -0,0 +1,90 @@
+package net.swofty.commons.protocol.objects.punishment;
+
+import com.google.gson.Gson;
+import net.swofty.commons.protocol.ProtocolObject;
+import net.swofty.commons.protocol.Serializer;
+import net.swofty.commons.punishment.PunishmentReason;
+import org.jetbrains.annotations.NotNull;
+import org.jetbrains.annotations.Nullable;
+import org.json.JSONObject;
+
+import java.util.UUID;
+
+public class GetActivePunishmentProtocolObject
+        extends ProtocolObject<GetActivePunishmentProtocolObject.GetActivePunishmentMessage,
+        GetActivePunishmentProtocolObject.GetActivePunishmentResponse> {
+
+    @Override
+    public Serializer<GetActivePunishmentMessage> getSerializer() {
+        return new Serializer<>() {
+            @Override
+            public String serialize(GetActivePunishmentMessage value) {
+                JSONObject json = new JSONObject();
+                json.put("target", value.target().toString());
+                return json.toString();
+            }
+
+            @Override
+            public GetActivePunishmentMessage deserialize(String json) {
+                JSONObject obj = new JSONObject(json);
+                return new GetActivePunishmentMessage(
+                        UUID.fromString(obj.getString("target"))
+                );
+            }
+
+            @Override
+            public GetActivePunishmentMessage clone(GetActivePunishmentMessage value) {
+                return value;
+            }
+        };
+    }
+
+    @Override
+    public Serializer<GetActivePunishmentResponse> getReturnSerializer() {
+        return new Serializer<>() {
+            @Override
+            public String serialize(GetActivePunishmentResponse value) {
+                JSONObject json = new JSONObject();
+                json.put("found", value.found());
+                json.put("type", value.type());
+                json.put("banId", value.banId());
+                json.put("reason", value.reason() != null ? new Gson().toJson(value.reason()) : null);
+                json.put("expiresAt", value.expiresAt());
+                return json.toString();
+            }
+
+            @Override
+            public GetActivePunishmentResponse deserialize(String json) {
+                JSONObject obj = new JSONObject(json);
+                boolean found = obj.getBoolean("found");
+                if (!found) {
+                    return new GetActivePunishmentResponse(false, null, null, null, 0);
+                }
+                return new GetActivePunishmentResponse(
+                        true,
+                        obj.optString("type", null),
+                        obj.optString("banId", null),
+                        obj.isNull("reason") ? null : new Gson().fromJson(obj.getString("reason"), PunishmentReason.class),
+                        obj.getLong("expiresAt")
+                );
+            }
+
+            @Override
+            public GetActivePunishmentResponse clone(GetActivePunishmentResponse value) {
+                return value;
+            }
+        };
+    }
+
+    public record GetActivePunishmentMessage(
+            @NotNull UUID target
+    ) {}
+
+    public record GetActivePunishmentResponse(
+            boolean found,
+            @Nullable String type,
+            @Nullable String banId,
+            @Nullable PunishmentReason reason,
+            long expiresAt
+    ) {}
+}

commons/src/main/java/net/swofty/commons/protocol/objects/punishment/GetAllBannedIdsProtocolObject.java

@@ -0,0 +1,66 @@
+package net.swofty.commons.protocol.objects.punishment;
+
+import net.swofty.commons.protocol.ProtocolObject;
+import net.swofty.commons.protocol.Serializer;
+import org.json.JSONArray;
+import org.json.JSONObject;
+
+import java.util.HashSet;
+import java.util.Set;
+
+public class GetAllBannedIdsProtocolObject
+        extends ProtocolObject<GetAllBannedIdsProtocolObject.GetAllBannedIdsMessage,
+        GetAllBannedIdsProtocolObject.GetAllBannedIdsResponse> {
+
+    @Override
+    public Serializer<GetAllBannedIdsMessage> getSerializer() {
+        return new Serializer<>() {
+            @Override
+            public String serialize(GetAllBannedIdsMessage value) {
+                return new JSONObject().toString();
+            }
+
+            @Override
+            public GetAllBannedIdsMessage deserialize(String json) {
+                return new GetAllBannedIdsMessage();
+            }
+
+            @Override
+            public GetAllBannedIdsMessage clone(GetAllBannedIdsMessage value) {
+                return value;
+            }
+        };
+    }
+
+    @Override
+    public Serializer<GetAllBannedIdsResponse> getReturnSerializer() {
+        return new Serializer<>() {
+            @Override
+            public String serialize(GetAllBannedIdsResponse value) {
+                JSONObject json = new JSONObject();
+                json.put("ids", new JSONArray(value.ids()));
+                return json.toString();
+            }
+
+            @Override
+            public GetAllBannedIdsResponse deserialize(String json) {
+                JSONObject obj = new JSONObject(json);
+                JSONArray arr = obj.getJSONArray("ids");
+                Set<String> ids = new HashSet<>();
+                for (int i = 0; i < arr.length(); i++) {
+                    ids.add(arr.getString(i));
+                }
+                return new GetAllBannedIdsResponse(ids);
+            }
+
+            @Override
+            public GetAllBannedIdsResponse clone(GetAllBannedIdsResponse value) {
+                return value;
+            }
+        };
+    }
+
+    public record GetAllBannedIdsMessage() {}
+
+    public record GetAllBannedIdsResponse(Set<String> ids) {}
+}

service.punishment/src/main/java/net/swofty/service/punishment/endpoints/GetActivePunishmentEndpoint.java

@@ -0,0 +1,36 @@
+package net.swofty.service.punishment.endpoints;
+
+import net.swofty.commons.impl.ServiceProxyRequest;
+import net.swofty.commons.protocol.ProtocolObject;
+import net.swofty.commons.protocol.objects.punishment.GetActivePunishmentProtocolObject;
+import net.swofty.commons.punishment.PunishmentRedis;
+import net.swofty.service.generic.redis.ServiceEndpoint;
+
+import java.util.Optional;
+
+public class GetActivePunishmentEndpoint implements ServiceEndpoint
+        <GetActivePunishmentProtocolObject.GetActivePunishmentMessage,
+                GetActivePunishmentProtocolObject.GetActivePunishmentResponse> {
+
+    @Override
+    public ProtocolObject<GetActivePunishmentProtocolObject.GetActivePunishmentMessage, GetActivePunishmentProtocolObject.GetActivePunishmentResponse> associatedProtocolObject() {
+        return new GetActivePunishmentProtocolObject();
+    }
+
+    @Override
+    public GetActivePunishmentProtocolObject.GetActivePunishmentResponse onMessage(ServiceProxyRequest message, GetActivePunishmentProtocolObject.GetActivePunishmentMessage messageObject) {
+        Optional<PunishmentRedis.ActivePunishment> existing = PunishmentRedis.getActive(messageObject.target());
+        if (existing.isEmpty()) {
+            return new GetActivePunishmentProtocolObject.GetActivePunishmentResponse(false, null, null, null, 0);
+        }
+
+        PunishmentRedis.ActivePunishment punishment = existing.get();
+        return new GetActivePunishmentProtocolObject.GetActivePunishmentResponse(
+                true,
+                punishment.type(),
+                punishment.banId(),
+                punishment.reason(),
+                punishment.expiresAt()
+        );
+    }
+}

service.punishment/src/main/java/net/swofty/service/punishment/endpoints/GetAllBannedIdsEndpoint.java

@@ -0,0 +1,25 @@
+package net.swofty.service.punishment.endpoints;
+
+import net.swofty.commons.impl.ServiceProxyRequest;
+import net.swofty.commons.protocol.ProtocolObject;
+import net.swofty.commons.protocol.objects.punishment.GetAllBannedIdsProtocolObject;
+import net.swofty.commons.punishment.PunishmentRedis;
+import net.swofty.service.generic.redis.ServiceEndpoint;
+
+import java.util.Set;
+
+public class GetAllBannedIdsEndpoint implements ServiceEndpoint
+        <GetAllBannedIdsProtocolObject.GetAllBannedIdsMessage,
+                GetAllBannedIdsProtocolObject.GetAllBannedIdsResponse> {
+
+    @Override
+    public ProtocolObject<GetAllBannedIdsProtocolObject.GetAllBannedIdsMessage, GetAllBannedIdsProtocolObject.GetAllBannedIdsResponse> associatedProtocolObject() {
+        return new GetAllBannedIdsProtocolObject();
+    }
+
+    @Override
+    public GetAllBannedIdsProtocolObject.GetAllBannedIdsResponse onMessage(ServiceProxyRequest message, GetAllBannedIdsProtocolObject.GetAllBannedIdsMessage messageObject) {
+        Set<String> ids = PunishmentRedis.getAllBannedPlayerIds();
+        return new GetAllBannedIdsProtocolObject.GetAllBannedIdsResponse(ids);
+    }
+}