vendor/shopware/core/Framework/DataAbstractionLayer/Cache/InvalidateCacheSubscriber.php line 52

Open in your IDE?
  1. <?php
  2. declare(strict_types=1);
  4. namespace Shopware\Core\Framework\DataAbstractionLayer\Cache;
  6. use Shopware\Core\Framework\Adapter\Cache\CacheClearer;
  7. use Shopware\Core\Framework\DataAbstractionLayer\Dbal\EntityDefinitionQueryHelper;
  8. use Shopware\Core\Framework\DataAbstractionLayer\DefinitionInstanceRegistry;
  9. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenContainerEvent;
  10. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  11. use Shopware\Core\Framework\DataAbstractionLayer\Field\FkField;
  12. use Shopware\Core\Framework\DataAbstractionLayer\Field\StorageAware;
  13. use Shopware\Core\Framework\DataAbstractionLayer\Field\TranslatedField;
  14. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  16. class InvalidateCacheSubscriber implements EventSubscriberInterface
  17. {
  18.     /**
  19.      * @var CacheClearer
  20.      */
  21.     private $cache;
  23.     /**
  24.      * @var EntityCacheKeyGenerator
  25.      */
  26.     private $cacheKeyGenerator;
  28.     /**
  29.      * @var DefinitionInstanceRegistry
  30.      */
  31.     private $definitionRegistry;
  33.     public function __construct(
  34.         CacheClearer $cache,
  35.         EntityCacheKeyGenerator $cacheKeyGenerator,
  36.         DefinitionInstanceRegistry $definitionRegistry
  37.     ) {
  38.         $this->cache = $cache;
  39.         $this->cacheKeyGenerator = $cacheKeyGenerator;
  40.         $this->definitionRegistry = $definitionRegistry;
  41.     }
  43.     public static function getSubscribedEvents(): array
  44.     {
  45.         return [
  46.             EntityWrittenContainerEvent::class => [
  47.                 ['entitiesWritten', -20000],
  48.             ],
  49.         ];
  50.     }
  52.     public function entitiesWritten(EntityWrittenContainerEvent $event): void
  53.     {
  54.         $keys = [];
  56.         $events = $event->getEvents();
  57.         if (!$events) {
  58.             return;
  59.         }
  61.         /** @var EntityWrittenEvent $writtenEvent */
  62.         foreach ($events as $writtenEvent) {
  63.             $definition = $this->definitionRegistry->getByEntityName($writtenEvent->getEntityName());
  65.             foreach ($writtenEvent->getWriteResults() as $result) {
  66.                 $id = $result->getPrimaryKey();
  68.                 if (\is_array($id)) {
  69.                     $id = implode('-', $id);
  70.                 }
  72.                 $keys[] = $this->cacheKeyGenerator->getEntityTag($id, $definition->getEntityName());
  74.                 foreach ($result->getPayload() as $propertyName => $value) {
  75.                     $field = $definition->getFields()->get($propertyName);
  77.                     if (($field instanceof FkField) && $value !== null) {
  78.                         $keys[] = $this->cacheKeyGenerator->getEntityTag($value, $field->getReferenceDefinition()->getEntityName());
  79.                     }
  81.                     if ($field instanceof TranslatedField) {
  82.                         $field = EntityDefinitionQueryHelper::getTranslatedField($definition, $field);
  83.                     }
  85.                     if (!$field instanceof StorageAware) {
  86.                         continue;
  87.                     }
  88.                     $keys[] = $this->cacheKeyGenerator->getFieldTag($definition, $field->getStorageName());
  89.                 }
  90.             }
  91.         }
  93.         $keys = array_filter(array_keys(array_flip($keys)));
  94.         $this->cache->invalidateTags($keys);
  95.     }
  96. }