src/EventSubscriber/AuthenticatedRateLimiterSubscriber.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 AuthenticatedRateLimiterSubscriber implements EventSubscriberInterface
  11. {
  13.     /**
  14.      * @var RateLimiterFactory
  15.      */
  16.     private $authenticatedApiLimiter;
  18.     public function __construct(RateLimiterFactory $authenticatedApiLimiter)
  19.     {
  20.         $this->authenticatedApiLimiter = $authenticatedApiLimiter;
  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();
  34.         if ($request->isMethod('post')) {
  35.             $apiKey = $request->headers->get('apikey');
  36.             $authLimiter = $this->authenticatedApiLimiter->create($apiKey);
  37.             $authLimiter->reserve(1)->wait();
  39.             if (false === $authLimiter->consume(1)->isAccepted()) {
  40.                 throw new TooManyRequestsHttpException();
  41.             }
  42.         }
  44.         /* $apiKey = $request->headers->get('apikey');
  45.         $limiter = $this->authenticatedApiLimiter->create($apiKey);
  47.         // this blocks the application until the given number of tokens can be consumed
  48.         $limiter->reserve(1)->wait();
  50.         if (false === $limiter->consume(1)->isAccepted()) {
  51.             throw new TooManyRequestsHttpException();
  52.         } */
  53.     }
  54. }