module CounterCulture

# File lib/counter_culture.rb, line 20
def self.aggregate_counter_updates
  return unless block_given?

  Thread.current[:aggregate_counter_updates] = true
  Thread.current[:aggregated_updates] = {}
  Thread.current[:primary_key_map] = {}

  result = yield

  # aggregate the updates for each target record and execute SQL queries
  Thread.current[:aggregated_updates].each do |klass, attrs|
    attrs.each do |rec_id, updates|
      update_snippets = updates.map do |operation, value|
        value = value.call if value.is_a?(Proc)
        %Q{#{operation} #{value.is_a?(String) ? "'#{value}'" : value}} unless value == 0
      end.compact

      if update_snippets.any?
        primary_key = Thread.current[:primary_key_map][klass]

        conditions =
          Array.wrap(primary_key)
              .zip(Array.wrap(rec_id))
              .to_h

        klass.where(conditions).update_all(update_snippets.join(', '))
      end
    end
  end

  result
ensure
  Thread.current[:aggregate_counter_updates] = false
  Thread.current[:aggregated_updates] = nil
  Thread.current[:primary_key_map] = nil
end

# File lib/counter_culture.rb, line 15
def self.config
  yield(self) if block_given?
  self
end

# File lib/counter_culture/configuration.rb, line 2
def self.configuration
  @configuration ||= Configuration.new
end

# File lib/counter_culture/configuration.rb, line 6
def self.configure
  yield(configuration)
end

# File lib/counter_culture/configuration.rb, line 10
def self.reset_configuration
  @configuration = Configuration.new
end

# File lib/counter_culture/configuration.rb, line 14
def self.supports_composite_keys?
  Gem::Requirement.new('>= 7.2.0').satisfied_by?(ActiveRecord.version)
end