src/EventSubscriber/InvalidateCacheSubscriber.php line 39

Open in your IDE?
  1. <?php
  3. namespace App\EventSubscriber;
  5. use App\Event\CreateIndustrialSiteEvent;
  6. use App\Event\DeleteOrganizationEvent;
  7. use App\Event\IndustrialSiteEventInterface;
  8. use App\Event\OrganizationEventInterface;
  9. use App\Event\UpdateIndustrialSiteEvent;
  10. use App\Event\UpdateOrganizationEvent;
  11. use App\Event\UpdateContractEvent;
  12. use Lexik\Bundle\JWTAuthenticationBundle\Events;
  13. use Psr\Cache\InvalidArgumentException;
  14. use Psr\Log\LoggerInterface;
  15. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  16. use Symfony\Contracts\Cache\TagAwareCacheInterface;
  18. class InvalidateCacheSubscriber implements EventSubscriberInterface
  19. {
  20.     private TagAwareCacheInterface $portailCachePool;
  21.     private LoggerInterface $logger;
  23.     public function __construct(TagAwareCacheInterface $portailCachePool, LoggerInterface $logger)
  24.     {
  25.         $this->portailCachePool = $portailCachePool;
  26.         $this->logger = $logger;
  27.     }
  29.     public static function getSubscribedEvents()
  30.     {
  31.         return [
  32.             UpdateOrganizationEvent::NAME => 'onUpdateOrganization',
  33.             DeleteOrganizationEvent::NAME => 'onDeleteOrganization',
  34.             UpdateContractEvent::NAME => 'onUpdateContract',
  35.             Events::JWT_CREATED => 'onUserLogin',
  36.         ];
  37.     }
  39.     public function onUpdateOrganization(OrganizationEventInterface $event): void
  40.     {
  41.         $organizationId = $event->getOrganization()->getId();
  42.         $this->invalidateTag($organizationId, "organization '$organizationId'");
  43.     }
  45.     public function onUpdateContract(UpdateContractEvent $event): void
  46.     {
  47.         $contractId = $event->getContract()->getId();
  48.         $this->invalidateTag($contractId, "contract '$contractId'");
  49.     }
  51.     public function onDeleteOrganization(OrganizationEventInterface $event): void
  52.     {
  53.         $organizationId = $event->getOrganization()->getId();
  54.         $this->invalidateTag($organizationId, "organization '$organizationId'");
  55.     }
  57.     public function onUserLogin($event): void
  58.     {
  59.         $userId = $event->getData()['heimdallId'] ?? null;
  60.         if (null !== $userId) {
  61.             $this->invalidateTag($userId, "user '$userId'");
  62.         }
  63.     }
  65.     private function invalidateTag(string $tagName, string $message): void
  66.     {
  67.         try {
  68.             $this->portailCachePool->invalidateTags([$tagName]);
  69.         } catch (InvalidArgumentException $e) {
  70.             $this->logger->error(sprintf('Cannot invalidate cache for %s on tag "%s"', $message, $tagName));
  71.         }
  72.     }
  73. }