custom/plugins/SwkwebProductSet/src/Core/Content/ProductSet/Cache/CacheInvalidationSubscriber.php line 44

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Swkweb\ProductSet\Core\Content\ProductSet\Cache;
  5. use Shopware\Core\Content\Product\ProductDefinition;
  6. use Shopware\Core\Framework\Adapter\Cache\CacheInvalidator;
  7. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenContainerEvent;
  8. use Swkweb\ProductSet\Core\Content\ProductSet\Aggregate\ProductSetPriceCalculation\ProductSetPriceCalculationDefinition;
  9. use Swkweb\ProductSet\Core\Content\ProductSet\ProductSetDefinition;
  10. use Swkweb\ProductSet\Core\Content\ProductSet\SalesChannel\CachedProductSetRoute;
  11. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  13. class CacheInvalidationSubscriber implements EventSubscriberInterface
  14. {
  15.     private CacheInvalidator $cacheInvalidator;
  17.     public function __construct(CacheInvalidator $cacheInvalidator)
  18.     {
  19.         $this->cacheInvalidator = $cacheInvalidator;
  20.     }
  22.     public static function getSubscribedEvents(): array
  23.     {
  24.         return [
  25.             EntityWrittenContainerEvent::class => [
  26.                 ['invalidateProductSetRoute'],
  27.                 ['invalidateProductSetIds'],
  28.                 ['invalidatePriceCalculationIds'],
  29.             ],
  30.         ];
  31.     }
  33.     public function invalidateProductSetRoute(EntityWrittenContainerEvent $event): void
  34.     {
  35.         $ids = $event->getPrimaryKeys(ProductDefinition::ENTITY_NAME);
  37.         if (count($ids) === 0) {
  38.             return;
  39.         }
  41.         $this->cacheInvalidator->invalidate(array_map(fn (string $id) => CachedProductSetRoute::buildName($id), $ids));
  42.     }
  44.     public function invalidateProductSetIds(EntityWrittenContainerEvent $event): void
  45.     {
  46.         $ids = $event->getPrimaryKeys(ProductSetDefinition::ENTITY_NAME);
  48.         if (count($ids) === 0) {
  49.             return;
  50.         }
  52.         $this->cacheInvalidator->invalidate(array_map(fn (string $id) => ProductSetCacheKeyGenerator::buildSetTag($id), $ids));
  53.     }
  55.     public function invalidatePriceCalculationIds(EntityWrittenContainerEvent $event): void
  56.     {
  57.         $ids = $event->getPrimaryKeys(ProductSetPriceCalculationDefinition::ENTITY_NAME);
  59.         if (count($ids) === 0) {
  60.             return;
  61.         }
  63.         $this->cacheInvalidator->invalidate(array_map(fn (string $id) => ProductSetCacheKeyGenerator::buildPriceCalculationTag($id), $ids));
  64.     }
  65. }