Happyr\Auth0Bundle\Factory\ManagementFactory

Complexity

Total Complexity

12

Size/Duplication

Total Lines	114
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Test Coverage

Coverage

56.76%

Importance

Changes	2
Bugs	0	Features	0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	13	1
A	create()	0	10	2
A	getCachedAccessToken()	0	14	2
A	getUncachedAccessToken()	0	8	2
B	getTokenStruct()	0	20	5

<?php

namespace Happyr\Auth0Bundle\Factory;

use Auth0\SDK\API\Authentication;
use Auth0\SDK\API\Management;
use Auth0\SDK\Exception\CoreException;
use Http\Client\HttpClient;
use Psr\Cache\CacheItemPoolInterface;
use Psr\Log\LoggerInterface;

class ManagementFactory
{
    /**
     * @var CacheItemPoolInterface|null
     */
    private $cacheItemPool;

    /**
     * @var Authentication
     */
    private $authentication;

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

    /**
     * @var HttpClient|null
     */
    private $httpClient;

    /**
     * @var LoggerInterface|null
     */
    private $logger;

    /**
     * ManagementFactory constructor.
     */
    public function __construct(
        Authentication $authentication,
        $domain,
        CacheItemPoolInterface $cacheItemPool = null,
        HttpClient $httpClient = null,
        LoggerInterface $logger = null
    ) {
        $this->cacheItemPool = $cacheItemPool;
        $this->authentication = $authentication;
        $this->domain = $domain;
        $this->httpClient = $httpClient;
        $this->logger = $logger;
    }

    /**
     * @return Management
     */
    public function create()
    {
        if ($this->cacheItemPool) {
            $accessToken = $this->getCachedAccessToken();
        } else {
            $accessToken = $this->getUncachedAccessToken();
        }

        return new Management($accessToken, $this->domain, $this->httpClient);
    }

    /**
     * @return string
     */
    protected function getCachedAccessToken()
    {
        $item = $this->cacheItemPool->getItem('auth0_management_access_token');

        if (!$item->isHit()) {
            $token = $this->getTokenStruct();

            $item->set($token['access_token']);
            $item->expiresAfter((int) $token['expires_in']);
            $this->cacheItemPool->save($item);
        }

        return $item->get();
    }

    /**
     * @return string
     */
    protected function getUncachedAccessToken()
    {
        if ($this->logger) {
            $this->logger->warning('Using the Auth0 management API without using an access token cache. This increases the number of API requests.');
        }

        return $this->getTokenStruct()['access_token'];
    }

    /**
     * @return array
     *
     * @throws CoreException
     */
    protected function getTokenStruct()
    {
        $token = $this->authentication->clientCredentials([
            'audience' => sprintf('https://%s/api/v2/', $this->domain),
        ]);

        if (isset($token['error'])) {
            throw new CoreException($token['error_description']);
        }

        if (empty($token['access_token'])) {
            throw new CoreException('Could not get access token');
        }

        if ($this->logger) {
            $this->logger->debug(sprintf('Got new access token for Auth0 managment API. Scope: "%s" ', isset($token['scope']) ? $token['scope'] : 'no scope'));
        }

        return $token;
    }
}