vendor/nellapp/sdk-bundle/src/ApiClientInterApp/Proxy/AbstractProxyClient.php line 23

Open in your IDE?
  1. <?php
  3. namespace Nellapp\Bundle\SDKBundle\ApiClientInterApp\Proxy;
  5. use Symfony\Component\HttpFoundation\Response;
  6. use Symfony\Component\HttpKernel\Exception\NotFoundHttpException;
  7. use Symfony\Component\HttpKernel\Exception\ServiceUnavailableHttpException;
  8. use Symfony\Component\HttpKernel\Exception\UnauthorizedHttpException;
  9. use Symfony\Contracts\HttpClient\Exception\ClientExceptionInterface;
  10. use Symfony\Contracts\HttpClient\Exception\RedirectionExceptionInterface;
  11. use Symfony\Contracts\HttpClient\Exception\ServerExceptionInterface;
  12. use Symfony\Contracts\HttpClient\Exception\TransportExceptionInterface;
  13. use Symfony\Contracts\HttpClient\ResponseInterface;
  15. abstract class AbstractProxyClient implements ProxyClientInterface
  16. {
  17.     /**
  18.      * @throws RedirectionExceptionInterface
  19.      * @throws ClientExceptionInterface
  20.      * @throws TransportExceptionInterface
  21.      * @throws ServerExceptionInterface
  22.      */
  23.     public function get(string $app, string $path, array $query = [], array $headers = []): Response
  24.     {
  25.         $response = $this->doGet($app, $path, $query, $headers);
  27.         if (401 === $response->getStatusCode()) {
  28.             throw new UnauthorizedHttpException('');
  29.         }
  31.         if (404 === $response->getStatusCode()) {
  32.             throw new NotFoundHttpException();
  33.         }
  35.         $statusCode = $response->getStatusCode();
  36.         if ($statusCode >= 500) {
  37.             throw new ServiceUnavailableHttpException();
  38.         }
  40.         $headers = array_filter($response->getHeaders(false), function (string $key) {
  41.             return in_array(strtolower($key), [
  42.                 'content-type',
  43.             ]);
  44.         }, ARRAY_FILTER_USE_KEY);
  46.         return new Response(
  47.             $response->getContent(),
  48.             $response->getStatusCode(),
  49.             $headers
  50.         );
  51.     }
  53.     abstract public function doGet(string $app, string $path, array $query = [], array $headers = []): ?ResponseInterface;
  54. }