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

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\Common\Persistence\ObjectManager;
  15. use Gesdinet\JWTRefreshTokenBundle\Entity\RefreshTokenRepository;
  16. use Gesdinet\JWTRefreshTokenBundle\Model\RefreshTokenManager as BaseRefreshTokenManager;
  17. use Gesdinet\JWTRefreshTokenBundle\Model\RefreshTokenInterface;
  19. class RefreshTokenManager extends BaseRefreshTokenManager
  20. {
  21.     /**
  22.      * @var ObjectManager
  23.      */
  24.     protected $objectManager;
  26.     /**
  27.      * @var string
  28.      */
  29.     protected $class;
  31.     /**
  32.      * @var RefreshTokenRepository
  33.      */
  34.     protected $repository;
  36.     /**
  37.      * Constructor.
  38.      *
  39.      * @param ObjectManager $om
  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
  54.      */
  55.     public function get($refreshToken)
  56.     {
  57.         return $this->repository->findOneBy(array('refreshToken' => $refreshToken));
  58.     }
  60.     /**
  61.      * @param string $username
  62.      *
  63.      * @return RefreshTokenInterface
  64.      */
  65.     public function getLastFromUsername($username)
  66.     {
  67.         return $this->repository->findOneBy(array('username' => $username), array('valid' => 'DESC'));
  68.     }
  70.     /**
  71.      * @param RefreshTokenInterface $refreshToken
  72.      * @param bool|true             $andFlush
  73.      */
  74.     public function save(RefreshTokenInterface $refreshToken, $andFlush = true)
  75.     {
  76.         $this->objectManager->persist($refreshToken);
  78.         if ($andFlush) {
  79.             $this->objectManager->flush();
  80.         }
  81.     }
  83.     /**
  84.      * @param RefreshTokenInterface $refreshToken
  85.      * @param bool                  $andFlush
  86.      */
  87.     public function delete(RefreshTokenInterface $refreshToken, $andFlush = true)
  88.     {
  89.         $this->objectManager->remove($refreshToken);
  91.         if ($andFlush) {
  92.             $this->objectManager->flush();
  93.         }
  94.     }
  96.     /**
  97.      * @param \DateTime $datetime
  98.      * @param bool      $andFlush
  99.      *
  100.      * @return RefreshTokenInterface[]
  101.      */
  102.     public function revokeAllInvalid($datetime = null, $andFlush = true)
  103.     {
  104.         $invalidTokens = $this->repository->findInvalid($datetime);
  106.         foreach ($invalidTokens as $invalidToken) {
  107.             $this->objectManager->remove($invalidToken);
  108.         }
  110.         if ($andFlush) {
  111.             $this->objectManager->flush();
  112.         }
  114.         return $invalidTokens;
  115.     }
  117.     /**
  118.      * Returns the RefreshToken fully qualified class name.
  119.      *
  120.      * @return string
  121.      */
  122.     public function getClass()
  123.     {
  124.         return $this->class;
  125.     }
  126. }