Revert "Format MQTT code with erlfmt"

Author: ChunyiLyu

.git-blame-ignore-revs

@@ -10,20 +10,18 @@
 
 -behaviour('Elixir.RabbitMQ.CLI.CommandBehaviour').
 
--export([
-    scopes/0,
-    switches/0,
-    aliases/0,
-    usage/0,
-    usage_doc_guides/0,
-    banner/2,
-    validate/2,
-    merge_defaults/2,
-    run/2,
-    output/2,
-    description/0,
-    help_section/0
-]).
+-export([scopes/0,
+         switches/0,
+         aliases/0,
+         usage/0,
+         usage_doc_guides/0,
+         banner/2,
+         validate/2,
+         merge_defaults/2,
+         run/2,
+         output/2,
+         description/0,
+         help_section/0]).
 
 scopes() -> [ctl].
 switches() -> [].
@@ -50,29 +48,20 @@ usage() ->
 usage_doc_guides() ->
     [?MQTT_GUIDE_URL].
 
-run([Node], #{
-    node := NodeName,
-    timeout := Timeout
-}) ->
+run([Node], #{node := NodeName,
+              timeout := Timeout}) ->
     case rabbit_misc:rpc_call(NodeName, rabbit_mqtt_collector, leave, [Node], Timeout) of
         {badrpc, _} = Error ->
             Error;
         nodedown ->
-            {ok,
-                list_to_binary(
-                    io_lib:format(
-                        "Node ~ts is down but has been successfully removed"
-                        " from the cluster",
-                        [Node]
-                    )
-                )};
+            {ok, list_to_binary(io_lib:format("Node ~ts is down but has been successfully removed"
+                                         " from the cluster", [Node]))};
         Result ->
             %% 'ok' or 'timeout'
             Result
     end.
 
-banner([Node], _) ->
-    list_to_binary(io_lib:format("Removing node ~ts from the list of MQTT nodes...", [Node])).
+banner([Node], _) -> list_to_binary(io_lib:format("Removing node ~ts from the list of MQTT nodes...", [Node])).
 
 output(Result, _Opts) ->
     'Elixir.RabbitMQ.CLI.DefaultOutput':output(Result).

deps/rabbitmq_mqtt/src/Elixir.RabbitMQ.CLI.Ctl.Commands.DecommissionMqttNodeCommand.erl

@@ -10,22 +10,20 @@
 
 -behaviour('Elixir.RabbitMQ.CLI.CommandBehaviour').
 
--export([
-    formatter/0,
-    scopes/0,
-    switches/0,
-    aliases/0,
-    usage/0,
-    usage_additional/0,
-    usage_doc_guides/0,
-    banner/2,
-    validate/2,
-    merge_defaults/2,
-    run/2,
-    output/2,
-    description/0,
-    help_section/0
-]).
+-export([formatter/0,
+         scopes/0,
+         switches/0,
+         aliases/0,
+         usage/0,
+         usage_additional/0,
+         usage_doc_guides/0,
+         banner/2,
+         validate/2,
+         merge_defaults/2,
+         run/2,
+         output/2,
+         description/0,
+         help_section/0]).
 
 formatter() -> 'Elixir.RabbitMQ.CLI.Formatters.Table'.
 scopes() -> [ctl, diagnostics].
@@ -39,14 +37,10 @@ help_section() ->
 
 validate(Args, _) ->
     InfoItems = lists:map(fun atom_to_list/1, ?INFO_ITEMS),
-    case
-        'Elixir.RabbitMQ.CLI.Ctl.InfoKeys':validate_info_keys(
-            Args,
-            InfoItems
-        )
-    of
+    case 'Elixir.RabbitMQ.CLI.Ctl.InfoKeys':validate_info_keys(Args,
+                                                               InfoItems) of
         {ok, _} -> ok;
-        Error -> Error
+        Error   -> Error
     end.
 
 merge_defaults([], Opts) ->
@@ -61,22 +55,19 @@ usage_additional() ->
     Prefix = <<" must be one of ">>,
     InfoItems = 'Elixir.Enum':join(lists:usort(?INFO_ITEMS), <<", ">>),
     [
-        {<<"<column>">>, <<Prefix/binary, InfoItems/binary>>}
+      {<<"<column>">>, <<Prefix/binary, InfoItems/binary>>}
     ].
 
 usage_doc_guides() ->
     [?MQTT_GUIDE_URL].
 
-run(Args, #{
-    node := NodeName,
-    timeout := Timeout,
-    verbose := Verbose
-}) ->
-    InfoKeys =
-        case Verbose of
-            true -> ?INFO_ITEMS;
-            false -> 'Elixir.RabbitMQ.CLI.Ctl.InfoKeys':prepare_info_keys(Args)
-        end,
+run(Args, #{node := NodeName,
+            timeout := Timeout,
+            verbose := Verbose}) ->
+    InfoKeys = case Verbose of
+        true  -> ?INFO_ITEMS;
+        false -> 'Elixir.RabbitMQ.CLI.Ctl.InfoKeys':prepare_info_keys(Args)
+    end,
 
     Nodes = 'Elixir.RabbitMQ.CLI.Core.Helpers':nodes_in_cluster(NodeName),
 
@@ -87,8 +78,7 @@ run(Args, #{
         [Nodes, InfoKeys],
         Timeout,
         InfoKeys,
-        length(Nodes)
-    ).
+        length(Nodes)).
 
 banner(_, _) -> <<"Listing MQTT connections ...">>.