Gemz\HttpClient\Client

Complexity

Total Complexity

17

Size/Duplication

Total Lines	198
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	6

Importance

Changes

0

16 Methods

Rating	Name	Duplication	Size	Complexity
A	create()	0	4	1
A	__construct()	0	9	2
A	transferThrowErrorsFromConfig()	0	6	1
A	transferBodyFormatFromConfig()	0	6	1
A	get()	0	4	1
A	head()	0	4	1
A	post()	0	4	1
A	put()	0	4	1
A	patch()	0	4	1
A	delete()	0	4	1
A	request()	0	9	1
A	stream()	0	8	1
A	buildClient()	0	4	1
A	config()	0	4	1
A	options()	0	4	1
A	client()	0	4	1

<?php

namespace Gemz\HttpClient;

use Gemz\HttpClient\Contracts\Options;
use Symfony\Component\HttpClient\HttpClient;
use Symfony\Contracts\HttpClient\HttpClientInterface;
use Symfony\Contracts\HttpClient\ResponseInterface;
use Symfony\Contracts\HttpClient\ResponseStreamInterface;

class Client
{
    use Options;

    /** @var HttpClientInterface */
    protected $client;

    /** @var Config|null */
    protected $config;

    /** @var array<mixed> */
    protected $options = [];

    /** @var string */
    protected $bodyFormat = 'json';

    /** @var bool */
    protected $throwErrors = false;

    /**
     * @param Config|null $config
     *
     * @return Client
     */
    public static function create(Config $config = null)
    {
        return new self($config);
    }

    /**
     * @param Config|null $config
     */
    public function __construct(Config $config = null)
    {
        $this->config = $config ?: new Config();

        $this->transferBodyFormatFromConfig();
        $this->transferThrowErrorsFromConfig();

        $this->client = $this->buildClient();
    }

    /**
     * @return $this
     */
    protected function transferThrowErrorsFromConfig(): self
    {
        $this->throwErrors = $this->config->shouldThrowErrors();

        return $this;
    }

    /**
     * @return $this
     */
    protected function transferBodyFormatFromConfig(): self
    {
        return $this->bodyFormat(
            $this->config->getBodyFormat()
        );
    }

    /**
     * @param string $endpoint
     *
     * @return Response|mixed
     *
     * @throws \Symfony\Contracts\HttpClient\Exception\TransportExceptionInterface
     */
    public function get(string $endpoint)
    {
        return $this->request('GET', $endpoint);
    }

    /**
     * @param string $endpoint
     *
     * @return Response|mixed
     *
     * @throws \Symfony\Contracts\HttpClient\Exception\TransportExceptionInterface
     */
    public function head(string $endpoint)
    {
        return $this->request('HEAD', $endpoint);
    }

    /**
     * @param string $endpoint
     *
     * @return Response|mixed
     *
     * @throws \Symfony\Contracts\HttpClient\Exception\TransportExceptionInterface
     */
    public function post(string $endpoint)
    {
        return $this->request('POST', $endpoint);
    }

    /**
     * @param string $endpoint
     *
     * @return Response|mixed
     *
     * @throws \Symfony\Contracts\HttpClient\Exception\TransportExceptionInterface
     */
    public function put(string $endpoint)
    {
        return $this->request('PUT', $endpoint);
    }

    /**
     * @param string $endpoint
     *
     * @return Response|mixed
     *
     * @throws \Symfony\Contracts\HttpClient\Exception\TransportExceptionInterface
     */
    public function patch(string $endpoint)
    {
        return $this->request('PATCH', $endpoint);
    }

    /**
     * @param string $endpoint
     *
     * @return Response
     *
     * @throws \Symfony\Contracts\HttpClient\Exception\TransportExceptionInterface
     */
    public function delete(string $endpoint)
    {
        return $this->request('DELETE', $endpoint);
    }

    /**
     * @param string $method
     * @param string $endpoint
     *
     * @return mixed|Response
     *
     * @throws \Symfony\Contracts\HttpClient\Exception\TransportExceptionInterface
     */
    protected function request(string $method, string $endpoint)
    {
        $this->resolvePayload();

        return Response::createFromResponse(
            $this->client->request($method, $endpoint, $this->options),
            $this->throwErrors
        );
    }

    /**
     * @param ResponseInterface|ResponseInterface[]|iterable $responses
     *
     * @return ResponseStreamInterface
     */
    public function stream($responses): ResponseStreamInterface
    {
        return $this->client->stream(
            collect($responses)->transform(function ($item) {
                return $item->response();
            })
        );
    }

    /**
     * @return HttpClientInterface
     */
    protected function buildClient(): HttpClientInterface
    {
        return HttpClient::create($this->config->toArray());
    }

    /**
     * @return array<String|Array>
     */
    public function config(): array
    {
        return $this->config->toArray();
    }

    /**
     * @return array<mixed>
     */
    public function options(): array
    {
        return $this->options;
    }

    /**
     * @return HttpClientInterface
     */
    public function client(): HttpClientInterface
    {
        return $this->client;
    }
 }