src/EventSubscriber/RequestCacheSubscriber.php line 42

Open in your IDE?
  1. <?php
  3. namespace App\EventSubscriber;
  5. use App\Services\RequestCacheService;
  6. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  7. use Symfony\Component\HttpKernel\Event\RequestEvent;
  8. use Symfony\Component\HttpKernel\Event\ResponseEvent;
  10. class RequestCacheSubscriber implements EventSubscriberInterface {
  12.     /**
  13.      * @var RequestCacheService
  14.      */
  15.     protected $requestCacheService;
  17.     /**
  18.      * @var bool
  19.      */
  20.     protected $supportsRequest = false;
  22.     /**
  23.      * @var bool
  24.      */
  25.     protected $usedCache = false;
  27.     /**
  28.      * RequestCacheSubscriber constructor.
  29.      * @param RequestCacheService $requestCacheService
  30.      */
  31.     public function __construct(RequestCacheService $requestCacheService) {
  32.         $this->requestCacheService = $requestCacheService;
  33.     }
  35.     public static function getSubscribedEvents(): array {
  36.         return [
  37.             'kernel.request' => 'onKernelRequest',
  38.             'kernel.response' => 'onKernelResponse',
  39.         ];
  40.     }
  42.     public function onKernelRequest(RequestEvent $event) {
  43.         if (!$event->isMasterRequest()) {
  44.             return;
  45.         }
  47.         $request = $event->getRequest();
  48.         $this->supportsRequest = $this->requestCacheService->supports($request);
  49.         if (!$this->supportsRequest) {
  50.             return;
  51.         }
  53.         $jsonResponse = $this->requestCacheService->getCachedResponse($request);
  54.         if (isset($jsonResponse)) {
  55.             $this->usedCache = true;
  56.             $event->setResponse($jsonResponse);
  57.         }
  58.     }
  60.     public function onKernelResponse(ResponseEvent $event) {
  61.         if (!$this->supportsRequest) {
  62.             return;
  63.         }
  65.         $response = $event->getResponse();
  67.         // Only cache success responses
  68.         if ($response->getStatusCode() !== 200) {
  69.             return;
  70.         }
  72.         // Prevent re-writing in kernel response
  73.         if ($this->usedCache) {
  74.             return;
  75.         }
  77.         $this->requestCacheService->cacheResponse($event->getRequest(), $response);
  78.     }
  80. }