AcquiaCloudApi\Connector\Connector

Complexity

Total Complexity

4

Size/Duplication

Total Lines	66
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	8	1
A	sendRequest()	0	5	1
A	createRequest()	0	10	2

<?php

namespace AcquiaCloudApi\Connector;

use League\OAuth2\Client\Provider\GenericProvider;
use League\OAuth2\Client\Provider\Exception\IdentityProviderException;
use GuzzleHttp\Client as GuzzleClient;
use GuzzleHttp\Exception\ClientException;
use Psr\Http\Message\ResponseInterface;
use Psr\Http\Message\StreamInterface;

/**
 * Class Connector
 * @package AcquiaCloudApi\CloudApi
 */
class Connector implements ConnectorInterface
{
    /**
     * @var string BASE_URI
     */
    const BASE_URI = 'https://cloud.acquia.com/api';

    /**
     * @var string URL_ACCESS_TOKEN
     */
    const URL_ACCESS_TOKEN = 'https://accounts.acquia.com/api/auth/oauth/token';

    /**
     * @var GenericProvider The OAuth 2.0 provider to use in communication.
     */
    protected $provider;

    /**
     * @var string The generated OAuth 2.0 access token.
     */
    protected $accessToken;

    /**
     * @var GuzzleClient The Guzzle Client to communicate with the API.
     */
    protected $client;

    /**
     * @var array Injected configuration values.
     */
    protected $config;

    /**
     * Connector constructor.
     *
     * @param array $config
     */
    public function __construct(array $config)
    {
        $this->provider = new GenericProvider([
            'clientId'                => $config['key'],
            'clientSecret'            => $config['secret'],
            'urlAuthorize'            => '',
            'urlAccessToken'          => self::URL_ACCESS_TOKEN,
            'urlResourceOwnerDetails' => '',
        ]);
    }

    public function createRequest($verb, $path)
    {
        if (! isset($this->accessToken)) {
            $this->accessToken = $this->provider->getAccessToken('client_credentials');
        }

        return $this->provider->getAuthenticatedRequest(
            $verb,
            self::BASE_URI . $path,
            $this->accessToken
        );
    }

    public function sendRequest($verb, $path, $options)
    {
        $request = $this->createRequest($verb, $path);
        $client = new GuzzleClient();
        return $client->send($request, $options);
    }
}