Contents

# frozen_string_literal: true

require 'spec_helper'

module QueueBus
  describe SubscriptionList do
    describe '.from_redis' do
      it 'should return from attributes' do
        mult = { 'event_one' => { 'class' => 'MyClass', 'queue_name' => 'default', 'key' => 'event_one', 'matcher' => { 'bus_event_type' => 'event_one' } },
                 'event_two' => { 'class' => 'MyClass', 'queue_name' => 'else', 'key' => 'event_two', 'matcher' => { 'bus_event_type' => 'event_two' } } }

        list = SubscriptionList.from_redis(mult)
        expect(list.size).to eq(2)
        one = list.key('event_one')
        two = list.key('event_two')

        expect(one.key).to eq('event_one')
        expect(one.key).to eq('event_one')
        expect(one.queue_name).to eq('default')
        expect(one.class_name).to eq('MyClass')
        expect(one.matcher.filters).to eq('bus_event_type' => 'event_one')

        expect(two.key).to eq('event_two')
        expect(two.key).to eq('event_two')
        expect(two.queue_name).to eq('else')
        expect(two.class_name).to eq('MyClass')
        expect(two.matcher.filters).to eq('bus_event_type' => 'event_two')
      end
    end

    describe '#to_redis' do
      it 'should generate what to store' do
        list = SubscriptionList.new
        list.add(Subscription.new('default', 'key1', 'MyClass', 'bus_event_type' => 'event_one'))
        list.add(Subscription.new('else_ok', 'key2', 'MyClass', 'bus_event_type' => 'event_two'))

        hash = list.to_redis
        expect(hash).to eq('key1' => { 'queue_name' => 'default', 'key' => 'key1', 'class' => 'MyClass', 'matcher' => { 'bus_event_type' => 'event_one' } },
                           'key2' => { 'queue_name' => 'else_ok', 'key' => 'key2', 'class' => 'MyClass', 'matcher' => { 'bus_event_type' => 'event_two' } })
      end
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
sidekiq-bus-0.9.0	spec/subscription_list_spec.rb
sidekiq-bus-0.8.2	spec/subscription_list_spec.rb