src/Race/EventSubscriber/RaceAttendeesSubscriber.php line 27

Open in your IDE?
  1. <?php
  3. namespace App\Race\EventSubscriber;
  5. use App\Race\Event\RaceAttendEvent;
  6. use App\Race\Event\RaceEvents;
  7. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  8. use Symfony\Component\Mercure\HubInterface;
  9. use Symfony\Component\Mercure\Update;
  11. class RaceAttendeesSubscriber implements EventSubscriberInterface
  12. {
  13.   public function __construct(
  14.     protected HubInterface $hub,
  15.     protected \Twig\Environment $twig
  16.   ) {
  17.   }
  19.   public static function getSubscribedEvents()
  20.   {
  21.     return [
  22.       RaceEvents::ATTEND => 'updateRaceAttendees',
  23.       RaceEvents::UNATTEND => 'updateRaceAttendees',
  24.     ];
  25.   }
  27.   public function updateRaceAttendees(RaceAttendEvent $event)
  28.   {
  29.     $html = $this->twig->render('network/race/event/attend.stream.twig', ['event' => $event->race]);
  30.     $this->hub->publish(new Update($event->getTopic(), $html));
  31.   }
  32. }