vendor/contao/core-bundle/src/Repository/RememberMeRepository.php line 32

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. /*
  6.  * This file is part of Contao.
  7.  *
  8.  * (c) Leo Feyer
  9.  *
  10.  * @license LGPL-3.0-or-later
  11.  */
  13. namespace Contao\CoreBundle\Repository;
  15. use Contao\CoreBundle\Entity\RememberMe;
  16. use Doctrine\Bundle\DoctrineBundle\Repository\ServiceEntityRepository;
  17. use Doctrine\DBAL\Connection;
  18. use Doctrine\DBAL\Types\Types;
  19. use Symfony\Bridge\Doctrine\ManagerRegistry;
  21. /**
  22.  * @template-extends ServiceEntityRepository<RememberMe>
  23.  *
  24.  * @internal
  25.  */
  26. class RememberMeRepository extends ServiceEntityRepository
  27. {
  28.     private Connection $connection;
  30.     public function __construct(ManagerRegistry $registry)
  31.     {
  32.         parent::__construct($registry, RememberMe::class);
  34.         $this->connection = $registry->getConnection();
  35.     }
  37.     public function lockTable(): void
  38.     {
  39.         $table = $this->getClassMetadata()->getTableName();
  41.         $this->connection->executeStatement("LOCK TABLES $table WRITE, $table AS t0_ WRITE");
  42.     }
  44.     public function unlockTable(): void
  45.     {
  46.         $this->connection->executeStatement('UNLOCK TABLES');
  47.     }
  49.     /**
  50.      * @return array<RememberMe>
  51.      */
  52.     public function findBySeries(string $series): array
  53.     {
  54.         $qb = $this->createQueryBuilder('rm');
  55.         $qb
  56.             ->where('rm.series = :series')
  57.             ->andWhere(
  58.                 $qb->expr()->orX(
  59.                     $qb->expr()->isNull('rm.expires'),
  60.                     $qb->expr()->lte('rm.expires', ':now')
  61.                 )
  62.             )
  63.             ->setParameter('series', $series)
  64.             ->setParameter('now', new \DateTime(), Types::DATETIME_MUTABLE)
  65.             ->orderBy('rm.expires', 'ASC')
  66.         ;
  68.         return $qb->getQuery()->getResult();
  69.     }
  71.     public function deleteSiblings(RememberMe $entity): void
  72.     {
  73.         $qb = $this->_em->createQueryBuilder();
  74.         $qb
  75.             ->delete($this->_entityName, 'rm')
  76.             ->where('rm.series = :series')
  77.             ->andWhere('rm.value != :value')
  78.             ->setParameter('series', $entity->getSeries())
  79.             ->setParameter('value', $entity->getValue())
  80.         ;
  82.         $qb->getQuery()->execute();
  83.     }
  85.     public function deleteBySeries(string $series): void
  86.     {
  87.         $qb = $this->_em->createQueryBuilder();
  88.         $qb
  89.             ->delete($this->_entityName, 'rm')
  90.             ->where('rm.series = :series')
  91.             ->setParameter('series', $series)
  92.         ;
  94.         $qb->getQuery()->execute();
  95.     }
  97.     public function deleteExpired(int $lastUsedLifetime, int $expiresLifetime): void
  98.     {
  99.         $qb = $this->_em->createQueryBuilder();
  100.         $qb
  101.             ->delete($this->_entityName, 'rm')
  102.             ->where('rm.lastUsed < :lastUsed')
  103.             ->orWhere('rm.expires < :expires')
  104.             ->setParameter('lastUsed', (new \DateTime())->sub(new \DateInterval('PT'.$lastUsedLifetime.'S')))
  105.             ->setParameter('expires', (new \DateTime())->sub(new \DateInterval('PT'.$expiresLifetime.'S')))
  106.         ;
  108.         $qb->getQuery()->execute();
  109.     }
  111.     public function persist(RememberMe ...$entities): void
  112.     {
  113.         foreach ($entities as $entity) {
  114.             $this->_em->persist($entity);
  115.         }
  117.         $this->_em->flush();
  118.     }
  119. }