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

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.  * @internal
  23.  */
  24. class RememberMeRepository extends ServiceEntityRepository
  25. {
  26.     /**
  27.      * @var Connection
  28.      */
  29.     private $connection;
  31.     public function __construct(ManagerRegistry $registry)
  32.     {
  33.         parent::__construct($registry, RememberMe::class);
  35.         $this->connection = $registry->getConnection();
  36.     }
  38.     public function lockTable(): void
  39.     {
  40.         $table = $this->getClassMetadata()->getTableName();
  42.         $this->connection->executeStatement("LOCK TABLES $table WRITE, $table AS t0_ WRITE");
  43.     }
  45.     public function unlockTable(): void
  46.     {
  47.         $this->connection->executeStatement('UNLOCK TABLES');
  48.     }
  50.     /**
  51.      * @return array<RememberMe>
  52.      */
  53.     public function findBySeries(string $series): array
  54.     {
  55.         $qb = $this->createQueryBuilder('rm');
  56.         $qb
  57.             ->where('rm.series = :series')
  58.             ->andWhere(
  59.                 $qb->expr()->orX(
  60.                     $qb->expr()->isNull('rm.expires'),
  61.                     $qb->expr()->lte('rm.expires', ':now')
  62.                 )
  63.             )
  64.             ->setParameter('series', $series)
  65.             ->setParameter('now', new \DateTime(), Types::DATETIME_MUTABLE)
  66.             ->orderBy('rm.expires', 'ASC')
  67.         ;
  69.         return $qb->getQuery()->getResult();
  70.     }
  72.     public function deleteSiblings(RememberMe $entity): void
  73.     {
  74.         $qb = $this->_em->createQueryBuilder();
  75.         $qb
  76.             ->delete($this->_entityName, 'rm')
  77.             ->where('rm.series = :series')
  78.             ->andWhere('rm.value != :value')
  79.             ->setParameter('series', $entity->getSeries())
  80.             ->setParameter('value', $entity->getValue())
  81.         ;
  83.         $qb->getQuery()->execute();
  84.     }
  86.     public function deleteBySeries(string $series): void
  87.     {
  88.         $qb = $this->_em->createQueryBuilder();
  89.         $qb
  90.             ->delete($this->_entityName, 'rm')
  91.             ->where('rm.series = :series')
  92.             ->setParameter('series', $series)
  93.         ;
  95.         $qb->getQuery()->execute();
  96.     }
  98.     public function deleteExpired(int $lastUsedLifetime, int $expiresLifetime): void
  99.     {
  100.         $qb = $this->_em->createQueryBuilder();
  101.         $qb
  102.             ->delete($this->_entityName, 'rm')
  103.             ->where('rm.lastUsed < :lastUsed')
  104.             ->orWhere('rm.expires < :expires')
  105.             ->setParameter('lastUsed', (new \DateTime())->sub(new \DateInterval('PT'.$lastUsedLifetime.'S')))
  106.             ->setParameter('expires', (new \DateTime())->sub(new \DateInterval('PT'.$expiresLifetime.'S')))
  107.         ;
  109.         $qb->getQuery()->execute();
  110.     }
  112.     public function persist(RememberMe ...$entities): void
  113.     {
  114.         foreach ($entities as $entity) {
  115.             $this->_em->persist($entity);
  116.         }
  118.         $this->_em->flush();
  119.     }
  120. }