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

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\RefreshTokenManagerInterface;
  15. use Gesdinet\JWTRefreshTokenBundle\Request\RequestRefreshToken;
  16. use Lexik\Bundle\JWTAuthenticationBundle\Event\AuthenticationSuccessEvent;
  17. use Symfony\Component\Security\Core\User\UserInterface;
  18. use Symfony\Component\Validator\Validator\ValidatorInterface;
  19. use Symfony\Component\HttpFoundation\RequestStack;
  20. use Symfony\Component\PropertyAccess\PropertyAccessor;
  22. class AttachRefreshTokenOnSuccessListener
  23. {
  24.     /**
  25.      * @var RefreshTokenManagerInterface
  26.      */
  27.     protected $refreshTokenManager;
  29.     /**
  30.      * @var int
  31.      */
  32.     protected $ttl;
  34.     /**
  35.      * @var ValidatorInterface
  36.      */
  37.     protected $validator;
  39.     /**
  40.      * @var RequestStack
  41.      */
  42.     protected $requestStack;
  44.     /**
  45.      * @var string
  46.      */
  47.     protected $userIdentityField;
  49.     /**
  50.      * AttachRefreshTokenOnSuccessListener constructor.
  51.      *
  52.      * @param RefreshTokenManagerInterface $refreshTokenManager
  53.      * @param int                          $ttl
  54.      * @param ValidatorInterface           $validator
  55.      * @param RequestStack                 $requestStack
  56.      * @param string                       $userIdentityField
  57.      */
  58.     public function __construct(
  59.         RefreshTokenManagerInterface $refreshTokenManager,
  60.         $ttl,
  61.         ValidatorInterface $validator,
  62.         RequestStack $requestStack,
  63.         $userIdentityField
  64.     ) {
  65.         $this->refreshTokenManager = $refreshTokenManager;
  66.         $this->ttl = $ttl;
  67.         $this->validator = $validator;
  68.         $this->requestStack = $requestStack;
  69.         $this->userIdentityField = $userIdentityField;
  70.     }
  72.     public function attachRefreshToken(AuthenticationSuccessEvent $event)
  73.     {
  74.         $data = $event->getData();
  75.         $user = $event->getUser();
  76.         $request = $this->requestStack->getCurrentRequest();
  78.         if (!$user instanceof UserInterface) {
  79.             return;
  80.         }
  82.         $refreshTokenString = RequestRefreshToken::getRefreshToken($request);
  84.         if ($refreshTokenString) {
  85.             $data['refresh_token'] = $refreshTokenString;
  86.         } else {
  87.             $datetime = new \DateTime();
  88.             $datetime->modify('+'.$this->ttl.' seconds');
  90.             $refreshToken = $this->refreshTokenManager->create();
  92.             $accessor = new PropertyAccessor();
  93.             $userIdentityFieldValue = $accessor->getValue($user, $this->userIdentityField);
  95.             $refreshToken->setUsername($userIdentityFieldValue);
  96.             $refreshToken->setRefreshToken();
  97.             $refreshToken->setValid($datetime);
  99.             $valid = false;
  100.             while (false === $valid) {
  101.                 $valid = true;
  102.                 $errors = $this->validator->validate($refreshToken);
  103.                 if ($errors->count() > 0) {
  104.                     foreach ($errors as $error) {
  105.                         if ('refreshToken' === $error->getPropertyPath()) {
  106.                             $valid = false;
  107.                             $refreshToken->setRefreshToken();
  108.                         }
  109.                     }
  110.                 }
  111.             }
  113.             $this->refreshTokenManager->save($refreshToken);
  114.             $data['refresh_token'] = $refreshToken->getRefreshToken();
  115.         }
  117.         $event->setData($data);
  118.     }
  119. }