more intuitive handling of prev existing session when subscribing

cloudamqp · Jan 27, 2025 · a77960b · a77960b
1 parent afc7c57
commit a77960b
Showing 1 changed file with 2 additions and 4 deletions.
diff --git a/src/lavinmq/mqtt/broker.cr b/src/lavinmq/mqtt/broker.cr
@@ -74,10 +74,8 @@ module LavinMQ
       end
 
       def subscribe(client, packet)
-        unless session = sessions[client.client_id]?
-          session = sessions.declare(client.client_id, client.@clean_session)
-          session.client = client
-        end
+        session = sessions[client.client_id]? || sessions.declare(client.client_id, client.@clean_session)
+        session.client = client
         qos = Array(MQTT::SubAck::ReturnCode).new(packet.topic_filters.size)
         packet.topic_filters.each do |tf|
           qos << MQTT::SubAck::ReturnCode.from_int(tf.qos)