ap2i/src/Service/Rest/ApiRequestService.php

<?php

declare(strict_types=1);

namespace App\Service\Rest;

use App\Service\Utils\UrlBuilder;
use Symfony\Component\HttpKernel\Exception\HttpException;
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;

/**
 * Base class for services sending requests to an external API.
 */
class ApiRequestService implements ApiRequestInterface
{
    public function __construct(
        protected HttpClientInterface $client,
    ) {
    }

    /**
     * Sends a GET request and returns the response's body decoded as json.
     *
     * @param array<mixed> $parameters
     * @param array<mixed> $options
     * @param bool         $throw      @see https://symfony.com/doc/current/http_client.html#handling-exceptions
     *
     * @return array<mixed>
     *
     * @throws HttpException
     * @throws \JsonException
     */
    public function getJsonContent(string $path, array $parameters = [], array $options = [], bool $throw = true): array
    {
        return json_decode($this->getContent($path, $parameters, $options, $throw), true, 512, JSON_THROW_ON_ERROR);
    }

    /**
     * Sends a GET request and returns the response's body.
     *
     * @param array<mixed> $parameters
     * @param array<mixed> $options
     * @param bool         $throw      @see https://symfony.com/doc/current/http_client.html#handling-exceptions
     *
     * @throws HttpException
     */
    public function getContent(string $path, array $parameters = [], array $options = [], bool $throw = true): string
    {
        try {
            return $this->get($path, $parameters, $options)->getContent($throw);
        } catch (ClientExceptionInterface|TransportExceptionInterface|RedirectionExceptionInterface|ServerExceptionInterface $e) {
            throw new HttpException($e->getCode(), 'Request error : '.$e->getMessage(), $e);
        }
    }

    /**
     * Sends a GET request and returns the response.
     *
     * @param array<mixed> $parameters
     * @param array<mixed> $options
     *
     * @throws HttpException
     */
    public function get(string $path, array $parameters = [], array $options = []): ResponseInterface
    {
        return $this->request('GET', $path, $parameters, $options);
    }

    /**
     * Complète les options en y ajoutant le body.
     *
     * @param array<mixed>        $options
     * @param array<mixed>|string $body
     *
     * @return array<mixed>
     */
    protected function addBodyOption(array $options, array|string $body): array
    {
        $option = is_array($body) ? ['json' => $body] : ['body' => $body];

        return array_merge($options, $option);
    }

    /**
     * Sends a POST request and returns the response.
     *
     * @param array<mixed>|string $body
     * @param array<mixed>        $parameters
     * @param array<mixed>        $options
     *
     * @throws HttpException
     */
    public function post(string $path, array|string $body, array $parameters = [], array $options = []): ResponseInterface
    {
        $options = $this->addBodyOption($options, $body);

        return $this->request('POST', $path, $parameters, $options);
    }

    /**
     * Sends a PUT request and returns the response.
     *
     * @param array<mixed>|string $body
     * @param array<mixed>        $parameters
     * @param array<mixed>        $options
     *
     * @throws HttpException
     */
    public function put(string $path, array|string $body, array $parameters = [], array $options = []): ResponseInterface
    {
        $options = $this->addBodyOption($options, $body);

        return $this->request('PUT', $path, $parameters, $options);
    }

    /**
     * Sends a DELETE request and returns the response.
     *
     * @param array<mixed> $parameters
     * @param array<mixed> $options
     *
     * @throws HttpException
     */
    public function delete(string $path, array $parameters = [], array $options = []): ResponseInterface
    {
        return $this->request('DELETE', $path, $parameters, $options);
    }

    /**
     * Send an HTTP request to a REST API,
     * and return the decoded content of the response's body.
     *
     * @param array<mixed> $parameters
     * @param array<mixed> $options
     *
     * @throws HttpException
     */
    public function request(
        string $method,
        string $url,
        array $parameters = [],
        array $options = [],
    ): ResponseInterface {
        $url = ltrim($url, '/');
        $url = UrlBuilder::concatParameters($url, $parameters);

        try {
            return $this->client->request($method, $url, $options);
        } catch (TransportExceptionInterface $e) {
            throw new HttpException($e->getCode(), 'Request error : '.$e->getMessage(), $e);
        }
    }
}