vendor/gesdinet/jwt-refresh-token-bundle/EventListener/AttachRefreshTokenOnSuccessListener.php line 86

Open in your IDE?
  1. <?php
  3. /*
  4.  * This file is part of the GesdinetJWTRefreshTokenBundle package.
  5.  *
  6.  * (c) Gesdinet <http://www.gesdinet.com/>
  7.  *
  8.  * For the full copyright and license information, please view the LICENSE
  9.  * file that was distributed with this source code.
  10.  */
  12. namespace Gesdinet\JWTRefreshTokenBundle\EventListener;
  14. use Gesdinet\JWTRefreshTokenBundle\Model\RefreshTokenInterface;
  15. use Gesdinet\JWTRefreshTokenBundle\Model\RefreshTokenManagerInterface;
  16. use Gesdinet\JWTRefreshTokenBundle\Request\RequestRefreshToken;
  17. use Lexik\Bundle\JWTAuthenticationBundle\Event\AuthenticationSuccessEvent;
  18. use Symfony\Component\Security\Core\User\UserInterface;
  19. use Symfony\Component\Validator\Validator\ValidatorInterface;
  20. use Symfony\Component\HttpFoundation\RequestStack;
  21. use Symfony\Component\PropertyAccess\PropertyAccessor;
  23. class AttachRefreshTokenOnSuccessListener
  24. {
  25.     /**
  26.      * @var RefreshTokenManagerInterface
  27.      */
  28.     protected $refreshTokenManager;
  30.     /**
  31.      * @var int
  32.      */
  33.     protected $ttl;
  35.     /**
  36.      * @var ValidatorInterface
  37.      */
  38.     protected $validator;
  40.     /**
  41.      * @var RequestStack
  42.      */
  43.     protected $requestStack;
  45.     /**
  46.      * @var string
  47.      */
  48.     protected $userIdentityField;
  50.     /**
  51.      * @var string
  52.      */
  53.     protected $tokenParameterName;
  55.     /**
  56.      * @var bool
  57.      */
  58.     protected $singleUse;
  60.     /**
  61.      * AttachRefreshTokenOnSuccessListener constructor.
  62.      *
  63.      * @param int    $ttl
  64.      * @param string $userIdentityField
  65.      * @param string $tokenParameterName
  66.      * @param bool   $singleUse
  67.      */
  68.     public function __construct(
  69.         RefreshTokenManagerInterface $refreshTokenManager,
  70.         $ttl,
  71.         ValidatorInterface $validator,
  72.         RequestStack $requestStack,
  73.         $userIdentityField,
  74.         $tokenParameterName,
  75.         $singleUse
  76.     ) {
  77.         $this->refreshTokenManager = $refreshTokenManager;
  78.         $this->ttl = $ttl;
  79.         $this->validator = $validator;
  80.         $this->requestStack = $requestStack;
  81.         $this->userIdentityField = $userIdentityField;
  82.         $this->tokenParameterName = $tokenParameterName;
  83.         $this->singleUse = $singleUse;
  84.     }
  86.     public function attachRefreshToken(AuthenticationSuccessEvent $event)
  87.     {
  88.         $data = $event->getData();
  89.         $user = $event->getUser();
  90.         $request = $this->requestStack->getCurrentRequest();
  92.         if (!$user instanceof UserInterface) {
  93.             return;
  94.         }
  96.         $refreshTokenString = RequestRefreshToken::getRefreshToken($request, $this->tokenParameterName);
  98.         if ($refreshTokenString && true === $this->singleUse) {
  99.             $refreshToken = $this->refreshTokenManager->get($refreshTokenString);
  100.             $refreshTokenString = null;
  102.             if ($refreshToken instanceof RefreshTokenInterface) {
  103.                 $this->refreshTokenManager->delete($refreshToken);
  104.             }
  105.         }
  107.         if ($refreshTokenString) {
  108.             $data[$this->tokenParameterName] = $refreshTokenString;
  109.         } else {
  110.             $datetime = new \DateTime();
  111.             $datetime->modify('+'.$this->ttl.' seconds');
  113.             $refreshToken = $this->refreshTokenManager->create();
  115.             $accessor = new PropertyAccessor();
  116.             $userIdentityFieldValue = $accessor->getValue($user, $this->userIdentityField);
  118.             $refreshToken->setUsername($userIdentityFieldValue);
  119.             $refreshToken->setRefreshToken();
  120.             $refreshToken->setValid($datetime);
  122.             $valid = false;
  123.             while (false === $valid) {
  124.                 $valid = true;
  125.                 $errors = $this->validator->validate($refreshToken);
  126.                 if ($errors->count() > 0) {
  127.                     foreach ($errors as $error) {
  128.                         if ('refreshToken' === $error->getPropertyPath()) {
  129.                             $valid = false;
  130.                             $refreshToken->setRefreshToken();
  131.                         }
  132.                     }
  133.                 }
  134.             }
  136.             $this->refreshTokenManager->save($refreshToken);
  137.             $data[$this->tokenParameterName] = $refreshToken->getRefreshToken();
  138.         }
  140.         $event->setData($data);
  141.     }
  142. }