Saxulum\HttpClient\Guzzle\HttpClient

Complexity

Total Complexity

8

Size/Duplication

Total Lines	70
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	7

Importance

Changes	1
Bugs	0	Features	0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	2
A	request()	0	15	1
A	prepareRequest()	0	18	2
A	prepareHeaders()	0	10	3

<?php

namespace Saxulum\HttpClient\Guzzle;

use GuzzleHttp\Client;
use GuzzleHttp\Message\Request as GuzzleRequest;
use GuzzleHttp\Message\Response as GuzzleResponse;
use GuzzleHttp\Stream\Stream;
use Saxulum\HttpClient\HeaderConverter;
use Saxulum\HttpClient\HttpClientInterface;
use Saxulum\HttpClient\Request;
use Saxulum\HttpClient\Response;

class HttpClient implements HttpClientInterface
{
    /**
     * @var Client
     */
    protected $client;

    public function __construct(Client $client = null)
    {
        $this->client = null !== $client ? $client : new Client();
    }

    /**
     * @param  Request  $request
     * @return Response
     */
    public function request(Request $request)
    {
        $guzzleRequest = $this->prepareRequest($request);

        /** @var GuzzleResponse $guzzleResponse */
        $guzzleResponse = $this->client->send($guzzleRequest);

        return new Response(
            $guzzleResponse->getProtocolVersion(),
            (int) $guzzleResponse->getStatusCode(),
            $guzzleResponse->getReasonPhrase(),
            HeaderConverter::convertComplexAssociativeToFlatAssociative($guzzleResponse->getHeaders()),
            (string) $guzzleResponse->getBody()
        );
    }

    /**
     * @param  Request       $request
     * @return GuzzleRequest
     */
    protected function prepareRequest(Request $request)
    {
        $guzzleRequest = $this->client->createRequest(
            $request->getMethod(),
            (string) $request->getUrl(),
            array(
                'version' => $request->getProtocolVersion(),
            )
        );

        if (null !== $content = $request->getContent()) {
            $guzzleRequest->setBody(Stream::factory($content));
        }

        $guzzleRequest->setHeaders($this->prepareHeaders($request));

        return $guzzleRequest;
    }

    /**
     * @param  Request $request
     * @return array
     */
    protected function prepareHeaders(Request $request)
    {
        $headers = $request->getHeaders();

        if (null !== $request->getContent() && !isset($headers['Content-Type'])) {
            $headers['Content-Type'] = 'application/x-www-form-urlencoded';
        }

        return $headers;
    }
}