src/Subscriber/FailedImportLogMessageSubscriber.php line 40

Open in your IDE?
  1. <?php
  3. namespace App\Subscriber;
  5. use Symfony\Component\DependencyInjection\ContainerInterface;
  6. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  7. use Symfony\Component\Mailer\Exception\TransportExceptionInterface;
  8. use Symfony\Component\Mailer\MailerInterface;
  9. use Symfony\Component\Messenger\Event\WorkerMessageFailedEvent;
  10. use Symfony\Component\Mime\Email;
  12. class FailedImportLogMessageSubscriber implements EventSubscriberInterface
  13. {
  14.   private ?object $loggerImport;
  15.   private MailerInterface $mailer;
  17.   /**
  18.    * @param ContainerInterface $container
  19.    * @param MailerInterface $mailer
  20.    */
  21.   public function __construct(ContainerInterface $container, MailerInterface $mailer){
  22.     $this->loggerImport = $container->get('monolog.logger.import');
  23.     $this->mailer = $mailer;
  24.   }
  26.   /**
  27.    * @return string[]
  28.    */
  29.   public static function getSubscribedEvents(): array
  30.   {
  31.     return [
  32.       WorkerMessageFailedEvent::class => 'onFailedMessage'
  33.     ];
  34.   }
  36.   /**
  37.    * @param WorkerMessageFailedEvent $event
  38.    * @throws TransportExceptionInterface
  39.    */
  40.   public function onFailedMessage(WorkerMessageFailedEvent $event){
  41.     $message = $event->getEnvelope()->getMessage();
  42.     $trace = $event->getThrowable()->getTraceAsString();
  43.     $this->loggerImport->error(get_class($message).'\n'.$trace);
  44.     $email = (new Email());
  45.     $email->from('noreply@kromi.fr');
  46.     $email->to('developers@kromi.fr');
  47.     $email->subject('Erreur : Kromi - Occupation : Import des logs');
  48.     $email->text(<<<TEXT
  49. Une erreur est survenue lors de l'import des logs
  50. TEXT);
  51.     $this->mailer->send($email);
  53.   }
  54. }