RateLimit\RequestsPerWindowRateLimiter

Complexity

Total Complexity

13

Size/Duplication

Total Lines	101
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	5

Test Coverage

Coverage

100%

Importance

Changes

0

10 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
A	__invoke()	0	18	3
A	resolveIdentity()	0	4	1
A	getCurrent()	0	4	1
A	isLimitExceeded()	0	4	1
A	initialHit()	0	4	1
A	hit()	0	4	1
A	onLimitExceeded()	0	12	1
A	onBelowLimit()	0	6	2
A	setRateLimitHeaders()	0	8	1

<?php
/**
 * This file is part of the Rate Limit package.
 *
 * Copyright (c) Nikola Posa
 *
 * For full copyright and license information, please refer to the LICENSE file,
 * located at the package root folder.
 */

declare(strict_types=1);

namespace RateLimit;

use Psr\Http\Message\RequestInterface;
use Psr\Http\Message\ResponseInterface;
use RateLimit\Storage\StorageInterface;
use RateLimit\Identity\IdentityResolverInterface;
use RateLimit\Options\RequestsPerWindowOptions;
use RateLimit\Exception\StorageValueNotFoundException;

/**
 * @author Nikola Posa <posa.nikola@gmail.com>
 */
final class RequestsPerWindowRateLimiter extends AbstractRateLimiter
{
    const LIMIT_EXCEEDED_HTTP_STATUS_CODE = 429; //HTTP 429 "Too Many Requests" (RFC 6585)

    const HEADER_LIMIT = 'X-RateLimit-Limit';
    const HEADER_REMAINING = 'X-RateLimit-Remaining';
    const HEADER_RESET = 'X-RateLimit-Reset';

    /**
     * @var RequestsPerWindowOptions
     */
    private $options;

    /**
     * @var string
     */
    private $identity;

    public function __construct(StorageInterface $storage, IdentityResolverInterface $identityResolver, RequestsPerWindowOptions $options)
    {
        parent::__construct($storage, $identityResolver);
        
        $this->options = $options;
    }

    /**
     * {@inheritdoc}
     */
    public function __invoke(RequestInterface $request, ResponseInterface $response, callable $out = null)
    {
        $this->resolveIdentity($request);

        try {
            $current = $this->getCurrent();

            if ($this->isLimitExceeded($current)) {
                return $this->onLimitExceeded($request, $response);
            }

            $this->hit();
        } catch (StorageValueNotFoundException $ex) {
            $this->initialHit();
        }

        return $this->onBelowLimit($request, $response, $out);
    }

    private function resolveIdentity(RequestInterface $request)
    {
        $this->identity = $this->identityResolver->getIdentity($request);
    }

    private function getCurrent() : int
    {
        return $this->storage->get($this->identity);
    }

    private function isLimitExceeded($current) : bool
    {
        return ($current >= $this->options->getLimit());
    }

    private function initialHit()
    {
        $this->storage->set($this->identity, 1, $this->options->getWindow());
    }

    private function hit()
    {
        $this->storage->increment($this->identity, 1);
    }

    private function onLimitExceeded(RequestInterface $request, ResponseInterface $response) : ResponseInterface
    {
        $response = $this
            ->setRateLimitHeaders($response)
            ->withStatus(self::LIMIT_EXCEEDED_HTTP_STATUS_CODE)
        ;

        $limitExceededHandler = $this->options->getLimitExceededHandler();
        $response = $limitExceededHandler($request, $response);

        return $response;
    }

    private function onBelowLimit(RequestInterface $request, ResponseInterface $response, callable $out = null) : ResponseInterface
    {
        $response = $this->setRateLimitHeaders($response);

        return $out ? $out($request, $response) : $response;
    }

    private function setRateLimitHeaders(ResponseInterface $response) : ResponseInterface
    {
        return $response
            ->withHeader(self::HEADER_LIMIT, (string) $this->options->getLimit())
            ->withHeader(self::HEADER_REMAINING, (string) ($this->options->getLimit() - $this->getCurrent()))
            ->withHeader(self::HEADER_RESET, (string) (time() + $this->storage->ttl($this->identity)))
        ;
    }
}