require File.join(File.dirname(__FILE__) + '/../spec_helper')

describe Resque::Job do
  it "should repush restriction queue when reserve" do
    Resque.redis.flushall
    Resque.push('restriction', :class => 'OneHourRestrictionJob', :args => ['any args'])
    Resque::Job.reserve('restriction').should be_nil
    Resque::Job.reserve('normal').should == Resque::Job.new('normal', {'class' => 'OneHourRestrictionJob', 'args' => ['any args']})
    Resque::Job.reserve('normal').should be_nil
  end

  it "should push back to restriction queue when still restricted" do
    Resque.redis.flushall
    Resque.redis.set(OneHourRestrictionJob.redis_key(:per_hour), -1)
    Resque.push('restriction', :class => 'OneHourRestrictionJob', :args => ['any args'])
    Resque::Job.reserve('restriction').should be_nil
    Resque.pop('restriction').should == {'class' => 'OneHourRestrictionJob', 'args' => ['any args']}
    Resque::Job.reserve('normal').should be_nil
  end

  it "should not repush when reserve normal queue" do
    Resque.push('normal', :class => 'OneHourRestrictionJob', :args => ['any args'])
    Resque::Job.reserve('normal').should == Resque::Job.new('normal', {'class' => 'OneHourRestrictionJob', 'args' => ['any args']})
    Resque::Job.reserve('normal').should be_nil
  end
end