Contents

require 'spec_helper'

module RabbitFeed
  describe Producer do
    describe '.publish' do
      let(:event_name) { 'event_name' }
      before do
        allow(RabbitFeed::ProducerConnection).to receive(:publish)
        EventDefinitions do
          define_event('event_name', version: '1.0.0') do
            defined_as do
              'The definition of the event'
            end
            payload_contains do
              field('field', type: 'string', definition: 'The definition of the field')
            end
          end
        end
      end
      subject{ RabbitFeed::Producer.publish_event event_name, { 'field' => 'value' } }

      context 'when event definitions are not set' do
        before{ RabbitFeed::Producer.event_definitions = nil }

        it 'raises an error' do
          expect{ subject }.to raise_error Error
        end
      end

      context 'when no event definition is found' do
        let(:event_name) { 'different event name' }

        it 'raises an error' do
          expect{ subject }.to raise_error Error
        end
      end

      it 'returns the event' do
        expect(subject).to be_a Event
      end

      it 'serializes the event and provides message metadata' do
        Timecop.freeze do
          expect(ProducerConnection).to receive(:publish).with(
            an_instance_of(String),
            {
              routing_key: 'test.rabbit_feed.event_name',
              type:        'event_name',
              app_id:      'rabbit_feed',
              timestamp:   Time.now.utc.to_i,
            })
          subject
        end
      end
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
rabbit_feed-1.0.2	spec/lib/rabbit_feed/producer_spec.rb
rabbit_feed-1.0.1	spec/lib/rabbit_feed/producer_spec.rb
rabbit_feed-1.0.0	spec/lib/rabbit_feed/producer_spec.rb