Larium\Pay\Client\RestClient

Complexity

Total Complexity

22

Size/Duplication

Total Lines	167
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	7

Test Coverage

Coverage

44.44%

Importance

Changes

0

14 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	11	1
A	addHeader()	0	4	1
A	get()	0	17	2
A	post()	0	4	1
A	put()	0	6	1
A	request()	0	14	1
A	delete()	0	6	1
A	getUri()	0	12	3
A	setBasicAuthentication()	0	5	1
A	setHeaderAuthentication()	0	4	1
A	authenticate()	0	19	4
A	normalizePayload()	0	8	2
A	getMessageFactory()	0	4	1
A	resolveResponse()	0	13	2

<?php

namespace Larium\Pay\Client;

use Psr\Http\Message\RequestInterface;
use Psr\Http\Message\ResponseInterface;
use Http\Discovery\HttpClientDiscovery;
use Http\Message\Authentication\BasicAuth;
use Http\Discovery\MessageFactoryDiscovery;

class RestClient extends AbstractClient
{
    private $baseUri;

    private $resource;

    private $username;

    private $pass;

    private $headerAuthentication = [];

    private $headers = [];

    public function __construct(
        $baseUri,
        $resource,
        array $headers = [],
        array $options = []
    ) {
        $this->baseUri = $baseUri;
        $this->headers = $headers;
        $this->options = $options;
        $this->resource = $resource;
    }

    public function addHeader($name, $value)
    {
        $this->headers[$name] = $value;
    }

    public function get($id = null, $payload = null)
    {
        $factory = $this->getMessageFactory();
        $uri = $this->getUri($id);
        if ($query = $this->normalizePayload($payload)) {
            $uri = $uri . '?' . ltrim($query, '?');
        }
        $request = $factory->createRequest(
            'GET',
            $uri,
            $this->headers
        );

        $request = $this->authenticate($request);

        return $this->resolveResponse($this->sendRequest($request));
    }

    public function post($payload)
    {
        return $this->request($this->getUri(), 'POST', $payload);
    }

    public function put($id, $payload = null)
    {
        $uri = $this->getUri($id);

        return $this->request($uri, 'PUT', $payload);
    }

    private function request($uri, $method, $payload = null)
    {
        $factory = $this->getMessageFactory();
        $request = $factory->createRequest(
            $method,
            $uri,
            $this->headers,
            $this->normalizePayload($payload)
        );

        $request = $this->authenticate($request);

        return $this->resolveResponse($this->sendRequest($request));
    }

    public function delete($id)
    {
        $uri = $this->getUri($id);

        return $this->request($uri, 'DELETE');
    }

    public function getUri($id = null)
    {
        $uri = $this->resource
            ? sprintf('%s/%s', $this->baseUri, $this->resource)
            : $this->baseUri;

        if ($id) {
            $uri = sprintf($uri, $id);
        }

        return $uri;
    }

    public function setBasicAuthentication($username, $password)
    {
        $this->username = $username;
        $this->pass = $password;
    }

    public function setHeaderAuthentication($name, $value)
    {
        $this->headerAuthentication = ['name' => $name, 'value' => $value];
    }

    protected function authenticate(RequestInterface $request)
    {
        if ($this->username || $this->pass) {
            $authentication = new BasicAuth($this->username, $this->pass);

            return $authentication->authenticate($request);
        }

        if (!empty($this->headerAuthentication)) {
            $request = $request->withHeader(
                $this->headerAuthentication['name'],
                $this->headerAuthentication['value']
            );

            return $request;
        }

        return $request;
    }

    private function normalizePayload($payload)
    {
        if (is_array($payload)) {
            return http_build_query($payload);
        }

        return $payload;
    }

    private function getMessageFactory()
    {
        return MessageFactoryDiscovery::find();
    }

    /**
     * Resolve the response from client.
     *
     * @param ResponseInterface $response
     * @return array An array with following values:
     *              'status': The Http status of response
     *              'headers': An array of response headers
     *              'body': The json decoded body response. (Since we are in
     *              RestClient)
     *              'raw_response': The raw body response for logging purposes.
     *              'raw_request': The raw body request for logging purposes.
     */
    protected function resolveResponse(ResponseInterface $response)
    {
        $body = $response->getBody()->__toString();
        $responseBody = json_decode($body, true) ?: [];

        return array(
            'status' => $response->getStatusCode(),
            'headers' => $response->getHeaders(),
            'body' => $responseBody,
            'raw_response' => $body,
            'raw_request' => $this->rawRequest,
        );
    }
}