src/EventSubscriber/MercureSubscriber.php line 26

  1. <?php
  3. namespace App\EventSubscriber;
  5. use App\Entity\User;
  6. use App\Event\NotificationCreatedEvent;
  7. use App\Event\NotificationReadEvent;
  8. use App\Queue\EnqueueMethod;
  9. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  10. use Symfony\Component\Mercure\HubInterface;
  11. use Symfony\Component\Mercure\Update;
  12. use Symfony\Component\Serializer\SerializerInterface;
  14. class MercureSubscriber implements EventSubscriberInterface
  15. {
  16.     public function __construct(private SerializerInterface $serializer, private EnqueueMethod $enqueue) {}
  18.     public static function getSubscribedEvents(): array
  19.     {
  20.         return [
  21.             NotificationCreatedEvent::class => 'publishNotification',
  22.             NotificationReadEvent::class => 'onNotificationRead',
  23.         ];
  24.     }
  26.     public function publishNotification(NotificationCreatedEvent $event): void
  27.     {
  28.         $notification = $event->getNotification();
  29.         $channel = $notification->getChannel();
  30.         if ('public' === $channel && $notification->getUser() instanceof User) {
  31.             $channel = 'user/'.$notification->getUser()->getId();
  32.         }
  33.         $update = new Update("/notifications/$channel", $this->serializer->serialize([
  34.             'type' => 'notification',
  35.             'data' => $notification,
  36.         ], 'json', [
  37.             'groups' => ['read:notification'],
  38.             'iri' => false,
  39.         ]), true);
  40.         $this->enqueue->enqueue(HubInterface::class, '__invoke', [$update]);
  41.     }
  43.     public function onNotificationRead(NotificationReadEvent $event): void
  44.     {
  45.         $user = $event->getUser();
  46.         $update = new Update(
  47.             "/notifications/user/{$user->getId()}",
  48.             '{"type": "markAsRead"}',
  49.             true
  50.         );
  51.         $this->enqueue->enqueue(HubInterface::class, '__invoke', [$update]);
  52.     }
  53. }