vendor/dvdw/events/src/Framework/Adapter/Cache/CacheInvalidationSubscriber.php line 63

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Dvdw\Events\Framework\Adapter\Cache;
  5. use Doctrine\DBAL\Connection;
  6. use Dvdw\Events\Content\DvdwEvent\Aggregate\DvdwEventUsp\DvdwEventUspDefinition;
  7. use Dvdw\Events\Content\DvdwEvent\DvdwEventDefinition;
  8. use Dvdw\Events\Content\DvdwEvent\SalesChannel\CachedDvdwEventRoute;
  9. use Dvdw\Events\Content\DvdwProduct\DvdwProductDefinition;
  10. use Dvdw\Events\Content\DvdwProduct\SalesChannel\CachedDvdwProductRoute;
  11. use Dvdw\Events\Content\DvdwPromotion\Aggregate\DvdwPromotionLimitation\DvdwPromotionLimitationDefinition;
  12. use Dvdw\Events\Content\DvdwPromotion\DvdwPromotionDefinition;
  13. use Dvdw\Events\Content\DvdwPromotion\SalesChannel\CachedDvdwPromotionRoute;
  14. use Dvdw\Events\Content\DvdwTicket\DvdwTicketDefinition;
  15. use Dvdw\Events\Content\DvdwTicket\SalesChannel\CachedDvdwTicketRoute;
  16. use Shopware\Core\Framework\Adapter\Cache\CacheInvalidator;
  17. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenContainerEvent;
  18. use Shopware\Core\Framework\Uuid\Uuid;
  19. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  21. class CacheInvalidationSubscriber implements EventSubscriberInterface
  22. {
  23.     private CacheInvalidator $cacheInvalidator;
  25.     private Connection $connection;
  27.     public function __construct(
  28.         CacheInvalidator $cacheInvalidator,
  29.         Connection $connection
  30.     )
  31.     {
  32.         $this->cacheInvalidator = $cacheInvalidator;
  33.         $this->connection = $connection;
  34.     }
  36.     public static function getSubscribedEvents(): iterable
  37.     {
  38.         return [
  39.             EntityWrittenContainerEvent::class => [
  40.                 ['invalidateDvdwEventIds', 2001],
  41.                 ['invalidateDvdwProductIds', 2002],
  42.                 ['invalidateDvdwPromotionIds', 2003],
  43.                 ['invalidateDvdwTicketIds', 2004]
  44.             ]
  45.         ];
  46.     }
  48.     public function invalidateDvdwEventIds(EntityWrittenContainerEvent $event): void
  49.     {
  50.         $this->cacheInvalidator->invalidate($this->getChangedDvdwEvents($event));
  51.     }
  53.     public function invalidateDvdwProductIds(EntityWrittenContainerEvent $event): void
  54.     {
  55.         $this->cacheInvalidator->invalidate($this->getChangedDvdwProducts($event));
  56.     }
  58.     public function invalidateDvdwPromotionIds(EntityWrittenContainerEvent $event): void
  59.     {
  60.         $this->cacheInvalidator->invalidate($this->getChangedDvdwPromotions($event));
  61.     }
  63.     public function invalidateDvdwTicketIds(EntityWrittenContainerEvent $event): void
  64.     {
  65.         $this->cacheInvalidator->invalidate($this->getChangedDvdwTickets($event));
  66.     }
  68.     private function getChangedDvdwEvents(EntityWrittenContainerEvent $event): array
  69.     {
  70.         $ids = array_merge(
  71.             $this->getRelevantIds($event, DvdwEventDefinition::ENTITY_NAME),
  72.             $this->getIdsFromAssociation($event, DvdwEventUspDefinition::ENTITY_NAME, 'dvdw_event_id')
  73.         );
  75.         if (empty($ids)) {
  76.             return [];
  77.         }
  79.         return $this->buildRouteNames(CachedDvdwEventRoute::class, $ids);
  80.     }
  82.     private function getChangedDvdwProducts(EntityWrittenContainerEvent $event): array
  83.     {
  84.         return $this->getChanged(
  85.             $event,
  86.             DvdwProductDefinition::ENTITY_NAME,
  87.             CachedDvdwProductRoute::class
  88.         );
  89.     }
  91.     private function getChangedDvdwPromotions(EntityWrittenContainerEvent $event): array
  92.     {
  93.         $ids = array_merge(
  94.             $this->getRelevantIds($event, DvdwPromotionDefinition::ENTITY_NAME),
  95.             $this->getIdsFromAssociation($event, DvdwPromotionLimitationDefinition::ENTITY_NAME, 'dvdw_promotion_id')
  96.         );
  98.         if (empty($ids)) {
  99.             return [];
  100.         }
  102.         return $this->buildRouteNames(CachedDvdwPromotionRoute::class, $ids);
  103.     }
  105.     private function getChangedDvdwTickets(EntityWrittenContainerEvent $event): array
  106.     {
  107.         return $this->getChanged(
  108.             $event,
  109.             DvdwTicketDefinition::ENTITY_NAME,
  110.             CachedDvdwTicketRoute::class
  111.         );
  112.     }
  114.     private function getChanged(EntityWrittenContainerEvent $event, string $entity, string $cachedRouteClass): array
  115.     {
  116.         $ids = $this->getRelevantIds($event, $entity);
  118.         if (empty($ids)) {
  119.             return [];
  120.         }
  122.         return $this->buildRouteNames($cachedRouteClass, $ids);
  123.     }
  125.     private function getRelevantIds(EntityWrittenContainerEvent $event, string $entity): array
  126.     {
  127.         return array_merge($event->getPrimaryKeys($entity), $event->getDeletedPrimaryKeys($entity));
  128.     }
  130.     private function buildRouteNames(string $cachedRouteClass, array $ids): array
  131.     {
  132.         return array_map([$cachedRouteClass, 'buildName'], $ids);
  133.     }
  135.     private function getIdsFromAssociation(EntityWrittenContainerEvent $event, string $association, string $column): array
  136.     {
  137.         $ids = $this->getRelevantIds($event, $association);
  139.         if (empty($ids)) {
  140.             return [];
  141.         }
  143.         return $this->connection->fetchFirstColumn(
  144.             sprintf('SELECT DISTINCT LOWER(HEX(%s)) FROM %s WHERE id IN (:ids)', $column, $association),
  145.             ['ids' => Uuid::fromHexToBytesList($ids)],
  146.             ['ids' => Connection::PARAM_STR_ARRAY]
  147.         );
  148.     }
  149. }