src/EventSubscriber/OneTimeConnexionSubscriber.php line 36

Open in your IDE?
  1. <?php
  3. namespace App\EventSubscriber;
  5. use App\Entity\Session;
  6. use App\Repository\SessionRepository;
  7. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  8. use Symfony\Component\HttpFoundation\JsonResponse;
  9. use Symfony\Component\HttpKernel\Event\RequestEvent;
  10. use Symfony\Component\HttpKernel\KernelEvents;
  11. use Doctrine\Persistence\ManagerRegistry;
  12. use Symfony\Component\Security\Core\Security;
  15. class OneTimeConnexionSubscriber implements EventSubscriberInterface
  16. {
  17.     private $entityManager;
  18.     private $sessionRepository;
  19.     private $security;
  21.     public function __construct(ManagerRegistry $doctrine, SessionRepository $sessionRepository, Security $security)
  22.     {
  23.         $this->entityManager = $doctrine->getManager();
  24.         $this->sessionRepository = $sessionRepository;
  25.         $this->security = $security;
  26.     }
  28.     public static function getSubscribedEvents()
  29.     {
  30.         // return the subscribed events, their methods and priorities
  31.         return [
  32.             KernelEvents::REQUEST => 'onKernelRequest',
  33.         ];
  34.     }
  36.     public function onKernelRequest(RequestEvent $event)
  37.     {
  38.         $token = $event->getRequest()->headers->get('authorization');
  40.         if ($token) {
  41.             $tokenFinal = explode('.', $token);
  42.             $session = $this->sessionRepository->findOneBy(["token" => $tokenFinal[2]]);
  44.             if (!$session) {
  45.                 $response = new JsonResponse([
  46.                     'code'          => 401,
  47.                     'message'       => "Votre session est expiré"
  48.                 ], 401);
  51.                 $event->setResponse($response);
  52.             }
  54.         }
  55.     }
  58. }