custom/plugins/WbfkCmsHideParts/src/Cache/CacheInvalidationSubscriber.php line 53

Open in your IDE?
  1. <?php
  3. namespace Wbfk\CmsHideParts\Cache;
  5. use Doctrine\DBAL\Connection;
  6. use Doctrine\DBAL\Exception;
  7. use Shopware\Core\Content\Category\SalesChannel\CachedCategoryRoute;
  8. use Shopware\Core\Framework\Adapter\Cache\CacheInvalidator;
  9. use Shopware\Core\Framework\DataAbstractionLayer\Cache\EntityCacheKeyGenerator;
  10. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenContainerEvent;
  11. use Shopware\Core\Framework\Uuid\Uuid;
  12. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  13. use Wbfk\CmsHideParts\DataAbstractionLayer\HiddenCmsPartsDefinition;
  14. use Wbfk\CmsHideParts\DataAbstractionLayer\HiddenEntityPartsDefinition;
  16. class CacheInvalidationSubscriber implements EventSubscriberInterface
  17. {
  19.     /**
  20.      * @var CacheInvalidator
  21.      */
  22.     private CacheInvalidator $cacheInvalidator;
  24.     /**
  25.      * @var Connection
  26.      */
  27.     private Connection $connection;
  30.     public function __construct(CacheInvalidator $cacheInvalidator, Connection $connection)
  31.     {
  32.         $this->cacheInvalidator = $cacheInvalidator;
  33.         $this->connection = $connection;
  34.     }
  37.     /**
  38.      * @return \array[][]
  39.      */
  40.     public static function getSubscribedEvents(): array
  41.     {
  42.         return [
  43.             EntityWrittenContainerEvent::class => [
  44.                 ['invalidatePage', 3001],
  45.             ]
  46.         ];
  47.     }
  50.     /**
  51.      * @throws Exception
  52.      */
  53.     public function invalidatePage(EntityWrittenContainerEvent $event): void
  54.     {
  55.         $pageHiddenPartsIds = $event->getPrimaryKeys(HiddenCmsPartsDefinition::ENTITY_NAME);
  56.         if ($pageHiddenPartsIds) {
  57.             $pageIdsToInvalidate = $this->connection->fetchFirstColumn(
  58.                 'SELECT LOWER(HEX(`cms_page_id`)) FROM `wbfk_hidden_cms_parts` WHERE `id` IN (:ids)',
  59.                 ['ids' => Uuid::fromHexToBytesList($pageHiddenPartsIds)],
  60.                 ['ids' => Connection::PARAM_STR_ARRAY]
  61.             );
  62.             if ($pageIdsToInvalidate) {
  63.                 $this->cacheInvalidator->invalidate(
  64.                     array_map([EntityCacheKeyGenerator::class, 'buildCmsTag'], $pageIdsToInvalidate)
  65.                 );
  66.             }
  67.         }
  69.         $entityHiddenPartsIds = $event->getPrimaryKeys(HiddenEntityPartsDefinition::ENTITY_NAME);
  70.         if ($entityHiddenPartsIds) {
  71.             $entitiesToInvalidate = $this->connection->fetchAllAssociative(
  72.                 'SELECT LOWER(HEX(`id`)) as `id`, entity, LOWER(HEX(`entity_id`)) as `entity_id` FROM `wbfk_hidden_entity_parts` WHERE `id` IN (:ids)',
  73.                 ['ids' => Uuid::fromHexToBytesList($entityHiddenPartsIds)],
  74.                 ['ids' => Connection::PARAM_STR_ARRAY]
  75.             );
  77.             $idsByType = [];
  78.             foreach ($entitiesToInvalidate as $entity) {
  79.                 $idsByType[$entity['entity']][] = $entity['id'];
  80.             }
  82.             if (array_key_exists('category', $idsByType)) {
  83.                 $this->cacheInvalidator->invalidate(
  84.                     array_map([CachedCategoryRoute::class, 'buildName'], $idsByType['category'])
  85.                 );
  86.             }
  88.             if (array_key_exists('product', $idsByType)) {
  89.                 $this->cacheInvalidator->invalidate(
  90.                     array_map([EntityCacheKeyGenerator::class, 'buildProductTag'], $idsByType['product'])
  91.                 );
  92.             }
  93.         }
  94.     }
  95. }