123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166 |
- <?php
- namespace GuzzleHttp\Exception;
- use GuzzleHttp\BodySummarizer;
- use GuzzleHttp\BodySummarizerInterface;
- use Psr\Http\Client\RequestExceptionInterface;
- use Psr\Http\Message\RequestInterface;
- use Psr\Http\Message\ResponseInterface;
- use Psr\Http\Message\UriInterface;
- class RequestException extends TransferException implements RequestExceptionInterface
- {
-
- private $request;
-
- private $response;
-
- private $handlerContext;
- public function __construct(
- string $message,
- RequestInterface $request,
- ResponseInterface $response = null,
- \Throwable $previous = null,
- array $handlerContext = []
- ) {
-
- $code = $response ? $response->getStatusCode() : 0;
- parent::__construct($message, $code, $previous);
- $this->request = $request;
- $this->response = $response;
- $this->handlerContext = $handlerContext;
- }
-
- public static function wrapException(RequestInterface $request, \Throwable $e): RequestException
- {
- return $e instanceof RequestException ? $e : new RequestException($e->getMessage(), $request, null, $e);
- }
-
- public static function create(
- RequestInterface $request,
- ResponseInterface $response = null,
- \Throwable $previous = null,
- array $handlerContext = [],
- BodySummarizerInterface $bodySummarizer = null
- ): self {
- if (!$response) {
- return new self(
- 'Error completing request',
- $request,
- null,
- $previous,
- $handlerContext
- );
- }
- $level = (int) \floor($response->getStatusCode() / 100);
- if ($level === 4) {
- $label = 'Client error';
- $className = ClientException::class;
- } elseif ($level === 5) {
- $label = 'Server error';
- $className = ServerException::class;
- } else {
- $label = 'Unsuccessful request';
- $className = __CLASS__;
- }
- $uri = $request->getUri();
- $uri = static::obfuscateUri($uri);
-
-
- $message = \sprintf(
- '%s: `%s %s` resulted in a `%s %s` response',
- $label,
- $request->getMethod(),
- $uri->__toString(),
- $response->getStatusCode(),
- $response->getReasonPhrase()
- );
- $summary = ($bodySummarizer ?? new BodySummarizer())->summarize($response);
- if ($summary !== null) {
- $message .= ":\n{$summary}\n";
- }
- return new $className($message, $request, $response, $previous, $handlerContext);
- }
-
- private static function obfuscateUri(UriInterface $uri): UriInterface
- {
- $userInfo = $uri->getUserInfo();
- if (false !== ($pos = \strpos($userInfo, ':'))) {
- return $uri->withUserInfo(\substr($userInfo, 0, $pos), '***');
- }
- return $uri;
- }
-
- public function getRequest(): RequestInterface
- {
- return $this->request;
- }
-
- public function getResponse(): ?ResponseInterface
- {
- return $this->response;
- }
-
- public function hasResponse(): bool
- {
- return $this->response !== null;
- }
-
- public function getHandlerContext(): array
- {
- return $this->handlerContext;
- }
- }
|