vendor/florianv/exchanger/src/Service/HttpService.php line 105

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. /*
  6.  * This file is part of Exchanger.
  7.  *
  8.  * (c) Florian Voutzinos <florian@voutzinos.com>
  9.  *
  10.  * For the full copyright and license information, please view the LICENSE
  11.  * file that was distributed with this source code.
  12.  */
  14. namespace Exchanger\Service;
  16. use Http\Client\HttpClient;
  17. use Http\Discovery\HttpClientDiscovery;
  18. use Http\Discovery\Psr17FactoryDiscovery;
  19. use Psr\Http\Client\ClientInterface;
  20. use Psr\Http\Message\RequestFactoryInterface;
  21. use Psr\Http\Message\RequestInterface;
  22. use Psr\Http\Message\ResponseInterface;
  24. /**
  25.  * Base class for http based services.
  26.  *
  27.  * @author Florian Voutzinos <florian@voutzinos.com>
  28.  */
  29. abstract class HttpService extends Service
  30. {
  31.     /**
  32.      * The client.
  33.      *
  34.      * @var HttpClient|ClientInterface
  35.      */
  36.     private $httpClient;
  38.     /**
  39.      * The request factory.
  40.      *
  41.      * @var RequestFactoryInterface
  42.      */
  43.     private $requestFactory;
  45.     /**
  46.      * @param HttpClient|ClientInterface|null $httpClient
  47.      * @param RequestFactoryInterface|null    $requestFactory
  48.      * @param array                           $options
  49.      */
  50.     public function __construct($httpClient = null, RequestFactoryInterface $requestFactory = null, array $options = [])
  51.     {
  52.         if (null === $httpClient) {
  53.             $httpClient = HttpClientDiscovery::find();
  54.         } else {
  55.             if (!$httpClient instanceof ClientInterface && !$httpClient instanceof HttpClient) {
  56.                 throw new \LogicException('Client must be an instance of Http\\Client\\HttpClient or Psr\\Http\\Client\\ClientInterface');
  57.             }
  58.         }
  60.         $this->httpClient = $httpClient;
  61.         $this->requestFactory = $requestFactory ?: Psr17FactoryDiscovery::findRequestFactory();
  63.         parent::__construct($options);
  64.     }
  66.     /**
  67.      * @param string $url
  68.      * @param array  $headers
  69.      *
  70.      * @return \Psr\Http\Message\RequestInterface
  71.      */
  72.     private function buildRequest($url, array $headers = []): RequestInterface
  73.     {
  74.         $request = $this->requestFactory->createRequest('GET', $url);
  75.         foreach ($headers as $header => $value) {
  76.             $request = $request->withHeader($header, $value);
  77.         }
  79.         return $request;
  80.     }
  82.     /**
  83.      * Fetches the content of the given url.
  84.      *
  85.      * @param string $url
  86.      * @param array  $headers
  87.      *
  88.      * @return string
  89.      */
  90.     protected function request($url, array $headers = []): string
  91.     {
  92.         return $this->getResponse($url, $headers)->getBody()->__toString();
  93.     }
  95.     /**
  96.      * Fetches the content of the given url.
  97.      *
  98.      * @param string $url
  99.      * @param array  $headers
  100.      *
  101.      * @return \Psr\Http\Message\ResponseInterface
  102.      */
  103.     protected function getResponse($url, array $headers = []): ResponseInterface
  104.     {
  105.         return $this->httpClient->sendRequest($this->buildRequest($url, $headers));
  106.     }
  107. }