src/FMT/Domain/Listener/UserNotificationListener.php line 27

Open in your IDE?
  1. <?php
  3. namespace FMT\Domain\Listener;
  5. use FMT\Data\Entity\User;
  6. use FMT\Domain\Repository\UserNotificationsRepositoryInterface;
  7. use Symfony\Component\HttpFoundation\Session\SessionInterface;
  8. use Symfony\Component\HttpKernel\Event\RequestEvent;
  9. use Symfony\Component\Security\Core\Authentication\Token\Storage\TokenStorageInterface;
  11. class UserNotificationListener
  12. {
  13.     private UserNotificationsRepositoryInterface $userNotificationsRepository;
  14.     private SessionInterface $session;
  15.     private TokenStorageInterface $tokenStorage;
  17.     public function __construct(
  18.         UserNotificationsRepositoryInterface $userNotificationsRepository,
  19.         SessionInterface $session,
  20.         TokenStorageInterface $tokenStorage
  21.     ) {
  22.         $this->userNotificationsRepository = $userNotificationsRepository;
  23.         $this->session = $session;
  24.         $this->tokenStorage = $tokenStorage;
  25.     }
  27.     public function onKernelRequest(RequestEvent $event)
  28.     {
  29.         $tokenStorage = $this->tokenStorage->getToken();
  31.         if (!$tokenStorage) {
  32.             return;
  33.         }
  35.         /** @var ?User $user */
  36.         $user = $tokenStorage->getUser();
  38.         if (!$user instanceof User) {
  39.             return;
  40.         }
  42.         $notifications = $this->userNotificationsRepository->findUserNotifications($user);
  44.         foreach ($notifications as $notification) {
  45.             $this->session->getFlashBag()->add('warning', $notification->getMessage());
  46.             $notification->setIsSent(1);
  47.             $this->userNotificationsRepository->add($notification);
  48.             $this->userNotificationsRepository->save($notification);
  49.         }
  50.     }
  51. }