vendor/store.shopware.com/swpasort/src/Subscriber/ProductUpdater.php line 52

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Swpa\SwpaSort\Subscriber;
  5. use Shopware\Core\Content\Product\Events\ProductIndexerEvent;
  6. use Shopware\Core\Framework\DataAbstractionLayer\EntityDefinition;
  7. use Shopware\Elasticsearch\Framework\Indexing\ElasticsearchIndexer;
  8. use Swpa\SwpaSort\Service\CatalogRepositoryInterface;
  9. use Swpa\SwpaSort\Service\Indexing\SwpaSortingMessage;
  10. use Swpa\SwpaSort\Service\SwpaSortingContextSource;
  11. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  12. use Symfony\Component\Messenger\MessageBusInterface;
  14. class ProductUpdater implements EventSubscriberInterface
  15. {
  17.     private ElasticsearchIndexer $indexer;
  19.     private EntityDefinition $definition;
  21.     private MessageBusInterface $messageBus;
  23.     private CatalogRepositoryInterface $catalogRepository;
  25.     private bool $elasticsearchEnabled;
  27.     /**
  28.      * @internal
  29.      */
  30.     public function __construct(
  31.         ElasticsearchIndexer       $indexer,
  32.         EntityDefinition           $definition,
  33.         MessageBusInterface        $messageBus,
  34.         CatalogRepositoryInterface $catalogRepository,
  35.         bool $elasticSearchEnabled
  36.     )
  37.     {
  38.         $this->indexer = $indexer;
  39.         $this->definition = $definition;
  40.         $this->messageBus = $messageBus;
  41.         $this->catalogRepository = $catalogRepository;
  42.         $this->elasticsearchEnabled = $elasticSearchEnabled;
  43.     }
  45.     public static function getSubscribedEvents()
  46.     {
  47.         return [
  48.             ProductIndexerEvent::class => ['update', -1],
  49.         ];
  50.     }
  52.     public function update(ProductIndexerEvent $event): void
  53.     {
  54.         if ($this->elasticsearchEnabled && $event->getContext()->getSource() instanceof SwpaSortingContextSource) {
  55.             $productIds = $event->getIds();
  56.             $productIds = array_unique($productIds);
  57.             $message = new SwpaSortingMessage($productIds, null);
  58.             $message->setIndexer('swpa.sort.product.indexer');
  59.             $this->messageBus->dispatch($message);
  60.             if ($children = $this->catalogRepository->fetchChildrenByProductIds($productIds)) {
  61.                 $this->indexer->updateIds($this->definition, $children);
  62.             }
  63.         }
  64.     }
  66. }