src/Modules/Notification/Event/Subscriber/SendNewChatMessageNotification.php line 54

Open in your IDE?
  1. <?php
  3. namespace App\Modules\Notification\Event\Subscriber;
  6. use App\Modules\Chat\Event\MessageSent;
  7. use App\Modules\Chat\Service\MessagesService;
  8. use App\Modules\Notification\Entity\NotificationEntity;
  9. use App\Modules\Notification\Message\System\YouHasNewChatMessageNotification;
  10. use App\Modules\Notification\Service\NotificationService;
  11. use App\Service\WebRoutes;
  12. use Doctrine\Common\Collections\ArrayCollection;
  13. use Psr\Log\LoggerInterface;
  14. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  16. class SendNewChatMessageNotification implements EventSubscriberInterface
  17. {
  18.     private $notificationService;
  19.     private $chatMessagesService;
  20.     private $logger;
  22.     public function __construct(NotificationService $notificationService, MessagesService $chatMessagesService, LoggerInterface $logger)
  23.     {
  24.         $this->notificationService = $notificationService;
  25.         $this->chatMessagesService = $chatMessagesService;
  26.         $this->logger = $logger;
  27.     }
  29.     /**
  30.      * Returns an array of event names this subscriber wants to listen to.
  31.      *
  32.      * The array keys are event names and the value can be:
  33.      *
  34.      *  * The method name to call (priority defaults to 0)
  35.      *  * An array composed of the method name to call and the priority
  36.      *  * An array of arrays composed of the method names to call and respective
  37.      *    priorities, or 0 if unset
  38.      *
  39.      * For instance:
  40.      *
  41.      *  * ['eventName' => 'methodName']
  42.      *  * ['eventName' => ['methodName', $priority]]
  43.      *  * ['eventName' => [['methodName1', $priority], ['methodName2']]]
  44.      *
  45.      * @return array The event names to listen to
  46.      */
  47.     public static function getSubscribedEvents()
  48.     {
  49.         return [
  50.             MessageSent::class => ['sendNotification']
  51.         ];
  52.     }
  54.     public function sendNotification(MessageSent $event)
  55.     {
  56.         try {
  57.             $message = $this->chatMessagesService->get($event->getChatId(), $event->getChatMessageId());
  58.             $author  = $message->getAuthor();
  59.             $chat    = $message->getChat();
  60.             $contract = $chat->getContract();
  62.             $systemNotificationReceivers = new ArrayCollection();
  64.             foreach ($chat->getParticipants() as $participant) {
  65.                 if ($participant != $author) {
  66.                     $systemNotificationReceivers->add($participant);
  67.                 }
  68.             }
  70.             $link = [
  71.                 'id' => $chat->getId(),
  72.                 'entity' => NotificationEntity::CHAT,
  73.                 'message' => $message->getContent(),
  74.                 'contract_ref' => !is_null($contract) ? $contract->getRef() : ''
  75.             ];
  77.             $message = new YouHasNewChatMessageNotification($link, $author, $systemNotificationReceivers);
  78.             $this->notificationService->sendSystem($message);
  80.         } catch (\Exception $e) {
  81.             $this->logger->error($e->getMessage());
  82.         }
  83.     }
  84. }