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

  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 NetzpBlog6\Resolver\BlogElementResolver;
  9. use Shopware\Core\Content\Category\Event\CategoryRouteCacheKeyEvent;
  10. use Shopware\Core\Content\Cms\Aggregate\CmsSlotTranslation\CmsSlotTranslationDefinition;
  11. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepository;
  12. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenContainerEvent;
  13. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  14. use Symfony\Component\DependencyInjection\ContainerInterface;
  15. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  16. use Shopware\Core\Framework\Adapter\Cache\CacheInvalidator;
  18. class CacheInvalidationSubscriber implements EventSubscriberInterface
  19. {
  20.     public function __construct(private readonly ContainerInterface $container,
  21.                                 private readonly CacheInvalidator $cacheInvalidator,
  22.                                 private readonly EntityRepository $cmsSlotsRepository)
  23.     {
  24.     }
  26.     public static function getSubscribedEvents(): array
  27.     {
  28.         return [
  29.             EntityWrittenContainerEvent::class => [ ['invalidate', 2001] ],
  30.             CategoryRouteCacheKeyEvent::class  => 'onCategoryRouteCacheKey'
  31.         ];
  32.     }
  34.     public function onCategoryRouteCacheKey(CategoryRouteCacheKeyEvent $event): void
  35.     {
  36.         $repo = $this->container->get('category.repository');
  37.         $criteria = (new Criteria([$event->getNavigationId()]));
  38.         $criteria->addAssociation('cmsPage.sections.blocks.slots.config');
  39.         $category = $repo->search($criteria, $event->getContext()->getContext())->getEntities()->first();
  40.         if( ! $category) {
  41.             return;
  42.         }
  43.         $page = $category->getCmsPage();
  44.         if ( ! $page) {
  45.             return;
  46.         }
  48.         $blogElements = $page->getElementsOfType(BlogElementResolver::ELEMENT_TYPE);
  49.         if(! empty($blogElements))
  50.         {
  51.             $customerId = $event->getContext()->getCustomer()?->getId();
  52.             $customerGroupId = $event->getContext()->getCustomer()?->getGroupId();
  53.             if ($customerId) {
  54.                 $event->addPart('customer_' . $customerId);
  55.             }
  56.             if ($customerGroupId) {
  57.                 $event->addPart('customergroup_' . $customerGroupId);
  58.             }
  59.         }
  60.     }
  62.     public function invalidate(EntityWrittenContainerEvent $event): void
  63.     {
  64.         $changesPost = $event->getPrimaryKeys(BlogDefinition::ENTITY_NAME);
  65.         $changesCmsSlots = $event->getPrimaryKeys(CmsSlotTranslationDefinition::ENTITY_NAME);
  66.         $changesNavigation = $event->getPrimaryKeys('category');
  68.         $mustInvalidateBlogListing = false;
  70.         if ( ! empty($changesPost)) {
  71.             $blogPostRoutes = [];
  72.             foreach ($changesPost as $postId) {
  73.                 $blogPostRoutes[] = CachedBlogPostRoute::buildName($postId);
  74.             }
  76.             $this->cacheInvalidator->invalidate($blogPostRoutes);
  77.             $mustInvalidateBlogListing = true;
  78.         }
  80.         if ( ! empty($changesNavigation)) {
  81.             $blogListingRoutes = [];
  82.             foreach ($changesNavigation as $navigationId) {
  83.                 $blogListingRoutes[] = CachedBlogListingRoute::buildName($navigationId);
  84.             }
  86.             $this->cacheInvalidator->invalidate($blogListingRoutes);
  87.         }
  89.         if( ! empty($changesCmsSlots)) {
  90.             $cmsSlotIds = array_map(function($item) {
  91.                 if(is_array($item) && array_key_exists('cmsSlotId', $item)) {
  92.                     return $item['cmsSlotId'];
  93.                 }
  94.                 return $item;
  95.             }, $changesCmsSlots);
  97.             if( ! empty($cmsSlotIds)) {
  98.                 $criteriaSlots = new Criteria($cmsSlotIds);
  99.                 $slots = $this->cmsSlotsRepository->search($criteriaSlots, $event->getContext())->getEntities();
  101.                 foreach($slots as $slot) {
  102.                     if($slot->getType() == BlogElementResolver::ELEMENT_TYPE) {
  103.                         $mustInvalidateBlogListing = true;
  104.                         break;
  105.                     }
  106.                 }
  107.             }
  108.         }
  110.         if($mustInvalidateBlogListing) {
  111.             $this->cacheInvalidator->invalidate([
  112.                 CachedBlogListingRoute::buildName('')
  113.             ]);
  114.         }
  115.     }
  116. }