Contents

require 'spec_helper'

describe Sidekiq::Status::ClientMiddleware do

  let!(:redis) { Sidekiq.redis { |conn| conn } }
  let!(:job_id) { SecureRandom.hex(12) }

  # Clean Redis before each test
  before { redis.flushall }

  describe "#call" do
    it "sets queued status" do
      SecureRandom.should_receive(:hex).once.and_return(job_id)
      StubJob.perform_async(:arg1 => 'val1').should == job_id
      redis.hget(job_id, :status).should == 'queued'
      Sidekiq::Status::queued?(job_id).should be_true
    end

    it "sets status hash ttl" do
      SecureRandom.should_receive(:hex).once.and_return(job_id)
      StubJob.perform_async(:arg1 => 'val1').should == job_id
      (1..Sidekiq::Status::DEFAULT_EXPIRY).should cover redis.ttl(job_id)
    end

  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
sidekiq-status-0.4.0	spec/lib/sidekiq-status/client_middleware_spec.rb
sidekiq-status-0.3.2	spec/lib/sidekiq-status/client_middleware_spec.rb
sidekiq-status-0.3.1	spec/lib/sidekiq-status/client_middleware_spec.rb
sidekiq-status-0.3.0	spec/lib/sidekiq-status/client_middleware_spec.rb