custom/plugins/NetzpEvents6/src/Controller/StoreApi/CacheInvalidationSubscriber.php line 39

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace NetzpEvents6\Controller\StoreApi;
  5. use NetzpEvents6\Controller\StoreApi\EventListing\CachedEventListingRoute;
  6. use NetzpEvents6\Core\Content\Event\EventDefinition;
  7. use Shopware\Core\Content\Cms\Aggregate\CmsSlotTranslation\CmsSlotTranslationDefinition;
  8. use Shopware\Core\Content\Product\SalesChannel\Detail\CachedProductDetailRoute;
  9. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  10. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenContainerEvent;
  11. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  12. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  13. use Shopware\Core\Framework\Adapter\Cache\CacheInvalidator;
  15. class CacheInvalidationSubscriber implements EventSubscriberInterface
  16. {
  17.     private CacheInvalidator $cacheInvalidator;
  18.     private $eventsRepository;
  19.     private $cmsSlotsRepository;
  21.     public function __construct(CacheInvalidator $cacheInvalidator,
  22.                                 EntityRepositoryInterface $eventsRepository,
  23.                                 EntityRepositoryInterface $cmsSlotsRepository)
  24.     {
  25.         $this->cacheInvalidator = $cacheInvalidator;
  26.         $this->eventsRepository = $eventsRepository;
  27.         $this->cmsSlotsRepository = $cmsSlotsRepository;
  28.     }
  30.     public static function getSubscribedEvents()
  31.     {
  32.         return [
  33.             EntityWrittenContainerEvent::class => [
  34.                 ['invalidate', 2001]
  35.             ],
  36.         ];
  37.     }
  39.     public function invalidate(EntityWrittenContainerEvent $event): void
  40.     {
  41.         $changes = $event->getPrimaryKeys(EventDefinition::ENTITY_NAME);
  42.         $changesCmsSlots = $event->getPrimaryKeys(CmsSlotTranslationDefinition::ENTITY_NAME);
  43.         $changesNavigation = $event->getPrimaryKeys('category');
  45.         $mustInvalidateEventListing = false;
  47.         if (! empty($changes)) {
  48.             $criteria = new Criteria($changes);
  49.             $events = $this->eventsRepository->search($criteria, $event->getContext())->getEntities();
  50.             foreach ($events as $event) {
  51.                 $productId = $event->getProductid();
  52.                 if ($productId) {
  53.                     $this->cacheInvalidator->invalidate([
  54.                         CachedProductDetailRoute::buildName($productId)
  55.                     ]);
  56.                 }
  57.             }
  58.             $mustInvalidateEventListing = true;
  59.         }
  61.         if ( ! empty($changesNavigation)) {
  62.             $eventListingRoutes = [];
  63.             foreach ($changesNavigation as $navigationId) {
  64.                 $eventListingRoutes[] = CachedEventListingRoute::buildName($navigationId);
  65.             }
  67.             $this->cacheInvalidator->invalidate($eventListingRoutes);
  68.         }
  70.         if( ! empty($changesCmsSlots)) {
  71.             $cmsSlotIds = array_map(function($item) {
  72.                 if(is_array($item) && array_key_exists('cmsSlotId', $item)) {
  73.                     return $item['cmsSlotId'];
  74.                 }
  75.                 return $item;
  76.             }, $changesCmsSlots);
  78.             if( ! empty($cmsSlotIds)) {
  79.                 $criteriaSlots = new Criteria($cmsSlotIds);
  80.                 $slots = $this->cmsSlotsRepository->search($criteriaSlots, $event->getContext())->getEntities();
  82.                 foreach($slots as $slot) {
  83.                     if($slot->getType() == 'netzp-events6') {
  84.                         $mustInvalidateEventListing = true;
  85.                         break;
  86.                     }
  87.                 }
  88.             }
  89.         }
  91.         if($mustInvalidateEventListing) {
  92.             $this->cacheInvalidator->invalidate([
  93.                 CachedEventListingRoute::buildName('')
  94.             ]);
  95.         }
  96.     }
  97. }