chillerlan\HTTP\Psr18\CurlClient

Complexity

Total Complexity

3

Size/Duplication

Total Lines	49
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	9

Importance

Changes

0

1 Method

Rating	Name	Duplication	Size	Complexity
A	sendRequest()	0	35	3

<?php
/**
 * Class HTTPClient
 *
 * @filesource   HTTPClient.php
 * @created      27.08.2018
 * @package      chillerlan\HTTP
 * @author       smiley <smiley@chillerlan.net>
 * @copyright    2018 smiley
 * @license      MIT
 */

namespace chillerlan\HTTP\Psr18;

use Psr\Http\Message\{RequestInterface, ResponseInterface};

class CurlClient extends HTTPClientAbstract{

	/**
	 * Sends a PSR-7 request.
	 *
	 * @param \Psr\Http\Message\RequestInterface $request
	 *
	 * @return \Psr\Http\Message\ResponseInterface
	 *
	 * @throws \Psr\Http\Client\ClientExceptionInterface If an error happens during processing the request.
	 * @throws \Exception                                If processing the request is impossible (eg. bad configuration).
	 */
	public function sendRequest(RequestInterface $request):ResponseInterface{
		/** @var \chillerlan\HTTP\Psr18\CurlHandle $handle */
		$handle = new $this->options->curlHandle($request, $this->responseFactory->createResponse(), $this->options);
		$handle->init();

		curl_exec($handle->curl);

		$errno = curl_errno($handle->curl);

		if($errno !== CURLE_OK){
			$error = curl_error($handle->curl);

			$network_errors = [
				CURLE_COULDNT_RESOLVE_PROXY,
				CURLE_COULDNT_RESOLVE_HOST,
				CURLE_COULDNT_CONNECT,
				CURLE_OPERATION_TIMEOUTED,
				CURLE_SSL_CONNECT_ERROR,
				CURLE_GOT_NOTHING,
			];

			$this->logger->error('cURL error #'.$errno.': '.$error);

			if(in_array($errno, $network_errors, true)){
				throw new NetworkException($error, $request);
			}

			throw new RequestException($error, $request);
		}

		$handle->close();
		$handle->response->getBody()->rewind();

		return $handle->response;
	}

}