src/Subscriber/Messenger/RouteSubscriber.php line 45

Open in your IDE?
  1. <?php
  3. namespace App\Subscriber\Messenger;
  5. use App\Dictionary\ConversationMessageType;
  6. use App\Event\Messenger\NewMessageEvent;
  7. use App\Event\User\MemberBlockedEvent;
  8. use App\Service\Messenger\RouteService;
  9. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  11. class RouteSubscriber implements EventSubscriberInterface
  12. {
  13.     protected RouteService $routeService;
  15.     /**
  16.      * RouteSubscriber constructor.
  17.      */
  18.     public function __construct(RouteService $routeService)
  19.     {
  20.         $this->routeService = $routeService;
  21.     }
  23.     protected function getRouteService(): RouteService
  24.     {
  25.         return $this->routeService;
  26.     }
  28.     public static function getSubscribedEvents(): array
  29.     {
  30.         return [
  31.             NewMessageEvent::class => [
  32.                 ['onNewMessageUpdateRoute', 100],
  33.                 ['onNewMessageUnhideRoutes', 101],
  34.                 ['onNewMessageUpdateCoinValue', 102],
  35.             ],
  36.             MemberBlockedEvent::class => [
  37.                 ['onMemberBlockedHideRoute', 100],
  38.             ],
  39.         ];
  40.     }
  42.     /**
  43.      * @throws \Exception
  44.      */
  45.     public function onMemberBlockedHideRoute(MemberBlockedEvent $event)
  46.     {
  47.         $entity = $event->getMemberBlocked();
  49.         $service = $this->getRouteService();
  50.         $route = $service->getRouteBySenderAndRecipient($entity->getTarget(), $entity->getOwner(), false);
  51.         if ($route) {
  52.             $service->hideRoute($route);
  53.         }
  54.     }
  56.     /**
  57.      * @throws \Doctrine\ORM\ORMException
  58.      * @throws \Doctrine\ORM\OptimisticLockException
  59.      */
  60.     public function onNewMessageUpdateRoute(NewMessageEvent $event)
  61.     {
  62.         $message = $event->getEntity();
  63.         $conversation = $message->getConversation();
  64.         $routes = $conversation->getRoutes();
  66.         $routesToUpdate = $routes;
  67.         if (ConversationMessageType::CONTENT_PURCHASE == $message->getType()) {
  68.             $routesToUpdate = [];
  70.             foreach ($routes as $route) {
  71.                 if ($route->getFromMember()->getId() == $event->getSender()->getId()) {
  72.                     $routesToUpdate[] = $route;
  73.                 }
  74.             }
  75.         }
  77.         foreach ($routesToUpdate as $route) {
  78.             $this->getRouteService()->updateLastMessage($route, $message, false);
  79.         }
  80.         $this->getRouteService()->delayedFlush();
  81.     }
  83.     public function onNewMessageUnhideRoutes(NewMessageEvent $event)
  84.     {
  85.         $sender = $event->getSender();
  86.         $conversation = $event->getEntity()->getConversation();
  88.         $manager = $this->getRouteService();
  90.         $recipientRoute = $manager->getRouteByRecipient($conversation, $sender);
  91.         if ($recipientRoute) {
  92.             if ($recipientRoute->getHidden()) {
  93.                 // additionally to unhide the route, we have to reset the hidden_at date, which will lead
  94.                 // to -all- messages in that conversation being visible again.
  95.                 // came up with the trash filter.
  96.                 $recipientRoute->setHiddenAt(null);
  97.             }
  99.             $manager->unhideRoute($recipientRoute);
  100.         }
  102.         $senderRoute = $manager->getRouteBySender($conversation, $sender);
  103.         if ($senderRoute) {
  104.             $manager->unhideRoute($senderRoute);
  105.         }
  106.     }
  108.     /**
  109.      * @throws \Doctrine\ORM\ORMException
  110.      * @throws \Doctrine\ORM\OptimisticLockException
  111.      */
  112.     public function onNewMessageUpdateCoinValue(NewMessageEvent $event)
  113.     {
  114.         $msg = $event->getEntity();
  115.         if (!$msg->getCoins()) {
  116.             return;
  117.         }
  119.         $conversation = $msg->getConversation();
  120.         $sender = $event->getSender();
  122.         $routeService = $this->getRouteService();
  123.         $route = $routeService->getRouteBySender($conversation, $sender);
  125.         if ($route) {
  126.             $route->increaseCoinValue($msg->getCoins());
  127.             $routeService->storeEntity($route);
  128.         }
  129.     }
  130. }