# frozen_string_literal: true

# Invoked by CounterAttribute concern when incrementing counter
# attributes. The method `flush_increments_to_database!` that
# this worker uses is itself idempotent as it runs with exclusive
# lease to ensure that only one instance at the time can flush
# increments from Redis to the database.
class FlushCounterIncrementsWorker
  include ApplicationWorker

  data_consistency :always

  sidekiq_options retry: 3
  loggable_arguments 0, 2

  # The increments in `ProjectStatistics` are owned by several teams depending
  # on the counter
  feature_category :not_owned # rubocop:disable Gitlab/AvoidFeatureCategoryNotOwned

  urgency :low
  deduplicate :until_executing, including_scheduled: true

  idempotent!

  def perform(model_name, model_id, attribute)
    return unless self.class.const_defined?(model_name)

    model_class = model_name.constantize
    model = model_class.find_by_id(model_id)
    return unless model

    model.flush_increments_to_database!(attribute)
  end
end