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

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