# frozen_string_literal: true

require 'spec_helper'

describe Ventable do
  before do
    class TestEvent
      include Ventable::Event
    end
  end

  describe '::enabled?' do
    after { described_class.enable }

    it 'is true by default' do
      expect(described_class.enabled?).to be true
    end

    it 'is false after Ventable is disabled' do
      described_class.disable
      expect(described_class.enabled?).to be false
    end

    it 'is true after Ventable is re-enabled' do
      described_class.disable
      described_class.enable
      expect(described_class.enabled?).to be true
    end
  end

  describe 'including Ventable::Event' do
    it 'creates a class instance variable to keep observers' do
      expect(TestEvent.observers).not_to be_nil
      expect(TestEvent.observers.class.name).to eq('Set')
    end

    it 'sees observers variable from instance methods' do
      observers = nil
      TestEvent.new.instance_eval do
        observers = self.class.observers
      end
      expect(observers).not_to be_nil
    end

    it 'maintains separate sets of observers for each event' do
      class AnotherEvent
        include Ventable::Event
      end

      expect(AnotherEvent.observers.object_id).not_to eq(TestEvent.observers.object_id)
    end
  end

  describe '#fire' do
    before do
      class TestEvent
        include Ventable::Event
      end
    end

    it 'properly call a Proc observer' do
      run_block = false
      event = nil
      TestEvent.notifies do |e|
        run_block = true
        event = e
      end
      expect(run_block).to be(false)
      expect(event).to be_nil

      # fire the event
      TestEvent.new.fire!

      expect(run_block).to be true
      expect(event).not_to be_nil
    end

    describe 'class observer' do
      before do
        class TestEvent
          class << self
            attr_accessor :flag
          end

          self.flag = 'unset'

          def flag=(value)
            self.class.flag = value
          end
        end

        class TestEventObserver
          def self.handle_test(event)
            event.flag = 'boo'
          end
        end

        class GlobalObserver
          class << self
            def handle_event(event)
              puts event.inspect
            end
          end
        end

        TestEvent.notifies TestEventObserver, GlobalObserver
        expect(TestEvent.flag).to eq('unset')
        expect(GlobalObserver).to receive(:handle_event).with(event)
      end

      let(:event) { TestEvent.new }

      it 'sets the flag and call observers' do
        event.fire!
        expect(TestEvent.flag).to eq('boo')
      end

      it 'also fire via the publish alias' do
        event.publish
      end

      context 'observer without a handler' do
        before {
          class ObserverWithoutAHandler
          end

          TestEvent.notifies ObserverWithoutAHandler
        }

        it 'raises an exception' do
          expect { event.publish }.to raise_error(Ventable::Error)
        end
      end
    end

    it 'properly call a group of observers' do
      transaction_called = false
      transaction_completed = false
      transaction = ->(observer_block) {
        transaction_called = true
        observer_block.call
        transaction_completed = true
      }

      TestEvent.group :transaction, &transaction
      observer_block_called = false

      # this flag ensures that this block really runs inside
      # the transaction group block
      transaction_already_completed = false
      event_inside = nil
      TestEvent.notifies inside: :transaction do |event|
        observer_block_called = true
        transaction_already_completed = transaction_completed
        event_inside = event
      end

      expect(transaction_called).to be false
      expect(transaction_already_completed).to be false
      expect(observer_block_called).to be false

      TestEvent.new.fire!

      expect(transaction_called).to be true
      expect(observer_block_called).to be true
      expect(transaction_called).to be true
      expect(transaction_already_completed).to be false
      expect(event_inside).not_to be_nil
      expect(event_inside).to be_a(TestEvent)
    end

    context 'when globally disabled' do
      before { described_class.disable }
      after { described_class.enable }

      it 'does not notify observers' do
        observers_notified = false

        TestEvent.notifies do |_event|
          observers_notified = true
        end

        TestEvent.new.fire!
        expect(observers_notified).to be false
      end
    end
  end

  describe '#default_callback_method' do
    before do
      class SomeAwesomeEvent
        include Ventable::Event
      end

      module Blah
        class AnotherSweetEvent
          include Ventable::Event
        end
      end

      class ClassWithCustomCallbackMethodEvent
        include Ventable::Event

        def self.ventable_callback_method_name
          :handle_my_special_event
        end
      end

      module Blah
        module Foo
          class BarClosedEvent
            include Ventable::Event
          end
        end
      end
    end

    it 'properly sets the callback method on a Module-less class' do
      expect(SomeAwesomeEvent.send(:default_callback_method)).to eq(:handle_some_awesome)
    end

    it 'properly sets the callback method on a Class within a Module' do
      expect(Blah::AnotherSweetEvent.send(:default_callback_method)).to eq(:handle_blah__another_sweet)
    end

    it 'properly sets the callback method on a class with a custom default method handler name' do
      expect(ClassWithCustomCallbackMethodEvent.send(:default_callback_method)).to eq(:handle_my_special_event)
    end

    it 'properly sets the callback method on a class within a nested module' do
      expect(Blah::Foo::BarClosedEvent.send(:default_callback_method)).to eq(:handle_blah__foo__bar_closed)
    end
  end

  describe '#configure' do
    it 'properly configures the event with observers' do
      notified_observer = false
      TestEvent.configure do
        notifies do
          notified_observer = true
        end
      end
      TestEvent.new.fire!
      expect(notified_observer).to be true
    end

    it 'configures observers with groups' do
      notified_observer = false
      called_transaction = false
      TestEvent.configure do
        group :transaction, &->(b) {
          b.call
          called_transaction = true
        }
        notifies inside: :transaction do
          notified_observer = true
        end
      end
      TestEvent.new.fire!
      expect(notified_observer).to be true
      expect(called_transaction).to be true
    end

    it 'throws exception if :inside references unknown group' do
      TestEvent.configure do
        notifies inside: :transaction do
          # some stuff
        end
      end
      fail 'Shouldn\'t reach here, must throw a valid exception'
    rescue Exception => e
      expect(e.class).to eq(Ventable::Error)
    end

    it 'throws exception if nil observer added to the list' do
      TestEvent.configure do
        notifies nil
      end
      fail 'Shouldn\'t reach here, must throw a valid exception'
    rescue Exception => e
      expect(e.class).to eq(Ventable::Error)
    end
  end
end