src/EventSubscriber/App/ProviderMessageEventSubscriber.php line 25

Open in your IDE?
  1. <?php
  3. namespace App\EventSubscriber\App;
  5. use App\Features\ProviderMessage\Event\ProviderMessageBaseEvent;
  6. use App\Features\ProviderMessage\Event\ProviderMessageFailedEvent;
  7. use App\Features\ProviderMessage\Event\ProviderMessageFirstSentEvent;
  8. use App\Features\ProviderMessage\Event\ProviderMessageSentEvent;
  9. use Doctrine\ORM\EntityManagerInterface;
  10. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  12. class ProviderMessageEventSubscriber implements EventSubscriberInterface
  13. {
  14.     public function __construct(private EntityManagerInterface $manager){}
  16.     public static function getSubscribedEvents(): array
  17.     {
  18.         return [
  19.             ProviderMessageSentEvent::NAME => 'notify',
  20.             ProviderMessageFirstSentEvent::NAME => 'notify',
  21.             ProviderMessageFailedEvent::NAME => 'notify',
  22.         ];
  23.     }
  25.     public function notify(ProviderMessageBaseEvent $event): void
  26.     {
  27.         $message = $event->getMessage();
  29.         if($event instanceof ProviderMessageSentEvent || $event instanceof ProviderMessageFirstSentEvent) {
  30.             $message->setLastSentAt(new \DateTime());
  32.             if($event instanceof ProviderMessageFirstSentEvent) {
  33.                 $message->setSentAt(new \DateTimeImmutable());
  34.             }
  35.         }
  37.         $this->manager->flush();
  38.     }
  39. }