src/EventSubscriber/EmailSubscriber.php line 41

  1. <?php
  3. namespace App\EventSubscriber;
  5. use App\Entity\App\Email;
  6. use App\Repository\App\EmailRepository;
  7. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  8. use Symfony\Component\Mailer\Event\FailedMessageEvent;
  9. use Symfony\Component\Mailer\Event\SentMessageEvent;
  11. class EmailSubscriber implements EventSubscriberInterface
  12. {
  13.     public function __construct(
  14.         private EmailRepository $emailRepository,
  15.     ){}
  17.     public static function getSubscribedEvents(): array
  18.     {
  19.         return [
  20.             SentMessageEvent::class => 'onEmailSent',
  21.             FailedMessageEvent::class => 'onEmailFailed',
  22.         ];
  23.     }
  25.     public function onEmailSent(SentMessageEvent $event): void
  26.     {
  27.         $message = $event->getMessage();
  28.         preg_match('/Subject: (.*)From:/sm', $message->getOriginalMessage()->toString(), $matches);
  29.         $subject = str_replace('=C3=A9?=', 'é', $matches[1]);
  31.         $email = (new Email())
  32.             ->setDate(new \DateTime())
  33.             ->setRecipients(implode(', ', array_map(fn($recipient) => $recipient->getAddress(), $message->getEnvelope()->getRecipients())))
  34.             ->setSubject($subject)
  35.             ->setStatus('sent')
  36.         ;
  38.         $this->emailRepository->save($email, true);
  39.     }
  41.     public function onEmailFailed(FailedMessageEvent $event): void
  42.     {
  43.         $message = $event->getMessage();
  44.         $error = $event->getError();
  45.         preg_match('/Subject: (.*)From:/sm', $message->toString(), $matches);
  46.         $subject = str_replace('=C3=A9?=', 'é', $matches[1]);
  47.         $recipients = preg_match('/To: (.*)Subject:/sm', $message->toString(), $matches);
  49.         $email = (new Email())
  50.             ->setDate(new \DateTime())
  51.             ->setRecipients($recipients)
  52.             ->setSubject($subject)
  53.             ->setError($error->getMessage())
  54.             ->setStatus('failed')
  55.         ;
  57.         $this->emailRepository->save($email, true);
  58.     }
  59. }