vendor/crehler/advanced-sort/src/Subscriber/CategorySubscriber.php line 40

Open in your IDE?
  1. <?php
  2. declare(strict_types=1);
  3. /**
  4.  * @copyright 2023 Crehler Sp. z o.o.
  5.  *
  6.  * https://crehler.com/
  7.  * support@crehler.com
  8.  *
  9.  * For the full copyright and license information, please view the LICENSE
  10.  * file that was distributed with this source code.
  11.  */
  13. namespace Crehler\AdvancedSort\Subscriber;
  15. use Crehler\AdvancedSort\Messages\CatalogInheritanceMessage;
  16. use Crehler\AdvancedSort\Services\Indexer\CategoryItemsUpdater;
  17. use Shopware\Core\Content\Category\CategoryEvents;
  18. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  19. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  20. use Symfony\Component\Messenger\MessageBusInterface;
  22. class CategorySubscriber implements EventSubscriberInterface
  23. {
  24.     private CategoryItemsUpdater $categoryItemsUpdater;
  25.     private MessageBusInterface $messageBus;
  27.     public function __construct(CategoryItemsUpdater $categoryItemsUpdater, MessageBusInterface $messageBus)
  28.     {
  29.         $this->categoryItemsUpdater = $categoryItemsUpdater;
  30.         $this->messageBus = $messageBus;
  31.     }
  33.     public static function getSubscribedEvents(): array
  34.     {
  35.         return [
  36.             CategoryEvents::CATEGORY_WRITTEN_EVENT => 'onCategoryWrittenEvent',
  37.         ];
  38.     }
  40.     public function onCategoryWrittenEvent(EntityWrittenEvent $event): void
  41.     {
  42.         $categories = $event->getIds();
  43.         foreach ($categories as $categoryId) {
  44.             $this->categoryItemsUpdater->handle($categoryId,  $event->getContext());
  45.         }
  46.         $message = new CatalogInheritanceMessage();
  47.         $this->messageBus->dispatch($message);
  49.     }
  51. }