vendor/dukecity/command-scheduler-bundle/EventSubscriber/SchedulerCommandSubscriber.php line 53

Open in your IDE?
  1. <?php
  3. namespace Dukecity\CommandSchedulerBundle\EventSubscriber;
  5. use Doctrine\ORM\EntityManagerInterface;
  6. use JetBrains\PhpStorm\ArrayShape;
  7. use Dukecity\CommandSchedulerBundle\Event\SchedulerCommandCreatedEvent;
  8. use Dukecity\CommandSchedulerBundle\Event\SchedulerCommandPostExecutionEvent;
  9. use Dukecity\CommandSchedulerBundle\Event\SchedulerCommandFailedEvent;
  10. use Dukecity\CommandSchedulerBundle\Event\SchedulerCommandPreExecutionEvent;
  11. use Dukecity\CommandSchedulerBundle\Notification\CronMonitorNotification;
  12. use Psr\Log\LoggerInterface;
  13. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  14. use Symfony\Component\Notifier\NotifierInterface;
  15. use Symfony\Component\Notifier\Recipient\Recipient;
  17. class SchedulerCommandSubscriber implements EventSubscriberInterface
  18. {
  19.     protected LoggerInterface $logger;
  20.     protected EntityManagerInterface $em;
  21.     protected NotifierInterface|null $notifier;
  23.     /**
  24.      * TODO check if parameters needed
  25.      */
  26.     public function __construct(LoggerInterface $logger, EntityManagerInterface $em, NotifierInterface|null $notifier = null, private array $monitor_mail = [], private string $monitor_mail_subject = 'CronMonitor:')
  27.     {
  28.         $this->logger = $logger;
  29.         $this->em = $em;
  30.         $this->notifier = $notifier;
  31.     }
  33.     /**
  34.      * {@inheritdoc}
  35.      */
  36.     #[ArrayShape([
  37.         SchedulerCommandCreatedEvent::class => 'array',
  38.         SchedulerCommandFailedEvent::class => 'array',
  39.         SchedulerCommandPreExecutionEvent::class => 'array',
  40.         SchedulerCommandPostExecutionEvent::class => 'array',
  41.     ])]
  42.     public static function getSubscribedEvents(): array
  43.     {
  44.         return [
  45.             SchedulerCommandCreatedEvent::class => ['onScheduledCommandCreated',    -10],
  46.             SchedulerCommandFailedEvent::class => ['onScheduledCommandFailed',     20],
  47.             SchedulerCommandPreExecutionEvent::class => ['onScheduledCommandPreExecution',   10],
  48.             SchedulerCommandPostExecutionEvent::class => ['onScheduledCommandPostExecution',   30],
  49.         ];
  50.     }
  52.     // TODO check if useful (could be handled by doctrine lifecycle events)
  53.     public function onScheduledCommandCreated(SchedulerCommandCreatedEvent $event)
  54.     {
  55.         $this->logger->info('ScheduledCommandCreated', ['name' => $event->getCommand()->getName()]);
  56.     }
  58.     public function onScheduledCommandFailed(SchedulerCommandFailedEvent $event)
  59.     {
  60.         # notifier is optional
  61.         if($this->notifier)
  62.         {
  63.             //...$this->notifier->getAdminRecipients()
  64.             $recipients = [];
  65.             foreach ($this->monitor_mail as $mailadress) {
  66.                 $recipients[] = new Recipient($mailadress);
  67.             }
  69.             $this->notifier->send(new CronMonitorNotification($event->getFailedCommands(), $this->monitor_mail_subject), ...$recipients);
  70.         }
  72.         //$this->logger->warning('SchedulerCommandFailedEvent', ['details' => $event->getMessage()]);
  73.     }
  75.     public function onScheduledCommandPreExecution(SchedulerCommandPreExecutionEvent $event)
  76.     {
  77.         #var_dump('ScheduledCommandPreExecution');
  78.         $this->logger->info('ScheduledCommandPreExecution', ['name' => $event->getCommand()->getName()]);
  79.     }
  81.     public function onScheduledCommandPostExecution(SchedulerCommandPostExecutionEvent $event)
  82.     {
  83.         #var_dump('ScheduledCommandPostExecution');
  85.         $this->logger->info('ScheduledCommandPostExecution', [
  86.             'name' => $event->getCommand()->getName(),
  87.             "result" => $event->getResult(),
  88.             #"log" => $event->getLog(),
  89.             "runtime" => $event->getRuntime()->format('%S seconds'),
  90.             #"exception" => $event->getException()?->getMessage() ?? null
  91.         ]);
  92.     }
  93. }