Audiens\AppnexusClient\Auth

Complexity

Total Complexity

9

Size/Duplication

Total Lines	109
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Importance

Changes

0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	12	1
A	request()	0	26	2
A	send()	0	4	1
A	sendAsync()	0	4	1
A	requestAsync()	0	4	1
A	getConfig()	0	4	1
A	needToRevalidate()	0	8	2

<?php

namespace Audiens\AppnexusClient;

use Audiens\AppnexusClient\authentication\AuthStrategyInterface;
use Doctrine\Common\Cache\Cache;
use GuzzleHttp\ClientInterface;
use Psr\Http\Message\RequestInterface;
use Psr\Http\Message\ResponseInterface;
use Psr\Http\Message\UriInterface;

/**
 * see https://wiki.apnexus.com/display/adnexusdocumentation/Segment+Service
 */
class Auth implements ClientInterface
{

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

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

    /** @var string */
    protected $token;

    /** @var string */
    protected $username;

    /** @var string */
    protected $password;

    protected $authStrategy;

    public function __construct(
        $username,
        $password,
        ClientInterface $clientInterface,
        AuthStrategyInterface $authStrategy
    ) {
        $this->username = $username;
        $this->password = $password;

        $this->client       = $clientInterface;
        $this->authStrategy = $authStrategy;
    }

    /**
     * @param string              $method
     * @param string|UriInterface $uri
     * @param array               $options
     *
     * @return mixed|\Psr\Http\Message\ResponseInterface
     * @throws \Exception
     */
    public function request($method, $uri, array $options = [])
    {
        $optionForToken = [
            'headers' => [
                'Authorization' => $this->authStrategy->authenticate($this->username, $this->password),
            ],
        ];

        $options = array_merge($options, $optionForToken);

        $response = $this->client->request($method, $uri, $options);

        if (!$this->needToRevalidate($response)) {
            return $response;
        }

        $optionForToken = [
            'headers' => [
                'Authorization' => $this->authStrategy->authenticate($this->username, $this->password),
            ],
        ];

        $options = array_merge($options, $optionForToken);

        return $this->client->request($method, $uri, $options);
    }

    /**
     * @inheritDoc
     */
    public function send(RequestInterface $request, array $options = [])
    {
        return $this->client->send($request, $options);
    }

    /**
     * @inheritDoc
     */
    public function sendAsync(RequestInterface $request, array $options = [])
    {
        return $this->client->sendAsync($request, $options);
    }

    /**
     * @inheritDoc
     */
    public function requestAsync($method, $uri, array $options = [])
    {
        return $this->client->requestAsync($method, $uri, $options);
    }

    /**
     * @inheritDoc
     */
    public function getConfig($option = null)
    {
        return $this->client->getConfig($option);
    }

    protected function needToRevalidate(ResponseInterface $response): bool
    {
        $content = json_decode($response->getBody()->getContents(), true);

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

        return isset($content['response']['error_id']) && $content['response']['error_id'] == 'NOAUTH';
    }
}