src/EventsSubscriber/Notification/NotificationSubscriber.php line 31

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace App\EventsSubscriber\Notification;
  7. use App\Event\Notification\NotificationLogEvent;
  8. use App\Event\Notification\PushNotificationEvent;
  9. use App\Messenger\Notification\NotificationLogMessage;
  10. use App\Messenger\Notification\PushNotificationMessage;
  11. use Psr\Log\LoggerInterface;
  12. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  13. use Symfony\Component\Messenger\MessageBusInterface;
  15. class NotificationSubscriber implements EventSubscriberInterface
  16. {
  17.     public function __construct(
  18.         private MessageBusInterface $bus,
  19.         private LoggerInterface $notifyLogger,
  20.     ) {
  21.     }
  23.     public static function getSubscribedEvents(): array
  24.     {
  25.         return [
  26.             NotificationLogEvent::class => 'log',
  27.             PushNotificationEvent::class => 'push',
  28.         ];
  29.     }
  31.     public function log(NotificationLogEvent $event)
  32.     {
  33.         foreach ($event->getRecipients() as $recipient) {
  34.             $this->bus->dispatch(new NotificationLogMessage($event->getType(), $recipient));
  35.         }
  36.     }
  38.     public function push(PushNotificationEvent $event)
  39.     {
  40.         $this->notifyLogger->info(
  41.             'Event: sending push notifications to users',
  42.             [
  43.                 'payload' => $event->getPayload(),
  44.                 'type' => $event->getType()->value,
  45.             ]
  46.         );
  47.         $this->bus->dispatch(
  48.             new PushNotificationMessage(
  49.                 $event->getType(),
  50.                 $event->getPayload(),
  51.                 ...$event->getRecipients(),
  52.             )
  53.         );
  54.     }
  55. }