vendor/shopware/core/Framework/Adapter/Translation/TranslatorCacheInvalidate.php line 40

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Shopware\Core\Framework\Adapter\Translation;
  5. use Doctrine\DBAL\Connection;
  6. use Psr\Cache\CacheItemPoolInterface;
  7. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  8. use Shopware\Core\System\Snippet\Aggregate\SnippetSet\SnippetSetDefinition;
  9. use Shopware\Core\System\Snippet\SnippetDefinition;
  10. use Shopware\Core\System\Snippet\SnippetEvents;
  11. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  13. /**
  14.  * @deprecated tag:v6.5.0 - reason:becomes-internal - EventSubscribers will become internal in v6.5.0
  15.  */
  16. class TranslatorCacheInvalidate implements EventSubscriberInterface
  17. {
  18.     private CacheItemPoolInterface $cache;
  20.     private Connection $connection;
  22.     /**
  23.      * @internal
  24.      */
  25.     public function __construct(CacheItemPoolInterface $cache, Connection $connection)
  26.     {
  27.         $this->cache = $cache;
  28.         $this->connection = $connection;
  29.     }
  31.     public static function getSubscribedEvents(): array
  32.     {
  33.         return [
  34.             SnippetEvents::SNIPPET_WRITTEN_EVENT => 'invalidate',
  35.             SnippetEvents::SNIPPET_DELETED_EVENT => 'invalidate',
  36.             SnippetEvents::SNIPPET_SET_DELETED_EVENT => 'invalidate',
  37.         ];
  38.     }
  40.     public function invalidate(EntityWrittenEvent $event): void
  41.     {
  42.         if ($event->getEntityName() === SnippetSetDefinition::ENTITY_NAME) {
  43.             $this->clearCache($event->getIds());
  45.             return;
  46.         }
  48.         if ($event->getEntityName() === SnippetDefinition::ENTITY_NAME) {
  49.             $snippetIds = $event->getIds();
  51.             $rows = $this->connection->fetchAll(
  52.                 'SELECT LOWER(HEX(snippet_set_id)) id FROM snippet WHERE HEX(id) IN (:ids)',
  53.                 ['ids' => $snippetIds],
  54.                 ['ids' => Connection::PARAM_STR_ARRAY]
  55.             );
  56.             $setIds = [];
  57.             foreach ($rows as ['id' => $id]) {
  58.                 $setIds[] = $id;
  59.             }
  61.             $this->clearCache($setIds);
  63.             return;
  64.         }
  65.     }
  67.     /**
  68.      * @param array<string> $snippetSetIds
  69.      */
  70.     private function clearCache(array $snippetSetIds): void
  71.     {
  72.         $snippetSetIds = array_unique($snippetSetIds);
  74.         foreach ($snippetSetIds as $id) {
  75.             $this->cache->deleteItem('translation.catalog.' . $id);
  76.         }
  77.     }
  78. }