Audiens\DoubleclickClient\authentication\Oauth2ServiceAccountStrategy

Complexity

Total Complexity

6

Size/Duplication

Total Lines	71
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	7

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	8	1
A	authenticate()	0	33	4
A	getSlug()	0	4	1

<?php

namespace Audiens\DoubleclickClient\authentication;

use Audiens\DoubleclickClient\CachableTrait;
use Audiens\DoubleclickClient\CacheableInterface;
use Audiens\DoubleclickClient\entity\BearerToken;
use Doctrine\Common\Cache\Cache;
use GuzzleHttp\ClientInterface;

class Oauth2ServiceAccountStrategy implements AuthStrategyInterface, CacheableInterface
{

    use CachableTrait;

    public const NAME = 'oauth2_service_account';

    public const BASE_URL = 'https://www.googleapis.com/oauth2/v4/token';

    public const CACHE_NAMESPACE  = 'oauth2_service_account';
    public const CACHE_EXPIRATION = 1800;

    public const SCOPE = 'https://ddp.googleapis.com/api/ddp/';

    /** @var Cache */
    protected $cache;

    /** @var JwtFactoryInterface */
    protected $jwtFactory;

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

    public function __construct(ClientInterface $clientInterface, Cache $cache, JwtFactoryInterface $jwtFactory)
    {
        $this->cache      = $cache;
        $this->client     = $clientInterface;
        $this->jwtFactory = $jwtFactory;

        $this->cacheEnabled = $cache instanceof Cache;
    }

    public function authenticate(bool $cache = true): BearerToken
    {
        $cacheKey = self::CACHE_NAMESPACE.sha1($this->jwtFactory->getHash().self::BASE_URL);

        if ($cache) {
            if ($this->cache->contains($cacheKey)) {
                return $this->cache->fetch($cacheKey);
            }
        }

        $token = $this->jwtFactory->build();

        $body = 'grant_type='.urlencode('urn:ietf:params:oauth:grant-type:jwt-bearer').'&assertion='.$token;

        $response = $this->client->request(
            'POST',
            self::BASE_URL,
            [
                'body' => $body,
                'headers' => ['Content-Type' => 'application/x-www-form-urlencoded'],
            ]
        );

        $bearerToken = BearerToken::fromArray(json_decode($response->getBody()->getContents(), true));

        $response->getBody()->rewind();

        if ($this->isCacheEnabled()) {
            $this->cache->save($cacheKey, $bearerToken, self::CACHE_EXPIRATION);
        }

        return $bearerToken;
    }

    public function getSlug(): string
    {
        return self::NAME;
    }
}