module Rage::Events::Subscriber

def self.included(handler_class)
  handler_class.extend ClassMethods
end

def __call(event, context: nil)
  Rage::Telemetry.tracer.span_events_subscriber_process(event:, context:, subscriber: self) do
    Rage.logger.with_context(self.class.__log_context) do
      with_exception_handler do
        context.nil? ? call(event) : call(event, context: context.freeze)
      end
    end
  end
rescue Exception => e
  Rage.logger.with_context(self.class.__log_context) do
    Rage.logger.error("Subscriber failed with exception: #{e.class} (#{e.message}):\n#{e.backtrace.join("\n")}")
  end
  raise e if self.class.__is_deferred
end

def __deferred_suppress_exception_logging?
  true
end

def call(_)
end

def with_exception_handler
  yield
end