src/Timeline/EventSubscriber/TimelineMercureSubscriber.php line 60

Open in your IDE?
  1. <?php
  3. namespace App\Timeline\EventSubscriber;
  5. use App\Timeline\Event\TimelinePostDeletedEvent;
  6. use App\Timeline\Event\TimelinePostEditedEvent;
  7. use App\Timeline\Event\TimelinePostEvents;
  8. use App\Timeline\Event\TimelinePostLikedEvent;
  9. use App\Timeline\Event\TimelinePostPublishedEvent;
  10. use App\Timeline\Event\TimelinePostSharedEvent;
  11. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  12. use Symfony\Component\HttpFoundation\RequestStack;
  13. use Symfony\Component\Mercure\HubInterface;
  14. use Symfony\Component\Mercure\Update;
  16. class TimelineMercureSubscriber implements EventSubscriberInterface
  17. {
  18.   public function __construct(
  19.     protected HubInterface $hub,
  20.     protected \Twig\Environment $twig,
  21.     protected RequestStack $requestStack
  22.   ) {
  23.   }
  25.   public static function getSubscribedEvents()
  26.   {
  27.     return [
  28.         TimelinePostEvents::PUBLISHED => 'postPublished',
  29.         TimelinePostEvents::EDITED => 'postEdited',
  30.         TimelinePostEvents::DELETED => 'postDeleted',
  31.         TimelinePostEvents::LIKED => 'postLiked',
  32.         TimelinePostEvents::DISLIKED => 'postLiked',
  33.     ];
  34.   }
  36.   public function postPublished(TimelinePostPublishedEvent $event)
  37.   {
  38.     $post = $event->post;
  39.     $html = $this->twig->render('network/event/timeline-post/published.stream.twig', [
  40.       'post' => $post,
  41.     ]);
  43.     $targets = [$post->getProfile(), ...$post->getShowPostAt()];
  45.     foreach ($targets as $target) {
  46.       $this->hub->publish(new Update(sprintf('timeline-posts-%s', $target->getId()), $html));
  47.     }
  48.   }
  50.   public function postEdited(TimelinePostEditedEvent $event)
  51.   {
  52.     $post = $event->post;
  53.     $html = $this->twig->render('network/event/timeline-post/edited.stream.twig', [
  54.       'post' => $post,
  55.     ]);
  57.     $this->hub->publish(new Update($event->getTopic(), $html));
  58.   }
  60.   public function postDeleted(TimelinePostDeletedEvent $event)
  61.   {
  62.     $postId = $event->postId;
  63.     $html = $this->twig->render('network/event/timeline-post/deleted.stream.twig', [
  64.       'postId' => $postId,
  65.     ]);
  67.     $this->hub->publish(new Update($event->getTopic(), $html));
  68.   }
  70.   public function postLiked(TimelinePostLikedEvent $event)
  71.   {
  72.     $post = $event->post;
  73.     $html = $this->twig->render('network/event/timeline-post/liked.stream.twig', [
  74.       'post' => $post,
  75.     ]);
  77.     $this->hub->publish(new Update($event->getTopic(), $html));
  78.   }
  79. }