Sha256: 48b091aa49e79fdb21cc851266605892f8d8063e5ae079d2d2ef287fa6c8ddea
Contents?: true
Size: 1.76 KB
Versions: 14
Compression:
Stored size: 1.76 KB
Contents
require 'spec_helper'
describe Sidekiq::Status::ClientMiddleware do
let!(:redis) { Sidekiq.redis { |conn| conn } }
let!(:job_id) { SecureRandom.hex(12) }
before do
allow(SecureRandom).to receive(:hex).once.and_return(job_id)
end
describe "without :expiration parameter" do
it "sets queued status" do
expect(StubJob.perform_async arg1: 'val1').to eq(job_id)
expect(redis.hget("sidekiq:status:#{job_id}", :status)).to eq('queued')
expect(Sidekiq::Status::queued?(job_id)).to be_truthy
end
it "sets status hash ttl" do
expect(StubJob.perform_async arg1: 'val1').to eq(job_id)
expect(1..Sidekiq::Status::DEFAULT_EXPIRY).to cover redis.ttl("sidekiq:status:#{job_id}")
end
context "when redis_pool passed" do
it "uses redis_pool" do
redis_pool = double(:redis_pool)
allow(redis_pool).to receive(:with)
expect(Sidekiq).to_not receive(:redis)
Sidekiq::Status::ClientMiddleware.new.call(StubJob, {'jid' => SecureRandom.hex}, :queued, redis_pool) do end
end
end
context "when redis_pool is not passed" do
it "uses Sidekiq.redis" do
allow(Sidekiq).to receive(:redis)
Sidekiq::Status::ClientMiddleware.new.call(StubJob, {'jid' => SecureRandom.hex}, :queued) do end
end
end
end
describe "with :expiration parameter" do
let(:huge_expiration) { Sidekiq::Status::DEFAULT_EXPIRY * 100 }
# Ensure client middleware is loaded with an expiration parameter set
before do
client_middleware expiration: huge_expiration
end
it "overwrites default expiry value" do
StubJob.perform_async arg1: 'val1'
expect((Sidekiq::Status::DEFAULT_EXPIRY+1)..huge_expiration).to cover redis.ttl("sidekiq:status:#{job_id}")
end
end
end
Version data entries
14 entries across 14 versions & 1 rubygems