WIP

Author: dumbbell

deps/rabbit/Makefile

@@ -150,6 +150,21 @@ DEP_PLUGINS = rabbit_common/mk/rabbitmq-plugin.mk
 include ../../rabbitmq-components.mk
 include ../../erlang.mk
 
+CLI_SCRIPTS := scripts/rmq3
+
+ebin/$(PROJECT).app:: $(CLI_SCRIPTS)
+
+$(CLI_SCRIPTS): ebin/rabbit_cli_escript.beam
+	$(gen_verbose) echo '#!/usr/bin/env escript' > "$@"
+	$(verbose) echo '%%! -start_epmd false' >> "$@"
+	$(verbose) cat $^ >> "$@"
+	$(verbose) chmod a+x "$@"
+
+clean:: clean-cli
+
+clean-cli:
+	$(gen_verbose) rm -f $(CLI_SCRIPTS)
+
 ifeq ($(strip $(BATS)),)
 BATS := $(ERLANG_MK_TMP)/bats/bin/bats
 endif

deps/rabbit/src/rabbit_cli_cmd_list_exchanges.erl

@@ -0,0 +1,46 @@
+-module(rabbit_cli_cmd_list_exchanges).
+
+-export([cli/0]).
+
+cli() ->
+    #{commands => #{
+        "exchange" => #{
+          commands => #{
+            "list" => #{
+              help => "Lists exchanges",
+              handler => fun list_exchanges/1
+             }
+           },
+          help => "Provides sub-commands to manage exchanges",
+          handler => fun(_) -> ok end
+         },
+
+        "list_exchanges" => #{
+          help => "Lists exchanges",
+          handler => fun list_exchanges/1
+         }
+       }
+     }.
+
+list_exchanges(Args) ->
+    Node = get_nodename(Args),
+    VHost = get_vhost(Args),
+    InfoKeys = [name, type, durable, auto_delete, internal, arguments, policy],
+    net_kernel:start([foobar, shortnames]),
+    io:format("Exchanges on vhost ~p on node ~s~n", [VHost, Node]),
+    Ret = rpc:call(Node,
+                   rabbit_exchange,
+                   info_all,
+                   [VHost, InfoKeys]),
+    io:format("~p~n", [Ret]).
+
+get_nodename(#{node := Nodename}) ->
+    Nodename;
+get_nodename(_) ->
+    #{nodename := Nodename} = rabbit_env:get_context(),
+    Nodename.
+
+get_vhost(#{vhost := VHost}) ->
+    VHost;
+get_vhost(_) ->
+    <<"/">>.

deps/rabbit/src/rabbit_cli_cmd_version.erl

@@ -0,0 +1,17 @@
+-module(rabbit_cli_cmd_version).
+
+-export([cli/0]).
+
+cli() ->
+    #{commands => #{
+        "version" => #{
+          help => "Shows the version of RabbitMQ and exit",
+          handler => fun show_version/1
+         }
+       }
+     }.
+
+show_version(_) ->
+    ok = application:load(rabbit),
+    {ok, Version} = application:get_key(rabbit, vsn),
+    io:format("~s~n", [Version]).

deps/rabbit/src/rabbit_cli_escript.erl

@@ -0,0 +1,24 @@
+-module(rabbit_cli_escript).
+
+-export([main/1]).
+
+main(Args) ->
+    ScriptName = filename:absname(escript:script_name()),
+    ScriptDir = filename:dirname(ScriptName),
+    ProgName = list_to_atom(filename:basename(ScriptName, ".bat")),
+
+    %% Add RabbitMQ components to Erlang code path.
+    ErlLibs = filename:join([ScriptDir, "..", "plugins"]),
+    lists:foreach(
+      fun(Dir) -> true = code:add_path(Dir) end,
+      filelib:wildcard(filename:join([ErlLibs, "*", "ebin"]))),
+
+    %% Run the CLI.
+    Mods = [% FIXME: Generate that list.
+            rabbit_cli_global_options,
+            rabbit_cli_cmd_list_exchanges,
+            rabbit_cli_cmd_version
+           ],
+    cli:run(Args, #{progname => ProgName,
+                    modules => Mods,
+                    warn => suppress}).

deps/rabbit/src/rabbit_cli_global_options.erl

@@ -0,0 +1,24 @@
+-module(rabbit_cli_global_options).
+
+-export([cli/0]).
+
+cli() ->
+    #{arguments =>
+      [
+       #{name => node,
+         short => $n,
+         long => "-node",
+         type => string,
+         action => store},
+
+       #{name => vhost,
+         short => $v,
+         long => "-vhost",
+         type => binary,
+         action => store},
+
+       #{name => verbose,
+         short => $V,
+         long => "-verbose",
+         action => count}
+      ]}.