# frozen_string_literal: true

require 'spec_helper'

module QueueBus
  describe SubscriptionList do
    describe '.from_redis' do
      let(:mult) do
        { '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' } } }
      end

      it 'should return from attributes' do
        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

      it 'raises an error if a subscription key already exists' do
        mult['event_two']['key'] = 'event_one'

        expect { SubscriptionList.from_redis(mult) }
          .to raise_error(RuntimeError)
      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

    context "when modifying the subscription" do
      let(:list) { SubscriptionList.new }
      let(:subscription_1) { Subscription.new("default", "key1", "MyClass", {"bus_event_type" => "event_one"}) }
      let(:subscription_2) { Subscription.new("else_ok", "key2", "MyClass", {"bus_event_type" => "event_two"}) }

      context "when adding subscriptions" do
        it "adds the subscription successfully" do
          list.add(subscription_1)
          list.add(subscription_2)

          expect(list.to_redis).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

        it "errors if the subscription already exists" do
          list.add(subscription_1)

          expect { list.add(subscription_1) }.to raise_exception(RuntimeError, /Duplicate key/)
        end
      end
    end
  end
end