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\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. * @deprecated tag:v6.5.0 - reason:becomes-internal - EventSubscribers will become internal in v6.5.0
  16. */
  17. #[Package('core')]
  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. }