custom/plugins/ZeobvGetNotified/src/FlowBuilder/Action/NotificationAction.php line 49

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace Zeobv\GetNotified\FlowBuilder\Action;
  7. use Shopware\Core\Content\Flow\Dispatching\Action\FlowAction;
  8. use Shopware\Core\Content\MailTemplate\Exception\MailEventConfigurationException;
  9. use Shopware\Core\Content\MailTemplate\Exception\SalesChannelNotFoundException;
  10. use Shopware\Core\Framework\DataAbstractionLayer\Exception\InconsistentCriteriaIdsException;
  11. use Shopware\Core\Framework\Event\FlowEvent;
  12. use Symfony\Component\Messenger\MessageBusInterface;
  13. use Symfony\Contracts\EventDispatcher\Event;
  14. use Zeobv\GetNotified\FlowBuilder\Aware\ProductAware;
  15. use Zeobv\GetNotified\MessageBus\Message\NotificationActionMessage;
  16. use Zeobv\GetNotified\Service\StockSubscriptionService;
  18. class NotificationAction extends FlowAction
  19. {
  20.     protected StockSubscriptionService $stockSubscriptionService;
  21.     private MessageBusInterface $messageBus;
  23.     public function __construct(
  24.         StockSubscriptionService $stockSubscriptionService,
  25.         MessageBusInterface $messageBus
  26.     ) {
  27.         $this->stockSubscriptionService = $stockSubscriptionService;
  28.         $this->messageBus = $messageBus;
  29.     }
  31.     public static function getName(): string
  32.     {
  33.         // your own action name
  34.         return 'zeobv-get-notified.action.send.notification';
  35.     }
  37.     public static function getSubscribedEvents(): array
  38.     {
  39.         return [
  40.             self::getName() => 'handle',
  41.         ];
  42.     }
  44.     public function requirements(): array
  45.     {
  46.         return [ProductAware::class];
  47.     }
  49.     public function handle(Event $event): void
  50.     {
  51.         if (!$event instanceof FlowEvent) {
  52.             return;
  53.         }
  55.         $notificationEvent = $event->getEvent();
  57.         if (!$notificationEvent instanceof ProductAware) {
  58.             throw new \Exception('Not an instance of ProductAware, instance given ' . \get_class($notificationEvent));
  59.         }
  61.         $productId = $notificationEvent->getProductId();
  63.         $this->messageBus->dispatch(new NotificationActionMessage($productId, $event->getConfig()));
  64.     }
  65. }