Acquia\Hmac\Guzzle\HmacAuthMiddleware

Complexity

Total Complexity

5

Size/Duplication

Total Lines	73
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes	4
Bugs	0	Features	1

3 Methods

Rating	Name	Duplication	Size	Complexity
A	signRequest()	0	3	1
A	__invoke()	0	23	3
A	__construct()	0	5	1

<?php

namespace Acquia\Hmac\Guzzle;

use Acquia\Hmac\Exception\MalformedResponseException;
use Acquia\Hmac\KeyInterface;
use Acquia\Hmac\RequestSigner;
use Acquia\Hmac\ResponseAuthenticator;
use Psr\Http\Message\RequestInterface;
use Psr\Http\Message\ResponseInterface;

class HmacAuthMiddleware
{
    /**
     * @var \Acquia\Hmac\KeyInterface
     *  The key with which to sign requests and responses.
     */
    protected $key;

    /**
     * @var \Acquia\Hmac\RequestSignerInterface
     */
    protected $requestSigner;

    /**
     * @var array
     */
    protected $customHeaders = [];

    /**
     * @param \Acquia\Hmac\KeyInterface $key
     * @param string $realm
     * @param array $customHeaders
     */
    public function __construct(KeyInterface $key, $realm = 'Acquia', array $customHeaders = [])
    {
        $this->key = $key;
        $this->customHeaders = $customHeaders;
        $this->requestSigner = new RequestSigner($key, $realm);
    }

    /**
     * Called when the middleware is handled.
     *
     * @param callable $handler
     *
     * @return \Closure
     */
    public function __invoke(callable $handler)
    {
        return function ($request, array $options) use ($handler) {
            $request = $this->signRequest($request);

            $promise = function (ResponseInterface $response) use ($request) {
                if ($response->getStatusCode() != 401) {
                    $authenticator = new ResponseAuthenticator($request, $this->key);

                    if (!$authenticator->isAuthentic($response)) {
                        throw new MalformedResponseException(
                            'Could not verify the authenticity of the response.',
                            null,
                            0,
                            $response
                        );
                    }
                }

                return $response;
            };

            return $handler($request, $options)->then($promise);
        };
    }

    /**
     * Signs the request with the appropriate headers.
     *
     * @param \Psr\Http\Message\RequestInterface $request
     *
     * @return \Psr\Http\Message\RequestInterface
     */
    public function signRequest(RequestInterface $request)
    {
        return $this->requestSigner->signRequest($request, $this->customHeaders);
    }
}