vendor/league/oauth2-server-bundle/src/Manager/Doctrine/AccessTokenManager.php line 28

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace League\Bundle\OAuth2ServerBundle\Manager\Doctrine;
  7. use Doctrine\ORM\EntityManagerInterface;
  8. use League\Bundle\OAuth2ServerBundle\Manager\AccessTokenManagerInterface;
  9. use League\Bundle\OAuth2ServerBundle\Model\AccessToken;
  10. use League\Bundle\OAuth2ServerBundle\Model\AccessTokenInterface;
  12. final class AccessTokenManager implements AccessTokenManagerInterface
  13. {
  14.     /**
  15.      * @var EntityManagerInterface
  16.      */
  17.     private $entityManager;
  19.     /** @var bool */
  20.     private $persistAccessToken;
  22.     public function __construct(EntityManagerInterface $entityManager, bool $persistAccessToken)
  23.     {
  24.         $this->entityManager = $entityManager;
  25.         $this->persistAccessToken = $persistAccessToken;
  26.     }
  28.     public function find(string $identifier): ?AccessTokenInterface
  29.     {
  30.         if (!$this->persistAccessToken) {
  31.             return null;
  32.         }
  34.         return $this->entityManager->find(AccessToken::class, $identifier);
  35.     }
  37.     public function save(AccessTokenInterface $accessToken): void
  38.     {
  39.         if (!$this->persistAccessToken) {
  40.             return;
  41.         }
  43.         $this->entityManager->persist($accessToken);
  44.         $this->entityManager->flush();
  45.     }
  47.     public function clearExpired(): int
  48.     {
  49.         if (!$this->persistAccessToken) {
  50.             return 0;
  51.         }
  53.         /** @var int */
  54.         return $this->entityManager->createQueryBuilder()
  55.             ->delete(AccessToken::class, 'at')
  56.             ->where('at.expiry < :expiry')
  57.             ->setParameter('expiry', new \DateTimeImmutable(), 'datetime_immutable')
  58.             ->getQuery()
  59.             ->execute();
  60.     }
  61. }