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

  1. <?php declare(strict_types=1);
  3. namespace Shopware\Core\Framework\Adapter\Translation;
  5. use Doctrine\DBAL\ArrayParameterType;
  6. use Doctrine\DBAL\Connection;
  7. use Shopware\Core\Framework\Adapter\Cache\CacheInvalidator;
  8. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  9. use Shopware\Core\Framework\Log\Package;
  10. use Shopware\Core\System\Snippet\Aggregate\SnippetSet\SnippetSetDefinition;
  11. use Shopware\Core\System\Snippet\SnippetDefinition;
  12. use Shopware\Core\System\Snippet\SnippetEvents;
  13. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  15. /**
  16.  * @internal
  17.  */
  18. #[Package('core')]
  19. class TranslatorCacheInvalidate implements EventSubscriberInterface
  20. {
  21.     /**
  22.      * @internal
  23.      */
  24.     public function __construct(
  25.         private readonly CacheInvalidator $cacheInvalidator,
  26.         private readonly Connection $connection
  27.     ) {
  28.     }
  30.     public static function getSubscribedEvents(): array
  31.     {
  32.         return [
  33.             SnippetEvents::SNIPPET_WRITTEN_EVENT => 'invalidate',
  34.             SnippetEvents::SNIPPET_DELETED_EVENT => 'invalidate',
  35.             SnippetEvents::SNIPPET_SET_DELETED_EVENT => 'invalidate',
  36.         ];
  37.     }
  39.     public function invalidate(EntityWrittenEvent $event): void
  40.     {
  41.         if ($event->getEntityName() === SnippetSetDefinition::ENTITY_NAME) {
  42.             $this->clearCache($event->getIds());
  44.             return;
  45.         }
  47.         if ($event->getEntityName() === SnippetDefinition::ENTITY_NAME) {
  48.             $snippetIds = $event->getIds();
  50.             $setIds = $this->connection->fetchFirstColumn(
  51.                 'SELECT LOWER(HEX(snippet_set_id)) FROM snippet WHERE HEX(id) IN (:ids)',
  52.                 ['ids' => $snippetIds],
  53.                 ['ids' => ArrayParameterType::STRING]
  54.             );
  56.             $this->clearCache($setIds);
  57.         }
  58.     }
  60.     /**
  61.      * @param array<string> $snippetSetIds
  62.      */
  63.     private function clearCache(array $snippetSetIds): void
  64.     {
  65.         $snippetSetIds = array_unique($snippetSetIds);
  67.         $snippetSetCacheKeys = array_map(fn (string $setId) => 'translation.catalog.' . $setId, $snippetSetIds);
  69.         $this->cacheInvalidator->invalidate($snippetSetCacheKeys, true);
  70.     }
  71. }