vendor/crehler/arrangements/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\Arrangements\Subscriber;
  16. use Crehler\Arrangements\Entity\Arrangement\Aggregate\ArrangementProduct\ArrangementProductDefinition;
  17. use Crehler\Arrangements\Message\WriteArrangementProductMessage;
  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.             'arrangement_product.written' => 'onProductWrite',
  42.         ];
  43.     }
  45.     public function onProductWrite(EntityWrittenEvent $event): void
  46.     {
  47.         $context = $event->getContext();
  48.         if ($this->crehlerContext->get(CrehlerContextService::CREHLER_PRODUCT_IMPORT_COMMAND, false)
  49.             || ($context->hasExtension('isFromMessage') && $context->getExtension('isFromMessage')->isFromMessage())) {
  50.             return;
  51.         }
  53.         $message = new WriteArrangementProductMessage();
  55.         if ($event->getEntityName() === ArrangementProductDefinition::ENTITY_NAME) {
  56.             $message->setIsArrangementProducts(true);
  57.         }
  59.         $message->withContext($context)
  60.             ->setIds($event->getIds());
  62.         $this->messageBus->dispatch($message, [new TransportConfiguration(['topic' => 'crehlerarrangements'])]);
  63.     }
  64. }