fixup! abstract amqp_connection to prepare for multiple protocols

cloudamqp · Aug 14, 2024 · a5a4073 · a5a4073
1 parent 93e3c42
commit a5a4073
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 11 deletions.
diff --git a/src/lavinmq/amqp/client.cr b/src/lavinmq/amqp/client.cr
@@ -32,11 +32,11 @@ module LavinMQ
       Log        = ::Log.for "AMQP.client"
 
       def initialize(@socket : IO,
-                    @connection_info : ConnectionInfo,
-                    @vhost : VHost,
-                    @user : User,
-                    tune_ok,
-                    start_ok)
+                     @connection_info : ConnectionInfo,
+                     @vhost : VHost,
+                     @user : User,
+                     tune_ok,
+                     start_ok)
         @remote_address = @connection_info.src
         @local_address = @connection_info.dst
 
@@ -244,11 +244,11 @@ module LavinMQ
               @log.trace { "Send BodyFrame (pos #{pos}, length #{length})" }
             {% end %}
             body = case msg
-                  in BytesMessage
-                    AMQP::Frame::BytesBody.new(frame.channel, length, msg.body[pos, length])
-                  in Message
-                    AMQP::Frame::Body.new(frame.channel, length, msg.body_io)
-                  end
+                   in BytesMessage
+                     AMQP::Frame::BytesBody.new(frame.channel, length, msg.body[pos, length])
+                   in Message
+                     AMQP::Frame::Body.new(frame.channel, length, msg.body_io)
+                   end
             socket.write_bytes body, ::IO::ByteFormat::NetworkEndian
             socket.flush if websocket
             @send_oct_count += 8_u64 + body.bytesize

diff --git a/src/lavinmq/amqp/connection_factory.cr b/src/lavinmq/amqp/connection_factory.cr
@@ -102,7 +102,7 @@ module LavinMQ
         username, password = credentials(start_ok)
         user = users[username]?
         return user if user && user.password && user.password.not_nil!.verify(password) &&
-                      guest_only_loopback?(remote_address, user)
+                       guest_only_loopback?(remote_address, user)
 
         if user.nil?
           Log.warn { "User \"#{username}\" not found" }