require "honeybadger/plugin"

module Honeybadger
  module Plugins
    Plugin.register :karafka do
      requirement { defined?(::Karafka) && ::Karafka.respond_to?(:monitor) }

      execution do
        require "honeybadger/karafka"

        if Honeybadger.config[:"exceptions.enabled"]
          errors_listener = ::Honeybadger::Karafka::ErrorsListener.new
          ::Karafka.monitor.subscribe(errors_listener)
          ::Karafka.producer.monitor.subscribe(errors_listener) if ::Karafka.respond_to?(:producer)
        end

        if config.load_plugin_insights?(:karafka)
          ::Karafka.monitor.subscribe(::Honeybadger::Karafka::InsightsListener.new)
        end
      end
    end
  end
end