src/EventSubscriber/IdempotenceSubscriber.php line 102

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