Swis\JsonApi\Client\Client

Complexity

Total Complexity

14

Size/Duplication

Total Lines	184
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes

0

13 Methods

Rating	Name	Duplication	Size	Complexity
A	setBaseUri()	0	3	1
A	getBaseUri()	0	3	1
A	__construct()	0	8	1
A	request()	0	8	2
A	get()	0	3	1
A	getDefaultHeaders()	0	3	1
A	setDefaultHeaders()	0	3	1
A	post()	0	3	1
A	delete()	0	3	1
A	buildRequest()	0	3	1
A	getEndpoint()	0	3	1
A	patch()	0	3	1
A	mergeHeaders()	0	3	1

<?php

namespace Swis\JsonApi\Client;

use Http\Client\Exception\HttpException;
use Http\Client\HttpClient;
use Http\Message\MessageFactory;
use Psr\Http\Message\RequestInterface;
use Swis\JsonApi\Client\Interfaces\ClientInterface;

class Client implements ClientInterface
{
    /**
     * @var string
     */
    const METHOD_DELETE = 'DELETE';

    /**
     * @var string
     */
    const METHOD_GET = 'GET';

    /**
     * @var string
     */
    const METHOD_PATCH = 'PATCH';

    /**
     * @var string
     */
    const METHOD_POST = 'POST';

    /**
     * @var \Http\Client\HttpClient
     */
    private $client;

    /**
     * @var string
     */
    private $baseUri;

    /**
     * @var MessageFactory
     */
    private $messageFactory;

    protected $defaultHeaders = [
        'Accept'       => 'application/vnd.api+json',
        'Content-Type' => 'application/vnd.api+json',
    ];

    /**
     * @param \Http\Client\HttpClient $client
     * @param string                  $baseUri
     * @param MessageFactory          $messageFactory
     */
    public function __construct(
        HttpClient $client,
        string $baseUri,
        MessageFactory $messageFactory
    ) {
        $this->client = $client;
        $this->baseUri = $baseUri;
        $this->messageFactory = $messageFactory;
    }

    /**
     * @return string
     */
    public function getBaseUri(): string
    {
        return $this->baseUri;
    }

    /**
     * @param string $baseUri
     */
    public function setBaseUri(string $baseUri)
    {
        $this->baseUri = $baseUri;
    }

    /**
     * @param string $endpoint
     * @param array  $headers
     *
     * @throws \Http\Client\Exception
     *
     * @return \Psr\Http\Message\ResponseInterface
     */
    public function get(string $endpoint, array $headers = [])
    {
        return $this->request(static::METHOD_GET, $endpoint, null, $headers);
    }

    /**
     * @param string                                                                         $endpoint
     * @param resource|string|int|float|bool|\Psr\Http\Message\StreamInterface|callable|null $body
     * @param array                                                                          $headers
     *
     * @throws \Http\Client\Exception
     *
     * @return \Psr\Http\Message\ResponseInterface
     */
    public function post(string $endpoint, $body, array $headers = [])
    {
        return $this->request(static::METHOD_POST, $endpoint, $body, $headers);
    }

    /**
     * @param string                                                                         $endpoint
     * @param resource|string|int|float|bool|\Psr\Http\Message\StreamInterface|callable|null $body
     * @param array                                                                          $headers
     *
     * @throws \Http\Client\Exception
     *
     * @return \Psr\Http\Message\ResponseInterface
     */
    public function patch(string $endpoint, $body, array $headers = [])
    {
        return $this->request(static::METHOD_PATCH, $endpoint, $body, $headers);
    }

    /**
     * @param string $endpoint
     * @param array  $headers
     *
     * @throws \Http\Client\Exception
     *
     * @return \Psr\Http\Message\ResponseInterface
     */
    public function delete(string $endpoint, array $headers = [])
    {
        return $this->request(static::METHOD_DELETE, $endpoint, null, $headers);
    }

    /**
     * @param string                                                                         $method
     * @param string                                                                         $endpoint
     * @param resource|string|int|float|bool|\Psr\Http\Message\StreamInterface|callable|null $body
     * @param array                                                                          $headers
     *
     * @throws \Http\Client\Exception
     *
     * @return \Psr\Http\Message\ResponseInterface
     */
    public function request(string $method, string $endpoint, $body = null, array $headers = [])
    {
        $request = $this->buildRequest($method, $endpoint, $body, $headers);

        try {
            return $this->client->sendRequest($request);
        } catch (HttpException $e) {
            return $e->getResponse();
        }
    }

    /**
     * @param string                                                                         $method
     * @param string                                                                         $endpoint
     * @param resource|string|int|float|bool|\Psr\Http\Message\StreamInterface|callable|null $body
     * @param array                                                                          $headers
     *
     * @return \Psr\Http\Message\RequestInterface
     */
    protected function buildRequest(string $method, string $endpoint, $body = null, array $headers = []): RequestInterface
    {
        return $this->messageFactory->createRequest($method, $this->getEndpoint($endpoint), $this->mergeHeaders($headers), $body);
    }

    /**
     * @param string $endpoint
     *
     * @return string
     */
    protected function getEndpoint(string $endpoint): string
    {
        return $this->baseUri.$endpoint;
    }

    protected function mergeHeaders(array $headers = [])
    {
        return array_merge($this->defaultHeaders, $headers);
    }

    public function getDefaultHeaders(): array
    {
        return $this->defaultHeaders;
    }

    public function setDefaultHeaders(array $defaultHeaders)
    {
        $this->defaultHeaders = $defaultHeaders;
    }
}