require_relative 'spec_helper.rb'

def publish_and_consume_once(queue_name="test_sink", data="data")
  amqp do
    q = MQ.queue(queue_name)
    q.subscribe do |hdr, msg|
      hdr.should be_an MQ::Header
      msg.should == data
      done {q.unsubscribe; q.delete}
    end
    EM.add_timer(0.2) do
      MQ.queue(queue_name).publish data
    end
  end
end

describe RSPEC do
  it 'should work as normal without AMQP-Spec' do
    1.should == 1
  end
end

describe 'Evented AMQP specs' do
  describe AMQP, " when testing with AMQP::SpecHelper" do
    include AMQP::SpecHelper

    default_options AMQP_OPTS if defined? AMQP_OPTS
    default_timeout 1 # Can be used to set default :spec_timeout for all your amqp-based specs

    puts "Default timeout: #{default_timeout.inspect}, Default options:"
    p default_options

    it_should_behave_like 'SpecHelper examples'

    context 'inside embedded context / example group' do

      it_should_behave_like 'SpecHelper examples'
    end
  end

  describe AMQP, " when testing with AMQP::Spec" do
    include AMQP::Spec
    it_should_behave_like 'Spec examples'

    context 'inside embedded context / example group' do
      it_should_behave_like 'Spec examples'
    end
  end

  describe AMQP, " tested with AMQP::SpecHelper when Rspec failures occur" do
    include AMQP::SpecHelper

    it "bubbles failing expectations up to Rspec" do
      expect {
        amqp do
          :this.should == :fail
        end
      }.to raise_error RSPEC::Expectations::ExpectationNotMetError
      AMQP.conn.should == nil
    end

    it "should NOT ignore failing expectations after 'done'" do
      expect {
        amqp do
          done
          :this.should == :fail
        end
      }.to raise_error RSPEC::Expectations::ExpectationNotMetError
      AMQP.conn.should == nil
    end

    it "should properly close AMQP connection after Rspec failures" do
      AMQP.conn.should == nil
    end
  end

  describe 'MQ', " when MQ.queue/fanout/topic tries to access Thread.current[:mq] across examples" do
    include AMQP::SpecHelper

    it 'sends data to the queue' do
      publish_and_consume_once
    end

    it 'does not hang sending data to the same queue, again' do
      publish_and_consume_once
    end

    it 'cleans Thread.current[:mq] after pubsub examples' do
      Thread.current[:mq].should be_nil
    end
  end
end

describe RSPEC, " when running an example group after another group that uses AMQP-Spec " do
  it "should work normally" do
    :does_not_hang.should_not be_false
  end
end