Contents

require 'wisper/sidekiq'

RSpec.describe Wisper::SidekiqBroadcaster do
  class PublisherUnderTest
    include Wisper::Publisher

    def run
      broadcast(:it_happened)
    end
  end

  class RegularSubscriberUnderTest
    def self.it_happened(*_)
    end
  end

  class CustomizedSubscriberUnderTest
    def self.it_happened
    end

    def self.sidekiq_options
      { queue: "my_queue" }
    end
  end

  let(:publisher) { PublisherUnderTest.new }

  before { Sidekiq::Testing.fake! }
  after { Sidekiq::Testing.disable! }

  describe '#broadcast' do
    it 'schedules a sidekiq job' do
      publisher.subscribe(RegularSubscriberUnderTest, async: described_class.new)

      expect { publisher.run }
        .to change(Sidekiq::Queues["default"], :size).by(1)
    end

    it 'can respect custom sidekiq_options' do
      publisher.subscribe(CustomizedSubscriberUnderTest, async: described_class.new)

      expect { publisher.run }
        .to change(Sidekiq::Queues["my_queue"], :size).by(1)
    end

    context 'when provides subscriber with args' do
      let(:subscriber) { RegularSubscriberUnderTest }
      let(:event) { 'it_happened' }
      let(:args) { [1,2,3] }

      subject(:broadcast_event) { described_class.new.broadcast(subscriber, nil, event, args) }

      it 'subscriber receives event with corrects args' do
        expect(RegularSubscriberUnderTest).to receive(event).with(*args)

        Sidekiq::Testing.inline! { broadcast_event }
      end
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
wisper-sidekiq-1.2.0	spec/wisper/sidekiq_broadcaster_spec.rb
wisper-sidekiq-1.1.0	spec/wisper/sidekiq_broadcaster_spec.rb