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. }