src/App/Subscriber/ConsoleExceptionSubscriber.php line 39

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace App\Subscriber;
  5. use App\Email\ConsoleExceptionType;
  6. use PhpAmqpLib\Exception\AMQPTimeoutException;
  7. use Sindrive\EmailSenderBundle\Service\EmailSender;
  8. use Symfony\Component\Console\ConsoleEvents;
  9. use Symfony\Component\Console\Event\ConsoleCommandEvent;
  10. use Symfony\Component\Console\Event\ConsoleErrorEvent;
  11. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  13. class ConsoleExceptionSubscriber implements EventSubscriberInterface
  14. {
  16.     private EmailSender $emailSender;
  18.     public function __construct(EmailSender $emailSender)
  19.     {
  20.         $this->emailSender = $emailSender;
  21.     }
  23.     /**
  24.      * @return array<string, array<int|string, array<int|string, int|string>|int|string>|string>
  25.      */
  26.     public static function getSubscribedEvents(): array
  27.     {
  28.         return [
  29.             ConsoleEvents::ERROR => 'onError',
  30.             ConsoleEvents::COMMAND => 'onCommand',
  31.         ];
  32.     }
  34.     public function onCommand(ConsoleCommandEvent $event): void
  35.     {
  36.         // nothing - initialize EmailSender on each command before any output
  37.     }
  39.     public function onError(ConsoleErrorEvent $event): void
  40.     {
  41.         $exception = $event->getError();
  42.         $input = $event->getInput();
  44.         if ($exception instanceof AMQPTimeoutException) {
  45.             return;
  46.         }
  48.         $subject = 'Command error';
  50.         if (null !== $event->getCommand()) {
  51.             $subject = $event->getCommand()->getName() . ' ' . $subject;
  52.         }
  54.         $body = 'Input: arguments: ' . json_encode($input->getArguments(), JSON_THROW_ON_ERROR);
  55.         $body .= ' options: ' . json_encode($input->getOptions(), JSON_THROW_ON_ERROR);
  56.         $body .= '<br/>';
  57.         $body .= '<br/>';
  58.         $body .= $exception->getMessage();
  59.         $body .= '<br/>';
  60.         $body .= $exception->getFile() . '  Line: ' . $exception->getLine();
  61.         $body .= '<br/>';
  62.         $body .= '<br/>';
  63.         $body .= $exception->getTraceAsString();
  65.         $this->emailSender->sendType(new ConsoleExceptionType($subject, $body));
  66.     }
  68. }