src/EventSubscriber/KernelTerminateSubscriber.php line 49

Open in your IDE?
  1. <?php
  4. namespace App\EventSubscriber;
  6. use App\Entity\Notification;
  7. use App\Repository\NotificationRepository;
  8. use App\Service\NotificationSender;
  9. use App\Service\NotificationService;
  10. use Psr\Log\LoggerInterface;
  11. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  12. use Symfony\Component\HttpKernel\Event\TerminateEvent;
  13. use Symfony\Component\HttpKernel\KernelEvents;
  15. class KernelTerminateSubscriber implements EventSubscriberInterface
  16. {
  17.     /** @var NotificationRepository $notificationRepository The notification data repository */
  18.     private NotificationRepository $notificationRepository;
  19.     /** @var NotificationSender $notificationSender The notification sender. */
  20.     private NotificationSender $notificationSender;
  22.     private LoggerInterface $logger;
  24.     /**
  25.      * KernelTerminateSubscriber constructor.
  26.      * @param NotificationRepository $notificationRepository
  27.      * @param NotificationSender $notificationSender
  28.      */
  29.     public function __construct(NotificationRepository $notificationRepository, NotificationSender $notificationSender, LoggerInterface $logger)
  30.     {
  31.         $this->notificationRepository = $notificationRepository;
  32.         $this->notificationSender = $notificationSender;
  33.         $this->logger = $logger;
  34.     }
  36.     /**
  37.      * Returns an array mapping events to functions to trigger.
  38.      * @return array The mapping array.
  39.      */
  40.     public static function getSubscribedEvents(): array
  41.     {
  42.         return [KernelEvents::TERMINATE => 'triggerDirectSendNotification'];
  43.     }
  45.     /**
  46.      * Handles the KernelTerminateEvent and sends notifications with directSend capabilities for this requies.
  47.      * @param TerminateEvent $event The KernelTerminate event.
  48.      */
  49.     public function triggerDirectSendNotification(TerminateEvent $event): void {
  50.         $request = $event->getRequest();
  51.         $directSendStorage = $request->attributes->get(NotificationService::NOTIFICATION_STORAGE_KEY, null);
  53.         if(false === is_null($directSendStorage)) {
  54.             foreach ($directSendStorage as $notificationId) {
  55.                 /** @var Notification $notification */
  56.                 $notification = $this->notificationRepository->findOneBy(['id' => $notificationId]);
  58.                 if(false === is_null($notification)) {
  59.                     $this->notificationSender->send($notification);
  60.                 }
  61.             }
  63.             $event->getRequest()->attributes->set(NotificationService::NOTIFICATION_STORAGE_KEY, null);
  64.         }
  65.     }
  66. }