src/EventSubscriber/RateLimiterSubscriber.php line 30

Open in your IDE?
  1. <?php
  3. namespace App\EventSubscriber;
  5. use Symfony\Component\HttpKernel\Event\RequestEvent;
  6. use Symfony\Component\RateLimiter\RateLimiterFactory;
  7. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  8. use Symfony\Component\HttpKernel\Exception\TooManyRequestsHttpException;
  10. class RateLimiterSubscriber implements EventSubscriberInterface
  11. {
  13.     /**
  14.      * @var RateLimiterFactory
  15.      */
  16.     private $anonymousApiLimiter;
  18.     public function __construct(RateLimiterFactory $anonymousApiLimiter)
  19.     {
  20.         $this->anonymousApiLimiter = $anonymousApiLimiter;
  21.     }
  23.     public static function getSubscribedEvents(): array
  24.     {
  25.         return [
  26.             RequestEvent::class => 'onKernelRequest',
  27.         ];
  28.     }
  30.     public function onKernelRequest(RequestEvent $event): void
  31.     {
  32.         $request = $event->getRequest();
  33.         if ($request->isMethod('get')) {
  34.             $limiter = $this->anonymousApiLimiter->create($request->getClientIp());
  35.             /* $limit = $limiter->consume();
  36.             $headers = [
  37.                 'X-RateLimit-Remaining' => $limit->getRemainingTokens(),
  38.                 'X-RateLimit-Retry-After' => $limit->getRetryAfter()->getTimestamp(),
  39.                 'X-RateLimit-Limit' => $limit->getLimit(),
  40.             ]; */
  42.             if (false === $limiter->consume(1)->isAccepted()) {
  43.                 throw new TooManyRequestsHttpException();
  44.             }
  45.         }
  46.     }
  47. }