vendor/ibexa/taxonomy/src/lib/Search/ElasticSearch/IndexCreateSubscriber.php line 42

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\Taxonomy\Search\ElasticSearch;
  11. use Ibexa\Contracts\Core\Persistence\Content as SPIContent;
  12. use Ibexa\Contracts\Core\Persistence\Content\Handler as ContentHandler;
  13. use Ibexa\Contracts\Core\Search\Document;
  14. use Ibexa\Contracts\Elasticsearch\Mapping\Event\ContentIndexCreateEvent;
  15. use Ibexa\Contracts\Elasticsearch\Mapping\Event\LocationIndexCreateEvent;
  16. use Ibexa\Taxonomy\Search\SearchIndexDataProvider;
  17. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  19. final class IndexCreateSubscriber implements EventSubscriberInterface
  20. {
  21.     private SearchIndexDataProvider $searchIndexDataProvider;
  23.     private ContentHandler $contentHandler;
  25.     public function __construct(SearchIndexDataProvider $searchIndexDataProvider, ContentHandler $contentHandler)
  26.     {
  27.         $this->searchIndexDataProvider = $searchIndexDataProvider;
  28.         $this->contentHandler = $contentHandler;
  29.     }
  31.     /**
  32.      * @return array<string,string>
  33.      */
  34.     public static function getSubscribedEvents(): array
  35.     {
  36.         return [
  37.             ContentIndexCreateEvent::class => 'onContentIndexCreate',
  38.             LocationIndexCreateEvent::class => 'onLocationIndexCreate',
  39.         ];
  40.     }
  42.     public function onContentIndexCreate(ContentIndexCreateEvent $event): void
  43.     {
  44.         $this->appendSearchData($event->getDocument(), $event->getContent());
  45.     }
  47.     public function onLocationIndexCreate(LocationIndexCreateEvent $event): void
  48.     {
  49.         $content = $this->contentHandler->load(
  50.             $event->getLocation()->contentId
  51.         );
  53.         $this->appendSearchData($event->getDocument(), $content);
  54.     }
  56.     private function appendSearchData(Document $document, SPIContent $content): void
  57.     {
  58.         $fields = $this->searchIndexDataProvider->getSearchData($content);
  59.         foreach ($fields as $field) {
  60.             $document->fields[] = $field;
  61.         }
  62.     }
  63. }