mirror of
https://github.com/discourse/discourse.git
synced 2024-12-16 10:58:23 +08:00
135 lines
2.1 KiB
Ruby
135 lines
2.1 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: @manager)
|
|
end
|
|
|
|
let :cache_name do
|
|
SecureRandom.hex
|
|
end
|
|
|
|
let! :cache1 do
|
|
cache(cache_name)
|
|
end
|
|
|
|
let! :cache2 do
|
|
cache(cache_name)
|
|
end
|
|
|
|
it 'supports arrays with hashes' do
|
|
|
|
c1 = cache("test1")
|
|
c2 = cache("test1")
|
|
|
|
c1["test"] = [{ test: :test }]
|
|
|
|
wait_for do
|
|
c2["test"] == [{ test: :test }]
|
|
end
|
|
|
|
expect(c2[:test]).to eq([{ test: :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
|