src/Listener/JWTCreatedListener.php line 39

Open in your IDE?
  1. <?php
  4. namespace App\Listener;
  7. use App\Repository\UserRepository;
  8. use Lexik\Bundle\JWTAuthenticationBundle\Event\JWTCreatedEvent;
  9. use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
  10. use Symfony\Component\HttpFoundation\RequestStack;
  11. use DateInterval;
  12. use App\Services\SqlService\SqlService;
  14. class JWTCreatedListener extends AbstractController
  15. {
  16.     private $requestStack;
  17.     private $userRepository;
  18.     private $sqlService;
  19.     
  22.     /**
  23.      * @param RequestStack $requestStack
  24.      * @param UserRepository $userRepository
  25.      */
  26.     public function __construct(RequestStack $requestStack, UserRepository $userRepository, SqlService $sqlService)
  27.     {
  28.         $this->requestStack = $requestStack;
  29.         $this->userRepository = $userRepository;
  30.         $this->sqlService = $sqlService;
  31.     }
  33.     /**
  34.      * @param JWTCreatedEvent $event
  35.      * @param UserRepository $userRepository
  36.      * @return void
  37.      *  este se inicia el primero
  38.      */
  39.     public function onJWTCreated(JWTCreatedEvent $event)
  40.     {
  41.         $payload = $event->getData();
  42.         $data = $this->userRepository->findOneByEmail($payload['username']);
  43.         // Fecha de expiracion del token 3 horas a partir de la ultima visita
  44.         $expiration = new \DateTime();
  45.         $expiration->add(new DateInterval('PT2H'));
  47.         $sql = "SELECT valor FROM custom_values 
  48.         WHERE entidad = 'USER' AND entidad_id = ? AND clave = 'foto'";
  49.         
  50.         
  51.         // Solo se activa cuando se hace login //
  52.         $payload = $event->getData();
  53.         $payload['exp'] = $expiration->getTimestamp();
  54.         $payload['uuid'] = $data->getId();
  55.         $payload['username'] = $data->getEmail();
  56.         $payload['roles'] = $data->getRoles();
  57.         $payload['dni'] = $data->getDni();
  58.         $payload['nombre'] = $data->getNombre();
  59.         $payload['estado'] = $data->getEstado();
  61.         $foto = $this->sqlService->generateSql($sql, [$data->getId()]);
  62.         if ($foto) {
  63.             $payload['foto'] = $foto['valor'];
  64.         }
  66.         $event->setData($payload);
  67.         $header = $event->getHeader();
  68.         $header['cty'] = 'JWT';
  69.         $event->setHeader($header);
  70.     }
  71. }