src/V4/EventSubscriber/Sentry/CommandMonitoringEventSubscriber.php line 41

Open in your IDE?
  1. <?php
  3. namespace App\V4\EventSubscriber\Sentry;
  5. use App\Command\SentryMonitoringAwareInterface;
  6. use App\V4\Logger\SentryMonitoring;
  7. use Symfony\Component\Console\Command\Command;
  8. use Symfony\Component\Console\ConsoleEvents;
  9. use Symfony\Component\Console\Event\ConsoleCommandEvent;
  10. use Symfony\Component\Console\Event\ConsoleErrorEvent;
  11. use Symfony\Component\Console\Event\ConsoleTerminateEvent;
  12. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  14. class CommandMonitoringEventSubscriber implements EventSubscriberInterface
  15. {
  16.     /**
  17.      * @var SentryMonitoring
  18.      */
  19.     private $sentryMonitoring;
  20.     private $checkInId = 'missing-check-in-id';
  22.     public function __construct(SentryMonitoring $sentryMonitoring)
  23.     {
  24.         $this->sentryMonitoring = $sentryMonitoring;
  25.     }
  27.     public static function getSubscribedEvents(): array
  28.     {
  29.         return [
  30.             ConsoleEvents::COMMAND => 'notifyBegin',
  31.             ConsoleEvents::ERROR => 'notifyError',
  32.             ConsoleEvents::TERMINATE => 'notifyFinish',
  33.         ];
  34.     }
  36.     public function supports(?Command $command): bool
  37.     {
  38.         return $command instanceof SentryMonitoringAwareInterface;
  39.     }
  41.     public function notifyBegin(ConsoleCommandEvent $event): void
  42.     {
  43.         /** @var SentryMonitoringAwareInterface&Command $command */
  44.         $command = $event->getCommand();
  45.         if (!$this->supports($command)) {
  46.             return;
  47.         }
  49.         $this->checkInId = $this
  50.             ->sentryMonitoring
  51.             ->notifyCronInProgress($command->getMonitorSlug());
  52.     }
  54.     public function notifyError(ConsoleErrorEvent $event): void
  55.     {
  56.         /** @var SentryMonitoringAwareInterface&Command $command */
  57.         $command = $event->getCommand();
  58.         if (!$this->supports($command)) {
  59.             return;
  60.         }
  62.         $this
  63.             ->sentryMonitoring
  64.             ->notifyCronFailed($command->getMonitorSlug(), $this->checkInId);
  65.     }
  67.     public function notifyFinish(ConsoleTerminateEvent $event): void
  68.     {
  69.         /** @var SentryMonitoringAwareInterface&Command $command */
  70.         $command = $event->getCommand();
  71.         if (!$this->supports($command)) {
  72.             return;
  73.         }
  75.         $this
  76.             ->sentryMonitoring
  77.             ->notifyCronFinished($command->getMonitorSlug(), $this->checkInId);
  78.     }
  79. }