src/Raceday/EventSubscriber/RacedayAttendeesSubscriber.php line 28

Open in your IDE?
  1. <?php
  3. namespace App\Raceday\EventSubscriber;
  5. use App\Profile\Model\Profile;
  6. use App\Raceday\Event\RacedayAttendEvent;
  7. use App\Raceday\Event\RacedayEvents;
  8. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  9. use Symfony\Component\Mercure\HubInterface;
  10. use Symfony\Component\Mercure\Update;
  12. class RacedayAttendeesSubscriber implements EventSubscriberInterface
  13. {
  14.   public function __construct(
  15.     protected HubInterface $hub,
  16.     protected \Twig\Environment $twig
  17.   ) {
  18.   }
  20.   public static function getSubscribedEvents()
  21.   {
  22.     return [
  23.       RacedayEvents::ATTEND => 'updateRacedayAttendees',
  24.       RacedayEvents::UNATTEND => 'updateRacedayAttendees',
  25.     ];
  26.   }
  28.   public function updateRacedayAttendees(RacedayAttendEvent $event)
  29.   {
  30.     $attendees = $event->raceday->getAttendees();
  32.     $attendeeProfiles = [];
  33.     foreach ($attendees as $attendee) {
  34.       $attendeeProfiles[] = Profile::getById($attendee->getObjectId());
  35.     }
  37.     $sortedAttendeeProfile = [];
  38.     foreach ($attendeeProfiles as $profile) {
  39.       $key = explode('\\', $profile->getPrimaryProfile());
  40.       $key = end($key);
  41.       $key = str_replace('Profile', '', $key);
  42.       $key = mb_strtolower($key);
  44.       $sortedAttendeeProfile[$key][] = $profile;
  46.       usort($sortedAttendeeProfile[$key], fn ($a, $b) => strcmp($a->getName(), $b->getName()));
  47.     }
  49.     // dd($sortedAttendeeProfile);
  51.     $html = $this->twig->render('network/raceday/event/attend.stream.twig', ['event' => $event->raceday, 'attendees' => $sortedAttendeeProfile]);
  52.     $this->hub->publish(new Update($event->getTopic(), $html));
  53.   }
  54. }