src/EventSubscriber/JwtSseSubscriber.php line 24

Open in your IDE?
  1. <?php
  3. namespace App\EventSubscriber;
  5. use Firebase\JWT\JWT;
  6. use Symfony\Component\HttpKernel\KernelEvents;
  7. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  8. use Symfony\Component\Dotenv\Dotenv;
  9. use Symfony\Component\HttpFoundation\Cookie;
  10. use Symfony\Component\HttpKernel\Event\ResponseEvent;
  12. class JwtSseSubscriber implements EventSubscriberInterface
  13. {
  14.     public function __construct() {}
  16.     public static function getSubscribedEvents()
  17.     {
  18.         return [
  19.             KernelEvents::RESPONSE => 'setJwt',
  20.             // KernelEvents::TERMINATE : Appelé une seul fois après le traitement de la rêquete, evite les doublons dans la dbb
  21.         ];
  22.     }
  24.     public function setJwt(ResponseEvent $event)
  25.     {
  26.         $response = $event->getResponse();
  28.         $dotenv = new Dotenv();
  29.         $dotenv->load(__DIR__ . '/../../.env');
  30.         $key = $_ENV['MERCURE_JWT_SECRET'];
  32.         $head = [
  33.             "alg" => "HS256",
  34.             "typ" => "JWT"
  35.         ];
  36.         $payload = [
  37.             'mercure' => [
  38.                 // 'subscribe' => [
  39.                 //     $user->getFlux()->getTopicLabel(),
  40.                 //     // 'GLOBALTOPIC',
  41.                 //     // 'http://monsite.fr/message',
  42.                 //     // 'http://monsite.fr/user/'.$this->getUser()->getUsername()
  43.                 // ],
  44.                 // 'publish' => [ // publish add also to subcribse
  45.                 //     'http://monsite.fr/message',
  46.                 //     'http://monsite.fr/user/'.$this->getUser()->getUsername()
  47.                 // ],
  48.                 'subscribe' => [
  49.                     '*'
  50.                 ],
  51.                 'publish' => [ // publish add also to subcribse
  52.                     '*'
  53.                 ],
  54.             ],
  55.         ];
  56.         $jwt = JWT::encode($payload, $key, 'HS256', null, $head);
  59.         // $response = new RedirectResponse('/social', 302);
  60.         // $response = $this->forward('App\Controller\HomeController::index', []);
  61.         // $response = new Response();
  63.         // $response->headers->set('set-cookie', "mercureAuthorization={$jwt}; HttpOnly;");
  64.         $response->headers->setCookie(Cookie::create('mercureAuthorization', $jwt));
  65.     }
  66. }