vendor/appaydin/pd-api/Listener/JWTExceptionListener.php line 44

Open in your IDE?
  1. <?php
  3. /**
  4.  * This file is part of the pd-admin pd-api package.
  5.  *
  6.  * @package     pd-api
  7.  * @license     LICENSE
  8.  * @author      Ramazan APAYDIN <apaydin541@gmail.com>
  9.  * @link        https://github.com/appaydin/pd-api
  10.  */
  12. namespace Pd\ApiBundle\Listener;
  14. use Lexik\Bundle\JWTAuthenticationBundle\Event\AuthenticationFailureEvent;
  15. use Lexik\Bundle\JWTAuthenticationBundle\Event\JWTExpiredEvent;
  16. use Lexik\Bundle\JWTAuthenticationBundle\Event\JWTInvalidEvent;
  17. use Lexik\Bundle\JWTAuthenticationBundle\Event\JWTNotFoundEvent;
  18. use Lexik\Bundle\JWTAuthenticationBundle\Events;
  19. use Pd\ApiBundle\Services\AcceptContentType;
  20. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  21. use Symfony\Component\HttpFoundation\Response;
  22. use Symfony\Component\Serializer\SerializerInterface;
  23. use Symfony\Contracts\Translation\TranslatorInterface;
  25. class JWTExceptionListener implements EventSubscriberInterface
  26. {
  27.     public function __construct(
  28.         private SerializerInterface $serializer,
  29.         private TranslatorInterface $translator,
  30.         private AcceptContentType $accept)
  31.     {
  32.     }
  34.     public function onJWTAuthFailure(AuthenticationFailureEvent $event): void
  35.     {
  36.         $event->setResponse($this->handleException($event->getResponse(), (new \ReflectionClass($event->getException()))->getShortName()));
  37.     }
  39.     public function onJWTInvalid(JWTInvalidEvent $event): void
  40.     {
  41.         $event->setResponse($this->handleException($event->getResponse(), 'InvalidTokenException'));
  42.     }
  44.     public function onJWTExpired(JWTExpiredEvent $event): void
  45.     {
  46.         $event->setResponse($this->handleException($event->getResponse(), 'ExpiredTokenException'));
  47.     }
  49.     public function onJWTNotFound(JWTNotFoundEvent $event): void
  50.     {
  51.         $event->setResponse($this->handleException($event->getResponse(), 'MissingTokenException'));
  52.     }
  54.     private function handleException(Response $response, string $type): Response
  55.     {
  56.         // Create Exception Response
  57.         $message = json_decode($response->getContent(), true)['message'];
  58.         $response->setContent($this->serializer->serialize([
  59.             'message' => $this->translator->trans($message, [], 'exception'),
  60.             'code' => $response->getStatusCode(),
  61.             'type' => $type,
  62.         ], $this->accept->getAcceptType()));
  64.         // Set Accept Content Type
  65.         $response->headers->set('Content-Type', 'application/'.$this->accept->getAcceptType());
  67.         return $response;
  68.     }
  70.     public static function getSubscribedEvents(): array
  71.     {
  72.         return [
  73.             Events::AUTHENTICATION_FAILURE => [['onJWTAuthFailure']],
  74.             Events::JWT_INVALID => [['onJWTInvalid']],
  75.             Events::JWT_EXPIRED => [['onJWTExpired']],
  76.             Events::JWT_NOT_FOUND => [['onJWTNotFound']],
  77.         ];
  78.     }
  79. }