Class: Mongoid::Validatable::UniquenessValidator

# File 'lib/mongoid/validatable/uniqueness.rb', line 96

def create_criteria(base, document, attribute, value)
  criteria = scope(base.unscoped, document, attribute)
  field = document.fields[document.database_field_name(attribute)]

  # In the past, we were calling value.mongoize in all cases, which
  # would call Object's mongoize method. This is a problem for StringifiedSymbol,
  # because a Symbol should mongoize to a String, but calling .mongoize
  # on a Symbol mongoizes it to a Symbol.
  # Therefore, we call the field's mongoize in all cases except when the
  # field is localized, because by the time we arrive at this code, the
  # value is already in the form of { lang => translation } and calling
  # the field's mongoize will nest that further into { lang =>
  # "\{ lang => translation \}"} (assuming the field type is a string).
  # Therefore, we call Object's mongoize method so it returns the hash as
  # it is.
  mongoized = field.try(:localized?) ? value.mongoize : field.mongoize(value)
  criteria.selector.update(criterion(document, attribute, mongoized))
  criteria
end

# File 'lib/mongoid/validatable/uniqueness.rb', line 128

def criterion(document, attribute, value)
  field = document.database_field_name(attribute)

  if value && localized?(document, field)
    conditions = (value || {}).inject([]) { |acc, (k,v)| acc << { "#{field}.#{k}" => filter(v) }}
    selector = { "$or" => conditions }
  else
    selector = { field => filter(value) }
  end

  if document.persisted? && !document.embedded?
    selector.merge!(_id: { "$ne" => document._id })
  end
  selector
end

# File 'lib/mongoid/validatable/uniqueness.rb', line 154

def filter(value)
  !case_sensitive? && value ? /\A#{Regexp.escape(value.to_s)}\z/i : value
end

# File 'lib/mongoid/validatable/uniqueness.rb', line 300

def localized?(document, attribute)
  document.fields[document.database_field_name(attribute)].try(:localized?)
end

# File 'lib/mongoid/validatable/uniqueness.rb', line 169

def scope(criteria, document, _attribute)
  Array.wrap(options[:scope]).each do |item|
    name = document.database_field_name(item)
    criteria = criteria.where(item => document.attributes[name])
  end
  criteria
end

# File 'lib/mongoid/validatable/uniqueness.rb', line 201

def scope_value_changed?(document)
  Array.wrap(options[:scope]).any? do |item|
    document.send("attribute_changed?", item.to_s)
  end
end

# File 'lib/mongoid/validatable/uniqueness.rb', line 187

def skip_validation?(document)
  !document._parent || document.embedded_one?
end

# File 'lib/mongoid/validatable/uniqueness.rb', line 222

def to_validate(document, attribute, value)
  association = document.relations[attribute.to_s]
  if association && association.stores_foreign_key?
    [ association.foreign_key, value && value._id ]
  else
    [ attribute, value ]
  end
end

# File 'lib/mongoid/validatable/uniqueness.rb', line 41

def validate_each(document, attribute, value)
  with_query(document) do
    attrib, val = to_validate(document, attribute, value)
    return unless validation_required?(document, attrib)
    if document.embedded?
      validate_embedded(document, attrib, val)
    else
      validate_root(document, attrib, val)
    end
  end
end

# File 'lib/mongoid/validatable/uniqueness.rb', line 241

def validate_embedded(document, attribute, value)
  return if skip_validation?(document)
  relation = document._parent.send(document.association_name)
  criteria = create_criteria(relation, document, attribute, value)
  criteria = criteria.merge(options[:conditions].call) if options[:conditions]
  criteria = criteria.read(mode: :primary).limit(2)
  add_error(document, attribute, value) if criteria.count > 1
end

# File 'lib/mongoid/validatable/uniqueness.rb', line 260

def validate_root(document, attribute, value)
  klass = document.class

  while klass.superclass.respond_to?(:validators) && klass.superclass.validators.include?(self)
    klass = klass.superclass
  end
  criteria = create_criteria(klass, document, attribute, value)
  criteria = criteria.merge(options[:conditions].call) if options[:conditions]

  if criteria.read(mode: :primary).exists?
    add_error(document, attribute, value)
  end
end

# File 'lib/mongoid/validatable/uniqueness.rb', line 283

def validation_required?(document, attribute)
  document.new_record? ||
    document.send("attribute_changed?", attribute.to_s) ||
    scope_value_changed?(document)
end