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
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
|
require 'spec_helper'
require 'mail_room/arbitration/redis'
describe MailRoom::Arbitration::Redis do
let(:mailbox) {
build_mailbox(
arbitration_options: {
namespace: "mail_room",
redis_url: ENV['REDIS_URL']
}
)
}
let(:options) { described_class::Options.new(mailbox) }
subject { described_class.new(options) }
# Private, but we don't care.
let(:redis) { subject.send(:client) }
describe '#deliver?' do
context "when called the first time" do
after do
redis.del("delivered:123")
end
it "returns true" do
expect(subject.deliver?(123)).to be_truthy
end
it "increments the delivered flag" do
subject.deliver?(123)
expect(redis.get("delivered:123")).to eq("1")
end
it "sets an expiration on the delivered flag" do
subject.deliver?(123)
expect(redis.ttl("delivered:123")).to be > 0
end
end
context "when called the second time" do
before do
#Short expiration, 1 second, for testing
subject.deliver?(123, 1)
end
after do
redis.del("delivered:123")
end
it "returns false" do
expect(subject.deliver?(123, 1)).to be_falsey
end
it "after expiration returns true" do
# Fails locally because fakeredis returns 0, not false
expect(subject.deliver?(123, 1)).to be_falsey
sleep(redis.ttl("delivered:123")+1)
expect(subject.deliver?(123, 1)).to be_truthy
end
end
context "when called for another uid" do
before do
subject.deliver?(123)
end
after do
redis.del("delivered:123")
redis.del("delivered:124")
end
it "returns true" do
expect(subject.deliver?(124)).to be_truthy
end
end
end
context 'redis client connection params' do
context 'when only url is present' do
let(:redis_url) { ENV.fetch('REDIS_URL', 'redis://localhost:6379') }
let(:mailbox) {
build_mailbox(
arbitration_options: {
redis_url: redis_url
}
)
}
after do
redis.del("delivered:123")
end
xit 'client has same specified url' do
subject.deliver?(123)
expect(redis.client.options[:url]).to eq redis_url
end
it 'client is a instance of Redis class' do
expect(redis).to be_a Redis
end
end
context 'when namespace is present' do
let(:namespace) { 'mail_room' }
let(:mailbox) {
build_mailbox(
arbitration_options: {
namespace: namespace
}
)
}
it 'client has same specified namespace' do
expect(redis.namespace).to eq(namespace)
end
it 'client is a instance of RedisNamespace class' do
expect(redis).to be_a ::Redis::Namespace
end
end
context 'when sentinel is present' do
let(:redis_url) { 'redis://:mypassword@sentinel-master:6379' }
let(:sentinels) { [{ host: '10.0.0.1', port: '26379' }] }
let(:mailbox) {
build_mailbox(
arbitration_options: {
redis_url: redis_url,
sentinels: sentinels
}
)
}
before { ::Redis::Client::Connector::Sentinel.any_instance.stubs(:resolve).returns(sentinels) }
xit 'client has same specified sentinel params' do
expect(redis.client.instance_variable_get(:@connector)).to be_a Redis::Client::Connector::Sentinel
expect(redis.client.options[:host]).to eq('sentinel-master')
expect(redis.client.options[:password]).to eq('mypassword')
expect(redis.client.options[:sentinels]).to eq(sentinels)
end
end
end
end
|
