src/Subscriber/Messenger/MessengerCacheSubscriber.php line 80

Open in your IDE?
  1. <?php
  2. /*
  3.  * Author: Dominik Piekarski <code@dompie.de>
  4.  * Created at: 2021/10/13 12:08
  5.  */
  6. declare(strict_types=1);
  8. namespace App\Subscriber\Messenger;
  10. use App\Dto\PregenerateMessengerCacheDto;
  11. use App\Entity\ConversationRoute;
  12. use App\Event\Messenger\ConversationDeleteEvent;
  13. use App\Event\Messenger\ConversationRouteChangeEvent;
  14. use App\Event\Messenger\ConversationStartEvent;
  15. use App\Event\Messenger\MessengerEventInterface;
  16. use App\Event\Messenger\NewMessageEvent;
  17. use App\Event\Messenger\RouteReadEvent;
  18. use App\Pure\Builder\PureConversationBuilder;
  19. use App\Service\Messenger\MessengerCacheService;
  20. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  21. use Symfony\Component\HttpKernel\Event\TerminateEvent;
  23. class MessengerCacheSubscriber implements EventSubscriberInterface
  24. {
  25.     protected MessengerCacheService $messengerCache;
  27.     protected PureConversationBuilder $builder;
  29.     protected array $filtersToClear = [
  30.         PureConversationBuilder::FILTER_ALL,
  31.         PureConversationBuilder::FILTER_UNREAD,
  32.         PureConversationBuilder::FILTER_READ,
  33.         PureConversationBuilder::FILTER_UNANSWERED_BY_ME,
  34.         PureConversationBuilder::FILTER_ANSWERED_BY_ME,
  35.         PureConversationBuilder::FILTER_SEARCH,
  36.         PureConversationBuilder::FILTER_TRASH,
  37.     ];
  39.     public function __construct(PureConversationBuilder $builder, MessengerCacheService $messengerCache)
  40.     {
  41.         $this->messengerCache = $messengerCache;
  42.         $this->builder = $builder;
  43.     }
  45.     public static function getSubscribedEvents(): array
  46.     {
  47.         return [
  48.             ConversationStartEvent::class => [['onConversationStartClearCache', 0]],
  49.             ConversationRouteChangeEvent::class => [['onConversationRouteHiddenClearCache', 0]],
  50.             ConversationDeleteEvent::class => [['onConversationDeleteClearCache', 0]],
  51.             RouteReadEvent::class => [['onConversationRouteReadEventClearCache', 0]],
  52.             NewMessageEvent::class => [['onMessageEventClearCache', 0]],
  53.             TerminateEvent::class => [['onTerminatePregenerateCaches', 0]],
  54.         ];
  55.     }
  57.     /**
  58.      * @throws \Psr\Cache\InvalidArgumentException
  59.      */
  60.     public function onConversationRouteReadEventClearCache(RouteReadEvent $event): void
  61.     {
  62.         $route = $event->getEntity();
  63.         $recipient = $route->getToMember();
  64.         $this->messengerCache->clearConversationsCacheForMemberFilter($recipient->getId(), $this->filtersToClear);
  65.     }
  67.     /**
  68.      * @throws \Psr\Cache\InvalidArgumentException
  69.      */
  70.     public function onConversationRouteHiddenClearCache(ConversationRouteChangeEvent $event): void
  71.     {
  72.         $conversationRoute = $event->getEntity();
  73.         $this->messengerCache->clearConversationsCacheForMember($conversationRoute->getToMember()->getId());
  74.         $this->messengerCache->clearConversationsCacheForMember($conversationRoute->getFromMember()->getId());
  75.     }
  77.     /**
  78.      * @throws \Psr\Cache\InvalidArgumentException
  79.      */
  80.     public function onConversationStartClearCache(MessengerEventInterface $event): void
  81.     {
  82.         /** @var ConversationRoute $conversationRoute */
  83.         $conversationRoute = $event->getEntity()->getRoutes()->first();
  84.         $this->messengerCache->clearConversationsCacheForMemberFilter($conversationRoute->getToMember()->getId(), $this->filtersToClear);
  85.         $this->messengerCache->clearConversationsCacheForMemberFilter($conversationRoute->getFromMember()->getId(), $this->filtersToClear);
  86.     }
  88.     public function onConversationDeleteClearCache(ConversationDeleteEvent $event): void
  89.     {
  90.         $this->messengerCache->clearMessagesCacheForConversation($event->getId());
  91.     }
  93.     public function onMessageEventClearCache(MessengerEventInterface $event): void
  94.     {
  95.         /** @var ConversationRoute $conversationRoute */
  96.         $conversationRoute = $event->getEntity()->getConversation()->getRoutes()->first();
  97.         $this->messengerCache->clearMessagesCacheForConversation($conversationRoute->getConversation()->getId());
  98.         $this->messengerCache->clearConversationsCacheForMemberFilter($conversationRoute->getToMember()->getId(), $this->filtersToClear);
  99.         $this->messengerCache->clearConversationsCacheForMemberFilter($conversationRoute->getFromMember()->getId(), $this->filtersToClear);
  100.     }
  102.     public function onTerminatePregenerateCaches(TerminateEvent $event): void
  103.     {
  104.         $request = $event->getRequest();
  105.         $pregenCacheDto = $request->attributes->get('pregenerateCache');
  106.         if (!$event->isMainRequest() || 200 !== $event->getResponse()->getStatusCode() || !$pregenCacheDto instanceof PregenerateMessengerCacheDto) {
  107.             return;
  108.         }
  110.         if ($pregenCacheDto->isTypeConversationList()) {
  111.             foreach ($pregenCacheDto->getPages() as $page) {
  112.                 $this->builder->getCachedConversationList($pregenCacheDto->getMember(), $page, $pregenCacheDto->getFilter());
  113.             }
  115.             return;
  116.         }
  117.     }
  118. }