hamburgscleanest\GuzzleAdvancedThrottle\Middleware\ThrottleMiddleware

Complexity

Total Complexity

5

Size/Duplication

Total Lines	35
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes	4
Bugs	0	Features	0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__invoke()	0	3	1
A	_requestHandler()	0	12	2
A	handle()	0	5	1
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
{
    private RequestLimitRuleset $_requestLimitRuleset;

    public function __construct(RequestLimitRuleset $requestLimitRuleset)
    {
        $this->_requestLimitRuleset = $requestLimitRuleset;
    }

    public function __invoke(): callable
    {
        return $this->handle();
    }

    public function handle(): callable
    {
        return function(callable $handler): callable {
            return function(RequestInterface $request, array $options) use ($handler) {
                return $this->_requestLimitRuleset->cache($request, $this->_requestHandler($handler, $request, $options));
            };
        };
    }

    private function _requestHandler(callable $handler, RequestInterface $request, array $options): callable
    {
        return function() use ($handler, $request, $options) {
            $requestLimitGroup = $this->_requestLimitRuleset->getRequestLimitGroup();
            if (!$requestLimitGroup->canRequest($request, $options)) {
                throw new TooManyRequestsHttpException(
                    $requestLimitGroup->getRetryAfter(),
                    'The rate limit was exceeded. Please try again later.'
                );
            }

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