feat: add UsetrenoHttpClient

!fixup bb244e40f5fa42294acc7cc7f925796325ada4c5

src/Service/Remote/Exception/AuthorizeException.php

@@ -0,0 +1,8 @@
+<?php
+
+namespace App\Service\Remote\Exception;
+
+class AuthorizeException extends \RuntimeException
+{
+
+}

src/Service/Remote/UsetrenoHttpClient.php

@@ -0,0 +1,145 @@
+<?php
+declare(strict_types=1);
+
+namespace App\Service\Remote;
+
+use App\Entity\Remote\Usetreno\AuthRequest;
+use App\Service\Remote\Exception\AuthorizeException;
+use Psr\Log\LoggerInterface;
+use Symfony\Contracts\HttpClient\Exception\ClientExceptionInterface;
+use Symfony\Contracts\HttpClient\Exception\RedirectionExceptionInterface;
+use Symfony\Contracts\HttpClient\Exception\ServerExceptionInterface;
+use Symfony\Contracts\HttpClient\Exception\TransportExceptionInterface;
+use Symfony\Contracts\HttpClient\HttpClientInterface;
+use Symfony\Contracts\HttpClient\ResponseInterface;
+use Symfony\Contracts\HttpClient\ResponseStreamInterface;
+
+class UsetrenoHttpClient implements HttpClientInterface
+{
+    const AUTHORIZE_API = "https://topapi.top-test.cz/chameleon/api/v1/token";
+
+    protected ?string $authorizationToken = null;
+
+    public function __construct(protected HttpClientInterface $innerClient, protected readonly LoggerInterface $logger, protected readonly string $username,
+                                protected readonly string $password) { }
+
+    /**
+     * @param string $method
+     * @param string $url
+     * @param array<string, mixed> $options
+     * @return ResponseInterface
+     * @throws ClientExceptionInterface
+     * @throws RedirectionExceptionInterface
+     * @throws ServerExceptionInterface
+     * @throws TransportExceptionInterface
+     */
+    public function request(string $method, string $url, array $options = []): ResponseInterface {
+        if ($this->authorizationToken === null) {
+            $this->authorize();
+        }
+
+        return $this->innerClient->request($method, $url, $options);
+    }
+
+    /**
+     * @param ResponseInterface|iterable<array-key, ResponseInterface> $responses One or more responses created by the current HTTP client
+     * @param float|null $timeout
+     * @return ResponseStreamInterface
+     * @throws ClientExceptionInterface
+     * @throws RedirectionExceptionInterface
+     * @throws ServerExceptionInterface
+     * @throws TransportExceptionInterface
+     */
+    public function stream(iterable|ResponseInterface $responses, float $timeout = null): ResponseStreamInterface
+    {
+        if ($this->authorizationToken === null) {
+            $this->authorize();
+        }
+
+        return $this->innerClient->stream($responses, $timeout);
+    }
+
+    /**
+     * @param array<string, mixed> $options
+     * @return static(UsetrenoHttpClient)
+     * @throws ClientExceptionInterface
+     * @throws RedirectionExceptionInterface
+     * @throws ServerExceptionInterface
+     * @throws TransportExceptionInterface
+     */
+    public function withOptions(array $options): static
+    {
+        if ($this->authorizationToken === null) {
+            $this->authorize();
+        }
+
+        $this->innerClient = $this->innerClient->withOptions($options);
+        return $this;
+    }
+
+    /**
+     * @throws TransportExceptionInterface
+     * @throws ClientExceptionInterface
+     * @throws RedirectionExceptionInterface
+     * @throws ServerExceptionInterface
+     */
+    protected function authorize(): void {
+        $this->logger->debug("trying authorize request", [
+            "AUTHORIZE_API" => static::AUTHORIZE_API
+        ]);
+
+        $rq = $this->innerClient->request(
+            "POST",
+            static::AUTHORIZE_API,
+            [
+                'json' => new AuthRequest($this->username, $this->password),
+            ]
+        );
+
+        $statusCode = $rq->getStatusCode();
+        $responseData = $rq->getContent(false);
+
+        if ($statusCode != 200) {
+            $this->logger->error("authorization request status code is not ok", [
+               "AUTHORIZE_API" => static::AUTHORIZE_API,
+                "statusCode" => $statusCode,
+                "content" => $responseData,
+                "username" => $this->username
+            ]);
+
+            throw new AuthorizeException("Return code is not 200 OK (got: code: $statusCode)");
+        }
+
+        $this->authorizationToken = $this->processAuthorizeResponse($responseData);
+        $this->innerClient = $this->innerClient->withOptions([
+            'headers' => [
+                'Authorization' => "Bearer " . $this->authorizationToken
+            ]
+        ]);
+    }
+
+    /**
+     * @param string $responseData
+     * @return string Bearer token
+     * @throws AuthorizeException
+     */
+    protected function processAuthorizeResponse(string $responseData): string {
+        $data = json_decode($responseData);
+
+        if (!is_object($data)) {
+            $this->logger->error("authorize: received null response data", [
+                "responseData" => $responseData
+            ]);
+            throw new AuthorizeException("Can't decode json response");
+        }
+
+        if (!isset($data->data->token)) {
+            $this->logger->error("authorize: empty token in response data", [
+                "responseData" => $responseData
+            ]);
+            throw new AuthorizeException("Got invalid json response");
+        }
+
+        return $data->data->token;
+    }
+}