hydra-sql/src/Service/SQLLoginService.php

<?php

namespace App\Service;

use App\SQLLogin\Exception\DatabaseConnectionException;
use App\SQLLogin\Exception\DataToFetchConfigurationException;
use App\SQLLogin\Exception\EmptyResultException;
use App\SQLLogin\Exception\LoginElementsConfigurationException;
use App\SQLLogin\Exception\NullDataToFetchException;
use App\SQLLogin\SQLLoginConnect;
use App\SQLLogin\SQLLoginRequest;
use PDO;
use PDOException;
use Psr\Log\LoggerInterface;
use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;

class SQLLoginService extends AbstractController
{
    public const MAX_RETRY = 3;
    private PDO $pdo;

    public function __construct(
        private SQLLoginRequest $sqlLoginRequest,
        private LoggerInterface $loggerInterface
    ) {
        $this->sqlLoginRequest = $sqlLoginRequest;
        $this->loggerInterface = $loggerInterface;
        $this->pdo = $this->getConnection();
    }

    public function fetchPasswordAndDatas(string $login): array
    {
        try {
            $dataRequest = $this->sqlLoginRequest->getDatasRequest();
            $datas = $this->executeRequestWithLogin($dataRequest, $login);
        } catch (NullDataToFetchException $e) {
            throw new DataToFetchConfigurationException($e->getMessage());
        } catch (PDOException $e) {
            $this->loggerInterface->critical($e->getMessage());
            throw new LoginElementsConfigurationException($e->getMessage());
        }

        return $datas;
    }

    private function executeRequestWithLogin(string $request, string $login): array
    {
        $attempt = 0;
        while ($attempt < self::MAX_RETRY) {
            $query = $this->pdo->prepare($request);
            $query->execute([$this->sqlLoginRequest->getLoginColumnName() => $login]);
            $datas = $query->fetch(PDO::FETCH_ASSOC);
            $query->closeCursor();
            if (false === $datas) {
                usleep(1000);
                ++$attempt;
            } else {
                break;
            }
        }
        if (self::MAX_RETRY === $attempt) {
            throw new EmptyResultException('Résultat vide après 3 tentatives');
        }

        return $datas;
    }

    private function getConnection(): PDO
    {
        // Appel du singleton
        try {
            $sqlLogin = SQLLoginConnect::getInstance();
            $pdo = $sqlLogin->connect($this->sqlLoginRequest->getDatabaseDsn(), $this->sqlLoginRequest->getDbUser(), $this->sqlLoginRequest->getDbPassword());
        } catch (PDOException $e) {
            $this->loggerInterface->critical($e->getMessage());
            throw new DatabaseConnectionException($e->getMessage());
        }

        return $pdo;
    }
}