custom/plugins/SwagEnterpriseSearchPlatform/src/Category/CategoryUpdater.php line 36

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Swag\EnterpriseSearch\Category;
  5. use Shopware\Core\Content\Category\Event\CategoryIndexerEvent;
  6. use Shopware\Core\Framework\DataAbstractionLayer\EntityDefinition;
  7. use Shopware\Elasticsearch\Framework\Indexing\ElasticsearchIndexer;
  8. use Swag\EnterpriseSearch\Common\VersionHelper;
  9. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  11. class CategoryUpdater implements EventSubscriberInterface
  12. {
  13.     /**
  14.      * @var ElasticsearchIndexer
  15.      */
  16.     private $indexer;
  18.     /**
  19.      * @var EntityDefinition
  20.      */
  21.     private $definition;
  23.     public function __construct(ElasticsearchIndexer $indexer, EntityDefinition $definition)
  24.     {
  25.         $this->indexer = $indexer;
  26.         $this->definition = $definition;
  27.     }
  29.     public static function getSubscribedEvents(): array
  30.     {
  31.         return [
  32.             CategoryIndexerEvent::class => 'update',
  33.         ];
  34.     }
  36.     public function update(CategoryIndexerEvent $event): void
  37.     {
  38.         if (VersionHelper::isShopware64X()) {
  39.             $this->indexer->updateIds(
  40.                 $this->definition,
  41.                 $event->getIds()
  42.             );
  44.             return;
  45.         }
  47.         $this->indexer->sendIndexingMessages(
  48.             $this->definition,
  49.             $event->getIds()
  50.         );
  51.     }
  52. }