# frozen_string_literal: true

RSpec.shared_examples 'an event which synchronously dispatches' do |*dispatcher_klasses|
  specify do
    reactors = Eventsimple::EventDispatcher.rules.for(described_class.new)

    # Order is important here since the synchronous reactors are executed sequentially
    expect(reactors.sync & dispatcher_klasses).to eq(dispatcher_klasses)
  end
end

RSpec.shared_examples 'an event which asynchronously dispatches' do |*dispatcher_klasses|
  specify do
    reactors = Eventsimple::EventDispatcher.rules.for(described_class.new)

    # Order is _not_ important here since async reactors have no order guarantee
    expect(reactors.async).to include(*dispatcher_klasses)
  end
end

RSpec.shared_examples 'an event in invalid state' do
  it 'raises an InvalidTransition error' do
    expect { event.save }.to raise_error(Eventsimple::InvalidTransition).and not_change(
      event.class, :count
    )
  end
end

RSpec.shared_examples 'an event in invalid state that is rescued' do
  context 'when save' do
    it 'does not InvalidTransition error on save' do
      expect { event.save }.not_to raise_error
    end

    it 'does not write event on save' do
      expect { event.save }.not_to change(event.class, :count)
    end
  end

  context 'when save!' do
    it 'does not InvalidTransition error on save!' do
      expect { event.save! }.not_to raise_error
    end

    it 'does not write event on save!' do
      expect { event.save! }.not_to change(event.class, :count)
    end
  end
end

RSpec::Matchers.define_negated_matcher(:not_change, :change)