Deprecated: Constant E_STRICT is deprecated in /home/pastorz/old-espace-client/vendor/symfony/error-handler/ErrorHandler.php on line 58

Deprecated: Constant E_STRICT is deprecated in /home/pastorz/old-espace-client/vendor/symfony/error-handler/ErrorHandler.php on line 76
Symfony Profiler

src/Service/Auctionis/AuctionisService.php line 77

Open in your IDE?
  1. <?php
  3. namespace App\Service\Auctionis;
  5. use App\Model\Auctionis\ErrorApiResponse;
  6. use App\Model\Auctionis\SuccessApiResponse;
  7. use DateTime;
  8. use Psr\Log\LoggerInterface;
  9. use Symfony\Component\DependencyInjection\ParameterBag\ParameterBagInterface;
  10. use Symfony\Component\HttpFoundation\Cookie;
  11. use Symfony\Component\HttpFoundation\RequestStack;
  12. use Symfony\Component\Routing\RouterInterface;
  13. use Symfony\Component\Serializer\SerializerInterface;
  14. use Symfony\Contracts\HttpClient\HttpClientInterface;
  15. use Symfony\Contracts\HttpClient\ResponseInterface;
  17. class AuctionisService
  18. {
  19.     private ?string $jwt;
  21.     public function __construct(
  22.         private RequestStack $requestStack,
  23.         private HttpClientInterface $auctionisClient,
  24.         private LoggerInterface $auctionisLogger,
  25.         private RouterInterface $router,
  26.         private SerializerInterface $serializer,
  27.         private ParameterBagInterface $params
  28.     )
  29.     {
  30.         $this->jwt = $requestStack->getCurrentRequest()?->cookies->get('auctionisJwt');
  31.     }
  33.     public function login(): string
  34.     {
  35.         $params = [
  36.             'POST', 'login_check', [
  37.                 'json' => [
  38.                     'username' => 'bo.npcj',
  39.                     'password' => 'bo.npcj',
  40.                 ]
  41.             ],
  42.         ];
  44.         $response = $this->auctionisClient->request(...$params);
  46.         $apiResponse = $this->handleResponse($response, $params);
  48.         return $apiResponse->getData()['token'];
  49.     }
  51.     public function createTokenCookie(string $token): Cookie
  52.     {
  53.         return Cookie::create('auctionisJwt', $token);
  54.     }
  56.     public function tokenIsExpired(): bool
  57.     {
  58.         if (!$this->jwt) {
  59.             return true;
  60.         }
  62.         return new DateTime() > (new DateTime())->setTimestamp($this->tokenDecode($this->jwt)->exp);
  63.     }
  65.     public function getToken(): ?string
  66.     {
  67.         return $this->jwt;
  68.     }
  70.     private function tokenDecode($token)
  71.     {
  72.         list($header, $payload) = explode('.', $token);
  74.         return json_decode(base64_decode($payload));
  75.     }
  77.     public function request(string $method, string $path, array $body = null, array $query = null, string $dto = null, string $errorRedirectRoute = 'app_security_login', array $errorRedirectRouteParameters = []): mixed
  78.     {
  79.         if ($this->tokenIsExpired()) {
  80.             $this->jwt = null;
  81.         }
  83.         if ($path === 'login_buyer_folder') {
  84.             $this->jwt = null;
  85.         }
  87.         if (!$this->jwt) {
  88.             $token = $this->login();
  89.             $this->jwt = $token;
  90.         }
  92.         $params = [
  93.             $method, $path, [
  94.                 'query' => $query,
  95.                 'json' => $body,
  96.                 'headers' => [
  97.                     'Content-Type' => $method === 'PATCH' ? 'application/merge-patch+json' : 'application/json',
  98.                     'Authorization' => sprintf('Bearer %s', $this->jwt),
  99.                 ],
  100.             ],
  101.         ];
  103.         $response = $this->auctionisClient->request(...$params);
  105.         $apiResponse = $this->handleResponse($response, $params);
  106.         if ($apiResponse instanceof ErrorApiResponse) {
  107.             if ($apiResponse->getStatusCode() == 401 && $apiResponse->getMessage() == "JWT Token not found") {
  108.                 $this->requestStack->getSession()->getFlashBag()->add('error', 'Vous devez être connecté pour accéder à cette page');
  109.             } else {
  110.                 $this->requestStack->getSession()->getFlashBag()->add('error', $apiResponse->getMessage());
  111.             }
  112.         }
  114.         if (empty($apiResponse->getData())) {
  115.             return null;
  116.         }
  118.         $data = $apiResponse->getData();
  119.         if (!$dto) {
  120.             return $data ?? $apiResponse;
  121.         }
  123.         if (str_ends_with($dto, '[]')) {
  124.             $data = $data['hydra:member'];
  125.         }
  127.         return $this->serializer->deserialize(json_encode($data), $dto, 'json');
  128.     }
  130.     private function handleResponse(ResponseInterface $response, array $params): ErrorApiResponse|SuccessApiResponse
  131.     {
  132.         if ($response->getStatusCode() >= 500) {
  133.             $headers = $response->getHeaders(false);
  134.             $debugLink = array_key_exists('x-debug-token-link', $headers) ? $headers['x-debug-token-link'][0] : '';
  136.             $this->auctionisLogger->error(sprintf('Auctionis API server error (%s): %s', $debugLink, $response->getContent(false)), [
  137.                 'status_code' => $response->getStatusCode(),
  138.                 'response_headers' => $headers,
  139.                 'params' => $params,
  140.             ]);
  142.             $message = 'error.server_error';
  144.             if ($this->params->get('env') === 'dev') {
  145.                 $message .= ' - ' . $debugLink;
  146.             }
  148.             return new ErrorApiResponse($response->getStatusCode(), message: $message);
  149.         }
  151.         if ($response->getStatusCode() >= 400) {
  152.             $headers = $response->getHeaders(false);
  153.             $debugLink = array_key_exists('x-debug-token-link', $headers) ? $headers['x-debug-token-link'][0] : '';
  155.             // Do not log 401 errors (JWT Token not found / Invalid credentials)
  156.             if ($response->getStatusCode() !== 401) {
  157.                 $this->auctionisLogger->error(sprintf('Auctionis API client error (%s): %s', $debugLink, $response->getContent(false)), [
  158.                     'status_code' => $response->getStatusCode(),
  159.                     'response_headers' => $headers,
  160.                     'params' => $params,
  161.                 ]);
  162.             }
  164.             $data = $response->toArray(false);
  166.             if (array_key_exists('message', $data)) {
  167.                 $message = $data['message'];
  168.             } elseif (array_key_exists('hydra:description', $data)) {
  169.                 $message = $data['hydra:description'];
  170.             } else {
  171.                 $message = 'error.client_error';
  172.             }
  174.             return new ErrorApiResponse($response->getStatusCode(), $message, $data);
  175.         }
  177.         if ($response->getStatusCode() >= 300) {
  178.             return new ErrorApiResponse($response->getStatusCode(), 'error.server_error');
  179.         }
  181.         return new SuccessApiResponse($response->getStatusCode(), 'success', $response->toArray(false));
  182.     }
  183. }