Style-guide compliance.
This commit is contained in:
parent
2775ed5a82
commit
a843b837d8
|
|
@ -4,13 +4,13 @@ defmodule CLI do
|
||||||
import StatusCommand
|
import StatusCommand
|
||||||
|
|
||||||
def main(command) do
|
def main(command) do
|
||||||
unless Node.alive?(), do: :net_kernel.start([:rabbitmqctl, :shortnames])
|
:net_kernel.start([:rabbitmqctl, :shortnames])
|
||||||
|
|
||||||
{parsed_cmd, options} = parse(command)
|
{parsed_cmd, options} = parse(command)
|
||||||
|
|
||||||
case options[:node] do
|
case options[:node] do
|
||||||
nil -> IO.puts connect_to_rabbitmq()
|
nil -> connect_to_rabbitmq |> IO.puts
|
||||||
_ -> IO.puts connect_to_rabbitmq(String.to_atom(options[:node]))
|
_ -> options[:node] |> String.to_atom |> connect_to_rabbitmq |> IO.puts
|
||||||
end
|
end
|
||||||
|
|
||||||
run_command(parsed_cmd, options)
|
run_command(parsed_cmd, options)
|
||||||
|
|
@ -18,7 +18,7 @@ defmodule CLI do
|
||||||
end
|
end
|
||||||
|
|
||||||
defp print_nodedown_error(options) do
|
defp print_nodedown_error(options) do
|
||||||
target_node = options[:node] || get_rabbit_hostname()
|
target_node = options[:node] || get_rabbit_hostname
|
||||||
|
|
||||||
IO.puts "Status of #{target_node} ..."
|
IO.puts "Status of #{target_node} ..."
|
||||||
IO.puts "Error: unable to connect to node '#{target_node}': nodedown"
|
IO.puts "Error: unable to connect to node '#{target_node}': nodedown"
|
||||||
|
|
@ -26,8 +26,8 @@ defmodule CLI do
|
||||||
|
|
||||||
defp run_command(["status"], options) do
|
defp run_command(["status"], options) do
|
||||||
case result = status(options) do
|
case result = status(options) do
|
||||||
{:badrpc, :nodedown} -> print_nodedown_error(options)
|
{:badrpc, :nodedown} -> print_nodedown_error(options)
|
||||||
_ -> print_status(result)
|
_ -> print_status(result)
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
|
||||||
|
|
@ -1,8 +1,10 @@
|
||||||
defmodule Helpers do
|
defmodule Helpers do
|
||||||
def get_rabbit_hostname(), do: "rabbit@" <> hostname() |> String.to_atom()
|
@rabbit_host "rabbit"
|
||||||
|
|
||||||
def connect_to_rabbitmq(), do: :net_kernel.connect_node(get_rabbit_hostname())
|
def get_rabbit_hostname(), do: (@rabbit_host <> "@" <> hostname) |> String.to_atom
|
||||||
|
|
||||||
|
def connect_to_rabbitmq(), do: :net_kernel.connect_node(get_rabbit_hostname)
|
||||||
def connect_to_rabbitmq(input), do: :net_kernel.connect_node(input)
|
def connect_to_rabbitmq(input), do: :net_kernel.connect_node(input)
|
||||||
|
|
||||||
defp hostname(), do: elem(:inet.gethostname,1) |> List.to_string()
|
defp hostname(), do: :inet.gethostname() |> elem(1) |> List.to_string
|
||||||
end
|
end
|
||||||
|
|
|
||||||
|
|
@ -9,6 +9,7 @@ defmodule Parser do
|
||||||
{clear_on_empty_command(cmd), options}
|
{clear_on_empty_command(cmd), options}
|
||||||
end
|
end
|
||||||
|
|
||||||
|
# Discards entire command if first command term is empty.
|
||||||
defp clear_on_empty_command(command_args) do
|
defp clear_on_empty_command(command_args) do
|
||||||
case command_args do
|
case command_args do
|
||||||
[] -> []
|
[] -> []
|
||||||
|
|
|
||||||
|
|
@ -6,18 +6,19 @@ defmodule StatusCommand do
|
||||||
|
|
||||||
def status(options) do
|
def status(options) do
|
||||||
case options[:node] do
|
case options[:node] do
|
||||||
nil -> :rpc.call(get_rabbit_hostname(), :rabbit, :status, [])
|
nil -> get_rabbit_hostname |> :rpc.call(:rabbit, :status, [])
|
||||||
host when is_atom(host) -> :rpc.call(host, :rabbit, :status, [])
|
host when is_atom(host) -> host |> :rpc.call(:rabbit, :status, [])
|
||||||
host when is_binary(host) -> :rpc.call(String.to_atom(host), :rabbit, :status, [])
|
host when is_binary(host) -> host |> String.to_atom() |> :rpc.call(:rabbit, :status, [])
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
||||||
def print_status(result) do
|
def print_status(result) do
|
||||||
result |>
|
result
|
||||||
print_pid |>
|
|> print_pid
|
||||||
print_running_apps
|
|> print_running_apps
|
||||||
end
|
end
|
||||||
|
|
||||||
|
defp print_pid(result) when not is_list(result), do: result
|
||||||
defp print_pid(result) when is_list(result) do
|
defp print_pid(result) when is_list(result) do
|
||||||
case result[:pid] do
|
case result[:pid] do
|
||||||
nil -> nil
|
nil -> nil
|
||||||
|
|
@ -26,26 +27,22 @@ defmodule StatusCommand do
|
||||||
result
|
result
|
||||||
end
|
end
|
||||||
|
|
||||||
defp print_pid(result) when not is_list(result) do
|
defp print_running_apps(result) when not is_list(result), do: result
|
||||||
result
|
|
||||||
end
|
|
||||||
|
|
||||||
defp print_running_apps(result) when is_list(result) do
|
defp print_running_apps(result) when is_list(result) do
|
||||||
IO.puts "Applications currently running:"
|
IO.puts "Applications currently running:"
|
||||||
IO.puts "---------------------------------------"
|
IO.puts "---------------------------------------"
|
||||||
|
|
||||||
case result[:running_applications] do
|
case result[:running_applications] do
|
||||||
nil -> nil
|
nil -> nil
|
||||||
_ -> Enum.map(
|
_ -> result[:running_applications] |> Enum.map(
|
||||||
result[:running_applications],
|
fn ({id, name, version}) ->
|
||||||
fn ({id, name, version}) -> :io.format("~-#{@id_length}s | ~-#{@name_length}s | ~s\n", [id, name, version])
|
:io.format(
|
||||||
|
"~-#{@id_length}s | ~-#{@name_length}s | ~s\n",
|
||||||
|
[id, name, version]
|
||||||
|
)
|
||||||
end
|
end
|
||||||
)
|
)
|
||||||
end
|
end
|
||||||
result
|
result
|
||||||
end
|
end
|
||||||
|
|
||||||
defp print_running_apps(result) when not is_list(result) do
|
|
||||||
result
|
|
||||||
end
|
|
||||||
end
|
end
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue