custom/plugins/NetzpBlog6/src/Controller/StoreApi/CacheInvalidationSubscriber.php line 35

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace NetzpBlog6\Controller\StoreApi;
  5. use NetzpBlog6\Controller\StoreApi\BlogListing\CachedBlogListingRoute;
  6. use NetzpBlog6\Controller\StoreApi\BlogPost\CachedBlogPostRoute;
  7. use NetzpBlog6\Core\Content\Blog\BlogDefinition;
  8. use Shopware\Core\Content\Cms\Aggregate\CmsSlotTranslation\CmsSlotTranslationDefinition;
  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 $cmsSlotsRepository;
  20.     public function __construct(CacheInvalidator $cacheInvalidator, EntityRepositoryInterface $cmsSlotsRepository)
  21.     {
  22.         $this->cacheInvalidator = $cacheInvalidator;
  23.         $this->cmsSlotsRepository = $cmsSlotsRepository;
  24.     }
  26.     public static function getSubscribedEvents()
  27.     {
  28.         return [
  29.             EntityWrittenContainerEvent::class => [
  30.                 ['invalidate', 2001]
  31.             ]
  32.         ];
  33.     }
  35.     public function invalidate(EntityWrittenContainerEvent $event): void
  36.     {
  37.         $changesPost = $event->getPrimaryKeys(BlogDefinition::ENTITY_NAME);
  38.         $changesCmsSlots = $event->getPrimaryKeys(CmsSlotTranslationDefinition::ENTITY_NAME);
  39.         $changesNavigation = $event->getPrimaryKeys('category');
  41.         $mustInvalidateBlogListing = false;
  43.         if ( ! empty($changesPost)) {
  44.             $blogPostRoutes = [];
  45.             foreach ($changesPost as $postId) {
  46.                 $blogPostRoutes[] = CachedBlogPostRoute::buildName($postId);
  47.             }
  49.             $this->cacheInvalidator->invalidate($blogPostRoutes);
  50.             $mustInvalidateBlogListing = true;
  51.         }
  53.         if ( ! empty($changesNavigation)) {
  54.             $blogListingRoutes = [];
  55.             foreach ($changesNavigation as $navigationId) {
  56.                 $blogListingRoutes[] = CachedBlogListingRoute::buildName($navigationId);
  57.             }
  59.             $this->cacheInvalidator->invalidate($blogListingRoutes);
  60.         }
  62.         if( ! empty($changesCmsSlots)) {
  63.             $cmsSlotIds = array_map(function($item) {
  64.                 if(is_array($item) && array_key_exists('cmsSlotId', $item)) {
  65.                     return $item['cmsSlotId'];
  66.                 }
  67.                 return $item;
  68.             }, $changesCmsSlots);
  70.             if( ! empty($cmsSlotIds)) {
  71.                 $criteriaSlots = new Criteria($cmsSlotIds);
  72.                 $slots = $this->cmsSlotsRepository->search($criteriaSlots, $event->getContext())->getEntities();
  74.                 foreach($slots as $slot) {
  75.                     if($slot->getType() == 'netzp-blog6') {
  76.                         $mustInvalidateBlogListing = true;
  77.                         break;
  78.                     }
  79.                 }
  80.             }
  81.         }
  83.         if($mustInvalidateBlogListing) {
  84.             $this->cacheInvalidator->invalidate([
  85.                 CachedBlogListingRoute::buildName('')
  86.             ]);
  87.         }
  88.     }
  89. }