LauLamanApps\IzettleApi\GuzzleIzettleClient

Complexity

Total Complexity

9

Size/Duplication

Total Lines	78
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Test Coverage

Coverage

100%

Importance

Changes

0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
A	get()	0	6	1
A	post()	0	13	1
A	put()	0	14	1
A	delete()	0	4	1
A	getJson()	0	4	1
A	getAuthorizationHeader()	0	6	1
A	validateAccessToken()	0	12	2

<?php

declare(strict_types=1);

namespace LauLamanApps\IzettleApi;

use DateTime;
use GuzzleHttp\ClientInterface;
use LauLamanApps\IzettleApi\Client\AccessToken;
use LauLamanApps\IzettleApi\Client\Exceptions\AccessTokenExpiredException;
use Psr\Http\Message\ResponseInterface;

class GuzzleIzettleClient implements IzettleClientInterface
{
    private $guzzleClient;
    private $accessToken;

    public function __construct(ClientInterface $guzzleClient, AccessToken $accessToken)
    {
        $this->guzzleClient = $guzzleClient;
        $this->accessToken = $accessToken;
        $this->validateAccessToken();
    }

    public function get(string $url, ?array $queryParameters = null): ResponseInterface
    {
        $options =  array_merge(['headers' => $this->getAuthorizationHeader()], ['query' => $queryParameters]);

        return $this->guzzleClient->get($url, $options);
    }

    public function post(string $url, string $jsonData): void
    {
        $headers = array_merge(
            $this->getAuthorizationHeader(),
            [
                'content-type' => 'application/json',
                'Accept' => 'application/json',
            ]
        );

        $options =  array_merge(['headers' => $headers], ['body' => $jsonData]);
        $this->guzzleClient->post($url, $options);
    }

    public function put(string $url, string $jsonData): void
    {
        $headers = array_merge(
            $this->getAuthorizationHeader(),
            [
                'content-type' => 'application/json',
                'Accept' => 'application/json',
            ]
        );

        $options =  array_merge(['headers' => $headers], ['body' => $jsonData]);

        $this->guzzleClient->put($url, $options);
    }

    public function delete(string $url): void
    {
        $this->guzzleClient->delete($url, ['headers' => $this->getAuthorizationHeader()]);
    }

    public function getJson(ResponseInterface $response): string
    {
        return $response->getBody()->getContents();
    }

    private function getAuthorizationHeader(): array
    {
        $this->validateAccessToken();

        return ['Authorization' => sprintf('Bearer %s', $this->accessToken->getToken())];
    }

    private function validateAccessToken(): void
    {
        if ($this->accessToken->isExpired()) {
            throw new AccessTokenExpiredException(
                sprintf(
                    'Access Token was valid till \'%s\' it\'s now \'%s\'',
                    $this->accessToken->getExpires()->format('Y-m-d H:i:s.u'),
                    (new DateTime())->format('Y-m-d H:i:s.u')
                )
            );
        }
    }
}