vendor/gesdinet/jwt-refresh-token-bundle/Doctrine/RefreshTokenManager.php line 66

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\Doctrine;
  14. use Doctrine\Persistence\ObjectManager;
  15. use Gesdinet\JWTRefreshTokenBundle\Generator\RefreshTokenGeneratorInterface;
  16. use Gesdinet\JWTRefreshTokenBundle\Model\RefreshTokenInterface;
  17. use Gesdinet\JWTRefreshTokenBundle\Model\RefreshTokenManagerInterface;
  19. class RefreshTokenManager implements RefreshTokenManagerInterface
  20. {
  21.     /**
  22.      * @var ObjectManager
  23.      */
  24.     protected $objectManager;
  26.     /**
  27.      * @var class-string<RefreshTokenInterface>
  28.      */
  29.     protected $class;
  31.     /**
  32.      * @var RefreshTokenRepositoryInterface<RefreshTokenInterface>
  33.      */
  34.     protected $repository;
  36.     /**
  37.      * @param class-string<RefreshTokenInterface> $class
  38.      *
  39.      * @throws \LogicException if the object repository does not implement `Gesdinet\JWTRefreshTokenBundle\Doctrine\RefreshTokenRepositoryInterface`
  40.      */
  41.     public function __construct(ObjectManager $om, $class)
  42.     {
  43.         $this->objectManager = $om;
  45.         $repository = $om->getRepository($class);
  47.         if (!$repository instanceof RefreshTokenRepositoryInterface) {
  48.             throw new \LogicException(sprintf('Repository mapped for "%s" should implement %s.', $class, RefreshTokenRepositoryInterface::class));
  49.         }
  51.         $this->repository = $repository;
  53.         $metadata = $om->getClassMetadata($class);
  54.         $this->class = $metadata->getName();
  55.     }
  57.     /**
  58.      * Creates an empty RefreshTokenInterface instance.
  59.      *
  60.      * @return RefreshTokenInterface
  61.      *
  62.      * @deprecated to be removed in 2.0, use a `Gesdinet\JWTRefreshTokenBundle\Generator\RefreshTokenGeneratorInterface` instead.
  63.      */
  64.     public function create()
  65.     {
  66.         trigger_deprecation('gesdinet/jwt-refresh-token-bundle', '1.0', '%s() is deprecated and will be removed in 2.0, use a "%s" instance to create new %s objects.', __METHOD__, RefreshTokenGeneratorInterface::class, RefreshTokenInterface::class);
  68.         $class = $this->getClass();
  70.         return new $class();
  71.     }
  73.     /**
  74.      * @param string $refreshToken
  75.      *
  76.      * @return RefreshTokenInterface|null
  77.      */
  78.     public function get($refreshToken)
  79.     {
  80.         return $this->repository->findOneBy(['refreshToken' => $refreshToken]);
  81.     }
  83.     /**
  84.      * @param string $username
  85.      *
  86.      * @return RefreshTokenInterface|null
  87.      */
  88.     public function getLastFromUsername($username)
  89.     {
  90.         return $this->repository->findOneBy(['username' => $username], ['valid' => 'DESC']);
  91.     }
  93.     /**
  94.      * @param bool $andFlush
  95.      *
  96.      * @return void
  97.      */
  98.     public function save(RefreshTokenInterface $refreshToken, $andFlush = true)
  99.     {
  100.         $this->objectManager->persist($refreshToken);
  102.         if ($andFlush) {
  103.             $this->objectManager->flush();
  104.         }
  105.     }
  107.     /**
  108.      * @param bool $andFlush
  109.      *
  110.      * @return void
  111.      */
  112.     public function delete(RefreshTokenInterface $refreshToken, $andFlush = true)
  113.     {
  114.         $this->objectManager->remove($refreshToken);
  116.         if ($andFlush) {
  117.             $this->objectManager->flush();
  118.         }
  119.     }
  121.     /**
  122.      * @param \DateTimeInterface|null $datetime
  123.      * @param bool                    $andFlush
  124.      *
  125.      * @return RefreshTokenInterface[]
  126.      */
  127.     public function revokeAllInvalid($datetime = null, $andFlush = true)
  128.     {
  129.         $invalidTokens = $this->repository->findInvalid($datetime);
  131.         foreach ($invalidTokens as $invalidToken) {
  132.             $this->objectManager->remove($invalidToken);
  133.         }
  135.         if ($andFlush) {
  136.             $this->objectManager->flush();
  137.         }
  139.         return $invalidTokens;
  140.     }
  142.     /**
  143.      * Returns the RefreshToken fully qualified class name.
  144.      *
  145.      * @return class-string<RefreshTokenInterface>
  146.      */
  147.     public function getClass()
  148.     {
  149.         return $this->class;
  150.     }
  151. }