vendor/ibexa/elasticsearch/src/lib/DocumentMapper/EventSubscriber/UserContentDocumentMapper.php line 32

Open in your IDE?
  1. <?php
  3. /**
  4.  * @copyright Copyright (C) Ibexa AS. All rights reserved.
  5.  * @license For full copyright and license information view LICENSE file distributed with this source code.
  6.  */
  7. declare(strict_types=1);
  9. namespace Ibexa\Elasticsearch\DocumentMapper\EventSubscriber;
  11. use Ibexa\Contracts\Core\Persistence\Content as SPIContent;
  12. use Ibexa\Contracts\Core\Search\Field;
  13. use Ibexa\Contracts\Core\Search\FieldType\IdentifierField;
  14. use Ibexa\Contracts\Elasticsearch\Mapping\Event\ContentIndexCreateEvent;
  15. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  17. final class UserContentDocumentMapper implements EventSubscriberInterface
  18. {
  19.     /** @internal */
  20.     public const HASHING_ALGORITHM = 'sha256';
  22.     public static function getSubscribedEvents(): array
  23.     {
  24.         return [
  25.             ContentIndexCreateEvent::class => [
  26.                 'onContentIndexCreate',
  27.                 -100,
  28.             ],
  29.         ];
  30.     }
  32.     public function onContentIndexCreate(ContentIndexCreateEvent $event): void
  33.     {
  34.         $content = $event->getContent();
  36.         $field = $this->getUserField($content);
  37.         if ($field === null) {
  38.             return;
  39.         }
  41.         $document = $event->getDocument();
  43.         if (isset($field->value->externalData['login'])) {
  44.             $document->fields[] = new Field(
  45.                 'user_login',
  46.                 hash(self::HASHING_ALGORITHM, $field->value->externalData['login']),
  47.                 new IdentifierField()
  48.             );
  49.         }
  51.         if (isset($field->value->externalData['email'])) {
  52.             $document->fields[] = new Field(
  53.                 'user_email',
  54.                 hash(self::HASHING_ALGORITHM, $field->value->externalData['email']),
  55.                 new IdentifierField()
  56.             );
  57.         }
  58.     }
  60.     private function getUserField(SPIContent $content): ?SPIContent\Field
  61.     {
  62.         foreach ($content->fields as $field) {
  63.             if ($field->type === 'ezuser') {
  64.                 return $field;
  65.             }
  66.         }
  68.         return null;
  69.     }
  70. }