discourse/spec/components/distributed_cache_spec.rb

117 lines
1.8 KiB
Ruby

require 'rails_helper'
require 'distributed_cache'
describe DistributedCache do
before :all do
@bus = MessageBus::Instance.new
@bus.configure(backend: :memory)
@manager = DistributedCache::Manager.new(@bus)
end
after :all do
@bus.destroy
end
def cache(name)
DistributedCache.new(name, @manager)
end
let! :cache1 do
cache("test")
end
let! :cache2 do
cache("test")
end
it 'allows us to store Set' do
c1 = cache("test1")
c2 = cache("test1")
set = Set.new
set << 1
set << "b"
set << 92803984
set << 93739739873973
c1["cats"] = set
wait_for do
c2["cats"] == set
end
expect(c2["cats"]).to eq(set)
set << 5
c2["cats"] = set
wait_for do
c1["cats"] == set
end
expect(c1["cats"]).to eq(set)
end
it 'does not leak state across caches' do
c2 = cache("test1")
c3 = cache("test1")
c2["hi"] = "hi"
wait_for do
c3["hi"] == "hi"
end
Thread.pass
expect(cache1["hi"]).to eq(nil)
end
it 'allows coerces symbol keys to strings' do
cache1[:key] = "test"
expect(cache1["key"]).to eq("test")
wait_for do
cache2[:key] == "test"
end
expect(cache2["key"]).to eq("test")
end
it 'sets other caches' do
cache1["test"] = "world"
wait_for do
cache2["test"] == "world"
end
end
it 'deletes from other caches' do
cache1["foo"] = "bar"
wait_for do
cache2["foo"] == "bar"
end
cache1.delete("foo")
expect(cache1["foo"]).to eq(nil)
wait_for do
cache2["foo"] == nil
end
end
it 'clears cache on request' do
cache1["foo"] = "bar"
wait_for do
cache2["foo"] == "bar"
end
cache1.clear
expect(cache1["foo"]).to eq(nil)
wait_for do
cache2["boom"] == nil
end
end
end