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

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\BooleanField;
  14. use Ibexa\Contracts\Core\Search\FieldType\IdentifierField;
  15. use Ibexa\Contracts\Elasticsearch\Mapping\Event\ContentIndexCreateEvent;
  16. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  18. final class UserContentDocumentMapper implements EventSubscriberInterface
  19. {
  20. /** @internal */
  21. public const HASHING_ALGORITHM = 'sha256';
  23. public static function getSubscribedEvents(): array
  24. {
  25. return [
  26. ContentIndexCreateEvent::class => [
  27. 'onContentIndexCreate',
  28. -100,
  29. ],
  30. ];
  31. }
  33. public function onContentIndexCreate(ContentIndexCreateEvent $event): void
  34. {
  35. $content = $event->getContent();
  37. $field = $this->getUserField($content);
  38. if ($field === null) {
  39. return;
  40. }
  42. $document = $event->getDocument();
  44. if (isset($field->value->externalData['login'])) {
  45. $document->fields[] = new Field(
  46. 'user_login',
  47. hash(self::HASHING_ALGORITHM, $field->value->externalData['login']),
  48. new IdentifierField()
  49. );
  50. }
  52. if (isset($field->value->externalData['email'])) {
  53. $document->fields[] = new Field(
  54. 'user_email',
  55. hash(self::HASHING_ALGORITHM, $field->value->externalData['email']),
  56. new IdentifierField()
  57. );
  58. }
  60. if (isset($field->value->externalData['enabled'])) {
  61. $document->fields[] = new Field(
  62. 'user_is_enabled',
  63. $field->value->externalData['enabled'],
  64. new BooleanField()
  65. );
  66. }
  67. }
  69. private function getUserField(SPIContent $content): ?SPIContent\Field
  70. {
  71. foreach ($content->fields as $field) {
  72. if ($field->type === 'ezuser') {
  73. return $field;
  74. }
  75. }
  77. return null;
  78. }
  79. }