Contents

module SandthornSequelProjection
  class EventHandler

    attr_reader :projection, :filter, :message

    def initialize(options)
      @filter = SandthornEventFilter::Filter.new
      parse_options(options)
    end

    def handle(target, event)
      if filter.match?(event)
        call_handler(target, event)
      end
    end

  private

    def parse_options(options)
      if options.is_a? Symbol
        set_method(options)
      elsif options.is_a? Hash
        method_name = options.keys.first
        set_method(method_name)
        construct_filter(options[method_name])
      end
    end

    def call_handler(target, event)
      target.send(message, event)
    end

    def construct_filter(options)
      types, event_names = extract_filter_options(options)
      @filter = @filter.extract(types: types) if types.any?
      @filter = @filter.extract(events: event_names) if types.any?
    end

    def extract_filter_options(options)
      types   = Array.wrap(options[:aggregate_type] || options[:aggregate_types])
      events  = Array.wrap(options[:event_name] || options[:event_names])
      [types, events]
    end

    def set_method(message)
      @message = message
    end
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
sandthorn_sequel_projection-0.1.0	lib/sandthorn_sequel_projection/event_handler.rb
sandthorn_sequel_projection-0.0.4	lib/sandthorn_sequel_projection/event_handler.rb
sandthorn_sequel_projection-0.0.3	lib/sandthorn_sequel_projection/event_handler.rb
sandthorn_sequel_projection-0.0.2	lib/sandthorn_sequel_projection/event_handler.rb
sandthorn_sequel_projection-0.0.1	lib/sandthorn_sequel_projection/event_handler.rb