src/Security/JWTAuthenticatedEventListener.php line 75

Open in your IDE?
  1. <?php
  3. namespace App\Security;
  5. use App\DataProvider\UserInfo\UserInfoItemDataProvider;
  6. use App\Model\Security\UserInfo;
  7. use App\Security\Exception\TokenNotWhitelistedException;
  8. use App\Service\Cache\CacheManager;
  9. use App\V4\Model\Security\UserInfo as UserInfoV4;
  10. use DateTime;
  11. use Exception;
  12. use Lexik\Bundle\JWTAuthenticationBundle\Event\JWTAuthenticatedEvent;
  13. use Lexik\Bundle\JWTAuthenticationBundle\Security\Guard\JWTTokenAuthenticator;
  14. use Symfony\Component\Security\Core\Authentication\Token\Storage\TokenStorage;
  16. /**
  17.  * Class JWTAuthenticatedEventListener.
  18.  */
  19. final class JWTAuthenticatedEventListener extends JWTTokenAuthenticator
  20. {
  21.     /**
  22.      * @var UserInfoItemDataProvider
  23.      */
  24.     private $userInfoItemDataProvider;
  26.     /**
  27.      * @var TokenStorage
  28.      */
  29.     private $tokenStorage;
  31.     /**
  32.      * @var CacheManager
  33.      */
  34.     private $cacheManager;
  36.     /**
  37.      * @var bool
  38.      */
  39.     private $enableTokenWhitelist;
  41.     /**
  42.      * @var string
  43.      */
  44.     private $environnement;
  46.     /**
  47.      * @param UserInfoItemDataProvider $userInfoItemDataProvider
  48.      * @param TokenStorage             $tokenStorage
  49.      * @param CacheManager             $cacheManager
  50.      * @param bool                     $enableTokenWhitelist
  51.      * @param string|null              $environnement
  52.      * @SuppressWarnings(PHPMD.BooleanArgumentFlag)
  53.      */
  54.     public function __construct(
  55.         UserInfoItemDataProvider $userInfoItemDataProvider,
  56.         TokenStorage $tokenStorage,
  57.         CacheManager $cacheManager,
  58.         bool $enableTokenWhitelist = false,
  59.         string $environnement = null
  60.     ) {
  61.         $this->userInfoItemDataProvider = $userInfoItemDataProvider;
  62.         $this->tokenStorage = $tokenStorage;
  63.         $this->cacheManager = $cacheManager;
  64.         $this->enableTokenWhitelist = $enableTokenWhitelist;
  65.         $this->environnement = $environnement;
  66.     }
  68.     /**
  69.      * @param JWTAuthenticatedEvent $event
  70.      *
  71.      * @return void
  72.      *
  73.      * @throws Exception
  74.      */
  75.     public function onLexikjwtauthenticationOnjwtauthenticated(JWTAuthenticatedEvent $event): void
  76.     {
  77.         $payload = $event->getPayload();
  78.         $this->tokenStorage->setToken($event->getToken());
  80.         /**
  81.          * Voir : https://gist.github.com/benjaminrau/865f94d142605eb72a23a34ccdd0617a
  82.          * As a mechanism to invalidate issued tokes we force token issue date to be higher than a date stored on User::tokenValidAfter
  83.          * By updating the User::tokenValidAfter to current date all previously issued tokens become invalid.
  84.          *
  85.          * Its intended we dont mark as invalid if user isnt found on persistence level because we rely on core JWT
  86.          * implementation to handle this case. We want to handle only the validation of tokenValidAfter here.
  87.          *
  88.          * @var UserInfo User
  89.          */
  90.         // Toutes les 5 requêtes, on vérifie que le token de l'utilisateur n'est pas expiré
  91.         $current = $this->cacheManager->get(UserInfo::class, 'jwtAuthCheck', $payload['user_id']);
  92.         if ($current > 5) {
  93.             $current = 0;
  94.             $user = $this->userInfoItemDataProvider->getItem(UserInfo::class, $payload['user_id']);
  95.             if ($user &&
  96.                 $user->getTokenValidAfter() instanceof DateTime &&
  97.                 $payload['iat'] < $user->getTokenValidAfter()->getTimestamp() &&
  98.                 $this->enableTokenWhitelist
  99.             ) {
  100.                 throw new TokenNotWhitelistedException('This token is no longer authorized.');
  101.             }
  103.             $this->cacheManager->invalidate(UserInfo::class, CacheManager::CACHE_ACTION_KEY_ITEM, null, $payload['user_id']);
  104.             $this->cacheManager->invalidate(UserInfoV4::class, CacheManager::CACHE_ACTION_KEY_ITEM, null, $payload['user_id']);
  105.         }
  106.         $this->cacheManager->set(UserInfo::class, 'jwtAuthCheck', $current + 1, $payload['user_id']);
  107.         $this->cacheManager->set(UserInfoV4::class, 'jwtAuthCheck', $current + 1, $payload['user_id']);
  108.     }
  109. }