custom/static-plugins/relewise/src/Subscriber/IntegrationSubscriber.php line 45

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Wexo\Relewise\Subscriber;
  5. use Shopware\Core\Content\Category\Event\CategoryIndexerEvent;
  6. use Shopware\Core\Content\Product\Events\ProductIndexerEvent;
  7. use Shopware\Core\Framework\Feature;
  8. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  9. use Symfony\Component\Messenger\MessageBusInterface;
  10. use Wexo\Relewise\Component\RelewiseContentMessage;
  11. use Wexo\Relewise\Component\RelewiseProductMessage;
  12. use Wexo\Relewise\Service\Model\Export\Content\ContentUpdate;
  13. use Wexo\Relewise\Service\Model\Export\Product\ProductUpdate;
  15. class IntegrationSubscriber implements EventSubscriberInterface
  16. {
  17.     /**
  18.      * @var MessageBusInterface
  19.      */
  20.     private MessageBusInterface $bus;
  22.     /**
  23.      * @param MessageBusInterface $bus
  24.      */
  25.     public function __construct(
  26.         MessageBusInterface $bus
  27.     ) {
  28.         $this->bus = $bus;
  29.     }
  31.     /**
  32.      * @return string[]
  33.      */
  34.     public static function getSubscribedEvents(): array
  35.     {
  36.         return [
  37.             ProductIndexerEvent::class => 'onProductIndexer',
  38.             CategoryIndexerEvent::class => 'onCategoryIndexer'
  39.         ];
  40.     }
  42.     /**
  43.      * @param ProductIndexerEvent $event
  44.      */
  45.     public function onProductIndexer(ProductIndexerEvent $event): void
  46.     {
  47.         if (Feature::isActive('v6.5.0.0')) {
  48.             $ids = $event->getIds();
  49.         } else {
  50.             $ids = array_merge($event->getIds(), $event->getChildrenIds(), $event->getParentIds());
  51.         }
  53.         $this->bus->dispatch(
  54.             new RelewiseProductMessage(
  55.                 new ProductUpdate(),
  56.                 array_unique($ids),
  57.                 $event->getContext()
  58.             )
  59.         );
  60.     }
  62.     /**
  63.      * @param CategoryIndexerEvent $event
  64.      */
  65.     public function onCategoryIndexer(CategoryIndexerEvent $event): void
  66.     {
  67.         $this->bus->dispatch(
  68.             new RelewiseContentMessage(
  69.                 new ContentUpdate(),
  70.                 array_unique($event->getIds()),
  71.                 $event->getContext()
  72.             )
  73.         );
  74.     }
  75. }