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
|
require 'test_helper'
class MockRedis
def initialize
@sets = []
@setexes = []
@setnxes = []
@expires = []
end
def set(*a)
@sets << a
end
def has_set?(*a)
@sets.include?(a)
end
def setex(*a)
@setexes << a
end
def has_setex?(*a)
@setexes.include?(a)
end
def setnx(*a)
@setnxes << a
end
def has_setnx?(*a)
@setnxes.include?(a)
end
def multi(&block)
instance_eval do
def setnx(*a)
@setnxes << a
end
block.call(self)
end
end
alias_method :pipelined, :multi
def expire(*a)
@expires << a
end
def has_expire?(*a)
@expires.include?(a)
end
end
class MockTtlStore < MockRedis
include Redis::Store::Ttl
end
describe MockTtlStore do
let(:key) { 'hello' }
let(:mock_value) { 'value' }
let(:options) { { :expire_after => 3600 } }
let(:redis) { MockTtlStore.new }
describe '#set' do
describe 'without options' do
it 'must call super with key and value' do
redis.set(key, mock_value)
_(redis.has_set?(key, mock_value, nil)).must_equal true
end
end
describe 'with options' do
it 'must call setex with proper expiry and set raw to true' do
redis.set(key, mock_value, options)
_(redis.has_setex?(key, options[:expire_after], mock_value, :raw => true)).must_equal true
end
end
describe 'with nx and ex option' do
it 'must call super with key and value and options' do
set_options = { nx: true, ex: 3600 }
redis.set(key, mock_value, set_options)
_(redis.has_set?(key, mock_value, set_options)).must_equal true
end
end
end
describe '#setnx' do
describe 'without expiry' do
it 'must call super with key and value' do
redis.setnx(key, mock_value)
redis.has_setnx?(key, mock_value)
end
it 'must not call expire' do
redis.expects(:expire).never
redis.setnx(key, mock_value)
end
end
describe 'with expiry' do
it 'uses the mutli command to chain commands' do
redis.expects(:multi)
redis.setnx(key, mock_value, options)
end
it 'must call expire' do
redis.setnx(key, mock_value, options)
_(redis.has_expire?(key, options[:expire_after])).must_equal true
end
describe 'avoiding multi commands' do
let(:options) { { :expire_after => 3600, :avoid_multi_commands => true } }
it 'uses the redis pipelined feature to chain commands' do
redis.expects(:pipelined)
redis.setnx(key, mock_value, options)
end
it 'must call expire' do
redis.setnx(key, mock_value, options)
_(redis.has_expire?(key, options[:expire_after])).must_equal true
end
end
describe 'using a redis cluster' do
let(:options) { { :expire_after => 3600, :cluster => %w[redis://127.0.0.1:6379/0] } }
it 'uses the redis pipelined feature to chain commands' do
redis.expects(:pipelined)
redis.setnx(key, mock_value, options)
end
it 'must call expire' do
redis.setnx(key, mock_value, options)
_(redis.has_expire?(key, options[:expire_after])).must_equal true
end
end
end
end
end
|
