hamburgscleanest\GuzzleAdvancedThrottle\Middleware\ThrottleMiddleware

Complexity

Total Complexity

3

Size/Duplication

Total Lines	36
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	handle()	0	15	2
A	__construct()	0	3	1

<?php

namespace hamburgscleanest\GuzzleAdvancedThrottle\Middleware;

use hamburgscleanest\GuzzleAdvancedThrottle\RequestLimitRuleset;
use Psr\Http\Message\RequestInterface;
use Symfony\Component\HttpKernel\Exception\TooManyRequestsHttpException;

/**
 * Class ThrottleMiddleware
 * @package hamburgscleanest\GuzzleAdvancedThrottle\Middleware
 */
class ThrottleMiddleware
{

    /** @var \hamburgscleanest\GuzzleAdvancedThrottle\RequestLimitGroup */
    private $_requestLimitGroup;

    /**
     * ThrottleMiddleware constructor.
     * @param RequestLimitRuleset $requestLimitRuleset
     * @throws \Exception
     */
    public function __construct(RequestLimitRuleset $requestLimitRuleset)
    {
        $this->_requestLimitGroup = $requestLimitRuleset->getRequestLimitGroup();
    }

    /**
     * @return callable
     * @throws \Symfony\Component\HttpKernel\Exception\TooManyRequestsHttpException
     * @throws \Exception
     */
    public function handle() : callable
    {
        return function(callable $handler) : callable
        {
            return function(RequestInterface $request, array $options) use ($handler)
            {
                if (!$this->_requestLimitGroup->canRequest())
                {
                    throw new TooManyRequestsHttpException(
                        $this->_requestLimitGroup->getRetryAfter(),
                        'The rate limit was exceeded. Please try again later.'
                    );
                }

                return $handler($request, $options);
            };
        };
    }
}