Swis\JsonApi\Client\Client

Complexity

Total Complexity

20

Size/Duplication

Total Lines	194
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes

0

13 Methods

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

<?php

namespace Swis\JsonApi\Client;

use Http\Discovery\Psr17FactoryDiscovery;
use Http\Discovery\Psr18ClientDiscovery;
use Psr\Http\Client\ClientInterface as HttpClientInterface;
use Psr\Http\Message\RequestFactoryInterface;
use Psr\Http\Message\RequestInterface;
use Psr\Http\Message\ResponseInterface;
use Psr\Http\Message\StreamFactoryInterface;
use Psr\Http\Message\StreamInterface;
use Swis\JsonApi\Client\Interfaces\ClientInterface;

class Client implements ClientInterface
{
    /**
     * @var \Psr\Http\Client\ClientInterface
     */
    private $client;

    /**
     * @var \Psr\Http\Message\RequestFactoryInterface
     */
    private $requestFactory;

    /**
     * @var \Psr\Http\Message\StreamFactoryInterface
     */
    private $streamFactory;

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

    /**
     * @var array
     */
    private $defaultHeaders = [
        'Accept'       => 'application/vnd.api+json',
        'Content-Type' => 'application/vnd.api+json',
    ];

    /**
     * @param \Psr\Http\Client\ClientInterface|null          $client
     * @param \Psr\Http\Message\RequestFactoryInterface|null $requestFactory
     * @param \Psr\Http\Message\StreamFactoryInterface|null  $streamFactory
     */
    public function __construct(
        HttpClientInterface $client = null,
        RequestFactoryInterface $requestFactory = null,
        StreamFactoryInterface $streamFactory = null
    ) {
        $this->client = $client ?: Psr18ClientDiscovery::find();
        $this->requestFactory = $requestFactory ?: Psr17FactoryDiscovery::findRequestFactory();
        $this->streamFactory = $streamFactory ?: Psr17FactoryDiscovery::findStreamFactory();
    }

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

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

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

    /**
     * @param array $defaultHeaders
     */
    public function setDefaultHeaders(array $defaultHeaders): void
    {
        $this->defaultHeaders = $defaultHeaders;
    }

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

    /**
     * @param string                                                 $endpoint
     * @param string|resource|\Psr\Http\Message\StreamInterface|null $body
     * @param array                                                  $headers
     *
     * @throws \Psr\Http\Client\ClientExceptionInterface
     *
     * @return \Psr\Http\Message\ResponseInterface
     */
    public function post(string $endpoint, $body, array $headers = []): ResponseInterface
    {
        return $this->request('POST', $endpoint, $body, $headers);
    }

    /**
     * @param string                                                 $endpoint
     * @param string|resource|\Psr\Http\Message\StreamInterface|null $body
     * @param array                                                  $headers
     *
     * @throws \Psr\Http\Client\ClientExceptionInterface
     *
     * @return \Psr\Http\Message\ResponseInterface
     */
    public function patch(string $endpoint, $body, array $headers = []): ResponseInterface
    {
        return $this->request('PATCH', $endpoint, $body, $headers);
    }

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

    /**
     * @param string                                                 $method
     * @param string                                                 $endpoint
     * @param string|resource|\Psr\Http\Message\StreamInterface|null $body
     * @param array                                                  $headers
     *
     * @throws \Psr\Http\Client\ClientExceptionInterface
     *
     * @return \Psr\Http\Message\ResponseInterface
     */
    public function request(string $method, string $endpoint, $body = null, array $headers = []): ResponseInterface
    {
        return $this->client->sendRequest($this->buildRequest($method, $endpoint, $body, $headers));
    }

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

        if ($body !== null) {
            if (is_resource($body)) {
                $body = $this->streamFactory->createStreamFromResource($body);
            }
            if (!($body instanceof StreamInterface)) {
                $body = $this->streamFactory->createStream($body);

It seems like $body can also be of type null and resource; however, parameter $content of Psr\Http\Message\StreamFactoryInterface::createStream() does only seem to accept string, maybe add an additional type check?

            }

            $request = $request->withBody($body);
        }

        foreach ($this->mergeHeaders($headers) as $name => $value) {
            $request = $request->withHeader($name, $value);
        }

        return $request;
    }

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

    /**
     * @param array $headers
     *
     * @return array
     */
    protected function mergeHeaders(array $headers): array
    {
        return array_merge($this->defaultHeaders, $headers);
    }
}