b0VIM 7.3UTC74vagrantsqueeze-rbenv-amd64~vagrant/code/sidekiq-unique-jobs/spec/lib/sidekiq_testing_enabled_spec.rbutf-8 3210#"! UtpKad'K[CBvF Y O N   ~ N  c =  x r q : #  G ia`b91+'&%eeeeeeeeeeeeeeeeeeeeeeeeeeendend enend end end end end InlineWorker.perforend endend end end InlineWorker.perform_async('test') InlineWorker.perform_async('test') expect(TestClass).to receive(:run).once InlineWorker.sidekiq_options :unique => true, :unique_unlock_order => :never it 'if the unique is kept forever it does not allows to run the job again' do end InlineWorker.perform_async('test') InlineWorker.perform_async('test') expect(TestClass).to receive(:run).exactly(2).times InlineWorker.sidekiq_options :unique => true, :unique_unlock_order => nil it 'once the job is completed allows to run another one' do end end def self.run(x) class TestClass end end TestClass.run(x) def perform(x) include Sidekiq::Worker class InlineWorker describe 'when set to :inline!', sidekiq: :inline do end end end expect(MyWorker.jobs.size).to eq(2) MyWorker.perform_async(param) expect(MyWorker).to have_enqueued_job(param) expect(MyWorker.jobs.size).to eq(1) MyWorker.perform_async(param) expect(MyWorker.jobs.size).to eq(0) param = 'work' it "pushes duplicates messages" do context "with non-unique worker" do end end expect(UniqueWorker.jobs.first['unique_hash']).to eq(hash) expect(UniqueWorker.jobs.size).to eq(1) UniqueWorker.perform_async(param) hash = SidekiqUniqueJobs::PayloadHelper.get_payload(UniqueWorker, :working, [param]) param = 'hash' it "adds the unique_hash to the message" do end expect(UniqueWorker.jobs.size).to eq(1) UniqueWorker.perform_async(param) expect(UniqueWorker).to have_enqueued_job(param) expect(UniqueWorker.jobs.size).to eq(1) UniqueWorker.perform_async(param) expect(UniqueWorker.jobs.size).to eq(0) param = 'work' it "does not push duplicate messages" do context "with unique worker" do describe 'when set to :fake!', sidekiq: :fake dodescribe "When Sidekiq::Testing is enabled" dorequire 'rspec-sidekiq'require 'sidekiq-unique-jobs/middleware/server/unique_jobs'require 'sidekiq/scheduled'require "sidekiq-unique-jobs"require 'sidekiq/worker'require 'spec_helper'