function UniqueFieldValueValidator::validate

File

core/lib/Drupal/Core/Validation/Plugin/Validation/Constraint/UniqueFieldValueValidator.php, line 41

Class

UniqueFieldValueValidator

Validates that a field is unique for the given entity type.

Namespace

Code

public function validate($items, Constraint $constraint) {
    if (!$items->first()) {
        return;
    }
    
    /** @var \Drupal\Core\Entity\EntityInterface $entity */
    $entity = $items->getEntity();
    $entity_type = $entity->getEntityType();
    $entity_type_id = $entity_type->id();
    $entity_label = $entity->getEntityType()
        ->getSingularLabel();
    $field_name = $items->getFieldDefinition()
        ->getName();
    $field_label = $items->getFieldDefinition()
        ->getLabel();
    $field_storage_definitions = $this->entityFieldManager
        ->getFieldStorageDefinitions($entity_type_id);
    $property_name = $field_storage_definitions[$field_name]->getMainPropertyName();
    $id_key = $entity_type->getKey('id');
    $is_multiple = $field_storage_definitions[$field_name]->isMultiple();
    $is_new = $entity->isNew();
    $item_values = array_column($items->getValue(), $property_name);
    // Check if any item values for this field already exist in other entities.
    $query = $this->entityTypeManager
        ->getStorage($entity_type_id)
        ->getAggregateQuery()
        ->accessCheck(FALSE)
        ->groupBy("{$field_name}.{$property_name}");
    if (!$is_new) {
        $entity_id = $entity->id();
        $query->condition($id_key, $entity_id, '<>');
    }
    if ($constraint->caseSensitive) {
        $query->condition($field_name, $item_values, 'IN');
    }
    else {
        $or_group = $query->orConditionGroup();
        foreach ($item_values as $item_value) {
            $or_group->condition($field_name, \Drupal::database()->escapeLike($item_value), 'LIKE');
        }
        $query->condition($or_group);
    }
    $results = $query->execute();
    if (!empty($results)) {
        // The results array is a single-column multidimensional array. The
        // column key includes the field name but may or may not include the
        // property name. Pop the column key from the first result to be sure.
        $column_key = key(reset($results));
        $other_entity_values = array_column($results, $column_key);
        // If our entity duplicates field values in any other entity, the query
        // will return all field values that belong to those entities. Narrow
        // down to only the specific duplicate values.
        $duplicate_values = $this->caseInsensitiveArrayIntersect($item_values, $other_entity_values);
        foreach ($duplicate_values as $delta => $dupe) {
            $violation = $this->context
                ->buildViolation($constraint->message)
                ->setParameter('@entity_type', $entity_label)
                ->setParameter('@field_name', $field_label)
                ->setParameter('%value', $dupe);
            if ($is_multiple) {
                $violation->atPath((string) $delta);
            }
            $violation->addViolation();
        }
    }
    // Check if items are duplicated within this entity.
    if ($is_multiple) {
        $duplicate_values = $this->extractDuplicates($item_values);
        foreach ($duplicate_values as $delta => $dupe) {
            $this->context
                ->buildViolation($constraint->message)
                ->setParameter('@entity_type', $entity_label)
                ->setParameter('@field_name', $field_label)
                ->setParameter('%value', $dupe)
                ->atPath((string) $delta)
                ->addViolation();
        }
    }
}