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
  end
end