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
|
# frozen_string_literal: true
require_relative "../test_helper"
require "action_mailbox/relayer"
module ActionMailbox
class RelayerTest < ActiveSupport::TestCase
URL = "https://example.com/rails/action_mailbox/relay/inbound_emails"
INGRESS_PASSWORD = "secret"
setup do
@relayer = ActionMailbox::Relayer.new(url: URL, password: INGRESS_PASSWORD)
end
test "successfully relaying an email" do
stub_request(:post, URL).to_return status: 204
result = @relayer.relay(file_fixture("welcome.eml").read)
assert_equal "2.0.0", result.status_code
assert_equal "Successfully relayed message to ingress", result.message
assert_predicate result, :success?
assert_not result.failure?
assert_requested :post, URL, body: file_fixture("welcome.eml").read,
basic_auth: [ "actionmailbox", INGRESS_PASSWORD ],
headers: { "Content-Type" => "message/rfc822", "User-Agent" => /\AAction Mailbox relayer v\d+\./ }
end
test "unsuccessfully relaying with invalid credentials" do
stub_request(:post, URL).to_return status: 401
result = @relayer.relay(file_fixture("welcome.eml").read)
assert_equal "4.7.0", result.status_code
assert_equal "Invalid credentials for ingress", result.message
assert_not result.success?
assert_predicate result, :failure?
end
test "unsuccessfully relaying due to an unspecified server error" do
stub_request(:post, URL).to_return status: 500
result = @relayer.relay(file_fixture("welcome.eml").read)
assert_equal "4.0.0", result.status_code
assert_equal "HTTP 500", result.message
assert_not result.success?
assert_predicate result, :failure?
end
test "unsuccessfully relaying due to a gateway timeout" do
stub_request(:post, URL).to_return status: 504
result = @relayer.relay(file_fixture("welcome.eml").read)
assert_equal "4.0.0", result.status_code
assert_equal "HTTP 504", result.message
assert_not result.success?
assert_predicate result, :failure?
end
test "unsuccessfully relaying due to ECONNRESET" do
stub_request(:post, URL).to_raise Errno::ECONNRESET.new
result = @relayer.relay(file_fixture("welcome.eml").read)
assert_equal "4.4.2", result.status_code
assert_equal "Network error relaying to ingress: Connection reset by peer", result.message
assert_not result.success?
assert_predicate result, :failure?
end
test "unsuccessfully relaying due to connection failure" do
stub_request(:post, URL).to_raise SocketError.new("Failed to open TCP connection to example.com:443")
result = @relayer.relay(file_fixture("welcome.eml").read)
assert_equal "4.4.2", result.status_code
assert_equal "Network error relaying to ingress: Failed to open TCP connection to example.com:443", result.message
assert_not result.success?
assert_predicate result, :failure?
end
test "unsuccessfully relaying due to client-side timeout" do
stub_request(:post, URL).to_timeout
result = @relayer.relay(file_fixture("welcome.eml").read)
assert_equal "4.4.2", result.status_code
assert_equal "Timed out relaying to ingress", result.message
assert_not result.success?
assert_predicate result, :failure?
end
test "unsuccessfully relaying due to an unhandled exception" do
stub_request(:post, URL).to_raise StandardError.new("Something went wrong")
result = @relayer.relay(file_fixture("welcome.eml").read)
assert_equal "4.0.0", result.status_code
assert_equal "Error relaying to ingress: Something went wrong", result.message
assert_not result.success?
assert_predicate result, :failure?
end
end
end
|
