src/CronBundle/EventSubscriber/CronScheduleEventSubscriber.php line 67

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. /*
  6.  * This file is part of SolidInvoice project.
  7.  *
  8.  * (c) Pierre du Plessis <[email protected]>
  9.  *
  10.  * This source file is subject to the MIT license that is bundled
  11.  * with this source code in the file LICENSE.
  12.  */
  14. namespace SolidInvoice\CronBundle\EventSubscriber;
  16. use Sentry\CheckInStatus;
  17. use Sentry\MonitorConfig;
  18. use Sentry\MonitorSchedule;
  19. use Sentry\MonitorScheduleUnit;
  20. use Sentry\State\Scope;
  21. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  22. use Zenstruck\ScheduleBundle\Event\AfterScheduleEvent;
  23. use Zenstruck\ScheduleBundle\Event\BeforeScheduleEvent;
  24. use function date_default_timezone_get;
  25. use function Sentry\captureCheckIn;
  26. use function Sentry\configureScope;
  28. final class CronScheduleEventSubscriber implements EventSubscriberInterface
  29. {
  30.     private const MONITOR_SLUG = 'cron-schedule';
  32.     private ?string $checkInId = null;
  34.     public static function getSubscribedEvents(): array
  35.     {
  36.         return [
  37.             BeforeScheduleEvent::class => 'beforeSchedule',
  38.             AfterScheduleEvent::class => 'afterSchedule',
  39.         ];
  40.     }
  42.     public function beforeSchedule(BeforeScheduleEvent $event): void
  43.     {
  44.         configureScope(function (Scope $scope): void {
  45.             $scope->setContext('monitor', [
  46.                 'slug' => self::MONITOR_SLUG,
  47.             ]);
  48.         });
  50.         $monitorSchedule = MonitorSchedule::interval(1, MonitorScheduleUnit::minute());
  52.         $monitorConfig = new MonitorConfig(
  53.             $monitorSchedule,
  54.             2, // check-in margin in minutes
  55.             5, // max runtime in minutes
  56.         );
  58.         $this->checkInId = captureCheckIn(
  59.             self::MONITOR_SLUG,
  60.             CheckInStatus::inProgress(),
  61.             null,
  62.             $monitorConfig,
  63.             date_default_timezone_get()
  64.         );
  65.     }
  67.     public function afterSchedule(AfterScheduleEvent $event): void
  68.     {
  69.         if ($this->checkInId === null || $this->checkInId === '') {
  70.             return;
  71.         }
  73.         captureCheckIn(
  74.             self::MONITOR_SLUG,
  75.             CheckInStatus::ok(),
  76.             $event->runContext()->getDuration(),
  77.             null,
  78.             $this->checkInId
  79.         );
  81.         $this->checkInId = null;
  82.     }
  83. }