src/EventListener/AuthenticationSuccessListener.php line 21

Open in your IDE?
  1. <?php
  2. // src/EventListener/AuthenticationSuccessListener.php
  4. namespace App\EventListener;
  6. use Lexik\Bundle\JWTAuthenticationBundle\Event\AuthenticationSuccessEvent;
  7. use Gesdinet\JWTRefreshTokenBundle\Model\RefreshTokenManagerInterface;
  8. use Symfony\Component\Security\Core\User\UserInterface;
  10. class AuthenticationSuccessListener
  11. {
  12.     private RefreshTokenManagerInterface $refreshTokenManager;
  13.     private int $ttl;
  15.     public function __construct(RefreshTokenManagerInterface $refreshTokenManager, int $ttl)
  16.     {
  17.         $this->refreshTokenManager = $refreshTokenManager;
  18.         $this->ttl = $ttl;
  19.     }
  21.     public function onAuthenticationSuccess(AuthenticationSuccessEvent $event): void
  22.     {
  23.         $user = $event->getUser();
  25.         if (!$user instanceof UserInterface) {
  26.             error_log("ERREUR: L'utilisateur n'est pas une instance de UserInterface");
  27.             return;
  28.         }
  30.         try {
  31.             // Récupérer l'email
  32.             $email = $this->getUserEmail($user);
  34.             if (empty($email)) {
  35.                 throw new \RuntimeException("Impossible de récupérer l'email de l'utilisateur");
  36.             }
  38.             error_log("AuthenticationSuccessListener: Email utilisé = " . $email);
  40.             // Créer le refresh token
  41.             $refreshToken = $this->refreshTokenManager->create();
  42.             $refreshToken->setUsername($email);
  43.             $refreshToken->setRefreshToken();
  44.             $refreshToken->setValid((new \DateTime())->modify('+' . $this->ttl . ' seconds'));
  46.             error_log("AuthenticationSuccessListener: Refresh token créé");
  48.             $this->refreshTokenManager->save($refreshToken);
  50.             error_log("AuthenticationSuccessListener: Refresh token sauvegardé");
  52.             // Ajouter le refresh token à la réponse
  53.             $data = $event->getData();
  54.             $data['success'] = true;
  55.             $data['refresh_token'] = $refreshToken->getRefreshToken();
  57.             $event->setData($data);
  59.         } catch (\Exception $e) {
  60.             error_log("ERREUR AuthenticationSuccessListener: " . $e->getMessage());
  62.             // En cas d'erreur, on retourne quand même le JWT mais sans refresh token
  63.             $data = $event->getData();
  64.             $data['success'] = true;
  65.             $data['warning'] = 'Connexion réussie mais le refresh token n\'a pas pu être créé';
  67.             $event->setData($data);
  68.         }
  69.     }
  71.     private function getUserEmail(UserInterface $user): ?string
  72.     {
  73.         if (method_exists($user, 'getUserIdentifier')) {
  74.             return $user->getUserIdentifier();
  75.         }
  77.         if (method_exists($user, 'getEmail')) {
  78.             return $user->getEmail();
  79.         }
  81.         if (method_exists($user, 'getUsername')) {
  82.             return $user->getUsername();
  83.         }
  85.         return null;
  86.     }
  87. }