custom/plugins/SwagEnterpriseSearchPlatform/src/Manufacturer/ManufacturerUpdater.php line 37

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Swag\EnterpriseSearch\Manufacturer;
  5. use Shopware\Core\Content\Product\Aggregate\ProductManufacturer\ProductManufacturerDefinition;
  6. use Shopware\Core\Framework\DataAbstractionLayer\EntityDefinition;
  7. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  8. use Shopware\Elasticsearch\Framework\Indexing\ElasticsearchIndexer;
  9. use Swag\EnterpriseSearch\Common\VersionHelper;
  10. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  12. class ManufacturerUpdater implements EventSubscriberInterface
  13. {
  14.     /**
  15.      * @var ElasticsearchIndexer
  16.      */
  17.     private $indexer;
  19.     /**
  20.      * @var EntityDefinition
  21.      */
  22.     private $definition;
  24.     public function __construct(ElasticsearchIndexer $indexer, EntityDefinition $definition)
  25.     {
  26.         $this->indexer = $indexer;
  27.         $this->definition = $definition;
  28.     }
  30.     public static function getSubscribedEvents(): array
  31.     {
  32.         return [
  33.             ProductManufacturerDefinition::ENTITY_NAME . '.written' => 'update',
  34.         ];
  35.     }
  37.     public function update(EntityWrittenEvent $event): void
  38.     {
  39.         if (VersionHelper::isShopware64X()) {
  40.             $this->indexer->updateIds(
  41.                 $this->definition,
  42.                 $event->getIds()
  43.             );
  45.             return;
  46.         }
  48.         $this->indexer->sendIndexingMessages(
  49.             $this->definition,
  50.             $event->getIds()
  51.         );
  52.     }
  53. }