# frozen_string_literal: true

module Gitlab
  module EventStore
    class Subscription
      attr_reader :worker, :condition, :delay

      def initialize(worker, condition, delay)
        @worker = worker
        @condition = condition
        @delay = delay
      end

      def consume_event(event)
        return unless condition_met?(event)

        if delay
          worker.perform_in(delay, event.class.name, event.data.deep_stringify_keys)
        else
          worker.perform_async(event.class.name, event.data.deep_stringify_keys)
        end

        # We rescue and track any exceptions here because we don't want to
        # impact other subscribers if one is faulty.
        # The method `condition_met?`, since it can run a block, it might encounter
        # a bug. By raising an exception here we could interrupt the publishing
        # process, preventing other subscribers from consuming the event.
      rescue StandardError => e
        Gitlab::ErrorTracking.track_and_raise_for_dev_exception(e, event_class: event.class.name, event_data: event.data)
      end

      private

      def condition_met?(event)
        return true unless condition

        condition.call(event)
      end
    end
  end
end