vendor/dvdw/auto-email/src/Content/Product/Subscriber/ProductSubscriber.php line 27

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Dvdw\AutoEmail\Content\Product\Subscriber;
  5. use Dvdw\AutoEmail\Content\Product\Message\ProductInsertedMessage;
  6. use Shopware\Core\Content\Product\ProductEvents;
  7. use Shopware\Core\Defaults;
  8. use Shopware\Core\Framework\DataAbstractionLayer\EntityWriteResult;
  9. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  10. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  11. use Symfony\Component\Messenger\MessageBusInterface;
  13. class ProductSubscriber implements EventSubscriberInterface
  14. {
  15.     private MessageBusInterface $bus;
  17.     public function __construct(MessageBusInterface $bus)
  18.     {
  19.         $this->bus = $bus;
  20.     }
  21.     
  22.     public static function getSubscribedEvents(): iterable
  23.     {
  24.         return [ProductEvents::PRODUCT_WRITTEN_EVENT => 'onProductWritten'];
  25.     }
  27.     public function onProductWritten(EntityWrittenEvent $event): void
  28.     {
  29.         $context = $event->getContext();
  31.         if ($context->getVersionId() !== Defaults::LIVE_VERSION) {
  32.             return;
  33.         }
  35.         foreach ($event->getWriteResults() as $writeResult) {
  36.             if ($writeResult->getOperation() !== EntityWriteResult::OPERATION_INSERT) {
  37.                 continue;
  38.             }
  40.             $id = $writeResult->getPrimaryKey();
  42.             if (is_array($id)) {
  43.                 $id = reset($id);
  44.             }
  46.             $this->bus->dispatch(new ProductInsertedMessage($id, $context));
  47.         }
  48.     }
  49. }