vendor/payneticsteam/paynetics-bundle/src/Paynetics/EventSubscriber/EntityCacheLoadSubscriber.php line 65

Open in your IDE?
  1. <?php
  3. namespace Paynetics\EventSubscriber;
  5. use Paynetics\Annotation\Cache\Settings;
  6. use Paynetics\Cache\CacheableInterface;
  7. use Paynetics\Cache\RedisCacheRequest;
  8. use Paynetics\Event\EntityCacheEvent;
  9. use Paynetics\Extractor\AnnotationExtractor;
  10. use Psr\Cache\InvalidArgumentException;
  11. use ReflectionException;
  12. use Symfony\Component\DependencyInjection\ContainerInterface;
  13. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  15. /**
  16.  * Class EntityCacheLoadSubscriber
  17.  * @package Paynetics\EventSubscriber
  18.  */
  19. class EntityCacheLoadSubscriber implements EventSubscriberInterface
  20. {
  22.     /**
  23.      * @var AnnotationExtractor
  24.      */
  25.     private $extractor;
  27.     /**
  28.      * @var ContainerInterface
  29.      */
  30.     private $container;
  32.     /**
  33.      * @var RedisCacheRequest
  34.      */
  35.     private $cache;
  37.     /**
  38.      * EntityCacheLoadSubscriber constructor.
  39.      * @param AnnotationExtractor $extractor
  40.      * @param ContainerInterface $container
  41.      * @param RedisCacheRequest $cache
  42.      */
  43.     public function __construct(AnnotationExtractor $extractor, ContainerInterface $container, RedisCacheRequest $cache)
  44.     {
  45.         $this->extractor = $extractor;
  46.         $this->container = $container;
  47.         $this->cache = $cache;
  48.     }
  50.     /**
  51.      * @inheritDoc
  52.      */
  53.     public static function getSubscribedEvents():array
  54.     {
  55.         return [
  56.             EntityCacheEvent::class => 'onEntityLoaded'
  57.         ];
  58.     }
  60.     /**
  61.      * @param EntityCacheEvent $event
  62.      * @throws InvalidArgumentException
  63.      * @throws ReflectionException
  64.      */
  65.     public function onEntityLoaded(EntityCacheEvent $event): void
  66.     {
  67.         $config = $this->container->getParameter('cache');
  69.         if (!$config['enable']) {
  70.             return;
  71.         }
  73.         $entity = $event->getEntity();
  75.         if (!$entity instanceof CacheableInterface) {
  76.             return;
  77.         }
  79.         [$identity, $options, $fields] = $this->prepare($entity);
  81.         $this->cache->set($identity, json_encode($fields, JSON_THROW_ON_ERROR, 512), $options['ex'] ?? 0);
  82.     }
  84.     /**
  85.      * @param $entity
  86.      * @return array
  87.      * @throws InvalidArgumentException
  88.      * @throws ReflectionException
  89.      */
  90.     private function prepare($entity): array
  91.     {
  93.         $data = $this->extractor->extract($entity);
  95.         /**
  96.          * @var $settings Settings
  97.          */
  98.         $settings = $data['settings'];
  100.         $fields = $data['fields'];
  102.         $identity = "{$data['identity']}:{$fields['identity']}";
  104.         unset($fields['identity']);
  106.         $options = [];
  108.         if ($settings->expiration > 0) {
  109.             $options['ex'] = $settings->expiration;
  110.         }
  112.         return [$identity, $options, $fields];
  113.     }
  114. }