src/Core/Framework/Adapter/Translation/TranslatorCacheInvalidate.php line 36

  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\Framework\Log\Package;
  9. use Shopware\Core\System\Snippet\Aggregate\SnippetSet\SnippetSetDefinition;
  10. use Shopware\Core\System\Snippet\SnippetDefinition;
  11. use Shopware\Core\System\Snippet\SnippetEvents;
  12. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  14. /**
  15.  * @internal
  16.  */
  17. #[Package('core')]
  18. class TranslatorCacheInvalidate implements EventSubscriberInterface
  19. {
  20.     /**
  21.      * @internal
  22.      */
  23.     public function __construct(private readonly CacheInvalidator $cacheInvalidator, private readonly Connection $connection)
  24.     {
  25.     }
  27.     public static function getSubscribedEvents(): array
  28.     {
  29.         return [
  30.             SnippetEvents::SNIPPET_WRITTEN_EVENT => 'invalidate',
  31.             SnippetEvents::SNIPPET_DELETED_EVENT => 'invalidate',
  32.             SnippetEvents::SNIPPET_SET_DELETED_EVENT => 'invalidate',
  33.         ];
  34.     }
  36.     public function invalidate(EntityWrittenEvent $event): void
  37.     {
  38.         if ($event->getEntityName() === SnippetSetDefinition::ENTITY_NAME) {
  39.             $this->clearCache($event->getIds());
  41.             return;
  42.         }
  44.         if ($event->getEntityName() === SnippetDefinition::ENTITY_NAME) {
  45.             $snippetIds = $event->getIds();
  47.             $setIds = $this->connection->fetchFirstColumn(
  48.                 'SELECT LOWER(HEX(snippet_set_id)) FROM snippet WHERE HEX(id) IN (:ids)',
  49.                 ['ids' => $snippetIds],
  50.                 ['ids' => Connection::PARAM_STR_ARRAY]
  51.             );
  53.             $this->clearCache($setIds);
  54.         }
  55.     }
  57.     /**
  58.      * @param array<string> $snippetSetIds
  59.      */
  60.     private function clearCache(array $snippetSetIds): void
  61.     {
  62.         $snippetSetIds = array_unique($snippetSetIds);
  64.         $snippetSetCacheKeys = array_map(fn (string $setId) => 'translation.catalog.' . $setId, $snippetSetIds);
  66.         $this->cacheInvalidator->invalidate($snippetSetCacheKeys, true);
  67.     }
  68. }