src/Auth/EventListener/JWTCreatedListener.php line 43

Open in your IDE?
  1. <?php
  3. namespace App\Auth\EventListener;
  5. use App\Auth\Repository\AuthUserRepositoryInterface;
  6. use App\Organization\Repository\OrganizationRepositoryInterface;
  7. use App\Worker\Repository\WorkerRepositoryInterface;
  8. use Lexik\Bundle\JWTAuthenticationBundle\Event\JWTCreatedEvent;
  9. use Symfony\Component\HttpFoundation\RequestStack;
  11. class JWTCreatedListener
  12. {
  13.     /**
  14.      * @var RequestStack
  15.      */
  16.     protected $requestStack;
  18.     /**
  19.      * @var AuthUserRepositoryInterface
  20.      */
  21.     protected $repository;
  23.     private OrganizationRepositoryInterface $organizationRepository;
  24.     private WorkerRepositoryInterface $workerRepository;
  26.     /**
  27.      * JWTCreatedListener constructor.
  28.      * @param RequestStack $requestStack
  29.      * @param AuthUserRepositoryInterface $repository
  30.      */
  31.     public function __construct(
  32.         RequestStack $requestStack,
  33.         AuthUserRepositoryInterface $repository,
  34.         OrganizationRepositoryInterface $organizationRepository,
  35.         WorkerRepositoryInterface $workerRepository
  36.     ) {
  37.         $this->requestStack = $requestStack;
  38.         $this->repository = $repository;
  39.         $this->organizationRepository = $organizationRepository;
  40.         $this->workerRepository = $workerRepository;
  41.     }
  43.     public function onJWTCreated(JWTCreatedEvent $event)
  44.     {
  45.         $request = $this->requestStack->getCurrentRequest();
  47.         $user = $event->getUser();
  49.         $user = $this->repository->findActiveUserByEmail($user->getUsername());
  51.         $payload = $event->getData();
  52.         $payload['user_id'] = (string) $user->getId();
  53.         $payload['fullName'] = $user->getFirstName(). ' ' . $user->getLastName();
  54.         $payload['firstName'] = $user->getFirstName();
  55.         $payload['lastName'] = $user->getLastName();
  56.         $payload['organizationId'] = $user->getOrganizationId() ? $user->getOrganizationId()->toString() : null;
  57.         $payload['avatar'] = $user->getAvatar() ?
  58.             sprintf(
  59.                 'https://%s.s3.%s.amazonaws.com/avatars/%s',
  60.                 $_SERVER['AWS_S3_BUCKET'],
  61.                 $_SERVER['AWS_S3_REGION'],
  62.                 $user->getAvatar()
  63.             )
  64.             : null;
  65.         $payload['uiTour'] = $user->getUITour();
  67.         if ($this->workerRepository->isOwner($user->getId())) {
  68.             $payload['roles'][] = 'ROLE_WORKER_OWNER';
  69.         }
  71.         if ($user->isTrackingFeature()) {
  72.             $payload['options'] = [
  73.                 'trackingFeatures' => true
  74.             ];
  75.         }
  77.         try {
  78.             if (null !== $user->getOrganizationId()) {
  79.                 $organization = $this->organizationRepository->findOneById($user->getOrganizationId());
  81.                 if (null !== $organization && $organization->getStripeCustomerId() && $organization->isOverduePayment()) {
  82.                     $payload['overduePayment'] = true;
  83.                 } else {
  84.                     $payload['overduePayment'] = false;
  85.                 }
  86.             } else {
  87.                 $payload['overduePayment'] = false;
  88.             }
  89.         } catch (\Exception $exception) {
  90.             $payload['overduePayment'] = false;
  91.         }
  93.         $event->setData($payload);
  94.     }
  95. }