src/EventListener/JWT/AuthenticationListener.php line 37

Open in your IDE?
  1. <?php
  3. namespace App\EventListener\JWT;
  5. use App\Entity\User;
  7. use App\Repository\UserTokenRepository;
  8. use Symfony\Component\HttpFoundation\JsonResponse;
  9. use Lexik\Bundle\JWTAuthenticationBundle\Event\JWTExpiredEvent;
  10. use Lexik\Bundle\JWTAuthenticationBundle\Event\JWTInvalidEvent;
  11. use Lexik\Bundle\JWTAuthenticationBundle\Event\JWTNotFoundEvent;
  13. use Lexik\Bundle\JWTAuthenticationBundle\Event\AuthenticationFailureEvent;
  14. use Lexik\Bundle\JWTAuthenticationBundle\Event\AuthenticationSuccessEvent;
  15. use Lexik\Bundle\JWTAuthenticationBundle\Response\JWTAuthenticationFailureResponse;
  17. class AuthenticationListener
  18. {
  19.     /**
  20.      * @var UserTokenRepository
  21.      */
  22.     private $userTokenRepo;
  24.     /**
  25.      * @param UserTokenRepository $userTokenRepo
  26.      */
  27.     public function __construct(UserTokenRepository $userTokenRepo)
  28.     {
  29.         $this->userTokenRepo = $userTokenRepo;
  30.     }
  32.     /**
  33.      * @param AuthenticationSuccessEvent $event
  34.      * @throws \Doctrine\ORM\ORMException
  35.      * @throws \Doctrine\ORM\OptimisticLockException
  36.      */
  37.     public function onAuthenticationSuccessResponse(AuthenticationSuccessEvent $event)
  38.     {
  39.         /** @var User $user */
  40.         $user = $event->getUser();
  41.         $tokenString = $event->getData()["token"] ?? "";
  43.         $this->userTokenRepo->disableOldTokens($user);
  44.         $this->userTokenRepo->create($user, $tokenString);
  45.     }
  47.     /**
  48.      * @param AuthenticationFailureEvent $event
  49.      */
  50.     public function onAuthenticationFailureResponse(AuthenticationFailureEvent $event)
  51.     {
  52.         $event->setResponse(new JWTAuthenticationFailureResponse('bad_credentials'));
  53.     }
  55.     /**
  56.      * @param JWTInvalidEvent $event
  57.      */
  58.     public function onJWTInvalid(JWTInvalidEvent $event)
  59.     {
  60.         $event->setResponse(new JsonResponse(['message' => "token.invalid"], 401));
  61.     }
  63.     /**
  64.      * @param JWTNotFoundEvent $event
  65.      */
  66.     public function onJWTNotFound(JWTNotFoundEvent $event)
  67.     {
  68.         $event->setResponse(new JsonResponse(['message' => "token.not_found"], 401));
  69.     }
  71.     /**
  72.      * @param JWTExpiredEvent $event
  73.      */
  74.     public function onJWTExpired(JWTExpiredEvent $event)
  75.     {
  76.         $event->setResponse(new JsonResponse(['message' => "token.expired"], 401));
  77.     }
  78. }