src/Subscriber/Caching/MessengerSubscriber.php line 40

Open in your IDE?
  1. <?php
  3. namespace App\Subscriber\Caching;
  5. use App\Event\Messenger\AttachmentBoughtEvent;
  6. use App\Event\Messenger\RouteReadEvent;
  7. use Frivol\Common\Service\CacheService;
  8. use App\Service\Client\Messenger\MessengerService;
  9. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  11. class MessengerSubscriber implements EventSubscriberInterface
  12. {
  13.     protected MessengerService $service;
  15.     protected CacheService $cacheService;
  17.     public function __construct(CacheService $cacheService, MessengerService $service)
  18.     {
  19.         $this->cacheService = $cacheService;
  20.         $this->service = $service;
  21.     }
  23.     public static function getSubscribedEvents()
  24.     {
  25.         return [
  26.             RouteReadEvent::class => [
  27.                 ['onRouteReadEvent', 0]
  28.             ],
  29.             AttachmentBoughtEvent::class => [
  30.                 ['onAttachmentBoughtEvent', 0]
  31.             ]
  32.         ];
  33.     }
  35.     /**
  36.      * @param AttachmentBoughtEvent $event
  37.      * @return void
  38.      * @throws \Psr\Cache\InvalidArgumentException
  39.      */
  40.     public function onAttachmentBoughtEvent(AttachmentBoughtEvent $event)
  41.     {
  42.         $this->cacheService->clearConversationCache($event->getConversation());
  43.     }
  45.     public function onRouteReadEvent(RouteReadEvent $event)
  46.     {
  47.         $this->service->markRouteAsRead($event->getConversation(), $event->getRoute());
  48.     }
  49. }