spec/subscription_spec.rb in sidekiq-bus-0.8.1 vs spec/subscription_spec.rb in sidekiq-bus-0.8.2

- old
+ new

@@ -1,53 +1,54 @@ +# frozen_string_literal: true + require 'spec_helper' module QueueBus describe Subscription do - it "should normalize the queue name" do - expect(Subscription.new("test", "my_event", "MyClass", {}, nil).queue_name).to eq("test") - expect(Subscription.new("tes t", "my_event", "MyClass", {}, nil).queue_name).to eq("tes_t") - expect(Subscription.new("t%s", "my_event", "MyClass", {}, nil).queue_name).to eq("t_s") + it 'should normalize the queue name' do + expect(Subscription.new('test', 'my_event', 'MyClass', {}, nil).queue_name).to eq('test') + expect(Subscription.new('tes t', 'my_event', 'MyClass', {}, nil).queue_name).to eq('tes_t') + expect(Subscription.new('t%s', 'my_event', 'MyClass', {}, nil).queue_name).to eq('t_s') end - - describe ".register" do - it "should take in args from dispatcher" do - executor = Proc.new { |attributes| } - sub = Subscription.register("queue_name", "mykey", "MyClass", {"bus_event_type" => "my_event"}, executor) + + describe '.register' do + it 'should take in args from dispatcher' do + executor = proc { |attributes| } + sub = Subscription.register('queue_name', 'mykey', 'MyClass', { 'bus_event_type' => 'my_event' }, executor) expect(sub.send(:executor)).to eq(executor) - expect(sub.matcher.filters).to eq({"bus_event_type" => "my_event"}) - expect(sub.queue_name).to eq("queue_name") - expect(sub.key).to eq("mykey") - expect(sub.class_name).to eq("MyClass") + expect(sub.matcher.filters).to eq('bus_event_type' => 'my_event') + expect(sub.queue_name).to eq('queue_name') + expect(sub.key).to eq('mykey') + expect(sub.class_name).to eq('MyClass') end end - - describe "#execute!" do - it "should call the executor with the attributes" do + + describe '#execute!' do + it 'should call the executor with the attributes' do exec = Object.new expect(exec).to receive(:call) - - sub = Subscription.new("x", "y", "ClassName", {}, exec) - sub.execute!({"ok" => true}) + + sub = Subscription.new('x', 'y', 'ClassName', {}, exec) + sub.execute!('ok' => true) end end - - describe "#to_redis" do - it "should return what to store for this subscription" do - sub = Subscription.new("queue_one", "xyz", "ClassName", {"bus_event_type" => "my_event"}, nil) - expect(sub.to_redis).to eq({"queue_name" => "queue_one", "key" => "xyz", "class" => "ClassName", "matcher" => {"bus_event_type" => "my_event"}}) + + describe '#to_redis' do + it 'should return what to store for this subscription' do + sub = Subscription.new('queue_one', 'xyz', 'ClassName', { 'bus_event_type' => 'my_event' }, nil) + expect(sub.to_redis).to eq('queue_name' => 'queue_one', 'key' => 'xyz', 'class' => 'ClassName', 'matcher' => { 'bus_event_type' => 'my_event' }) end end - - describe "#matches?" do - it "should do pattern stuff" do - expect(Subscription.new("x", "id", "ClassName", {"bus_event_type" => "one"}).matches?("bus_event_type" => "one")).to eq(true) - expect(Subscription.new("x", "id", "ClassName", {"bus_event_type" => "one"}).matches?("bus_event_type" => "onex")).to eq(false) - expect(Subscription.new("x", "id", "ClassName", {"bus_event_type" => "^one.*$"}).matches?("bus_event_type" => "onex")).to eq(true) - expect(Subscription.new("x", "id", "ClassName", {"bus_event_type" => "one.*"}).matches?("bus_event_type" => "onex")).to eq(true) - expect(Subscription.new("x", "id", "ClassName", {"bus_event_type" => "one.?"}).matches?("bus_event_type" => "onex")).to eq(true) - expect(Subscription.new("x", "id", "ClassName", {"bus_event_type" => "one.?"}).matches?("bus_event_type" => "one")).to eq(true) - expect(Subscription.new("x", "id", "ClassName", {"bus_event_type" => "\\"}).matches?("bus_event_type" => "one")).to eq(false) + + describe '#matches?' do + it 'should do pattern stuff' do + expect(Subscription.new('x', 'id', 'ClassName', 'bus_event_type' => 'one').matches?('bus_event_type' => 'one')).to eq(true) + expect(Subscription.new('x', 'id', 'ClassName', 'bus_event_type' => 'one').matches?('bus_event_type' => 'onex')).to eq(false) + expect(Subscription.new('x', 'id', 'ClassName', 'bus_event_type' => '^one.*$').matches?('bus_event_type' => 'onex')).to eq(true) + expect(Subscription.new('x', 'id', 'ClassName', 'bus_event_type' => 'one.*').matches?('bus_event_type' => 'onex')).to eq(true) + expect(Subscription.new('x', 'id', 'ClassName', 'bus_event_type' => 'one.?').matches?('bus_event_type' => 'onex')).to eq(true) + expect(Subscription.new('x', 'id', 'ClassName', 'bus_event_type' => 'one.?').matches?('bus_event_type' => 'one')).to eq(true) + expect(Subscription.new('x', 'id', 'ClassName', 'bus_event_type' => '\\').matches?('bus_event_type' => 'one')).to eq(false) end end - end -end \ No newline at end of file +end