src/Jockeyexchange/EventSubscriber/JockeyexchangeMercureSubscriber.php line 33

Open in your IDE?
  1. <?php
  3. namespace App\Jockeyexchange\EventSubscriber;
  5. use App\Jockeyexchange\Event\JockeyexchangeRacedayAttendEvent;
  6. use App\Jockeyexchange\Event\JockeyexchangeRacedayAttendEvents;
  7. use App\Jockeyexchange\Service\JockeyexchangeService;
  8. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  9. use Symfony\Component\HttpFoundation\RequestStack;
  10. use Symfony\Component\Mercure\HubInterface;
  11. use Symfony\Component\Mercure\Update;
  13. class JockeyexchangeMercureSubscriber implements EventSubscriberInterface
  14. {
  15.   public function __construct(
  16.     protected HubInterface $hub,
  17.     protected \Twig\Environment $twig,
  18.     protected RequestStack $requestStack,
  19.     protected JockeyexchangeService $jockeyexchangeService
  20.   ) {
  21.   }
  23.   public static function getSubscribedEvents()
  24.   {
  25.     return [
  26.         JockeyexchangeRacedayAttendEvents::RACEDAY_ATTEND => 'racedayAttend',
  27.         // JockeyexchangeRacedayAttendEvents::RACEDAY_CANCEL => 'racedayCancel',
  28.         // JockeyexchangeRacedayAttendEvents::RACE_ATTEND => 'raceAttend',
  29.         // JockeyexchangeRacedayAttendEvents::RACE_CANCEL => 'raceCancel',
  30.     ];
  31.   }
  33.   public function racedayAttend(JockeyexchangeRacedayAttendEvent $event)
  34.   {
  35.     $raceday = $event->getRaceday();
  36.     $attendedRaces = $event->getAttendedRaces();
  37.     $profile = $event->getProfile();
  39.     $racedayAttendees = $this->jockeyexchangeService->getOtherJockeyRacedayAttendees($raceday);
  41.     $html = $this->twig->render('/jockeyexchange/streams/raceday_list_stream.html.twig', [
  42.       'raceday' => $raceday,
  43.       'user' => $profile,
  44.       'otherRacedayAttendees' => $racedayAttendees,
  45.     ]);
  47.     $this->hub->publish(new Update(sprintf($event->getTopic(), $profile->getId()), $html, false));
  48.   }
  49. }