require 'spec_helper'

describe DispatchRider::Dispatcher, :nodb => true do
  class HandleSomething < DispatchRider::Handlers::Base
    def process(params)
      throw :something if params[:do_throw_something]
    end
  end

  class HandlerThatReturnsFalse < DispatchRider::Handlers::Base
    def process(params)
      false
    end
  end

  describe "#dispatch" do
    let(:message){ DispatchRider::Message.new(:subject => "handle_something", :body => { :do_throw_something => true }) }

    describe "callbacks" do
      let(:dummy) { double(:dummy) }
      let(:storage) { DispatchRider::Callbacks::Storage.new }
      let(:message){ DispatchRider::Message.new(:subject => "handle_something", :body => { :do_throw_something => true }) }

      before do
        DispatchRider.config.stub(:callbacks) { storage }
        storage.around(:dispatch_message) do |block, message|
          begin
            dummy.before
            dummy.log(message)
            block.call
          ensure
            dummy.after
          end
        end
        subject.register('handle_something')
      end
      example do
        dummy.should_receive(:before).once
        dummy.should_receive(:after).once
        dummy.should_receive(:log).with(message).once
        catch(:something) do
          subject.dispatch(message)
        end
      end
    end

    context "when the handler provided in the message is present" do
      before :each do
        subject.register('handle_something')
      end

      it "should process the message" do
        expect { subject.dispatch(message) }.to throw_symbol(:something)
      end
    end

    context "when the handler returns false" do
      let(:message){ DispatchRider::Message.new(:subject => "handler_that_returns_false", :body => { :do_throw_something => true }) }

      before :each do
        subject.register('handler_that_returns_false')
      end

      it "should return true indicating message is good to be removed" do
        expect(subject.dispatch(message)).to be true
      end
    end
  end
end