vendor/ibexa/search/src/lib/EventDispatcher/EventListener/ContentSuggestionSubscriber.php line 48

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\Search\EventDispatcher\EventListener;
  11. use Ibexa\Contracts\Core\Repository\Exceptions\InvalidArgumentException;
  12. use Ibexa\Contracts\Core\Repository\Values\Content\Query;
  13. use Ibexa\Contracts\Search\Event\BuildSuggestionCollectionEvent;
  14. use Ibexa\Contracts\Search\Mapper\SearchHitToContentSuggestionMapperInterface;
  15. use Ibexa\Contracts\Search\SortingDefinition\SortingDefinitionRegistryInterface;
  16. use Ibexa\Core\Repository\SiteAccessAware\SearchService;
  17. use Psr\Log\LoggerAwareInterface;
  18. use Psr\Log\LoggerAwareTrait;
  19. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  21. final class ContentSuggestionSubscriber implements EventSubscriberInterface, LoggerAwareInterface
  22. {
  23.     use LoggerAwareTrait;
  25.     private SearchService $searchService;
  27.     private SearchHitToContentSuggestionMapperInterface $contentSuggestionMapper;
  29.     private SortingDefinitionRegistryInterface $sortingDefinitionRegistry;
  31.     public function __construct(
  32.         SearchService $searchService,
  33.         SearchHitToContentSuggestionMapperInterface $contentSuggestionMapper,
  34.         SortingDefinitionRegistryInterface $sortingDefinitionRegistry
  35.     ) {
  36.         $this->searchService = $searchService;
  37.         $this->contentSuggestionMapper = $contentSuggestionMapper;
  38.         $this->sortingDefinitionRegistry = $sortingDefinitionRegistry;
  39.     }
  41.     public static function getSubscribedEvents(): array
  42.     {
  43.         return [
  44.             BuildSuggestionCollectionEvent::class => 'onBuildSuggestionCollectionEvent',
  45.         ];
  46.     }
  48.     public function onBuildSuggestionCollectionEvent(
  49.         BuildSuggestionCollectionEvent $event
  50.     ): BuildSuggestionCollectionEvent {
  51.         $query = $event->getQuery();
  53.         $value = $query->getQuery();
  54.         $limit = $query->getLimit();
  55.         $language = $query->getLanguageCode();
  57.         $query = $this->getQuery($value, $limit);
  59.         try {
  60.             $languageFilter = $language ? ['languages' => [$language]] : [];
  61.             $searchResult = $this->searchService->findContent($query, $languageFilter);
  62.             $suggestionCollection = $event->getSuggestionCollection();
  63.             foreach ($searchResult as $result) {
  64.                 $contentSuggestion = $this->contentSuggestionMapper->map($result);
  65.                 if ($contentSuggestion === null) {
  66.                     continue;
  67.                 }
  68.                 $suggestionCollection->append($contentSuggestion);
  69.             }
  71.             $suggestionCollection->increaseTotalCount($searchResult->totalCount ?? 0);
  72.         } catch (InvalidArgumentException $e) {
  73.             $this->logger->error($e);
  74.         }
  76.         return $event;
  77.     }
  79.     private function getQuery(string $value, int $limit): Query
  80.     {
  81.         $query = new Query();
  82.         $query->query = new Query\Criterion\FullText($value);
  83.         $query->limit = $limit;
  84.         $defaultSortClauses = $this->sortingDefinitionRegistry->getDefaultSortingDefinition();
  85.         if ($defaultSortClauses !== null) {
  86.             $query->sortClauses = $defaultSortClauses->getSortClauses();
  87.         }
  89.         return $query;
  90.     }
  91. }