[skip ci] Code formatting

mkuratczyk · mkuratczyk · commit c241780fe9cd · 2025-08-28T09:25:42.000+02:00
diff --git a/deps/amqp10_client/src/amqp10_client_connection.erl b/deps/amqp10_client/src/amqp10_client_connection.erl
@@ -249,7 +249,7 @@ hdr_sent(_EvtType, {protocol_header_received, 0, 1, 0, 0}, State) ->
 hdr_sent(_EvtType, {protocol_header_received, Protocol, Maj, Min,
                                 Rev}, State) ->
     ?LOG_WARNING("Unsupported protocol version: ~b ~b.~b.~b",
-                             [Protocol, Maj, Min, Rev]),
+                 [Protocol, Maj, Min, Rev]),
     {stop, normal, State};
 hdr_sent({call, From}, begin_session,
          #state{pending_session_reqs = PendingSessionReqs} = State) ->
@@ -344,7 +344,7 @@ opened(info, {'DOWN', MRef, process, _, _Info},
     {stop, normal};
 opened(_EvtType, Frame, State) ->
     ?LOG_WARNING("Unexpected connection frame ~tp when in state ~tp ",
-                   [Frame, State]),
+                 [Frame, State]),
     keep_state_and_data.
 
 close_sent(_EvtType, heartbeat, _Data) ->
diff --git a/deps/amqp10_client/src/amqp10_client_frame_reader.erl b/deps/amqp10_client/src/amqp10_client_frame_reader.erl
@@ -143,17 +143,17 @@ handle_event(info, {gun_ws, WsPid, StreamRef, WsFrame}, StateName,
             handle_socket_input(Bin, StateName, State);
         close ->
             ?LOG_INFO("peer closed AMQP over WebSocket connection in state '~s'",
-                        [StateName]),
+                      [StateName]),
             {stop, normal, socket_closed(State)};
         {close, ReasonStatusCode, ReasonUtf8} ->
             ?LOG_INFO("peer closed AMQP over WebSocket connection in state '~s', reason: ~b ~ts",
-                        [StateName, ReasonStatusCode, ReasonUtf8]),
+                      [StateName, ReasonStatusCode, ReasonUtf8]),
             {stop, {shutdown, {ReasonStatusCode, ReasonUtf8}}, socket_closed(State)}
     end;
 handle_event(info, {TcpError, _Sock, Reason}, StateName, State)
   when TcpError == tcp_error orelse TcpError == ssl_error ->
     ?LOG_WARNING("AMQP 1.0 connection socket errored, connection state: '~ts', reason: '~tp'",
-                   [StateName, Reason]),
+                 [StateName, Reason]),
     {stop, {error, Reason}, socket_closed(State)};
 handle_event(info, {TcpClosed, _}, StateName, State)
   when TcpClosed == tcp_closed orelse TcpClosed == ssl_closed ->
@@ -163,12 +163,12 @@ handle_event(info, {TcpClosed, _}, StateName, State)
 handle_event(info, {gun_down, WsPid, _Proto, Reason, _Streams}, StateName,
              #state{socket = {ws, WsPid, _StreamRef}} = State) ->
     ?LOG_WARNING("AMQP over WebSocket process ~p lost connection in state: '~s': ~p",
-                   [WsPid, StateName, Reason]),
+                 [WsPid, StateName, Reason]),
     {stop, Reason, socket_closed(State)};
 handle_event(info, {'DOWN', _Mref, process, WsPid, Reason}, StateName,
              #state{socket = {ws, WsPid, _StreamRef}} = State) ->
     ?LOG_WARNING("AMQP over WebSocket process ~p terminated in state: '~s': ~p",
-                   [WsPid, StateName, Reason]),
+                 [WsPid, StateName, Reason]),
     {stop, Reason, socket_closed(State)};
 
 handle_event(info, heartbeat, _StateName, #state{connection = Connection}) ->
diff --git a/deps/amqp10_client/src/amqp10_client_session.erl b/deps/amqp10_client/src/amqp10_client_session.erl
@@ -486,7 +486,7 @@ mapped(cast, #'v1_0.disposition'{role = true,
     {keep_state, State#state{outgoing_unsettled = Unsettled}};
 mapped(cast, Frame, State) ->
     ?LOG_WARNING("Unhandled session frame ~tp in state ~tp",
-                             [Frame, State]),
+                 [Frame, State]),
     {keep_state, State};
 mapped({call, From},
        {transfer, _Transfer, _Sections},
@@ -567,7 +567,7 @@ mapped({call, From}, Msg, State) ->
 
 mapped(_EvtType, Msg, _State) ->
     ?LOG_WARNING("amqp10_session: unhandled msg in mapped state ~W",
-                   [Msg, 10]),
+                 [Msg, 10]),
     keep_state_and_data.
 
 end_sent(_EvtType, #'v1_0.end'{} = End, State) ->
diff --git a/deps/amqp_client/src/amqp_channel.erl b/deps/amqp_client/src/amqp_channel.erl
@@ -781,8 +781,8 @@ handle_method_from_server1(
         State = #state{return_handler = ReturnHandler}) ->
     _ = case ReturnHandler of
         none        -> ?LOG_WARNING("Channel (~tp): received {~tp, ~tp} but there is "
-                                 "no return handler registered",
-                                 [self(), BasicReturn, AmqpMsg]);
+                                    "no return handler registered",
+                                    [self(), BasicReturn, AmqpMsg]);
         {Pid, _Ref} -> Pid ! {BasicReturn, AmqpMsg}
     end,
     {noreply, State};
diff --git a/deps/amqp_client/src/amqp_gen_connection.erl b/deps/amqp_client/src/amqp_gen_connection.erl
@@ -193,7 +193,7 @@ handle_cast({hard_error_in_channel, _Pid, Reason}, State) ->
     server_initiated_close(Reason, State);
 handle_cast({channel_internal_error, Pid, Reason}, State) ->
     ?LOG_WARNING("Connection (~tp) closing: internal error in channel (~tp): ~tp",
-              [self(), Pid, Reason]),
+                 [self(), Pid, Reason]),
     internal_error(Pid, Reason, State);
 handle_cast({server_misbehaved, AmqpError}, State) ->
     server_misbehaved_close(AmqpError, State);
@@ -324,7 +324,7 @@ server_initiated_close(Close, State) ->
 
 server_misbehaved_close(AmqpError, State) ->
     ?LOG_WARNING("Connection (~tp) closing: server misbehaved: ~tp",
-              [self(), AmqpError]),
+                 [self(), AmqpError]),
     {0, Close} = rabbit_binary_generator:map_exception(0, AmqpError, ?PROTOCOL),
     set_closing_state(abrupt, #closing{reason = server_misbehaved,
                                        close = Close}, State).
diff --git a/deps/oauth2_client/src/oauth2_client.erl b/deps/oauth2_client/src/oauth2_client.erl
@@ -24,7 +24,7 @@
     {error, unsuccessful_access_token_response() | any()}.
 get_access_token(OAuthProvider, Request) ->
     ?LOG_DEBUG("get_access_token using OAuthProvider:~p and client_id:~p",
-        [OAuthProvider, Request#access_token_request.client_id]),
+               [OAuthProvider, Request#access_token_request.client_id]),
         URL = OAuthProvider#oauth_provider.token_endpoint,
     Header = [],
     Type = ?CONTENT_URLENCODED,
@@ -221,7 +221,7 @@ do_update_oauth_provider_endpoints_configuration(OAuthProvider) when
         JwksUri -> set_env(jwks_uri, JwksUri)
     end,
     ?LOG_DEBUG("Updated oauth_provider details: ~p ",
-        [format_oauth_provider(OAuthProvider)]),
+               [format_oauth_provider(OAuthProvider)]),
     OAuthProvider;
 
 do_update_oauth_provider_endpoints_configuration(OAuthProvider) ->
@@ -273,7 +273,7 @@ get_oauth_provider(ListOfRequiredAttributes) ->
         undefined -> get_root_oauth_provider(ListOfRequiredAttributes);
         DefaultOauthProviderId ->
             ?LOG_DEBUG("Using default_oauth_provider ~p",
-                [DefaultOauthProviderId]),
+                       [DefaultOauthProviderId]),
             get_oauth_provider(DefaultOauthProviderId, ListOfRequiredAttributes)
     end.
 
@@ -296,7 +296,7 @@ ensure_oauth_provider_has_attributes(OAuthProvider, ListOfRequiredAttributes) ->
     case find_missing_attributes(OAuthProvider, ListOfRequiredAttributes) of
         [] ->
             ?LOG_DEBUG("Resolved oauth_provider ~p",
-                    [format_oauth_provider(OAuthProvider)]),
+                       [format_oauth_provider(OAuthProvider)]),
             {ok, OAuthProvider};
         _ = Attrs ->
             {error, {missing_oauth_provider_attributes, Attrs}}
@@ -305,13 +305,13 @@ ensure_oauth_provider_has_attributes(OAuthProvider, ListOfRequiredAttributes) ->
 get_root_oauth_provider(ListOfRequiredAttributes) ->
     OAuthProvider = lookup_root_oauth_provider(),
     ?LOG_DEBUG("Using root oauth_provider ~p",
-        [format_oauth_provider(OAuthProvider)]),
+               [format_oauth_provider(OAuthProvider)]),
     case find_missing_attributes(OAuthProvider, ListOfRequiredAttributes) of
         [] ->
             {ok, OAuthProvider};
         _ = MissingAttributes ->
             ?LOG_DEBUG("Looking up missing attributes ~p ...",
-                [MissingAttributes]),
+                       [MissingAttributes]),
             case download_oauth_provider(OAuthProvider) of
                 {ok, OAuthProvider2} ->
                     ensure_oauth_provider_has_attributes(OAuthProvider2,
@@ -335,11 +335,11 @@ get_oauth_provider(OAuth2ProviderId, ListOfRequiredAttributes)
 get_oauth_provider(OAuthProviderId, ListOfRequiredAttributes)
         when is_binary(OAuthProviderId) ->
     ?LOG_DEBUG("get_oauth_provider ~p with at least these attributes: ~p",
-        [OAuthProviderId, ListOfRequiredAttributes]),
+               [OAuthProviderId, ListOfRequiredAttributes]),
     case lookup_oauth_provider_config(OAuthProviderId) of
         {error, _} = Error0 ->
             ?LOG_DEBUG("Failed to find oauth_provider ~p configuration due to ~p",
-                [OAuthProviderId, Error0]),
+                       [OAuthProviderId, Error0]),
             Error0;
         Config ->
             ?LOG_DEBUG("Found oauth_provider configuration ~p", [Config]),
diff --git a/deps/rabbit/src/code_server_cache.erl b/deps/rabbit/src/code_server_cache.erl
@@ -73,7 +73,7 @@ handle_maybe_call_mfa(true, {Module, Function, Args, Default}, State) ->
             handle_maybe_call_mfa_error(Module, Default, State);
         Err:Reason ->
             ?LOG_ERROR("Calling ~tp:~tp failed: ~tp:~tp",
-                             [Module, Function, Err, Reason]),
+                       [Module, Function, Err, Reason]),
             handle_maybe_call_mfa_error(Module, Default, State)
     end.
 
diff --git a/deps/rabbit/src/mc_compat.erl b/deps/rabbit/src/mc_compat.erl
@@ -269,8 +269,8 @@ update_x_death_header(Info, Headers) ->
               [{table, rabbit_misc:sort_field_table(Info1)} | Others]);
         {<<"x-death">>, InvalidType, Header} ->
             ?LOG_WARNING("Message has invalid x-death header (type: ~tp)."
-                               " Resetting header ~tp",
-                               [InvalidType, Header]),
+                         " Resetting header ~tp",
+                         [InvalidType, Header]),
             %% if x-death is something other than an array (list)
             %% then we reset it: this happens when some clients consume
             %% a message and re-publish is, converting header values
diff --git a/deps/rabbit/src/pg_local.erl b/deps/rabbit/src/pg_local.erl
@@ -123,8 +123,8 @@ handle_call(clear, _From, S) ->
 
 handle_call(Request, From, S) ->
     ?LOG_WARNING("The pg_local server received an unexpected message:\n"
-                             "handle_call(~tp, ~tp, _)\n",
-                             [Request, From]),
+                 "handle_call(~tp, ~tp, _)\n",
+                 [Request, From]),
     {noreply, S}.
 
 handle_cast({join, Name, Pid}, S) ->
diff --git a/deps/rabbit/src/rabbit.erl b/deps/rabbit/src/rabbit.erl
@@ -1163,7 +1163,7 @@ pg_local_scope(Prefix) ->
 update_cluster_tags() ->
     Tags = application:get_env(rabbit, cluster_tags, []),
     ?LOG_DEBUG("Seeding cluster tags from application environment key...",
-                       #{domain => ?RMQLOG_DOMAIN_GLOBAL}),
+               #{domain => ?RMQLOG_DOMAIN_GLOBAL}),
     rabbit_runtime_parameters:set_global(cluster_tags, Tags, <<"internal_user">>).
 
 
diff --git a/deps/rabbit/src/rabbit_alarm.erl b/deps/rabbit/src/rabbit_alarm.erl
@@ -242,7 +242,7 @@ handle_event({node_down, Node}, #alarms{alarmed_nodes = AN} = State) ->
                         end,
     {ok, lists:foldr(fun(Source, AccState) ->
                              ?LOG_WARNING("~ts resource limit alarm cleared for dead node ~tp",
-                                                [Source, Node]),
+                                          [Source, Node]),
                              maybe_alert(fun dict_unappend/3, Node, Source, false, AccState)
                      end, State, AlarmsForDeadNode)};
 
@@ -350,7 +350,7 @@ handle_set_alarm(Alarm, State) ->
 
 handle_clear_resource_alarm(Source, Node, State) ->
     ?LOG_WARNING("~ts resource limit alarm cleared on node ~tp",
-                       [Source, Node]),
+                 [Source, Node]),
     {ok, maybe_alert(fun dict_unappend/3, Node, Source, false, State)}.
 
 handle_clear_alarm(file_descriptor_limit, State) ->
diff --git a/deps/rabbit/src/rabbit_amqp_management.erl b/deps/rabbit/src/rabbit_amqp_management.erl
@@ -51,7 +51,7 @@ handle_request(Request, Vhost, User, ConnectionPid, PermCaches0) ->
                             PermCaches0)
         catch throw:{?MODULE, StatusCode0, Explanation} ->
                   ?LOG_WARNING("request ~ts ~ts failed: ~ts",
-                                     [HttpMethod, HttpRequestTarget, Explanation]),
+                               [HttpMethod, HttpRequestTarget, Explanation]),
                   {StatusCode0, {utf8, Explanation}, PermCaches0}
         end,
 
diff --git a/deps/rabbit/src/rabbit_amqqueue.erl b/deps/rabbit/src/rabbit_amqqueue.erl
@@ -427,7 +427,7 @@ rebalance(Type, VhostSpec, QueueSpec) ->
 
 maybe_rebalance({true, Id}, Type, VhostSpec, QueueSpec) ->
     ?LOG_INFO("Starting queue rebalance operation: '~ts' for vhosts matching '~ts' and queues matching '~ts'",
-                    [Type, VhostSpec, QueueSpec]),
+              [Type, VhostSpec, QueueSpec]),
     Running = rabbit_maintenance:filter_out_drained_nodes_consistent_read(rabbit_nodes:list_running()),
     NumRunning = length(Running),
     ToRebalance = [Q || Q <- list(),
@@ -509,7 +509,7 @@ maybe_migrate(ByNode, MaxQueuesDesired, [N | Nodes]) ->
                 _ ->
                     [{Length, Destination} | _] = sort_by_number_of_queues(Candidates, ByNode),
                     ?LOG_INFO("Migrating queue ~tp from node ~tp with ~tp queues to node ~tp with ~tp queues",
-                                       [Name, N, length(All), Destination, Length]),
+                              [Name, N, length(All), Destination, Length]),
                     case Module:transfer_leadership(Q, Destination) of
                         {migrated, NewNode} ->
                             ?LOG_INFO("Queue ~tp migrated to ~tp", [Name, NewNode]),
@@ -1972,8 +1972,8 @@ delete_transient_queues_on_node(Node) ->
             case length(QueueNames) of
                 0 -> ok;
                 N -> ?LOG_INFO("~b transient queues from node '~ts' "
-                                     "deleted in ~fs",
-                                     [N, Node, Time / 1_000_000])
+                               "deleted in ~fs",
+                               [N, Node, Time / 1_000_000])
             end,
             notify_queue_binding_deletions(Deletions),
             rabbit_core_metrics:queues_deleted(QueueNames),
diff --git a/deps/rabbit/src/rabbit_amqqueue_sup_sup.erl b/deps/rabbit/src/rabbit_amqqueue_sup_sup.erl
@@ -76,7 +76,7 @@ start_for_vhost(VHost) ->
         %% e.g. some integration tests do it
         {error, {no_such_vhost, VHost}} ->
             ?LOG_ERROR("Failed to start a queue process supervisor for vhost ~ts: vhost no longer exists!",
-                             [VHost]),
+                       [VHost]),
             {error, {no_such_vhost, VHost}}
     end.
 
@@ -89,6 +89,6 @@ stop_for_vhost(VHost) ->
         %% see start/1
         {error, {no_such_vhost, VHost}} ->
             ?LOG_ERROR("Failed to stop a queue process supervisor for vhost ~ts: vhost no longer exists!",
-                             [VHost]),
+                       [VHost]),
             ok
     end.
diff --git a/deps/rabbit/src/rabbit_auth_backend_internal.erl b/deps/rabbit/src/rabbit_auth_backend_internal.erl
@@ -526,11 +526,11 @@ set_permissions(Username, VirtualHost, ConfigurePerm, WritePerm, ReadPerm, Actin
 
 clear_permissions(Username, VirtualHost, ActingUser) ->
     ?LOG_DEBUG("Asked to clear permissions for user '~ts' in virtual host '~ts'",
-                     [Username, VirtualHost]),
+               [Username, VirtualHost]),
     try
         R = rabbit_db_user:clear_user_permissions(Username, VirtualHost),
         ?LOG_INFO("Successfully cleared permissions for user '~ts' in virtual host '~ts'",
-                        [Username, VirtualHost]),
+                  [Username, VirtualHost]),
         rabbit_event:notify(permission_deleted, [{user,  Username},
                                                  {vhost, VirtualHost},
                                                  {user_who_performed_action, ActingUser}]),
@@ -636,11 +636,11 @@ set_topic_permissions(Username, VirtualHost, Exchange, WritePerm, ReadPerm, Acti
 
 clear_topic_permissions(Username, VirtualHost, ActingUser) ->
     ?LOG_DEBUG("Asked to clear topic permissions for user '~ts' in virtual host '~ts'",
-                     [Username, VirtualHost]),
+               [Username, VirtualHost]),
     try
         R = rabbit_db_user:clear_topic_permissions(Username, VirtualHost, '_'),
         ?LOG_INFO("Successfully cleared topic permissions for user '~ts' in virtual host '~ts'",
-                        [Username, VirtualHost]),
+                  [Username, VirtualHost]),
         rabbit_event:notify(topic_permission_deleted, [{user,  Username},
             {vhost, VirtualHost},
             {user_who_performed_action, ActingUser}]),
@@ -654,12 +654,12 @@ clear_topic_permissions(Username, VirtualHost, ActingUser) ->
 
 clear_topic_permissions(Username, VirtualHost, Exchange, ActingUser) ->
     ?LOG_DEBUG("Asked to clear topic permissions on exchange '~ts' for user '~ts' in virtual host '~ts'",
-                     [Exchange, Username, VirtualHost]),
+               [Exchange, Username, VirtualHost]),
     try
         R = rabbit_db_user:clear_topic_permissions(
               Username, VirtualHost, Exchange),
         ?LOG_INFO("Successfully cleared topic permissions on exchange '~ts' for user '~ts' in virtual host '~ts'",
-                        [Exchange, Username, VirtualHost]),
+                  [Exchange, Username, VirtualHost]),
         rabbit_event:notify(topic_permission_deleted, [{user,  Username},
                                                        {vhost, VirtualHost},
                                                        {user_who_performed_action, ActingUser}]),
diff --git a/deps/rabbit/src/rabbit_channel.erl b/deps/rabbit/src/rabbit_channel.erl
@@ -416,8 +416,8 @@ refresh_config_local() ->
           gen_server2:call(C, refresh_config, infinity)
         catch _:Reason ->
           ?LOG_ERROR("Failed to refresh channel config "
-                           "for channel ~tp. Reason ~tp",
-                           [C, Reason])
+                     "for channel ~tp. Reason ~tp",
+                     [C, Reason])
         end
       end,
       list_local()),
@@ -430,8 +430,8 @@ refresh_interceptors() ->
           gen_server2:call(C, refresh_interceptors, ?REFRESH_TIMEOUT)
         catch _:Reason ->
           ?LOG_ERROR("Failed to refresh channel interceptors "
-                           "for channel ~tp. Reason ~tp",
-                           [C, Reason])
+                     "for channel ~tp. Reason ~tp",
+                     [C, Reason])
         end
       end,
       list_local()),
diff --git a/deps/rabbit/src/rabbit_channel_tracking.erl b/deps/rabbit/src/rabbit_channel_tracking.erl
@@ -219,13 +219,13 @@ ensure_tracked_tables_for_this_node() ->
 %% Create tables
 ensure_tracked_channels_table_for_this_node() ->
     ?LOG_INFO("Setting up a table for channel tracking on this node: ~tp",
-                    [?TRACKED_CHANNEL_TABLE]),
+              [?TRACKED_CHANNEL_TABLE]),
     ets:new(?TRACKED_CHANNEL_TABLE, [named_table, public, {write_concurrency, true},
                                      {keypos, #tracked_channel.pid}]).
 
 ensure_per_user_tracked_channels_table_for_this_node() ->
     ?LOG_INFO("Setting up a table for channel tracking on this node: ~tp",
-                    [?TRACKED_CHANNEL_TABLE_PER_USER]),
+              [?TRACKED_CHANNEL_TABLE_PER_USER]),
     ets:new(?TRACKED_CHANNEL_TABLE_PER_USER, [named_table, public, {write_concurrency, true}]).
 
 get_tracked_channels_by_connection_pid(ConnPid) ->
diff --git a/deps/rabbit/src/rabbit_classic_queue.erl b/deps/rabbit/src/rabbit_classic_queue.erl
@@ -174,9 +174,9 @@ delete(Q0, IfUnused, IfEmpty, ActingUser) when ?amqqueue_is_classic(Q0) ->
                     case IfEmpty of
                         true ->
                             ?LOG_ERROR("Queue ~ts in vhost ~ts is down. "
-                                             "The queue may be non-empty. "
-                                             "Refusing to force-delete.",
-                                             [Name, Vhost]),
+                                       "The queue may be non-empty. "
+                                       "Refusing to force-delete.",
+                                       [Name, Vhost]),
                             {error, not_empty};
                         false ->
                             ?LOG_WARNING("Queue ~ts in vhost ~ts is down. "
@@ -637,7 +637,7 @@ recover_durable_queues(QueuesAndRecoveryTerms) ->
           [{rabbit_amqqueue_sup_sup:start_queue_process(node(), Q),
             {init, {self(), Terms}}} || {Q, Terms} <- QueuesAndRecoveryTerms]),
     _ = [?LOG_ERROR("Queue ~tp failed to initialise: ~tp",
-                      [Pid, Error]) || {Pid, Error} <- Failures],
+                    [Pid, Error]) || {Pid, Error} <- Failures],
     [Q || {_, {new, Q}} <- Results].
 
 capabilities() ->
diff --git a/deps/rabbit/src/rabbit_classic_queue_index_v2.erl b/deps/rabbit/src/rabbit_classic_queue_index_v2.erl
diff --git a/deps/rabbit/src/rabbit_classic_queue_store_v2.erl b/deps/rabbit/src/rabbit_classic_queue_store_v2.erl
diff --git a/deps/rabbit/src/rabbit_connection_tracking.erl b/deps/rabbit/src/rabbit_connection_tracking.erl
diff --git a/deps/rabbitmq_federation/src/rabbit_federation_link_util.erl b/deps/rabbitmq_federation/src/rabbit_federation_link_util.erl
diff --git a/deps/rabbitmq_shovel/src/rabbit_shovel_worker.erl b/deps/rabbitmq_shovel/src/rabbit_shovel_worker.erl
