finished working on id based packets part

Author: JavaSaBr

build.gradle

@@ -4,7 +4,7 @@ buildscript {
     }
     dependencies {
         classpath 'com.jfrog.bintray.gradle:gradle-bintray-plugin:1.8.4'
-        classpath 'net.ltgt.gradle:gradle-apt-plugin:0.19'
+        classpath 'net.ltgt.gradle:gradle-apt-plugin:0.21'
     }
 }
 
@@ -46,12 +46,14 @@ allprojects {
 
     dependencies {
         compileOnly "org.jetbrains:annotations:$jetbrainsAnnotation"
+        compileOnly "org.projectlombok:lombok:$lombokVersion"
+        annotationProcessor "org.projectlombok:lombok:$lombokVersion"
+    
         testCompile "org.junit.jupiter:junit-jupiter-api:$junitJupiterVersion"
+        testCompileOnly "org.projectlombok:lombok:$lombokVersion"
         testCompileOnly "org.jetbrains:annotations:$jetbrainsAnnotation"
         testRuntimeOnly "org.junit.jupiter:junit-jupiter-engine:$junitJupiterVersion"
-        compileOnly "org.projectlombok:lombok:$lombokVersion"
-        testCompileOnly "org.projectlombok:lombok:$lombokVersion"
-        annotationProcessor "org.projectlombok:lombok:$lombokVersion"
+        testAnnotationProcessor "org.projectlombok:lombok:$lombokVersion"
     }
 
     /*compileJava {

rlib-common/src/main/java/com/ss/rlib/common/util/Utils.java

@@ -229,6 +229,7 @@ public static short getShort(final byte[] bytes, final int offset) {
      * @param size  the size
      * @return строка с дампом.
      */
+    @Deprecated(forRemoval = true)
     public static @NotNull String hexdump(final byte[] array, final int size) {
         return hexdump(array, 0, size);
     }
@@ -241,6 +242,7 @@ public static short getShort(final byte[] bytes, final int offset) {
      * @param size   the size
      * @return the string dump.
      */
+    @Deprecated(forRemoval = true)
     public static @NotNull String hexdump(@NotNull final byte[] array, final int offset, final int size) {
 
         final StringBuilder builder = new StringBuilder();

rlib-network/src/main/java/com/ss/rlib/network/NetworkFactory.java

@@ -79,7 +79,7 @@ public final class NetworkFactory {
     /**
      * Create id based packet default asynchronous client network.
      *
-     * @param packetRegistry  the readable packet registry.
+     * @param packetRegistry the readable packet registry.
      * @return the server network.
      */
     public static @NotNull ClientNetwork<DefaultConnection> newDefaultClientNetwork(
@@ -91,6 +91,7 @@ public final class NetworkFactory {
             packetRegistry
         );
     }
+
     /**
      * Create id based packet default asynchronous client network.
      *
@@ -159,7 +160,7 @@ public final class NetworkFactory {
     /**
      * Create id based packet default asynchronous server network.
      *
-     * @param packetRegistry  the readable packet registry.
+     * @param packetRegistry the readable packet registry.
      * @return the server network.
      */
     public static @NotNull ServerNetwork<DefaultConnection> newDefaultServerNetwork(
@@ -171,6 +172,7 @@ public final class NetworkFactory {
             packetRegistry
         );
     }
+
     /**
      * Create id based packet default asynchronous server network.
      *

rlib-network/src/main/java/com/ss/rlib/network/client/impl/DefaultClientNetwork.java

@@ -4,7 +4,6 @@
 import static com.ss.rlib.common.util.Utils.uncheckedGet;
 import com.ss.rlib.common.concurrent.GroupThreadFactory;
 import com.ss.rlib.common.concurrent.atomic.AtomicReference;
-import com.ss.rlib.network.BufferAllocator;
 import com.ss.rlib.network.Connection;
 import com.ss.rlib.network.Network;
 import com.ss.rlib.network.NetworkConfig;
@@ -22,7 +21,6 @@
 import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.Executors;
 import java.util.function.BiFunction;
-import java.util.function.Function;
 
 /**
  * The default implementation of a client network.
@@ -100,7 +98,8 @@ public void failed(Throwable exc, Void attachment) {
 
     @Override
     public void shutdown() {
-        Optional.ofNullable(getCurrentConnection())
+        Optional
+            .ofNullable(getCurrentConnection())
             .ifPresent(connection -> {
                 unchecked(connection, C::close);
                 unchecked(group, AsynchronousChannelGroup::shutdown);

rlib-network/src/main/java/com/ss/rlib/network/impl/AbstractConnection.java

@@ -5,12 +5,18 @@
 import static com.ss.rlib.network.util.NetworkUtils.getSocketAddress;
 import com.ss.rlib.common.util.array.Array;
 import com.ss.rlib.common.util.array.ArrayFactory;
-import com.ss.rlib.logger.api.Logger;
-import com.ss.rlib.logger.api.LoggerManager;
-import com.ss.rlib.network.*;
-import com.ss.rlib.network.packet.*;
 import com.ss.rlib.common.util.linkedlist.LinkedList;
 import com.ss.rlib.common.util.linkedlist.LinkedListFactory;
+import com.ss.rlib.logger.api.Logger;
+import com.ss.rlib.logger.api.LoggerManager;
+import com.ss.rlib.network.BufferAllocator;
+import com.ss.rlib.network.Connection;
+import com.ss.rlib.network.Network;
+import com.ss.rlib.network.NetworkCryptor;
+import com.ss.rlib.network.packet.PacketReader;
+import com.ss.rlib.network.packet.PacketWriter;
+import com.ss.rlib.network.packet.ReadablePacket;
+import com.ss.rlib.network.packet.WritablePacket;
 import lombok.Getter;
 import org.jetbrains.annotations.NotNull;
 import org.jetbrains.annotations.Nullable;
@@ -115,8 +121,7 @@ protected void registerFluxOnReceivedEvents(
 
     protected void registerFluxOnReceivedPackets(@NotNull FluxSink<? super R> sink) {
 
-        BiConsumer<Connection<R, W>, R> listener =
-            (connection, packet) -> sink.next(packet);
+        BiConsumer<Connection<R, W>, R> listener = (connection, packet) -> sink.next(packet);
 
         onReceive(listener);
 

rlib-network/src/main/java/com/ss/rlib/network/impl/DefaultDataConnection.java

@@ -42,8 +42,7 @@ public DefaultDataConnection(
     }
 
     protected @NotNull PacketReader createPacketReader() {
-        return new DefaultPacketReader<>(
-            this,
+        return new DefaultPacketReader<>(this,
             channel,
             bufferAllocator,
             this::updateLastActivity,
@@ -55,8 +54,7 @@ public DefaultDataConnection(
     }
 
     protected @NotNull PacketWriter createPacketWriter() {
-        return new DefaultPacketWriter<W, Connection<R, W>>(
-            this,
+        return new DefaultPacketWriter<W, Connection<R, W>>(this,
             channel,
             bufferAllocator,
             this::updateLastActivity,

rlib-network/src/main/java/com/ss/rlib/network/impl/IdBasedPacketConnection.java

@@ -4,9 +4,10 @@
 import com.ss.rlib.network.Connection;
 import com.ss.rlib.network.Network;
 import com.ss.rlib.network.NetworkCryptor;
-import com.ss.rlib.network.packet.*;
-import com.ss.rlib.network.packet.impl.DefaultPacketReader;
-import com.ss.rlib.network.packet.impl.DefaultPacketWriter;
+import com.ss.rlib.network.packet.IdBasedReadablePacket;
+import com.ss.rlib.network.packet.IdBasedWritablePacket;
+import com.ss.rlib.network.packet.PacketReader;
+import com.ss.rlib.network.packet.PacketWriter;
 import com.ss.rlib.network.packet.impl.IdBasedPacketReader;
 import com.ss.rlib.network.packet.impl.IdBasedPacketWriter;
 import com.ss.rlib.network.packet.registry.ReadablePacketRegistry;

rlib-network/src/main/java/com/ss/rlib/network/impl/StringDataConnection.java

@@ -10,6 +10,9 @@
 
 import java.nio.channels.AsynchronousSocketChannel;
 
+/**
+ * @author JavaSaBr
+ */
 public class StringDataConnection extends DefaultDataConnection<StringReadablePacket, StringWritablePacket> {
 
     public StringDataConnection(

rlib-network/src/main/java/com/ss/rlib/network/packet/IdBasedReadablePacket.java

@@ -1,6 +1,7 @@
 package com.ss.rlib.network.packet;
 
 import com.ss.rlib.common.util.ClassUtils;
+import com.ss.rlib.network.Connection;
 import org.jetbrains.annotations.NotNull;
 
 /**
@@ -16,4 +17,13 @@ public interface IdBasedReadablePacket<S extends IdBasedReadablePacket<S>> exten
     default @NotNull S newInstance() {
         return ClassUtils.newInstance(getClass());
     }
+
+    /**
+     * Execute a logic of this packet.
+     *
+     * @param connection the owner's connection.
+     */
+    default void execute(@NotNull Connection<?, ?> connection) {
+
+    }
 }

rlib-network/src/main/java/com/ss/rlib/network/packet/PacketReader.java

@@ -1,5 +1,8 @@
 package com.ss.rlib.network.packet;
 
+/**
+ * @author JavaSaBr
+ */
 public interface PacketReader {
 
     /**