рефакторинг протокола

protocol/src/main/java/mc/protocol/NettyServer.java

@@ -17,8 +17,8 @@ import mc.protocol.io.codec.ProtocolDecoder;
 import mc.protocol.io.codec.ProtocolEncoder;
 import mc.protocol.io.codec.ProtocolSplitter;
 import mc.protocol.packets.ClientSidePacket;
-import mc.protocol.utils.EventBus;
-import mc.protocol.utils.PacketPool;
+import mc.protocol.event.EventBus;
+import mc.protocol.pool.PacketPool;
 
 import javax.annotation.Nonnull;
 import java.util.LinkedHashMap;
@@ -58,6 +58,7 @@ public class NettyServer implements Server {
 	}
 
 	@Override
+	@SuppressWarnings("java:S2326") // Сонар, ты бредишь
 	public <P extends ClientSidePacket> void listenPacket(State state, Class<P> packetClass, EventBus.EventHandler<P> eventHandler) {
 		this.eventBus.subscribe(state, packetClass, eventHandler);
 	}

protocol/src/main/java/mc/protocol/PacketInboundHandler.java

@@ -4,8 +4,8 @@ import io.netty.channel.ChannelHandlerContext;
 import io.netty.channel.SimpleChannelInboundHandler;
 import lombok.RequiredArgsConstructor;
 import mc.protocol.packets.ClientSidePacket;
-import mc.protocol.utils.EventBus;
-import mc.protocol.utils.PacketPool;
+import mc.protocol.event.EventBus;
+import mc.protocol.pool.PacketPool;
 
 @RequiredArgsConstructor
 public class PacketInboundHandler extends SimpleChannelInboundHandler<ClientSidePacket> {

protocol/src/main/java/mc/protocol/api/Server.java

@@ -2,7 +2,7 @@ package mc.protocol.api;
 
 import mc.protocol.State;
 import mc.protocol.packets.ClientSidePacket;
-import mc.protocol.utils.EventBus;
+import mc.protocol.event.EventBus;
 
 import java.util.function.Consumer;
 
@@ -13,5 +13,6 @@ public interface Server {
 	void onNewConnect(Consumer<ConnectionContext> consumer);
 	void onDisonnect(Consumer<ConnectionContext> consumer);
 
+	@SuppressWarnings("java:S2326") // Сонар, ты бредишь
 	<P extends ClientSidePacket> void listenPacket(State state, Class<P> packetClass, EventBus.EventHandler<P> eventHandler);
 }

protocol/src/main/java/mc/protocol/di/ProtocolModule.java

@@ -7,10 +7,10 @@ import mc.protocol.State;
 import mc.protocol.api.Server;
 import mc.protocol.packets.ClientSidePacket;
 import mc.protocol.packets.UnknownPacket;
-import mc.protocol.utils.EventBus;
-import mc.protocol.utils.PacketFactory;
-import mc.protocol.utils.PacketPool;
-import mc.protocol.utils.SimpleEventBus;
+import mc.protocol.event.EventBus;
+import mc.protocol.pool.PacketFactory;
+import mc.protocol.pool.PacketPool;
+import mc.protocol.event.SimpleEventBus;
 import org.apache.commons.pool2.ObjectPool;
 import org.apache.commons.pool2.impl.GenericObjectPool;
 

protocol/src/main/java/mc/protocol/event/EventBus.java

@@ -1,4 +1,4 @@
-package mc.protocol.utils;
+package mc.protocol.event;
 
 import mc.protocol.State;
 import mc.protocol.api.ConnectionContext;

protocol/src/main/java/mc/protocol/event/SimpleEventBus.java

@@ -1,8 +1,9 @@
-package mc.protocol.utils;
+package mc.protocol.event;
 
 import mc.protocol.State;
 import mc.protocol.api.ConnectionContext;
 import mc.protocol.packets.ClientSidePacket;
+import mc.protocol.utils.Table;
 
 @SuppressWarnings({ "rawtypes", "unchecked" })
 public class SimpleEventBus implements EventBus {

protocol/src/main/java/mc/protocol/io/codec/ProtocolDecoder.java

@@ -12,7 +12,7 @@ import mc.protocol.api.ConnectionContext;
 import mc.protocol.io.NetByteBuf;
 import mc.protocol.packets.ClientSidePacket;
 import mc.protocol.packets.UnknownPacket;
-import mc.protocol.utils.PacketPool;
+import mc.protocol.pool.PacketPool;
 
 import javax.annotation.Nonnull;
 import java.util.List;

protocol/src/main/java/mc/protocol/pool/PacketFactory.java

@@ -1,4 +1,4 @@
-package mc.protocol.utils;
+package mc.protocol.pool;
 
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;

protocol/src/main/java/mc/protocol/pool/PacketPool.java

@@ -1,4 +1,4 @@
-package mc.protocol.utils;
+package mc.protocol.pool;
 
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;