custom/plugins/SwagEnterpriseSearchPlatform/src/Product/ProductSuggestCriteriaSubscriber.php line 38

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Swag\EnterpriseSearch\Product;
  5. use Shopware\Core\Content\Product\Events\ProductSuggestCriteriaEvent;
  6. use Shopware\Core\Content\Product\ProductDefinition;
  7. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  8. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  9. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  10. use Shopware\Core\System\SalesChannel\SalesChannelContext;
  11. use Swag\EnterpriseSearch\Configuration\GatewayConfigurationEntity;
  12. use Swag\EnterpriseSearch\Configuration\GatewayNotConfiguredException;
  13. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  15. class ProductSuggestCriteriaSubscriber implements EventSubscriberInterface
  16. {
  17.     /**
  18.      * @var EntityRepositoryInterface
  19.      */
  20.     private $configRepository;
  22.     public function __construct(
  23.         EntityRepositoryInterface $configRepository
  24.     ) {
  25.         $this->configRepository = $configRepository;
  26.     }
  28.     /**
  29.      * {@inheritdoc}
  30.      */
  31.     public static function getSubscribedEvents(): array
  32.     {
  33.         return [
  34.             ProductSuggestCriteriaEvent::class => 'onProductSuggestCriteria',
  35.         ];
  36.     }
  38.     public function onProductSuggestCriteria(ProductSuggestCriteriaEvent $event): void
  39.     {
  40.         $criteria = $event->getCriteria();
  41.         $salesChannelContext = $event->getSalesChannelContext();
  43.         $machSuggestCount = $this->fetchLimit($salesChannelContext);
  45.         $criteria->setLimit($machSuggestCount);
  46.     }
  48.     private function fetchLimit(SalesChannelContext $salesChannelContext): int
  49.     {
  50.         $criteria = new Criteria();
  51.         $criteria
  52.             ->setLimit(1)
  53.             ->addFilter(new EqualsFilter('salesChannelId', $salesChannelContext->getSalesChannel()->getId()))
  54.             ->addFilter(new EqualsFilter('entityName', ProductDefinition::ENTITY_NAME));
  56.         /** @var GatewayConfigurationEntity|null $configuration */
  57.         $configuration = $this->configRepository->search($criteria, $salesChannelContext->getContext())->first();
  58.         if ($configuration === null) {
  59.             throw new GatewayNotConfiguredException('Search not configured for ' . ProductDefinition::ENTITY_NAME);
  60.         }
  62.         return $configuration->getMaxSuggestCount();
  63.     }
  64. }