made session present flag modifiable in connack packet

Author: Florian-Limpoeck

hivemq-edge/src/main/java/com/hivemq/extensions/packets/connack/ModifiableConnackPacketImpl.java

@@ -41,7 +41,7 @@
 public class ModifiableConnackPacketImpl implements ModifiableConnackPacket {
 
     private @NotNull ConnackReasonCode reasonCode;
-    private final boolean sessionPresent;
+    private boolean sessionPresent;
     private final long sessionExpiryInterval;
     private final int serverKeepAlive;
     private @Nullable String assignedClientId;
@@ -155,6 +155,15 @@ public void setAssignedClientIdentifier(final @Nullable String assignedClientIde
         modified = true;
     }
 
+    @Override
+    public void setSessionPresent(final boolean sessionPresent) {
+        if (Objects.equals(this.sessionPresent, sessionPresent)) {
+            return;
+        }
+        this.sessionPresent = sessionPresent;
+        modified = true;
+    }
+
     @Override
     public @NotNull Optional<String> getAuthenticationMethod() {
         return Optional.ofNullable(authenticationMethod);

hivemq-edge/src/test/java/com/hivemq/extensions/packets/connack/ModifiableConnackPacketImplTest.java

@@ -785,4 +785,36 @@ public void copy_changes() {
                 UserPropertiesImpl.of(ImmutableList.of(new MqttUserProperty("testName", "testValue"))));
         assertEquals(expectedPacket, copy);
     }
+
+    @Test
+    public void setSessionPresent() {
+        final ConnackPacketImpl packet = new ConnackPacketImpl(ConnackReasonCode.UNSPECIFIED_ERROR,
+                true,
+                10,
+                60,
+                null,
+                null,
+                null,
+                3,
+                1000,
+                10,
+                Qos.AT_LEAST_ONCE,
+                true,
+                true,
+                true,
+                true,
+                null,
+                null,
+                null,
+                UserPropertiesImpl.of(ImmutableList.of()));
+        final ModifiableConnackPacketImpl modifiablePacket =
+                new ModifiableConnackPacketImpl(packet, configurationService, true);
+
+        assertFalse(modifiablePacket.isModified());
+
+        modifiablePacket.setSessionPresent(false);
+
+        assertTrue(modifiablePacket.isModified());
+        assertFalse(modifiablePacket.getSessionPresent());
+    }
 }