infrastructure/OAuthBundle/Entity/TokenManager.php line 39

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. protected \Doctrine\ORM\EntityManagerInterface $em;
  25. /**
  26. * @var EntityRepository
  27. */
  28. protected $repository;
  30. /**
  31. * @var string
  32. */
  33. protected $class;
  35. public function __construct(EntityManagerInterface $em, $class)
  36. {
  37. // NOTE: bug in Doctrine, hinting EntityRepository|ObjectRepository when only EntityRepository is expected
  38. /** @var EntityRepository $repository */
  39. $repository = $em->getRepository($class);
  41. $this->em = $em;
  42. $this->repository = $repository;
  43. $this->class = $class;
  44. }
  46. /**
  47. * {@inheritdoc}
  48. */
  49. public function getClass()
  50. {
  51. return $this->class;
  52. }
  54. /**
  55. * {@inheritdoc}
  56. */
  57. public function findTokenBy(array $criteria)
  58. {
  59. return $this->repository->findOneBy($criteria);
  60. }
  62. /**
  63. * {@inheritdoc}
  64. */
  65. public function updateToken(TokenInterface $token)
  66. {
  67. $this->em->persist($token);
  68. $this->em->flush();
  69. }
  71. /**
  72. * {@inheritdoc}
  73. */
  74. public function deleteToken(TokenInterface $token)
  75. {
  76. $this->em->remove($token);
  77. $this->em->flush();
  78. }
  80. /**
  81. * {@inheritdoc}
  82. */
  83. public function deleteExpired()
  84. {
  85. $qb = $this->repository->createQueryBuilder('t');
  86. $qb
  87. ->delete()
  88. ->where('t.expiresAt < ?1')
  89. ->setParameters([1 => time()])
  90. ;
  92. return $qb->getQuery()->execute();
  93. }
  94. }