src/Services/Transaction/Workflow/EventSubscriber/TransactionSubscriber.php line 41

Open in your IDE?
  1. <?php
  3. namespace App\Services\Transaction\Workflow\EventSubscriber;
  5. use App\Entity\Transaction;
  6. use Doctrine\ORM\EntityManager;
  7. use Doctrine\ORM\EntityManagerInterface;
  8. use Psr\Log\LoggerInterface;
  9. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  10. use Symfony\Component\Workflow\Event\Event;
  11. use Exception;
  13. class TransactionSubscriber implements EventSubscriberInterface
  14. {
  15.     /**
  16.      * @var EntityManager
  17.      */
  18.     protected $em;
  20.     /**
  21.      * @var LoggerInterface
  22.      */
  23.     private $logger;
  25.     public function __construct(
  26.         EntityManagerInterface $entityManager,
  27.         LoggerInterface $logger
  28.     ) {
  29.         $this->em = $entityManager;
  30.         $this->logger = $logger;
  31.     }
  33.     public static function getSubscribedEvents(): array
  34.     {
  35.         return [
  36.             // announce is the event that is fired AFTER all subscribers we use in the system
  37.             'workflow.completed' => 'notifyTransactionStatusChange',
  38.         ];
  39.     }
  41.     public function notifyTransactionStatusChange(Event $event)
  42.     {
  43.         $trxEntity = $event->getSubject()->getEntity();
  44.         if (!$trxEntity instanceof Transaction) {
  45.             return;
  46.         }
  48.         try {
  49.             $this->em->flush($trxEntity);
  50.         } catch (Exception $e) {
  51.             $this->logger->error($e->getMessage());
  52.         }
  53.     }
  54. }