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
|
require 'spec_helper'
require 'mail_room/delivery/sidekiq'
describe MailRoom::Delivery::Sidekiq do
subject { described_class.new(options) }
let(:redis) { subject.send(:client) }
let(:options) { MailRoom::Delivery::Sidekiq::Options.new(mailbox) }
describe '#options' do
let(:redis_url) { 'redis://localhost' }
context 'when only redis_url is specified' do
let(:mailbox) {
build_mailbox(
delivery_method: :sidekiq,
delivery_options: {
redis_url: redis_url
}
)
}
xit 'client has same specified redis_url' do
expect(redis.client.options[:url]).to eq(redis_url)
end
it 'client is a instance of RedisNamespace class' do
expect(redis).to be_a ::Redis
end
end
context 'when namespace is specified' do
let(:namespace) { 'sidekiq_mailman' }
let(:mailbox) {
build_mailbox(
delivery_method: :sidekiq,
delivery_options: {
redis_url: redis_url,
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 specified' do
let(:redis_url) { 'redis://:mypassword@sentinel-master:6379' }
let(:sentinels) { [{ host: '10.0.0.1', port: '26379' }] }
let(:mailbox) {
build_mailbox(
delivery_method: :sidekiq,
delivery_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
|
