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
|
require 'flipper/adapters/operation_logger'
require 'flipper/adapters/redis_cache'
RSpec.describe Flipper::Adapters::RedisCache do
let(:client) do
options = {}
options[:url] = ENV['REDIS_URL'] if ENV['REDIS_URL']
Redis.new(options)
end
let(:memory_adapter) do
Flipper::Adapters::OperationLogger.new(Flipper::Adapters::Memory.new)
end
let(:adapter) { described_class.new(memory_adapter, client) }
let(:flipper) { Flipper.new(adapter) }
subject { adapter }
before do
begin
client.flushdb
rescue Redis::CannotConnectError
ENV['CI'] ? raise : skip('Redis not available')
end
end
it_should_behave_like 'a flipper adapter'
describe '#remove' do
it 'expires feature' do
feature = flipper[:stats]
adapter.get(feature)
adapter.remove(feature)
expect(client.get(described_class.key_for(feature))).to be(nil)
end
end
describe '#get' do
it 'uses correct cache key' do
stats = flipper[:stats]
adapter.get(stats)
expect(client.get(described_class.key_for(stats))).not_to be_nil
end
end
describe '#get_multi' do
it 'warms uncached features' do
stats = flipper[:stats]
search = flipper[:search]
other = flipper[:other]
stats.enable
search.enable
memory_adapter.reset
adapter.get(stats)
expect(client.get(described_class.key_for(search))).to be(nil)
expect(client.get(described_class.key_for(other))).to be(nil)
adapter.get_multi([stats, search, other])
search_cache_value, other_cache_value = [search, other].map do |f|
Marshal.load(client.get(described_class.key_for(f)))
end
expect(search_cache_value[:boolean]).to eq('true')
expect(other_cache_value[:boolean]).to be(nil)
adapter.get_multi([stats, search, other])
adapter.get_multi([stats, search, other])
expect(memory_adapter.count(:get_multi)).to eq(1)
end
end
describe '#get_all' do
let(:stats) { flipper[:stats] }
let(:search) { flipper[:search] }
before do
stats.enable
search.add
end
it 'warms all features' do
adapter.get_all
expect(Marshal.load(client.get(described_class.key_for(stats.key)))[:boolean]).to eq('true')
expect(Marshal.load(client.get(described_class.key_for(search.key)))[:boolean]).to be(nil)
expect(client.get(described_class::GetAllKey).to_i).to be_within(2).of(Time.now.to_i)
end
it 'returns same result when already cached' do
expect(adapter.get_all).to eq(adapter.get_all)
end
it 'only invokes one call to wrapped adapter' do
memory_adapter.reset
5.times { adapter.get_all }
expect(memory_adapter.count(:get_all)).to eq(1)
end
end
describe '#name' do
it 'is redis_cache' do
expect(subject.name).to be(:redis_cache)
end
end
end
|
