src/EventSubscriber/JWTSubscriber.php line 38

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace App\EventSubscriber;
  7. use App\Client\Qoodos\QoodosClient;
  8. use App\Entity\Security\Customer;
  9. use App\Entity\Security\Manager;
  10. use App\Entity\Security\ShopManager;
  11. use App\Entity\Security\UserInterface;
  12. use App\Helper\Image\ImageHelper;
  13. use App\Helper\Response\ResponseInterface as CustomResponseInterface;
  14. use App\Repository\Franchise\CustomerFranchiseRepository;
  15. use App\Repository\Franchise\FranchiseRepository;
  16. use App\Service\Security\CustomerService;
  17. use Lexik\Bundle\JWTAuthenticationBundle\Event\JWTCreatedEvent;
  18. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  19. use Symfony\Component\HttpFoundation\RequestStack;
  20. use Symfony\Component\HttpFoundation\Response;
  21. use Symfony\Component\HttpKernel\Exception\BadRequestHttpException;
  23. class JWTSubscriber implements EventSubscriberInterface
  24. {
  25.     private $request;
  27.     public function __construct(
  28.         private ImageHelper $imageHelper,
  29.         private FranchiseRepository $franchiseRepository,
  30.         private QoodosClient $qoodosClient,
  31.         private CustomerService $customerService,
  32.         private CustomerFranchiseRepository $customerFranchiseRepository,
  33.         RequestStack $requestStack,
  34.     ) {
  35.         $this->request = $requestStack->getCurrentRequest();
  36.     }
  38.     public function onLexikJwtAuthenticationOnJwtCreated(JWTCreatedEvent $event): void
  39.     {
  40.         $user = $event->getUser();
  41.         $payload = array_merge($event->getData(), [
  42.             'exp' => time() + UserInterface::TOKEN_LIFE_TIME,
  43.             'ip' => $this->request->getClientIp(),
  44.         ]);
  46.         if ($user instanceof Customer) {
  47.             $franchiseToken = $this->request->headers->get('franchise-token');
  48.             if (null === $franchiseToken) {
  49.                 throw new BadRequestHttpException(Response::$statusTexts[Response::HTTP_BAD_REQUEST]);
  50.             }
  52.             $franchise = $this->franchiseRepository->findOneBy(['token' => $franchiseToken]);
  53.             if (null === $franchise) {
  54.                 throw new BadRequestHttpException(CustomResponseInterface::FRANCHISE_NOT_FOUND);
  55.             }
  57.             if (false === $this->customerService->customerHasFranchise($user, $franchise)) {
  58.                 throw new BadRequestHttpException(CustomResponseInterface::CUSTOMER_NOT_FOUND_IN_FRANCHISE);
  59.             }
  61.             $payload = array_merge($payload, [
  62.                 'franchise' => $franchise->getId(),
  63.                 'name' => $user->getFullName(),
  64.                 'id' => $user->getId(),
  65.                 'imageUrl' => $this->imageHelper->getAbsolutePath($user),
  66.                 'askForSubscriptionToQoodos' => $this->customerFranchiseRepository->canAskForSubscriptionToQoodos($user, $franchise),
  67.             ]);
  69.             if (true === $franchise->hasQoodos()) {
  70.                 try {
  71.                     $this->qoodosClient->init($franchise);
  72.                     $result = $this->qoodosClient->getFranchise();
  73.                     $payload = array_merge($payload, [
  74.                         'canUseCashback' => $result['can_use_cashback'],
  75.                         'canUsePoints' => $result['can_use_points'],
  76.                     ]);
  77.                 } catch (\Exception $e) {
  78.                 }
  79.             }
  80.         }
  82.         if ($user instanceof ShopManager) {
  83.             $payload['shop'] = $user->getShop()->getId();
  84.         }
  86.         if ($user instanceof Manager) {
  87.             $payload['franchise'] = $user->getFranchise()->getId();
  88.         }
  90.         $event->setData($payload);
  91.         $header = $event->getHeader();
  92.         $header['cty'] = 'JWT';
  93.         $event->setHeader($header);
  94.     }
  96.     public static function getSubscribedEvents()
  97.     {
  98.         return [
  99.             'lexik_jwt_authentication.on_jwt_created' => 'onLexikJwtAuthenticationOnJwtCreated',
  100.         ];
  101.     }
  102. }