vendor/symfony/http-client/ScopingHttpClient.php line 35

  1. <?php
  3. /*
  4.  * This file is part of the Symfony package.
  5.  *
  6.  * (c) Fabien Potencier <fabien@symfony.com>
  7.  *
  8.  * For the full copyright and license information, please view the LICENSE
  9.  * file that was distributed with this source code.
  10.  */
  12. namespace Symfony\Component\HttpClient;
  14. use Psr\Log\LoggerAwareInterface;
  15. use Psr\Log\LoggerInterface;
  16. use Symfony\Component\HttpClient\Exception\InvalidArgumentException;
  17. use Symfony\Contracts\HttpClient\HttpClientInterface;
  18. use Symfony\Contracts\HttpClient\ResponseInterface;
  19. use Symfony\Contracts\HttpClient\ResponseStreamInterface;
  20. use Symfony\Contracts\Service\ResetInterface;
  22. /**
  23.  * Auto-configure the default options based on the requested URL.
  24.  *
  25.  * @author Anthony Martin <anthony.martin@sensiolabs.com>
  26.  */
  27. class ScopingHttpClient implements HttpClientInterface, ResetInterface, LoggerAwareInterface
  28. {
  29.     use HttpClientTrait;
  31.     private HttpClientInterface $client;
  32.     private array $defaultOptionsByRegexp;
  33.     private ?string $defaultRegexp;
  35.     public function __construct(HttpClientInterface $client, array $defaultOptionsByRegexp, string $defaultRegexp = null)
  36.     {
  37.         $this->client = $client;
  38.         $this->defaultOptionsByRegexp = $defaultOptionsByRegexp;
  39.         $this->defaultRegexp = $defaultRegexp;
  41.         if (null !== $defaultRegexp && !isset($defaultOptionsByRegexp[$defaultRegexp])) {
  42.             throw new InvalidArgumentException(sprintf('No options are mapped to the provided "%s" default regexp.', $defaultRegexp));
  43.         }
  44.     }
  46.     public static function forBaseUri(HttpClientInterface $client, string $baseUri, array $defaultOptions = [], string $regexp = null): self
  47.     {
  48.         $regexp ??= preg_quote(implode('', self::resolveUrl(self::parseUrl('.'), self::parseUrl($baseUri))));
  50.         $defaultOptions['base_uri'] = $baseUri;
  52.         return new self($client, [$regexp => $defaultOptions], $regexp);
  53.     }
  55.     public function request(string $method, string $url, array $options = []): ResponseInterface
  56.     {
  57.         $e = null;
  58.         $url = self::parseUrl($url, $options['query'] ?? []);
  60.         if (\is_string($options['base_uri'] ?? null)) {
  61.             $options['base_uri'] = self::parseUrl($options['base_uri']);
  62.         }
  64.         try {
  65.             $url = implode('', self::resolveUrl($url, $options['base_uri'] ?? null));
  66.         } catch (InvalidArgumentException $e) {
  67.             if (null === $this->defaultRegexp) {
  68.                 throw $e;
  69.             }
  71.             $defaultOptions = $this->defaultOptionsByRegexp[$this->defaultRegexp];
  72.             $options = self::mergeDefaultOptions($options, $defaultOptions, true);
  73.             if (\is_string($options['base_uri'] ?? null)) {
  74.                 $options['base_uri'] = self::parseUrl($options['base_uri']);
  75.             }
  76.             $url = implode('', self::resolveUrl($url, $options['base_uri'] ?? null, $defaultOptions['query'] ?? []));
  77.         }
  79.         foreach ($this->defaultOptionsByRegexp as $regexp => $defaultOptions) {
  80.             if (preg_match("{{$regexp}}A", $url)) {
  81.                 if (null === $e || $regexp !== $this->defaultRegexp) {
  82.                     $options = self::mergeDefaultOptions($options, $defaultOptions, true);
  83.                 }
  84.                 break;
  85.             }
  86.         }
  88.         return $this->client->request($method, $url, $options);
  89.     }
  91.     public function stream(ResponseInterface|iterable $responses, float $timeout = null): ResponseStreamInterface
  92.     {
  93.         return $this->client->stream($responses, $timeout);
  94.     }
  96.     public function reset()
  97.     {
  98.         if ($this->client instanceof ResetInterface) {
  99.             $this->client->reset();
  100.         }
  101.     }
  103.     public function setLogger(LoggerInterface $logger): void
  104.     {
  105.         if ($this->client instanceof LoggerAwareInterface) {
  106.             $this->client->setLogger($logger);
  107.         }
  108.     }
  110.     public function withOptions(array $options): static
  111.     {
  112.         $clone = clone $this;
  113.         $clone->client = $this->client->withOptions($options);
  115.         return $clone;
  116.     }
  117. }