app/Service/Repository/ORM/UserRepository.php line 20

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Sq\Service\Repository\ORM;
  5. use Doctrine\Bundle\DoctrineBundle\Repository\ServiceEntityRepository;
  6. use Doctrine\ORM\Query\ResultSetMappingBuilder;
  7. use Doctrine\Persistence\ManagerRegistry;
  8. use Sq\Entity\Schema\ORM\User;
  9. use Sq\Service\Config\SqConfig;
  10. use Symfony\Component\Security\Core\Exception\UserNotFoundException;
  11. use Symfony\Component\Security\Core\User\UserInterface;
  12. use Symfony\Component\Security\Core\User\UserProviderInterface;
  14. /**
  15.  * @method User|null find($id, $lockMode = null, $lockVersion = null)
  16.  * @method User|null findOneBy(array $criteria, array $orderBy = null)
  17.  * @method User[]    findAll()
  18.  * @method User[]    findBy(array $criteria, array $orderBy = null, $limit = null, $offset = null)
  19.  */
  20. class UserRepository extends ServiceEntityRepository implements UserProviderInterface
  21. {
  22.     private string $encryptionKey = '';
  24.     public function __construct(ManagerRegistry $registry, SqConfig $config)
  25.     {
  26.         parent::__construct($registry, User::class);
  27.         $key = $config->getConfig()['crypto_key'] ?? '';
  28.         $this->encryptionKey = is_string($key) ? $key : '';
  29.     }
  31.     /**
  32.      * This complicated query is necessary to ignore case differences.
  33.      */
  34.     public function findOneByEmail(string $email): ?User
  35.     {
  36.         $rsm = new ResultSetMappingBuilder($this->getEntityManager());
  37.         $rsm->addRootEntityFromClassMetadata(User::class, 'u');
  38.         $query = $this->getEntityManager()->createNativeQuery(sprintf(
  39.             'SELECT %s FROM `users` AS `u` WHERE LOWER(CONVERT(AES_DECRYPT(`u`.`u_email`, :key) USING \'utf8\')) = :email LIMIT 1;',
  40.             $rsm->generateSelectClause(['u' => 'u'])
  41.         ), $rsm);
  42.         $query->setParameters(['email' => strtolower($email), 'key' => $this->encryptionKey]);
  43.         return $query->getOneOrNullResult();
  44.     }
  46.     public function supportsClass(string $class): bool
  47.     {
  48.         return $class === User::class;
  49.     }
  51.     public function refreshUser(UserInterface $user): UserInterface
  52.     {
  53.         $this->getEntityManager()->refresh($user);
  54.         return $user;
  55.     }
  57.     /** @deprecated (delete when upgrading to Symfony 6+) */
  58.     public function loadUserByUsername(string $username): UserInterface
  59.     {
  60.         return $this->loadUserByIdentifier($username);
  61.     }
  63.     public function loadUserByIdentifier(string $identifier): UserInterface
  64.     {
  65.         if (null === $user = $this->findOneBy(['id' => $identifier]))
  66.         {
  67.             throw new UserNotFoundException;
  68.         }
  70.         // make sure the user is still in overhaul
  71.         if ($user->isRolledBackToLegacy())
  72.         {
  73.             throw new UserNotFoundException;
  74.         }
  75.         return $user;
  76.     }
  77. }