FAPI\Sylius\Http\AuthenticationPlugin

Complexity

Total Complexity

8

Size/Duplication

Total Lines	77
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Test Coverage

Coverage

0%

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
B	handleRequest()	0	44	6
A	getAccessToken()	0	4	1

<?php

declare(strict_types=1);

namespace FAPI\Sylius\Http;

use Http\Client\Common\Plugin;
use Psr\Http\Message\RequestInterface;
use Psr\Http\Message\ResponseInterface;

/**
 * This will automatically refresh expired access token.
 *
 * @author Tobias Nyholm <tobias.nyholm@gmail.com>
 */
class AuthenticationPlugin implements Plugin
{
    const RETRY_LIMIT = 2;

    /**
     * @var array
     */
    private $accessToken;

    /**
     * @var Authenticator
     */
    private $authenticator;

    /**
     * Store the retry counter for each request.
     *
     * @var array
     */
    private $retryStorage = [];

    public function __construct(Authenticator $authenticator, string $accessToken)
    {
        $this->authenticator = $authenticator;
        $this->accessToken = \json_decode($accessToken, true);
    }

    public function handleRequest(RequestInterface $request, callable $next, callable $first)
    {
        if (null === $this->accessToken) {
            return $next($request);
        }

        $chainIdentifier = \spl_object_hash((object) $first);
        $header = \sprintf('Bearer %s', $this->accessToken['access_token'] ?? '');
        $request = $request->withHeader('Authorization', $header);

        $promise = $next($request);

        return $promise->then(function (ResponseInterface $response) use ($request, $next, $first, $chainIdentifier) {
            if (!\array_key_exists($chainIdentifier, $this->retryStorage)) {
                $this->retryStorage[$chainIdentifier] = 0;
            }

            if (401 !== $response->getStatusCode() || $this->retryStorage[$chainIdentifier] >= self::RETRY_LIMIT) {
                unset($this->retryStorage[$chainIdentifier]);

                return $response;
            }

            $accessToken = $this->authenticator->refreshAccessToken($this->accessToken['access_token'], $this->accessToken['refresh_token']);
            if (null === $accessToken) {
                return $response;
            }

            // Save new token
            $this->accessToken = \json_decode($accessToken, true);

            // Add new token to request
            $header = \sprintf('Bearer %s', $this->accessToken['access_token']);
            $request = $request->withHeader('Authorization', $header);

Consider using a different name than the imported variable $request, or did you forget to import by reference?

            // Retry
            ++$this->retryStorage[$chainIdentifier];
            $promise = $this->handleRequest($request, $next, $first);

            return $promise->wait();
        });

        return $response;

return $response; does not seem to be reachable.

    }

    public function getAccessToken(): string
    {
        return \json_encode($this->accessToken);
    }
}