Monobank\MonobankClient

Complexity

Total Complexity

9

Size/Duplication

Total Lines	103
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	getPersonalStatement()	0	10	2
A	__construct()	0	5	1
A	decode()	0	9	2
A	getClientInfo()	0	3	1
A	getExchangeRates()	0	3	1
A	request()	0	13	2

<?php

declare(strict_types=1);

namespace Monobank;

use GuzzleHttp\RequestOptions;
use Monobank\ValueObject\Token;
use GuzzleHttp\ClientInterface;
use Psr\Http\Message\ResponseInterface;
use GuzzleHttp\Exception\GuzzleException;
use Monobank\Request\PersonalStatementRequest;
use Monobank\Exception\InvalidResponseException;

/**
 * Monobank HTTP client.
 */
class MonobankClient implements MonobankPublicDataClientInterface, MonobankPrivateDataClientInterface
{
    private const HOST = 'https://api.monobank.ua';

    /**
     * @var ClientInterface
     */
    private $client;

    /**
     * @var Token
     */
    private $token;

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

    /**
     * @param ClientInterface $client
     * @param Token           $token
     * @param string          $host
     */
    public function __construct(ClientInterface $client, Token $token, string $host = self::HOST)
    {
        $this->client = $client;
        $this->token = $token;
        $this->host = rtrim($host, '/');
    }

    /**
     * {@inheritdoc}
     */
    public function getExchangeRates(): array
    {
        return $this->decode($this->request('GET', '/bank/currency'));
    }

    /**
     * {@inheritdoc}
     */
    public function getClientInfo(): array
    {
        return $this->decode($this->request('GET', '/personal/client-info', $this->token));
    }

    /**
     * {@inheritdoc}
     */
    public function getPersonalStatement(PersonalStatementRequest $request): array
    {
        $endpoint = sprintf(
            '/personal/statement/%s/%d/%d',
            null === $request->getAccountID() ? '0' : strval($request->getAccountID()), // 0 - default account
            $request->getFrom()->getTimestamp(),
            $request->getTo()->getTimestamp()
        );

        return $this->decode($this->request('GET', $endpoint, $this->token));
    }

    /**
     * @param string     $method
     * @param string     $endpoint
     * @param Token|null $token
     *
     * @return ResponseInterface
     *
     * @throws GuzzleException
     */
    private function request(string $method, string $endpoint, Token $token = null): ResponseInterface
    {
        $headers = [
            'Accept' => 'application/json',
            'User-Agent' => sprintf('%s MonobankPHPClient/%s', $this->client->getConfig('headers')['User-Agent'], MONOBANK_CLIENT_VERSION),
        ];

        if (null !== $token) {
            $headers['X-Token'] = strval($token);
        }

        return $this->client->request($method, $this->host.$endpoint, [
            RequestOptions::HEADERS => $headers,
        ]);
    }

    /**
     * @param ResponseInterface $response
     *
     * @return array
     *
     * @throws InvalidResponseException
     */
    private function decode(ResponseInterface $response): array
    {
        $decodedContents = json_decode($response->getBody()->getContents(), true);

        if (!is_array($decodedContents)) {
            throw InvalidResponseException::wrongFormat();
        }

        return $decodedContents;
    }
}