src/EventSubscriber/IdempotenceSubscriber.php line 105

Open in your IDE?
  1. <?php
  2. /**
  3.  * @license Silk Software House Sp. Z O.O.
  4.  */
  6. declare(strict_types=1);
  8. namespace App\EventSubscriber;
  10. use App\Annotation\Idempotent;
  11. use App\Entity\CachedResponse;
  12. use App\Repository\CachedResponseRepository;
  13. use Doctrine\ORM\EntityManagerInterface as EntityManager;
  14. use Symfony\Component\HttpFoundation\JsonResponse;
  15. use Symfony\Component\HttpFoundation\Response;
  16. use Symfony\Component\HttpKernel\Event\ControllerEvent;
  17. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  18. use Symfony\Component\HttpKernel\Event\ResponseEvent;
  19. use Symfony\Component\HttpKernel\KernelEvents;
  20. use Doctrine\Common\Annotations\Reader;
  21. use ReflectionClass;
  22. use ReflectionException;
  24. /**
  25.  * Class IdempotenceSubscriber.
  26.  */
  27. class IdempotenceSubscriber implements EventSubscriberInterface
  28. {
  29.     /**
  30.      * Cache repository.
  31.      *
  32.      * @var CachedResponseRepository
  33.      */
  34.     private $cache;
  36.     /**
  37.      * Annotation reader.
  38.      *
  39.      * @var Reader
  40.      */
  41.     private $annotationReader;
  43.     /**
  44.      * IdempotenceSubscriber constructor.
  45.      *
  46.      * @param EntityManager $entityManager
  47.      * @param Reader        $reader
  48.      */
  49.     public function __construct(EntityManager $entityManager, Reader $reader)
  50.     {
  51.         $this->cache = $entityManager->getRepository(CachedResponse::class);
  52.         $this->annotationReader = $reader;
  53.     }
  55.     /**
  56.      * Get subscribed events.
  57.      *
  58.      * @return array
  59.      */
  60.     public static function getSubscribedEvents()
  61.     {
  62.         // return the subscribed events, their methods and priorities
  63.         return [
  64.             KernelEvents::CONTROLLER => [
  65.                 ['onKernelController', -2],
  66.             ],
  67.             KernelEvents::RESPONSE => [
  68.                 ['onKernelResponse', 10],
  69.             ],
  70.         ];
  71.     }
  73.     /**
  74.      * On kernel controller.
  75.      *
  76.      * @param ControllerEvent $event
  77.      */
  78.     public function onKernelController(ControllerEvent $event)
  79.     {
  80.         if (!$event->isMasterRequest()) {
  81.             return;
  82.         }
  83.         $annotation = $this->getIdempotentAnnotation($event->getController());
  84.         if (null === $annotation) {
  85.             return;
  86.         }
  89.         $idempotenceHash = $event->getRequest()->getContent();
  90.         $event->getRequest()->cookies->set('idempotent', $idempotenceHash);
  93.         if ($cached = $this->cache->getCachedResponse($idempotenceHash, $event->getRequest()->get('_route'))) {
  94.             $event->setController(function () use ($cached) {
  95.                 return $cached;
  96.             });
  97.         }
  98.     }
  100.     /**
  101.      * On kernel response.
  102.      *
  103.      * @param ResponseEvent $event
  104.      */
  105.     public function onKernelResponse(ResponseEvent $event)
  106.     {
  107.         $requestId = $event->getRequest()->cookies->get('idempotent');
  108.         if (!$requestId) {
  109.             return;
  110.         }
  112.         $response = $event->getResponse();
  113.         if (!$response instanceof JsonResponse || Response::HTTP_CREATED !== $response->getStatusCode()) {
  114.             return;
  115.         }
  117.         $this->cache->cache(
  118.             $requestId,
  119.             $response->getStatusCode(),
  120.             $response->getContent(),
  121.             $event->getRequest()->get('_route')
  122.         );
  123.     }
  125.     /**
  126.      * Does controller have idempotent annotation.
  127.      *
  128.      * @param callable $controllerData
  129.      *
  130.      * @return Idempotent|null
  131.      */
  132.     private function getIdempotentAnnotation($controllerData)
  133.     {
  134.         $annotation = null;
  135.         if (!is_array($controllerData)) {
  136.             return null;
  137.         }
  139.         [$controllerObject, $methodName] = $controllerData;
  141.         try {
  142.             $controller = new ReflectionClass($controllerObject);
  143.             $method = $controller->getMethod($methodName);
  144.             $annotation = $this->annotationReader->getMethodAnnotation($method, Idempotent::class);
  145.         } catch (ReflectionException $e) {
  146.             return null;
  147.         }
  149.         return $annotation instanceof Idempotent ? $annotation : null;
  150.     }
  151. }