src/Auction/EventSubscriber/AuctionAttendeesSubscriber.php line 28

Open in your IDE?
  1. <?php
  3. namespace App\Auction\EventSubscriber;
  5. use App\Auction\Event\AuctionAttendEvent;
  6. use App\Auction\Event\AuctionEvents;
  7. use App\Profile\Model\Profile;
  8. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  9. use Symfony\Component\Mercure\HubInterface;
  10. use Symfony\Component\Mercure\Update;
  12. class AuctionAttendeesSubscriber 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.       AuctionEvents::ATTEND => 'updateAuctionAttendees',
  24.       AuctionEvents::UNATTEND => 'updateAuctionAttendees',
  25.     ];
  26.   }
  28.   public function updateAuctionAttendees(AuctionAttendEvent $event)
  29.   {
  30.     $attendees = $event->auction->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.     $html = $this->twig->render('network/auction/event/attend.stream.twig', ['event' => $event->auction, 'attendees' => $sortedAttendeeProfile]);
  50.     $this->hub->publish(new Update($event->getTopic(), $html));
  51.   }
  52. }