[broker-22] reduce code duplication in packet handlers

Author: JavaSaBr

src/main/java/com/ss/mqtt/broker/handler/packet/in/PendingOutResponseInPacketHandler.java

@@ -0,0 +1,20 @@
+package com.ss.mqtt.broker.handler.packet.in;
+
+import com.ss.mqtt.broker.network.client.MqttClient.UnsafeMqttClient;
+import com.ss.mqtt.broker.network.packet.HasPacketId;
+import com.ss.mqtt.broker.network.packet.in.MqttReadablePacket;
+import lombok.RequiredArgsConstructor;
+import org.jetbrains.annotations.NotNull;
+
+@RequiredArgsConstructor
+public class PendingOutResponseInPacketHandler<R extends MqttReadablePacket & HasPacketId> extends
+    AbstractPacketHandler<UnsafeMqttClient, R> {
+
+    @Override
+    protected void handleImpl(@NotNull UnsafeMqttClient client, @NotNull R packet) {
+        var session = client.getSession();
+        if (session != null) {
+            session.updateOutPendingPacket(client, packet);
+        }
+    }
+}

src/main/java/com/ss/mqtt/broker/handler/packet/in/PublishAckInPacketHandler.java

@@ -1,18 +1,7 @@
 package com.ss.mqtt.broker.handler.packet.in;
 
-import com.ss.mqtt.broker.network.client.MqttClient.UnsafeMqttClient;
 import com.ss.mqtt.broker.network.packet.in.PublishAckInPacket;
 import lombok.RequiredArgsConstructor;
-import org.jetbrains.annotations.NotNull;
 
 @RequiredArgsConstructor
-public class PublishAckInPacketHandler extends AbstractPacketHandler<UnsafeMqttClient, PublishAckInPacket> {
-
-    @Override
-    protected void handleImpl(@NotNull UnsafeMqttClient client, @NotNull PublishAckInPacket packet) {
-        var session = client.getSession();
-        if (session != null) {
-            session.updateOutPendingPacket(client, packet);
-        }
-    }
-}
+public class PublishAckInPacketHandler extends PendingOutResponseInPacketHandler<PublishAckInPacket> {}

src/main/java/com/ss/mqtt/broker/handler/packet/in/PublishCompleteInPacketHandler.java

@@ -1,19 +1,7 @@
 package com.ss.mqtt.broker.handler.packet.in;
 
-import com.ss.mqtt.broker.network.client.MqttClient.UnsafeMqttClient;
-import com.ss.mqtt.broker.network.packet.in.PublishAckInPacket;
 import com.ss.mqtt.broker.network.packet.in.PublishCompleteInPacket;
 import lombok.RequiredArgsConstructor;
-import org.jetbrains.annotations.NotNull;
 
 @RequiredArgsConstructor
-public class PublishCompleteInPacketHandler extends AbstractPacketHandler<UnsafeMqttClient, PublishCompleteInPacket> {
-
-    @Override
-    protected void handleImpl(@NotNull UnsafeMqttClient client, @NotNull PublishCompleteInPacket packet) {
-        var session = client.getSession();
-        if (session != null) {
-            session.updateOutPendingPacket(client, packet);
-        }
-    }
-}
+public class PublishCompleteInPacketHandler extends PendingOutResponseInPacketHandler<PublishCompleteInPacket> {}

src/main/java/com/ss/mqtt/broker/handler/packet/in/PublishReceiveInPacketHandler.java

@@ -1,19 +1,7 @@
 package com.ss.mqtt.broker.handler.packet.in;
 
-import com.ss.mqtt.broker.network.client.MqttClient.UnsafeMqttClient;
-import com.ss.mqtt.broker.network.packet.in.PublishAckInPacket;
 import com.ss.mqtt.broker.network.packet.in.PublishReceivedInPacket;
 import lombok.RequiredArgsConstructor;
-import org.jetbrains.annotations.NotNull;
 
 @RequiredArgsConstructor
-public class PublishReceiveInPacketHandler extends AbstractPacketHandler<UnsafeMqttClient, PublishReceivedInPacket> {
-
-    @Override
-    protected void handleImpl(@NotNull UnsafeMqttClient client, @NotNull PublishReceivedInPacket packet) {
-        var session = client.getSession();
-        if (session != null) {
-            session.updateOutPendingPacket(client, packet);
-        }
-    }
-}
+public class PublishReceiveInPacketHandler extends PendingOutResponseInPacketHandler<PublishReceivedInPacket> {}