src/WebserviceBundle/Event/IdempotencyRequestListener.php line 32

Open in your IDE?
  1. <?php
  3. namespace WebserviceBundle\Event;
  5. use Predis\Client;
  6. use Symfony\Component\HttpFoundation\Response;
  7. use Symfony\Component\HttpKernel\Event\GetResponseEvent;
  9. /**
  10.  * Class IdempotencyRequestListener
  11.  * @package WebserviceBundle\Event
  12.  */
  13. class IdempotencyRequestListener
  14. {
  15.     /**
  16.      * @var Client
  17.      */
  18.     private $redisConnection;
  20.     /**
  21.      * IdempotencyRequestListener constructor.
  22.      * @param Client $redisConnection
  23.      */
  24.     public function __construct(Client $redisConnection)
  25.     {
  26.         $this->redisConnection = $redisConnection;
  27.     }
  29.     /**
  30.      * @param GetResponseEvent $event
  31.      */
  32.     public function onRequest(GetResponseEvent $event)
  33.     {
  34.         $request = $event->getRequest();
  36.         if (!$request->headers->has('idempotency-key') || !$request->headers->get('idempotency-key')) {
  37.             return;
  38.         }
  40.         $requestKey = $request->headers->get('idempotency-key');
  41.         $prefix = 'IDEMP_';
  43.         $value = $prefix . $requestKey;
  45.         // return 304 (not-modified) when key already exists
  46.         if ($this->redisConnection->exists($value)) {
  47.             $event->setResponse(new Response('Non-unique request', 304));
  48.         }
  50.         $this->redisConnection->setex($value, 3600, 'exists');
  51.     }
  52. }