src/App/Doctrine/Cache/InvalidateListener.php line 65

Open in your IDE?
  1. <?php declare(strict_types = 1);
  3. namespace App\Doctrine\Cache;
  5. use App\Doctrine\Common\Cache\TaggedMemcachedCache;
  6. use App\Entity\DealBid;
  7. use App\Entity\ProjectBid;
  8. use App\Entity\ProposalBid;
  9. use App\Event\CreditsEvent;
  10. use Doctrine\Common\Util\ClassUtils;
  11. use Doctrine\Persistence\Event\LifecycleEventArgs;
  12. use Doctrine\Persistence\ObjectManager;
  13. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  14. use Symfony\Component\Validator\Exception\UnexpectedTypeException;
  16. class InvalidateListener implements EventSubscriberInterface
  17. {
  19.     private TaggedMemcachedCache $taggedCache;
  21.     private bool $enabled = true;
  23.     public function __construct(TaggedMemcachedCache $taggedCache)
  24.     {
  25.         $this->taggedCache = $taggedCache;
  26.     }
  28.     /**
  29.      * note this listener is auto-removed if we do not use result_cache: service in doctrine config
  30.      *
  31.      * @see \App\DependencyInjection\Compiler\RemoveInvalidateListenerPass
  32.      * @phpcsSuppress SlevomatCodingStandard.TypeHints.ParameterTypeHint.MissingNativeTypeHint
  33.      * @param LifecycleEventArgs<ObjectManager> $args
  34.      * @param object $entity
  35.      */
  36.     public function postUpdate($entity, LifecycleEventArgs $args): void
  37.     {
  38.         if (!$this->enabled) {
  39.             return;
  40.         }
  42.         $className = get_class($entity);
  44.         $entityManager = $args->getObjectManager();
  45.         $metadata = $entityManager->getClassMetadata($className);
  47.         if (!isset($metadata->cache['region'])) {
  48.             return;
  49.         }
  51.         /** @var string $modelKey */
  52.         $modelKey = $metadata->cache['region'];
  53.         $this->taggedCache->removeTag($modelKey);
  55.         if ($modelKey === 'cache_project' || $modelKey === 'cache_deal' || $modelKey === 'cache_shop_video' || $modelKey === 'feed') {
  56.             $this->taggedCache->removeTag('categorization');
  57.         }
  58.     }
  60.     public function setEnabled(bool $enabled): void
  61.     {
  62.         $this->enabled = $enabled;
  63.     }
  65.     public function onCredits(CreditsEvent $event): void
  66.     {
  67.         $related = $event->getRelatedEntity();
  69.         if (!$related instanceof ProposalBid) {
  70.             return;
  71.         }
  73.         switch (ClassUtils::getClass($related)) {
  74.             case DealBid::class:
  75.                 $modelKey = 'cache_deal';
  76.                 break;
  77.             case ProjectBid::class:
  78.                 $modelKey = 'cache_project';
  79.                 break;
  80.             default:
  81.                 throw new UnexpectedTypeException($related, DealBid::class . '|' . ProjectBid::class);
  82.         }
  84.         $this->taggedCache->removeTag($modelKey);
  85.     }
  87.     /**
  88.      * @return array<string, array<int|string, array<int|string, int|string>|int|string>|string>
  89.      */
  90.     public static function getSubscribedEvents(): array
  91.     {
  92.         return [
  93.             CreditsEvent::class => ['onCredits', -255],
  94.         ];
  95.     }
  97. }