src/EventSubscriber/AgendaReminderDispatchSubscriber.php line 36

Open in your IDE?
  1. <?php
  3. namespace App\EventSubscriber;
  5. use App\Service\AgendaReminderService;
  6. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  7. use Symfony\Component\HttpFoundation\Request;
  8. use Symfony\Component\HttpKernel\Event\ControllerEvent;
  9. use Symfony\Component\HttpKernel\KernelEvents;
  10. use Symfony\Contracts\Cache\CacheInterface;
  11. use Symfony\Contracts\Cache\ItemInterface;
  13. /**
  14.  * Déclenche l'envoi des rappels agenda à la volée (sans cron),
  15.  * avec un throttling global pour éviter d'exécuter la tâche à chaque requête.
  16.  */
  17. class AgendaReminderDispatchSubscriber implements EventSubscriberInterface
  18. {
  19.     private const CACHE_KEY = 'agenda_reminders.last_dispatch';
  20.     private const DISPATCH_INTERVAL_SECONDS = 60;
  21.     private const DISPATCH_LIMIT = 150;
  23.     public function __construct(
  24.         private readonly AgendaReminderService $agendaReminderService,
  25.         private readonly CacheInterface $cache,
  26.     ) {
  27.     }
  29.     public static function getSubscribedEvents(): array
  30.     {
  31.         return [
  32.             KernelEvents::CONTROLLER => ['onKernelController', 0],
  33.         ];
  34.     }
  36.     public function onKernelController(ControllerEvent $event): void
  37.     {
  38.         if (!$event->isMainRequest()) {
  39.             return;
  40.         }
  42.         $request = $event->getRequest();
  43.         if ($this->isStaticAsset($request)) {
  44.             return;
  45.         }
  47.         $now = time();
  48.         $last = (int) $this->cache->get(self::CACHE_KEY, static function (ItemInterface $item) {
  49.             $item->expiresAfter(3600);
  50.             return 0;
  51.         });
  53.         if ($now - $last < self::DISPATCH_INTERVAL_SECONDS) {
  54.             return;
  55.         }
  57.         $this->cache->delete(self::CACHE_KEY);
  58.         $this->cache->get(self::CACHE_KEY, static function (ItemInterface $item) use ($now) {
  59.             $item->expiresAfter(3600);
  60.             return $now;
  61.         });
  63.         try {
  64.             $this->agendaReminderService->dispatchDueReminders(self::DISPATCH_LIMIT);
  65.         } catch (\Throwable $exception) {
  66.             // Ne pas bloquer la requête en cas d'erreur d'envoi des rappels.
  67.         }
  68.     }
  70.     private function isStaticAsset(Request $request): bool
  71.     {
  72.         $path = $request->getPathInfo();
  73.         return (bool) preg_match('#^/(build|assets|css|js|fonts|img|images|favicon\\.ico|robots\\.txt|_wdt|_profiler)#', $path);
  74.     }
  75. }