60 lines
		
	
	
		
			1.6 KiB
		
	
	
	
		
			PHP
		
	
	
			
		
		
	
	
			60 lines
		
	
	
		
			1.6 KiB
		
	
	
	
		
			PHP
		
	
	
<?php
 | 
						|
 | 
						|
/*
 | 
						|
 * This file is part of the Symfony package.
 | 
						|
 *
 | 
						|
 * (c) Fabien Potencier <fabien@symfony.com>
 | 
						|
 *
 | 
						|
 * For the full copyright and license information, please view the LICENSE
 | 
						|
 * file that was distributed with this source code.
 | 
						|
 */
 | 
						|
 | 
						|
namespace Symfony\Component\HttpFoundation\RateLimiter;
 | 
						|
 | 
						|
use Symfony\Component\HttpFoundation\Request;
 | 
						|
use Symfony\Component\RateLimiter\LimiterInterface;
 | 
						|
use Symfony\Component\RateLimiter\Policy\NoLimiter;
 | 
						|
use Symfony\Component\RateLimiter\RateLimit;
 | 
						|
 | 
						|
/**
 | 
						|
 * An implementation of RequestRateLimiterInterface that
 | 
						|
 * fits most use-cases.
 | 
						|
 *
 | 
						|
 * @author Wouter de Jong <wouter@wouterj.nl>
 | 
						|
 *
 | 
						|
 * @experimental in 5.3
 | 
						|
 */
 | 
						|
abstract class AbstractRequestRateLimiter implements RequestRateLimiterInterface
 | 
						|
{
 | 
						|
    public function consume(Request $request): RateLimit
 | 
						|
    {
 | 
						|
        $limiters = $this->getLimiters($request);
 | 
						|
        if (0 === \count($limiters)) {
 | 
						|
            $limiters = [new NoLimiter()];
 | 
						|
        }
 | 
						|
 | 
						|
        $minimalRateLimit = null;
 | 
						|
        foreach ($limiters as $limiter) {
 | 
						|
            $rateLimit = $limiter->consume(1);
 | 
						|
 | 
						|
            if (null === $minimalRateLimit || $rateLimit->getRemainingTokens() < $minimalRateLimit->getRemainingTokens()) {
 | 
						|
                $minimalRateLimit = $rateLimit;
 | 
						|
            }
 | 
						|
        }
 | 
						|
 | 
						|
        return $minimalRateLimit;
 | 
						|
    }
 | 
						|
 | 
						|
    public function reset(Request $request): void
 | 
						|
    {
 | 
						|
        foreach ($this->getLimiters($request) as $limiter) {
 | 
						|
            $limiter->reset();
 | 
						|
        }
 | 
						|
    }
 | 
						|
 | 
						|
    /**
 | 
						|
     * @return LimiterInterface[] a set of limiters using keys extracted from the request
 | 
						|
     */
 | 
						|
    abstract protected function getLimiters(Request $request): array;
 | 
						|
}
 |