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

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 DateTime;
  15. use Doctrine\Persistence\ObjectManager;
  16. use Gesdinet\JWTRefreshTokenBundle\Entity\RefreshTokenRepository;
  17. use Gesdinet\JWTRefreshTokenBundle\Model\RefreshTokenManager as BaseRefreshTokenManager;
  18. use Gesdinet\JWTRefreshTokenBundle\Model\RefreshTokenInterface;
  20. class RefreshTokenManager extends BaseRefreshTokenManager
  21. {
  22.     /**
  23.      * @var ObjectManager
  24.      */
  25.     protected $objectManager;
  27.     /**
  28.      * @var string
  29.      */
  30.     protected $class;
  32.     /**
  33.      * @var RefreshTokenRepository
  34.      */
  35.     protected $repository;
  37.     /**
  38.      * Constructor.
  39.      *
  40.      * @param string $class
  41.      */
  42.     public function __construct(ObjectManager $om, $class)
  43.     {
  44.         $this->objectManager = $om;
  45.         $this->repository = $om->getRepository($class);
  46.         $metadata = $om->getClassMetadata($class);
  47.         $this->class = $metadata->getName();
  48.     }
  50.     /**
  51.      * @param string $refreshToken
  52.      *
  53.      * @return RefreshTokenInterface|null
  54.      */
  55.     public function get($refreshToken)
  56.     {
  57.         return $this->repository->findOneBy(['refreshToken' => $refreshToken]);
  58.     }
  60.     /**
  61.      * @param string $username
  62.      *
  63.      * @return RefreshTokenInterface
  64.      */
  65.     public function getLastFromUsername($username)
  66.     {
  67.         return $this->repository->findOneBy(['username' => $username], ['valid' => 'DESC']);
  68.     }
  70.     /**
  71.      * @param bool|true $andFlush
  72.      */
  73.     public function save(RefreshTokenInterface $refreshToken, $andFlush = true)
  74.     {
  75.         $this->objectManager->persist($refreshToken);
  77.         if ($andFlush) {
  78.             $this->objectManager->flush();
  79.         }
  80.     }
  82.     /**
  83.      * @param bool $andFlush
  84.      */
  85.     public function delete(RefreshTokenInterface $refreshToken, $andFlush = true)
  86.     {
  87.         $this->objectManager->remove($refreshToken);
  89.         if ($andFlush) {
  90.             $this->objectManager->flush();
  91.         }
  92.     }
  94.     /**
  95.      * @param DateTime $datetime
  96.      * @param bool     $andFlush
  97.      *
  98.      * @return RefreshTokenInterface[]
  99.      */
  100.     public function revokeAllInvalid($datetime = null, $andFlush = true)
  101.     {
  102.         $invalidTokens = $this->repository->findInvalid($datetime);
  104.         foreach ($invalidTokens as $invalidToken) {
  105.             $this->objectManager->remove($invalidToken);
  106.         }
  108.         if ($andFlush) {
  109.             $this->objectManager->flush();
  110.         }
  112.         return $invalidTokens;
  113.     }
  115.     /**
  116.      * Returns the RefreshToken fully qualified class name.
  117.      *
  118.      * @return string
  119.      */
  120.     public function getClass()
  121.     {
  122.         return $this->class;
  123.     }
  124. }