Contents

require 'spec_helper'

RSpec.describe SidekiqUniqueJobs::Lock::UntilExecuted do
  describe '#execute' do
    subject { described_class.new(item) }
    let(:item) do
      { 'jid' => 'maaaahjid', 'class' => 'UntilExecutedJob', 'unique' => 'until_executed' }
    end
    let(:empty_callback) { -> {} }

    def execute
      subject.execute(empty_callback)
    end

    context 'when yield fails with Sidekiq::Shutdown' do
      before do
        allow(subject).to receive(:after_yield_yield) { raise Sidekiq::Shutdown }
        allow(subject).to receive(:unlock).and_return(true)
        expect(subject).not_to receive(:unlock)
        expect(subject.logger).to receive(:fatal)
        expect(empty_callback).not_to receive(:call)
      end

      specify { expect { subject.execute(empty_callback) }.to raise_error(Sidekiq::Shutdown) }
    end

    context 'when yield fails with other errors' do
      before do
        allow(subject).to receive(:after_yield_yield) { raise 'Hell' }
        expect(subject).to receive(:unlock).and_return(true)
        expect(empty_callback).to receive(:call)
      end

      specify { expect { subject.execute(empty_callback) }.to raise_error('Hell') }
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
sidekiq-unique-jobs-5.0.2	spec/lib/sidekiq_unique_jobs/lock/until_executed_spec.rb
sidekiq-unique-jobs-5.0.1	spec/lib/sidekiq_unique_jobs/lock/until_executed_spec.rb
sidekiq-unique-jobs-5.0.0	spec/lib/sidekiq_unique_jobs/lock/until_executed_spec.rb
sidekiq-unique-jobs-4.0.18	spec/lib/sidekiq_unique_jobs/lock/until_executed_spec.rb