src/Infrastructure/Notifications/EventSubscriber/NotificationSubscriber.php line 47

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace App\Infrastructure\Notifications\EventSubscriber;
  7. use App\Infrastructure\Notifications\Event\CreateNotificationEvent;
  8. use App\Infrastructure\Notifications\Event\FireBaseNotificationSendEvent;
  9. use DateTimeImmutable;
  10. use Doctrine\ORM\EntityManagerInterface;
  11. use Kreait\Firebase\Contract\Messaging;
  12. use Kreait\Firebase\Exception\FirebaseException;
  13. use Kreait\Firebase\Exception\MessagingException;
  15. use Kreait\Firebase\Messaging\CloudMessage;
  16. use Kreait\Firebase\Messaging\WebPushConfig as FireBaseWebPush;
  17. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  19. class NotificationSubscriber implements EventSubscriberInterface
  20. {
  21.     private Messaging $messaging;
  22.     private EntityManagerInterface $entityManager;
  23.     
  24.     public function __construct(
  25.        // Messaging $messaging,
  26.         EntityManagerInterface $entityManager
  27.     )
  28.     {
  29.   //      $this->messaging = $messaging;
  30.         $this->entityManager = $entityManager;
  31.     }
  32.     
  33.     public static function getSubscribedEvents(): array
  34.     {
  35.         return [
  36.             //Создание уведомления в бд
  37.             CreateNotificationEvent::class       => 'onNotificationCreated',
  38.             //Отправка уведомления
  39.             FireBaseNotificationSendEvent::class => 'onNotificationSendToFirebase',
  40.         ];
  41.     }
  42.     
  43.     /**
  44.      * @throws MessagingException
  45.      * @throws FirebaseException
  46.      */
  47.     public function onNotificationSendToFirebase(FireBaseNotificationSendEvent $notificationSendEvent): void
  48.     {
  49.         $notification = $notificationSendEvent->getNotification();
  50.         
  51.         //Если еще не отправлено и у пользователя есть токен
  52.         if($notification->getPostedAt() === null && $notification->getUser()->getNotificationToken() !== null){
  53.             $message = CloudMessage::withTarget('token', $notification->getUser()->getNotificationToken())
  54.                 ->withWebPushConfig(
  55.                     FireBaseWebPush::fromArray([
  56.                             'notification' => [
  57.                                 'title' => $notification->getTitle(),
  58.                                 'body' => $notification->getDescription(),
  59.                                 'icon' => '',
  60.                             ],
  61.                             'fcm_options' => [
  62.                                 'link' => $notification->getLink(),
  63.                             ]
  64.                     ])
  65.                 )
  66.                 ->withData([$notification->getAdditionalData()]);
  67.     
  68.             //$this->messaging->send($message);
  69.         }
  71.         $notification->setPostedAt(new DateTimeImmutable());
  72.         $this->entityManager->flush();
  73.     }
  74.     
  75.     public function onNotificationCreated(FireBaseNotificationSendEvent $notificationSendEvent): void
  76.     {
  77.         $notification = $notificationSendEvent->getNotification();
  78.         
  79.         $this->entityManager->persist($notification);
  80.         $this->entityManager->flush();
  81.     }
  82. }