src/Importer/Subscriber/ImportMessageSubscriber.php line 25

Open in your IDE?
  1. <?php
  3. namespace App\Importer\Subscriber;
  5. use App\Importer\Message\ImportMessage;
  6. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  7. use Symfony\Component\Mercure\HubInterface;
  8. use Symfony\Component\Mercure\Update;
  9. use Symfony\Component\Messenger\Event\WorkerMessageHandledEvent;
  10. use Twig;
  12. class ImportMessageSubscriber implements EventSubscriberInterface
  13. {
  14.   public function __construct(protected HubInterface $hub, protected Twig\Environment $twig)
  15.   {
  16.   }
  18.   public static function getSubscribedEvents()
  19.   {
  20.     return [
  21.       WorkerMessageHandledEvent::class => 'onMessageHandled',
  22.     ];
  23.   }
  25.   public function onMessageHandled(WorkerMessageHandledEvent $event)
  26.   {
  27.     $message = $event->getEnvelope()->getMessage();
  29.     if (!$message instanceof ImportMessage) {
  30.       return;
  31.     }
  33.     $view = $this->twig->render('importer/success.stream.html.twig', [
  34.       'envelope' => $event->getEnvelope(),
  35.     ]);
  37.     $this->hub->publish(new Update('imports', $view));
  38.   }
  39. }