src/Listener/CacheListener.php line 67

Open in your IDE?
  1. <?php
  4. namespace App\Listener;
  7. use App\Entity\User;
  8. use App\Services\CacheService;
  9. use Psr\Log\LoggerInterface;
  10. use Symfony\Component\HttpFoundation\JsonResponse;
  11. use Symfony\Component\HttpFoundation\Response;
  12. use Symfony\Component\HttpKernel\Event\KernelEvent;
  13. use Symfony\Component\HttpKernel\Event\RequestEvent;
  14. use Symfony\Component\HttpKernel\Event\ResponseEvent;
  15. use Symfony\Component\Security\Core\Security;
  17. class CacheListener
  18. {
  19.     /**
  20.      * @var CacheService
  21.      */
  22.     private $cacheService;
  24.     /**
  25.      * @var array
  26.      */
  27.     private $config;
  29.     /**
  30.      * @var Security
  31.      */
  32.     private $security;
  34.     /**
  35.      * @var array
  36.      */
  37.     private $cacheable = [];
  39.     /**
  40.      * CacheListener constructor.
  41.      * @param CacheService $cacheService
  42.      * @param array $config
  43.      * @param Security $security
  44.      */
  45.     public function __construct(CacheService $cacheService, array $config, Security $security)
  46.     {
  47.         $this->cacheService = $cacheService;
  48.         $this->config = $config;
  49.         $this->security = $security;
  50.         foreach ($this->config as $key => $item) {
  51.             if ($item === null) {
  52.                 $this->config[$key] = [];
  53.             }
  54.         }
  55.     }
  57.     /**
  58.      * Overwrites principal
  59.      * @param string $route
  60.      * @return array
  61.      */
  62.     private function getRouteConfig(string $route)
  63.     {
  64.         return array_merge($this->config['config'], $this->config[$route]);
  65.     }
  67.     public function onKernelRequest(RequestEvent $event)
  68.     {
  69.         $route = $event->getRequest()->get('_route');
  70.         if (isset($this->config[$route])) {
  71.             $_config = $this->getRouteConfig($route);
  72.             $user = $this->security->getUser();
  73.             if (isset($_config['roles']) || isset($_config['reverse_roles'])) {
  74.                 $roles = ($user instanceof User) ? $user->getRoles() : [];
  75.                 $inclusions = $_config['roles'] ?? [];
  76.                 $exclusions = $_config['reverse_roles'] ?? [];
  77.                 //if the route has an inclusive roles list or an exclusive roles list
  78.                 //if inclusions are detected and the role is not in the list
  79.                 //or if it has exclusions and the role is in the list
  80.                 if ((!empty($inclusions) && empty(array_intersect($roles, $inclusions))) ||
  81.                     (!empty($exclusions) && !empty(array_intersect($roles, $exclusions)))) {
  82.                     return;
  83.                 }
  84.             }
  85.             $content = $this->cacheService->getCacheRoute($route, $_config, $event->getRequest());
  86.             if (!empty($content)) {
  87.                 $response = new JsonResponse($content, 200, [], true);
  88.                 $event->setResponse($response);
  89.                 $event->stopPropagation();
  90.             } else {
  91.                 $this->cacheable[$route] = $_config;
  92.             }
  93.         }
  94.     }
  96.     public function onKernelResponse(ResponseEvent $event)
  97.     {
  98.         $route = $event->getRequest()->get('_route', 'empty');
  99.         if (isset($this->cacheable[$route])) {
  100.             $this->cacheService->cacheRoute($route, $this->cacheable[$route], $event->getRequest(), $event->getResponse());
  101.         }
  102.     }
  103. }