additional extending network api for mqtt implementation

Author: JavaSaBr

rlib-common/src/main/java/com/ss/rlib/common/function/ByteFunction.java

@@ -0,0 +1,10 @@
+package com.ss.rlib.common.function;
+
+/**
+ * @author JavaSaBr
+ */
+@FunctionalInterface
+public interface ByteFunction<R> {
+
+    R apply(byte value);
+}

rlib-network/src/main/java/com/ss/rlib/network/packet/impl/AbstractPacket.java

@@ -4,7 +4,6 @@
 import com.ss.rlib.logger.api.Logger;
 import com.ss.rlib.logger.api.LoggerManager;
 import com.ss.rlib.network.packet.Packet;
-import com.ss.rlib.network.util.NetworkUtils;
 import org.jetbrains.annotations.NotNull;
 
 import java.nio.ByteBuffer;
@@ -16,19 +15,8 @@
  */
 public abstract class AbstractPacket implements Packet {
 
-    @NotNull
     protected static final Logger LOGGER = LoggerManager.getLogger(Packet.class);
 
-    /**
-     * The name of this packet.
-     */
-    @NotNull
-    protected final String name;
-
-    public AbstractPacket() {
-        this.name = getNameImpl();
-    }
-
     /**
      * Handle the exception.
      *
@@ -39,30 +27,21 @@ protected void handleException(@NotNull ByteBuffer buffer, @NotNull Exception ex
         LOGGER.warning(this, exception);
 
         if (buffer.isDirect()) {
-            byte[] array = new byte[buffer.limit()];
+            var array = new byte[buffer.limit()];
             buffer.get(array, 0, buffer.limit());
-            LOGGER.warning(this, "buffer " + buffer + "\n" + NetworkUtils.hexDump(array, array.length));
+            LOGGER.warning("buffer: " + buffer + "\n" + hexDump(array, array.length));
         } else {
-            LOGGER.warning(this, "buffer " + buffer + "\n" + NetworkUtils.hexDump(buffer.array(), buffer.limit()));
+            LOGGER.warning("buffer: " + buffer + "\n" + hexDump(buffer.array(), buffer.limit()));
         }
     }
 
-    /**
-     * Get the name.
-     *
-     * @return the name
-     */
-    protected @NotNull String getNameImpl() {
-        return getClass().getName();
-    }
-
     @Override
     public @NotNull String getName() {
-        return name;
+        return getClass().getName();
     }
 
     @Override
     public String toString() {
-        return getClass().getSimpleName() + "{" + "name='" + name + '\'' + '}';
+        return getClass().getSimpleName() + "{" + "name='" + getName() + '\'' + '}';
     }
 }

rlib-network/src/main/java/com/ss/rlib/network/packet/impl/AbstractPacketReader.java

@@ -169,7 +169,7 @@ else if (waitedBytes > 0) {
 
             var positionBeforeRead = endPosition;
             var packetLength = readPacketLength(bufferToRead);
-            var dataLength = calcDataLength(packetLength, bufferToRead.position() - endPosition, bufferToRead);
+            var dataLength = getDataLength(packetLength, bufferToRead.position() - endPosition, bufferToRead);
 
             LOGGER.debug(packetLength, positionBeforeRead,
                 (length, pos) -> "Find next packet from position: " + pos + " with length: " + length);
@@ -300,7 +300,7 @@ else if (packetLength > readTempBuffer.capacity()) {
      * @param buffer       the buffer.
      * @return the length of packet data part.
      */
-    protected int calcDataLength(int packetLength, int readBytes, @NotNull ByteBuffer buffer) {
+    protected int getDataLength(int packetLength, int readBytes, @NotNull ByteBuffer buffer) {
         return packetLength - readBytes;
     }