Contents

require_relative '../../../../../app/models/resque_web/plugins/'\
                    'resque_scheduler/job_finder'

describe ResqueWeb::Plugins::ResqueScheduler::JobFinder do
  let(:non_matching_finder) do
    described_class.new('donkey')
  end

  after do
    reset_the_resque_schedule
  end

  context 'with a scheduled job queued in the future' do
    let(:time_in_future) { Time.now + 60 }
    let(:matching_finder) do
      described_class.new('ivar')
    end

    before do
      Resque.enqueue_at(time_in_future, SomeIvarJob)
    end

    it 'does not find a scheduled job that does not match' do
      expect(non_matching_finder.find_jobs).to be_empty
    end

    it 'finds a matching scheduled job' do
      expect(matching_finder.find_jobs.first['class']).to eq 'SomeIvarJob'
    end

    it 'sets "where_at" to "delayed" for the delayed scheduled jobs' do
      expect(matching_finder.find_jobs.first['where_at']).to eq 'delayed'
    end

    it 'sets the timestamp for the delayed scheduled jobs' do
      first_job_timestamp = matching_finder.find_jobs.first['timestamp']
      expect(first_job_timestamp).to eq time_in_future.to_i
    end
  end

  context 'with a job currently in the queue' do
    let(:matching_finder) do
      described_class.new('quick')
    end

    before do
      Resque.enqueue(SomeQuickJob)
    end

    it 'returns an empty result set with a nil search term' do
      expect(described_class.new(nil).find_jobs).to be_empty
    end

    it 'finds a matching queued job' do
      expect(matching_finder.find_jobs.first['class']).to eq 'SomeQuickJob'
    end

    it 'adds the queue name to the returned queued jobs' do
      expect(matching_finder.find_jobs.first['queue']).to eq 'quick'
    end

    it 'sets "where_at" to "queued" for the returned queued jobs' do
      expect(matching_finder.find_jobs.first['where_at']).to eq 'queued'
    end

    it 'does not find a queued job that does not match' do
      expect(non_matching_finder.find_jobs).to be_empty
    end
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
resque-scheduler-web-1.1.0	spec/models/resque_web/plugins/resque_scheduler/job_finder_spec.rb
resque-scheduler-web-1.0.1	spec/models/resque_web/plugins/resque_scheduler/job_finder_spec.rb
resque-scheduler-web-1.0.0	spec/models/resque_web/plugins/resque_scheduler/job_finder_spec.rb
resque-scheduler-web-0.0.4	spec/models/resque_web/plugins/resque_scheduler/job_finder_spec.rb
resque-scheduler-web-0.0.3	spec/models/resque_web/plugins/resque_scheduler/job_finder_spec.rb