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

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.         /** @var Connection $connection */
  35.         $connection = $registry->getConnection();
  37.         $this->connection = $connection;
  38.     }
  40.     public function lockTable(): void
  41.     {
  42.         $table = $this->getClassMetadata()->getTableName();
  44.         $this->connection->executeStatement("LOCK TABLES $table WRITE, $table AS t0_ WRITE");
  45.     }
  47.     public function unlockTable(): void
  48.     {
  49.         $this->connection->executeStatement('UNLOCK TABLES');
  50.     }
  52.     /**
  53.      * @return array<RememberMe>
  54.      */
  55.     public function findBySeries(string $series): array
  56.     {
  57.         $qb = $this->createQueryBuilder('rm');
  58.         $qb
  59.             ->where('rm.series = :series')
  60.             ->andWhere(
  61.                 $qb->expr()->orX(
  62.                     $qb->expr()->isNull('rm.expires'),
  63.                     $qb->expr()->lte('rm.expires', ':now')
  64.                 )
  65.             )
  66.             ->setParameter('series', $series)
  67.             ->setParameter('now', new \DateTime(), Types::DATETIME_MUTABLE)
  68.             ->orderBy('rm.expires', 'ASC')
  69.         ;
  71.         return $qb->getQuery()->getResult();
  72.     }
  74.     public function deleteSiblings(RememberMe $entity): void
  75.     {
  76.         $qb = $this->_em->createQueryBuilder();
  77.         $qb
  78.             ->delete($this->_entityName, 'rm')
  79.             ->where('rm.series = :series')
  80.             ->andWhere('rm.value != :value')
  81.             ->setParameter('series', $entity->getSeries())
  82.             ->setParameter('value', $entity->getValue())
  83.         ;
  85.         $qb->getQuery()->execute();
  86.     }
  88.     public function deleteBySeries(string $series): void
  89.     {
  90.         $qb = $this->_em->createQueryBuilder();
  91.         $qb
  92.             ->delete($this->_entityName, 'rm')
  93.             ->where('rm.series = :series')
  94.             ->setParameter('series', $series)
  95.         ;
  97.         $qb->getQuery()->execute();
  98.     }
  100.     public function deleteExpired(int $lastUsedLifetime, int $expiresLifetime): void
  101.     {
  102.         $qb = $this->_em->createQueryBuilder();
  103.         $qb
  104.             ->delete($this->_entityName, 'rm')
  105.             ->where('rm.lastUsed < :lastUsed')
  106.             ->orWhere('rm.expires < :expires')
  107.             ->setParameter('lastUsed', (new \DateTime())->sub(new \DateInterval('PT'.$lastUsedLifetime.'S')))
  108.             ->setParameter('expires', (new \DateTime())->sub(new \DateInterval('PT'.$expiresLifetime.'S')))
  109.         ;
  111.         $qb->getQuery()->execute();
  112.     }
  114.     public function persist(RememberMe ...$entities): void
  115.     {
  116.         foreach ($entities as $entity) {
  117.             $this->_em->persist($entity);
  118.         }
  120.         $this->_em->flush();
  121.     }
  122. }