module Dry::Events::Publisher::InstanceMethods

def __bus__
  @__bus__ ||= self.class.new_bus
end

def process(event_id, payload = EMPTY_HASH, &)
  __bus__.process(event_id, payload, &)
end

def publish(event_id, payload = EMPTY_HASH)
  if __bus__.can_handle?(event_id)
    __bus__.publish(event_id, payload)
    self
  else
    raise UnregisteredEventError, event_id
  end
end

def register_event(event_id, payload = EMPTY_HASH)
  __bus__.events[event_id] = Event.new(event_id, payload)
  self
end

def subscribe(object_or_event_id, filter_hash = EMPTY_HASH, &block)
  if __bus__.can_handle?(object_or_event_id)
    filter = Filter.new(filter_hash)
    if block
      __bus__.subscribe(object_or_event_id, filter, &block)
    else
      __bus__.attach(object_or_event_id, filter)
    end
    self
  else
    raise InvalidSubscriberError, object_or_event_id
  end
end

def subscribed?(listener)
  __bus__.subscribed?(listener)
end

def unsubscribe(listener)
  __bus__.detach(listener)
end