Sha256: 8e36ba2edcd832ede9a11f48472300d1fa2b09ba5be5be77fa4f72bffa8d90b2

Contents?: true

Size: 1.78 KB

Versions: 5

Compression:

Stored size: 1.78 KB

Contents

module Journaled::RelationChangeProtection
  def update_all(updates, force: false) # rubocop:disable Metrics/MethodLength, Metrics/AbcSize, Metrics/PerceivedComplexity
    unless force || !@klass.respond_to?(:journaled_attribute_names) || @klass.journaled_attribute_names.empty?
      conflicting_journaled_attribute_names = if updates.is_a?(Hash)
                                                @klass.journaled_attribute_names & updates.keys.map(&:to_sym)
                                              elsif updates.is_a?(String)
                                                @klass.journaled_attribute_names.select do |a|
                                                  updates.match?(/\b(?<!')#{a}(?!')\b/)
                                                end
                                              else
                                                raise "unsupported type '#{updates.class}' for 'updates'"
                                              end
      raise(<<~ERROR) if conflicting_journaled_attribute_names.present?
        .update_all aborted by Journaled::Changes due to journaled attributes:

          #{conflicting_journaled_attribute_names.join(', ')}

        Consider using .all(lock: true) or .find_each with #update to ensure journaling or invoke
         .update_all with additional arg `{ force: true }` to override and skip journaling.
      ERROR
    end
    super(updates)
  end

  def delete_all(force: false)
    if force || !@klass.respond_to?(:journaled_attribute_names) || @klass.journaled_attribute_names.empty?
      super()
    else
      raise(<<~ERROR)
        #delete_all aborted by Journaled::Changes.

        Call .destroy_all instead to ensure journaling or invoke .delete_all(force: true)
        to override and skip journaling.
      ERROR
    end
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version Path
journaled-2.4.0 lib/journaled/relation_change_protection.rb
journaled-2.3.1 lib/journaled/relation_change_protection.rb
journaled-2.3.0 lib/journaled/relation_change_protection.rb
journaled-2.2.0 lib/journaled/relation_change_protection.rb
journaled-2.1.1 lib/journaled/relation_change_protection.rb