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

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Shopware\Core\Framework\Adapter\Translation;
  5. use Doctrine\DBAL\Connection;
  6. use Shopware\Core\Framework\Adapter\Cache\CacheInvalidator;
  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.  * @package core
  15.  *
  16.  * @deprecated tag:v6.5.0 - reason:becomes-internal - EventSubscribers will become internal in v6.5.0
  17.  */
  18. class TranslatorCacheInvalidate implements EventSubscriberInterface
  19. {
  20.     private Connection $connection;
  22.     private CacheInvalidator $cacheInvalidator;
  24.     /**
  25.      * @internal
  26.      */
  27.     public function __construct(CacheInvalidator $cacheInvalidator, Connection $connection)
  28.     {
  29.         $this->connection = $connection;
  30.         $this->cacheInvalidator = $cacheInvalidator;
  31.     }
  33.     public static function getSubscribedEvents(): array
  34.     {
  35.         return [
  36.             SnippetEvents::SNIPPET_WRITTEN_EVENT => 'invalidate',
  37.             SnippetEvents::SNIPPET_DELETED_EVENT => 'invalidate',
  38.             SnippetEvents::SNIPPET_SET_DELETED_EVENT => 'invalidate',
  39.         ];
  40.     }
  42.     public function invalidate(EntityWrittenEvent $event): void
  43.     {
  44.         if ($event->getEntityName() === SnippetSetDefinition::ENTITY_NAME) {
  45.             $this->clearCache($event->getIds());
  47.             return;
  48.         }
  50.         if ($event->getEntityName() === SnippetDefinition::ENTITY_NAME) {
  51.             $snippetIds = $event->getIds();
  53.             $setIds = $this->connection->fetchFirstColumn(
  54.                 'SELECT LOWER(HEX(snippet_set_id)) FROM snippet WHERE HEX(id) IN (:ids)',
  55.                 ['ids' => $snippetIds],
  56.                 ['ids' => Connection::PARAM_STR_ARRAY]
  57.             );
  59.             $this->clearCache($setIds);
  60.         }
  61.     }
  63.     /**
  64.      * @param array<string> $snippetSetIds
  65.      */
  66.     private function clearCache(array $snippetSetIds): void
  67.     {
  68.         $snippetSetIds = array_unique($snippetSetIds);
  70.         $snippetSetCacheKeys = array_map(function (string $setId) {
  71.             return 'translation.catalog.' . $setId;
  72.         }, $snippetSetIds);
  74.         $this->cacheInvalidator->invalidate($snippetSetCacheKeys, true);
  75.     }
  76. }