FAPI\Sylius\Http\AuthenticationPlugin

Complexity

Total Complexity

5

Size/Duplication

Total Lines	55
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	handleRequest()	0	31	3
A	getAccessToken()	0	4	1

<?php

declare(strict_types=1);

namespace FAPI\Sylius\Http;

use Http\Client\Common\Plugin;
use Http\Promise\Promise;
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
{
    /**
     * @var array
     */
    private $accessToken;

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

    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)
    {
        $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) {
            if ($response->getStatusCode() !== 401) {
                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
            $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);
    }
}