vendor/crehler/inspirations/src/Subscriber/ProductWriteSubscriber.php line 45

Open in your IDE?
  1. <?php declare(strict_types=1);
  2. /**
  3.  * @copyright 2020 Crehler Sp. z o. o. <https://crehler.com>
  4.  *
  5.  * @author    Jakub Medyński <jme@crehler.com>
  6.  * @support   Crehler <support@crehler.com>
  7.  * @created   25 wrz 2020
  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\Inspirations\Subscriber;
  16. use Crehler\Inspirations\Entity\Inspiration\Aggregate\InspirationProduct\InspirationProductDefinition;
  17. use Crehler\Inspirations\Message\WriteInspirationProductMessage;
  18. use Crehler\MojeBambinoEngine\Service\CrehlerContextService;
  19. use Enqueue\MessengerAdapter\EnvelopeItem\TransportConfiguration;
  20. use Shopware\Core\Content\Product\ProductEvents;
  21. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  22. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  23. use Symfony\Component\Messenger\MessageBusInterface;
  25. class ProductWriteSubscriber implements EventSubscriberInterface
  26. {
  27.     private MessageBusInterface $messageBus;
  29.     private CrehlerContextService $crehlerContext;
  31.     public function __construct(MessageBusInterface $messageBus, CrehlerContextService $crehlerContext)
  32.     {
  33.         $this->messageBus = $messageBus;
  34.         $this->crehlerContext = $crehlerContext;
  35.     }
  37.     public static function getSubscribedEvents(): array
  38.     {
  39.         return [
  40.             ProductEvents::PRODUCT_WRITTEN_EVENT => 'onProductWrite',
  41.             'inspiration_product.written' => 'onProductWrite'
  42.         ];
  43.     }
  45.     public function onProductWrite(EntityWrittenEvent $event): void
  46.     {
  47.         $context = $event->getContext();
  49.         if ($this->crehlerContext->get(CrehlerContextService::CREHLER_PRODUCT_IMPORT_COMMAND, false)
  50.             || ($context->hasExtension('isFromMessage') && $context->getExtension('isFromMessage')->isFromMessage())) {
  51.             return;
  52.         }
  54.         $message = new WriteInspirationProductMessage();
  56.         if ($event->getEntityName() === InspirationProductDefinition::ENTITY_NAME) {
  57.             $message->setIsInspirationProducts(true);
  58.         }
  60.         $message->withContext($context)
  61.             ->setIds($event->getIds());
  63.         $this->messageBus->dispatch($message, [new TransportConfiguration(['topic' => 'crehlerinspirations'])]);
  64.     }
  65. }