custom/plugins/SwagEnterpriseSearchPlatform/src/Product/ProductSearchCriteriaSubscriber.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\ProductSearchCriteriaEvent;
  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 ProductSearchCriteriaSubscriber 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.             ProductSearchCriteriaEvent::class => 'onProductSearchCriteria',
  35.         ];
  36.     }
  38.     public function onProductSearchCriteria(ProductSearchCriteriaEvent $event): void
  39.     {
  40.         $criteria = $event->getCriteria();
  41.         $salesChannelContext = $event->getSalesChannelContext();
  43.         $maxSearchCount = $this->fetchLimit($salesChannelContext);
  45.         if (!$maxSearchCount) {
  46.             return;
  47.         }
  49.         $criteria->setLimit($maxSearchCount);
  50.     }
  52.     /**
  53.      * @throws \Shopware\Core\Framework\DataAbstractionLayer\Exception\InconsistentCriteriaIdsException
  54.      */
  55.     private function fetchLimit(SalesChannelContext $salesChannelContext): ?int
  56.     {
  57.         $criteria = new Criteria();
  58.         $criteria
  59.             ->setLimit(1)
  60.             ->addFilter(new EqualsFilter('salesChannelId', $salesChannelContext->getSalesChannel()->getId()))
  61.             ->addFilter(new EqualsFilter('entityName', ProductDefinition::ENTITY_NAME));
  63.         /** @var GatewayConfigurationEntity|null $configuration */
  64.         $configuration = $this->configRepository->search($criteria, $salesChannelContext->getContext())->first();
  65.         if ($configuration === null) {
  66.             throw new GatewayNotConfiguredException('Search not configured for ' . ProductDefinition::ENTITY_NAME);
  67.         }
  69.         return $configuration->getMaxSearchCount();
  70.     }
  71. }