vendor/friendsofsymfony/oauth-server-bundle/Entity/TokenManager.php line 42

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. /*
  6.  * This file is part of the FOSOAuthServerBundle package.
  7.  *
  8.  * (c) FriendsOfSymfony <http://friendsofsymfony.github.com/>
  9.  *
  10.  * For the full copyright and license information, please view the LICENSE
  11.  * file that was distributed with this source code.
  12.  */
  14. namespace FOS\OAuthServerBundle\Entity;
  16. use Doctrine\ORM\EntityManagerInterface;
  17. use Doctrine\ORM\EntityRepository;
  18. use FOS\OAuthServerBundle\Model\TokenInterface;
  19. use FOS\OAuthServerBundle\Model\TokenManager as BaseTokenManager;
  21. class TokenManager extends BaseTokenManager
  22. {
  23.     /**
  24.      * @var EntityManagerInterface
  25.      */
  26.     protected $em;
  28.     /**
  29.      * @var EntityRepository
  30.      */
  31.     protected $repository;
  33.     /**
  34.      * @var string
  35.      */
  36.     protected $class;
  38.     public function __construct(EntityManagerInterface $em, $class)
  39.     {
  40.         // NOTE: bug in Doctrine, hinting EntityRepository|ObjectRepository when only EntityRepository is expected
  41.         /** @var EntityRepository $repository */
  42.         $repository = $em->getRepository($class);
  44.         $this->em = $em;
  45.         $this->repository = $repository;
  46.         $this->class = $class;
  47.     }
  49.     /**
  50.      * {@inheritdoc}
  51.      */
  52.     public function getClass()
  53.     {
  54.         return $this->class;
  55.     }
  57.     /**
  58.      * {@inheritdoc}
  59.      */
  60.     public function findTokenBy(array $criteria)
  61.     {
  62.         return $this->repository->findOneBy($criteria);
  63.     }
  65.     /**
  66.      * {@inheritdoc}
  67.      */
  68.     public function updateToken(TokenInterface $token)
  69.     {
  70.         $this->em->persist($token);
  71.         $this->em->flush();
  72.     }
  74.     /**
  75.      * {@inheritdoc}
  76.      */
  77.     public function deleteToken(TokenInterface $token)
  78.     {
  79.         $this->em->remove($token);
  80.         $this->em->flush();
  81.     }
  83.     /**
  84.      * {@inheritdoc}
  85.      */
  86.     public function deleteExpired()
  87.     {
  88.         $qb = $this->repository->createQueryBuilder('t');
  89.         $qb
  90.             ->delete()
  91.             ->where('t.expiresAt < ?1')
  92.             ->setParameters([1 => time()])
  93.         ;
  95.         return $qb->getQuery()->execute();
  96.     }
  97. }