vendor/artibox/middleware/src/EventListener/Notification/NotificationCreateEventSubscriber.php line 30

Open in your IDE?
  1. <?php
  3. namespace App\EventListener\Notification;
  5. use App\Entity\Company\Company;
  6. use App\Enum\NotificationEvents;
  7. use App\Event\NotificationCreateEvent;
  8. use App\Repository\Company\UserRepository;
  9. use App\Service\Notification\NotificationService;
  10. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  12. class NotificationCreateEventSubscriber implements EventSubscriberInterface
  13. {
  14.     public function __construct(
  15.         private NotificationService $notificationService,
  16.         private UserRepository $userRepository
  18.     ) {
  19.         $this->notificationService = $notificationService;
  20.         $this->userRepository = $userRepository;
  21.     }
  23.     public static function getSubscribedEvents()
  24.     {
  25.         return [
  26.             NotificationCreateEvent::NAME => 'onNotificationCreation'
  27.         ];
  28.     }
  30.     public function onNotificationCreation(NotificationCreateEvent $event)
  31.     {
  32.         $data = $event->getData();
  33.         $data['link'] = $event->getLink();
  35.         if ($event->getTitleOptions()) {
  36.             $data['title'] = NotificationEvents::getTitle($event->getEvent(), $event->getTitleOptions());
  37.         }
  39.         if ($event->getContentOptions()) {
  40.             $data['content'] = NotificationEvents::getContent($event->getEvent(), $event->getContentOptions());
  41.         }
  43.         $data['event'] = $event->getEvent();
  44.         $data['route'] = $event->getRoute();
  45.         $data['route_params'] = $event->getRouteParams();
  46.         // envoyer notification web
  47.         $this->notificationService->send($data);
  49.         // envoyer notification push
  50.         $recipient = $data['recipient'];
  51.         $user = $recipient instanceof Company ? $this->userRepository->getCompanyPrincipalUser($recipient->getId()) : $this->userRepository->getCustomerCompanyPrincipalUser($recipient->getId());
  53.         if ($user && $user->getDeviceToken()) {
  54.             $this->notificationService->sendPushNotification($user->getDeviceToken(), $event->getEvent());
  55.         }
  56.     }
  57. }