acquiropay / php-sdk

src/Api.php

<?php

declare(strict_types=1);

namespace AcquiroPay;

use Exception;
use GuzzleHttp\Client;
use Illuminate\Support\Str;

This use statement conflicts with another class in this namespace, AcquiroPay\Str.

use GuzzleHttp\Psr7\Request;
use AcquiroPay\Contracts\Cache;
use Psr\Http\Message\StreamInterface;
use AcquiroPay\Exceptions\BaseException;
use GuzzleHttp\Exception\GuzzleException;
use GuzzleHttp\Exception\RequestException;
use AcquiroPay\Exceptions\NotFoundException;
use AcquiroPay\Exceptions\ForbiddenException;
use AcquiroPay\Exceptions\UnauthorizedException;

class Api
{
    protected $cache;
    protected $http;

    protected $url;
    protected $username;
    protected $password;

    public function __construct(Cache $cache, Client $http)
    {
        $this->cache = $cache;
        $this->http = $http;
    }

    public function setUrl(string $url): self
    {
        $this->url = $url;

        return $this;
    }

    public function setUsername(string $username): self
    {
        $this->username = $username;

        return $this;
    }

    public function setPassword(string $password): self
    {
        $this->password = $password;

        return $this;
    }

    /**
     * @param string $service
     * @param string $method
     * @param string $endpoint
     * @param array|null $parameters
     *
     * @param array $headers
     * @return mixed|string
     *
     * @throws BaseException
     * @throws ForbiddenException
     * @throws GuzzleException
     * @throws NotFoundException
     */
    public function callService(string $service, string $method, string $endpoint, array $parameters = null, array $headers = [])
    {
        $headers = array_merge(['Endpoint' => $endpoint], $headers);

        return $this->call($method, '/services/'.$service, $headers, $parameters);
    }

    /**
     * @param string $method
     * @param string $endpoint
     * @param array $headers
     * @param array|null $parameters
     *
     * @return mixed|string
     *
     * @throws ForbiddenException
     * @throws NotFoundException
     * @throws BaseException
     * @throws \GuzzleHttp\Exception\GuzzleException
     */
    public function call(string $method, string $endpoint, array $headers = [], array $parameters = null)
    {
        $stream = $this->makeCallRequest($method, $endpoint, $headers, $parameters);
        $json = json_decode((string) $stream);

        if (json_last_error() === JSON_ERROR_NONE) {
            return $json;
        }

        return (string) $stream;
    }

    /**
     * @param string $method
     * @param string $endpoint
     * @param array $headers
     * @param array|null $parameters
     * @param bool $retry
     *
     * @return StreamInterface
     *
     * @throws ForbiddenException
     * @throws NotFoundException
     * @throws BaseException
     * @throws GuzzleException
     */
    public function makeCallRequest(
        string $method,
        string $endpoint,
        array $headers = [],
        array $parameters = null,
        bool $retry = true
    ): StreamInterface {
        $method = Str::upper($method);
        if (!Str::startsWith($endpoint, ['http://', 'https://'])) {
            $endpoint = $this->url.'/'.ltrim($endpoint, '/');
        }

        try {
            $options = [
                'headers' => array_merge([
                    'Accept' => 'application/json',
                    'Content-Type' => 'application/json',
                    'Authorization' => 'Bearer '.$this->token(),
                ], $headers),
            ];

            if ($method === 'GET') {
                $options['query'] = $parameters;
            } else {
                $options['json'] = $parameters;
            }

            return $this->http->request($method, $endpoint, $options)->getBody();
        } catch (RequestException $exception) {
            $response = $exception->getResponse();

            if ($retry && $response && $response->getStatusCode() === 401) {
                $this->token();

                return $this->makeCallRequest($method, $endpoint, $headers, $parameters, false);
            }

            switch ($response->getStatusCode()) {
                case 404:
                    throw new NotFoundException((string) $response->getBody());
                case 403:
                    throw new ForbiddenException;
                default:
                    throw BaseException::fromGuzzle($exception);
            }
        }
    }

    /**
     * Authorize token for performing request.
     *
     * @param string $token
     * @param string $service
     * @param string $method
     * @param string $endpoint
     *
     * @return Consumer
     *
     * @throws UnauthorizedException
     * @throws \GuzzleHttp\Exception\GuzzleException
     */
    public function authorize(string $token, string $service, string $method, string $endpoint): Consumer
    {
        try {
            $headers = ['Content-Type' => 'application/json'];

            $url = $this->url.'/authorize';

            $body = json_encode(compact('token', 'service', 'method', 'endpoint'));

            $response = $this->http->send(new Request('POST', $url, $headers, $body));

            $json = \GuzzleHttp\json_decode((string) $response->getBody());

            if (!isset($json->authorized, $json->consumer_id) || $json->authorized !== true) {
                throw new UnauthorizedException('Consumer is not authorized for this request.');
            }

            return Consumer::create($json->consumer_id);
        } catch (Exception $exception) {
            throw new UnauthorizedException('Something went wrong.', 0, $exception);
        }
    }

    protected function token(): ?string
    {
        return $this->cache->remember('acquiropay_api_token_'.md5($this->url), 10, function () {
            $response = $this->http->post(
                $this->url.'/login',
                ['form_params' => ['username' => $this->username, 'password' => $this->password]]
            );

            return (string) $response->getBody();
        });
    }
}