src/Notification/EventSubscriber/NotificationSubscriber.php line 79

Open in your IDE?
  1. <?php
  3. namespace App\Notification\EventSubscriber;
  5. use App\Notification\Service\NotificationService;
  6. use App\Profile\Event\ProfileEvents;
  7. use App\Profile\Event\ProfileNetworkEvent;
  8. use App\Profile\Messages\Event\MessageSendEvent;
  9. use App\Profile\Messages\Event\MessagesEvents;
  10. use App\Profile\Model\Profile;
  11. use App\Timeline\Event\TimelinePostCommentedEvent;
  12. use App\Timeline\Event\TimelinePostEvents;
  13. use App\Timeline\Event\TimelinePostLikedEvent;
  14. use App\Timeline\Event\TimelinePostMentionedEvent;
  15. use App\Timeline\Event\TimelinePostSharedEvent;
  16. use Pimcore\Model\DataObject\TimelinePost;
  17. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  18. use Symfony\Component\Notifier\NotifierInterface;
  19. use Symfony\Contracts\Translation\TranslatorInterface;
  21. class NotificationSubscriber implements EventSubscriberInterface
  22. {
  23.   public function __construct(protected NotifierInterface $notifier, protected TranslatorInterface $translator, protected NotificationService $notificationService)
  24.   {
  25.   }
  27.   public static function getSubscribedEvents()
  28.   {
  29.     return [
  30.         ProfileEvents::NETWORK_ADD => 'onNetworkAdd',
  31.         ProfileEvents::NETWORK_REMOVE => 'onNetworkRemove',
  32.         TimelinePostEvents::LIKED => 'onPostLiked',
  33.         TimelinePostEvents::COMMENTED => 'onPostComment',
  34.         TimelinePostEvents::MENTIONED => 'onPostMention',
  35.         TimelinePostEvents::SHARED => 'onPostShared',
  36.         MessagesEvents::SEND => 'onMessageSend',
  37.     ];
  38.   }
  40.   // Event Methods
  41.   public function onNetworkAdd(ProfileNetworkEvent $event)
  42.   {
  43.     $this->notificationService->sendProfileNetworkNotification($event->getUser(), $event->getProfile(), 'profile.network.add', 'urgent');
  44.   }
  46.   public function onNetworkRemove(ProfileNetworkEvent $event)
  47.   {
  48.   }
  50.   public function onPostLiked(TimelinePostLikedEvent $event)
  51.   {
  52.     $profile = $event->post->getProfile();
  53.     $sender = $event->getUser();
  54.     $this->notificationService->sendTimelineNotification($event->post, $sender, $profile, 'post.liked', 'urgent');
  55.   }
  57.   public function onPostComment(TimelinePostCommentedEvent $event)
  58.   {
  59.     $profile = $event->comment->getParent()->getProfile();
  60.     $sender = $event->getUser();
  61.     $post = $this->findTimelinePost($event->comment);
  62.     $this->notificationService->sendTimelineNotification($post, $sender, $profile, 'post.comment', 'urgent');
  63.   }
  65.   private function findTimelinePost($post)
  66.   {
  67.     if ($post instanceof TimelinePost) {
  68.       return $post;
  69.     } else {
  70.       return $this->findTimelinePost($post->getParent());
  71.     }
  72.   }
  74.   public function onPostMention(TimelinePostMentionedEvent $event)
  75.   {
  76.     $this->notificationService->sendTimelineNotification($event->post, $event->user, $event->mentioned, 'post.mentioned', 'urgent');
  77.   }
  79.   public function onPostShared(TimelinePostSharedEvent $event)
  80.   {
  81.     $this->notificationService->sendTimelineNotification($event->post, $event->user, $event->originalPostUser, 'post.shared', 'urgent');
  82.   }
  84.   public function onMessageSend(MessageSendEvent $event)
  85.   {
  86.     $profile = Profile::getById($event->message->getReceiverId());
  87.     $sender = Profile::getById($event->message->getSenderId());
  89.     $this->notificationService->sendMessageNotification($event->message, $sender, $profile, 'chat.message', 'urgent');
  90.   }
  91. }