1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
|
## This Source Code Form is subject to the terms of the Mozilla Public
## License, v. 2.0. If a copy of the MPL was not distributed with this
## file, You can obtain one at https://mozilla.org/MPL/2.0/.
##
## Copyright (c) 2007-2020 VMware, Inc. or its affiliates. All rights reserved.
defmodule DefaultOutputTest do
use ExUnit.Case, async: false
test "ok is passed as is" do
assert match?(:ok, ExampleCommand.output(:ok, %{}))
end
test "ok with message is passed as is" do
assert match?({:ok, :message}, ExampleCommand.output({:ok, :message}, %{}))
assert match?({:ok, {:complex, "message"}}, ExampleCommand.output({:ok, {:complex, "message"}}, %{}))
end
test "enumerable is passed as stream" do
assert match?({:stream, 'list'}, ExampleCommand.output({:ok, 'list'}, %{}))
assert match?({:stream, 'list'}, ExampleCommand.output('list', %{}))
assert match?({:stream, [1,2,3]}, ExampleCommand.output({:ok, [1,2,3]}, %{}))
assert match?({:stream, [1,2,3]}, ExampleCommand.output([1,2,3], %{}))
stream = Stream.timer(10000)
assert match?({:stream, ^stream}, ExampleCommand.output({:ok, stream}, %{}))
assert match?({:stream, ^stream}, ExampleCommand.output(stream, %{}))
end
test "badrpc is an error" do
{:error, {:badrpc, :nodedown}} =
ExampleCommand.output({:badrpc, :nodedown}, %{})
{:error, {:badrpc, :timeout}} =
ExampleCommand.output({:badrpc, :timeout}, %{})
end
test "unknown atom is error" do
{:error, :error_message} = ExampleCommand.output(:error_message, %{})
end
test "unknown tuple is error" do
{:error, {:left, :right}} = ExampleCommand.output({:left, :right}, %{})
end
test "error_string is error" do
assert {:error, "I am string"} == ExampleCommand.output({:error_string, "I am string"}, %{})
end
test "error_string is converted to string" do
assert match?({:error, "I am charlist"},
ExampleCommand.output({:error_string, 'I am charlist'}, %{}))
end
test "error is formatted" do
{:error, "I am formatted \"string\""} =
ExampleCommand.output({:error, 'I am formatted ~p', ['string']}, %{})
end
test "non atom value is ok" do
val = "foo"
assert match?({:ok, ^val}, ExampleCommand.output(val, %{}))
val = 125
assert match?({:ok, ^val}, ExampleCommand.output(val, %{}))
val = 100.2
assert match?({:ok, ^val}, ExampleCommand.output(val, %{}))
val = {:one, :two, :three}
assert match?({:ok, ^val}, ExampleCommand.output(val, %{}))
end
test "custom output function can be defined" do
assert {:error, 125, "Non standard"} == ExampleCommandWithCustomOutput.output(:non_standard_output, %{})
end
test "default output works even if custom output is defined" do
assert :ok == ExampleCommandWithCustomOutput.output(:ok, %{})
assert {:ok, {:complex, "message"}} == ExampleCommandWithCustomOutput.output({:ok, {:complex, "message"}}, %{})
assert {:stream, [1,2,3]} == ExampleCommandWithCustomOutput.output({:ok, [1,2,3]}, %{})
assert {:stream, [1,2,3]} == ExampleCommandWithCustomOutput.output([1,2,3], %{})
assert {:error, {:badrpc, :nodedown}} ==
ExampleCommandWithCustomOutput.output({:badrpc, :nodedown}, %{})
assert {:error, {:badrpc, :timeout}} ==
ExampleCommandWithCustomOutput.output({:badrpc, :timeout}, %{})
error = %{i: [am: "arbitrary", error: 1]}
{:error, ^error} = ExampleCommandWithCustomOutput.output({:error, error}, %{})
assert {:error, "I am string"} == ExampleCommandWithCustomOutput.output({:error_string, "I am string"}, %{})
val = "foo"
assert match?({:ok, ^val}, ExampleCommandWithCustomOutput.output(val, %{}))
val = 125
assert match?({:ok, ^val}, ExampleCommandWithCustomOutput.output(val, %{}))
val = 100.2
assert match?({:ok, ^val}, ExampleCommandWithCustomOutput.output(val, %{}))
val = {:one, :two, :three}
assert match?({:ok, ^val}, ExampleCommandWithCustomOutput.output(val, %{}))
end
end
defmodule ExampleCommand do
use RabbitMQ.CLI.DefaultOutput
end
defmodule ExampleCommandWithCustomOutput do
def output(:non_standard_output, _) do
{:error, 125, "Non standard"}
end
use RabbitMQ.CLI.DefaultOutput
end
|
