src/Listener/JWTCreatedListener.php line 18

Open in your IDE?
  1. <?php
  3. namespace App\Listener;
  5. use Lexik\Bundle\JWTAuthenticationBundle\Event\JWTCreatedEvent;
  6. use Symfony\Component\HttpFoundation\RequestStack;
  7. use Symfony\Component\Security\Core\User\UserInterface;
  9. class JWTCreatedListener
  10. {
  11.     private RequestStack $requestStack;
  13.     public function __construct(RequestStack $requestStack)
  14.     {
  15.         $this->requestStack = $requestStack;
  16.     }
  18.     public function __invoke(JWTCreatedEvent $event): void
  19.     {
  20.         $request = $this->requestStack->getCurrentRequest();
  22.         // fallback si on n’est pas dans une requête HTTP (ex: CLI)
  23.         if (!$request) {
  24.             return;
  25.         }
  27.         $host = $request->headers->get('X-Server-Host');
  28.         $user = $event->getUser();
  29.         $userId = $user->getId();
  31.         $payload = $event->getData();
  32.         $payload['mercure'] = [
  33.             'subscribe' => [
  34.                 sprintf('https://%s/users/%d/notifications', $host, $userId),
  35.             ],
  36.         ];
  38.         $event->setData($payload);
  39.     }
  40. }