vendor/sylius/sylius/src/Sylius/Bundle/CoreBundle/CatalogPromotion/Listener/CatalogPromotionUpdateFailedMessageListener.php line 27

Open in your IDE?
  1. <?php
  3. /*
  4.  * This file is part of the Sylius package.
  5.  *
  6.  * (c) Paweł Jędrzejewski
  7.  *
  8.  * For the full copyright and license information, please view the LICENSE
  9.  * file that was distributed with this source code.
  10.  */
  12. declare(strict_types=1);
  14. namespace Sylius\Bundle\CoreBundle\CatalogPromotion\Listener;
  16. use Sylius\Component\Promotion\Event\CatalogPromotionFailed;
  17. use Sylius\Component\Promotion\Event\CatalogPromotionUpdated;
  18. use Symfony\Component\Messenger\Event\WorkerMessageFailedEvent;
  19. use Symfony\Component\Messenger\MessageBusInterface;
  21. final class CatalogPromotionUpdateFailedMessageListener
  22. {
  23.     public function __construct(private MessageBusInterface $messageBus)
  24.     {
  25.     }
  27.     public function onMessageFailed(WorkerMessageFailedEvent $event)
  28.     {
  29.         if (!$this->isWorkerMessageValid($event)) {
  30.             return;
  31.         }
  33.         $envelope = $event->getEnvelope();
  34.         $message = $envelope->getMessage();
  36.         $this->messageBus->dispatch(new CatalogPromotionFailed($message->code));
  37.     }
  39.     private function isWorkerMessageValid(WorkerMessageFailedEvent $event): bool
  40.     {
  41.         return
  42.             $event->willRetry() === false &&
  43.             $event->getEnvelope()->getMessage() instanceof CatalogPromotionUpdated
  44.         ;
  45.     }
  46. }