Sha256: 037d8bd089c1d16fd09f782403f954da1641365b1894072bed23e5f113ee94b5
Contents?: true
Size: 1.72 KB
Versions: 8
Compression:
Stored size: 1.72 KB
Contents
describe Sufia::RedisEventStore do
let(:redis_instance) { described_class.instance }
before do
redis_instance.keys('events:*').each { |key| redis_instance.del key }
end
describe "::create" do
subject { described_class.create("some action", "1234") }
context "when it is successful" do
it { is_expected.to eq(1) }
end
context "when the Redis command fails" do
before { allow(Redis).to receive(:current).and_raise(Redis::CommandError) }
context "without a logger" do
before { allow(Rails).to receive(:logger).and_return(false) }
it { is_expected.to be_nil }
end
context "with a logger" do
it "logs the error" do
expect(Rails.logger).to receive(:error).exactly(:once).with("unable to create event: Redis::CommandError")
expect(subject).to be_nil
end
end
end
end
describe "#fetch" do
subject { described_class.new("key").fetch("size") }
context "when the Redis command fails" do
before { allow(Redis).to receive(:current).and_raise(Redis::CommandError) }
it { is_expected.to eq([]) }
end
context "when the Redis is unavailable" do
before { allow(Redis).to receive(:current).and_raise(Redis::CannotConnectError) }
it { is_expected.to eq([]) }
end
end
describe "#push" do
subject { described_class.new("key").push("some value") }
context "when the Redis command fails" do
before { allow(Redis).to receive(:current).and_raise(Redis::CommandError) }
it { is_expected.to be_nil }
end
context "when the Redis is unavailable" do
before { allow(Redis).to receive(:current).and_raise(Redis::CannotConnectError) }
it { is_expected.to be_nil }
end
end
end
Version data entries
8 entries across 8 versions & 1 rubygems