src/EventSubscriber/LoginSuccessSubscriber.php line 61

Open in your IDE?
  1. <?php
  4. namespace App\EventSubscriber;
  7. use ApiPlatform\Core\EventListener\EventPriorities;
  8. use App\Entity\Device;
  9. use App\Repository\DeviceRepository;
  10. use Doctrine\ORM\EntityManagerInterface;
  11. use Lexik\Bundle\JWTAuthenticationBundle\Event\AuthenticationSuccessEvent;
  12. use Lexik\Bundle\JWTAuthenticationBundle\Events;
  13. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  14. use Symfony\Component\HttpFoundation\Request;
  15. use Symfony\Component\HttpKernel\Event\RequestEvent;
  16. use Symfony\Component\HttpKernel\KernelEvents;
  17. use Symfony\Component\Security\Core\Security;
  19. class LoginSuccessSubscriber implements EventSubscriberInterface
  20. {
  21.     /**
  22.      * @var Request
  23.      */
  24.     private $request;
  26.     /**
  27.      * @var DeviceRepository
  28.      */
  29.     private $deviceRepository;
  31.     /**
  32.      * @var EntityManagerInterface
  33.      */
  34.     private $entityManager;
  36.     /**
  37.      * @var Security
  38.      */
  39.     private $security;
  41.     /**
  42.      * LoginSuccessSubscriber constructor.
  43.      * @param DeviceRepository $deviceRepository
  44.      * @param EntityManagerInterface $entityManager
  45.      */
  46.     public function __construct(DeviceRepository $deviceRepository, EntityManagerInterface $entityManager, Security $security)
  47.     {
  48.         $this->deviceRepository = $deviceRepository;
  49.         $this->entityManager = $entityManager;
  50.         $this->security = $security;
  51.     }
  53.     public static function getSubscribedEvents()
  54.     {
  55.         return [
  56.             KernelEvents::REQUEST => ['onRequest', EventPriorities::POST_SERIALIZE],
  57.             Events::AUTHENTICATION_SUCCESS => 'onSuccess',
  58.         ];
  59.     }
  61.     public function onSuccess(AuthenticationSuccessEvent $event)
  62.     {
  63.         if($this->request !== null) {
  64.             $content = json_decode($this->request->getContent(), true);
  65.             if(empty($content['uuid'])) {
  66.                 return;
  67.             }
  68.             $device = $this->deviceRepository->findOneBy(['uuid' => $content['uuid']]);
  70.             if( ! $device) {
  71.                 $device = new Device();
  72.                 $device->setName($content['model']);
  73.                 $device->setUuid($content['uuid']);
  74.                 $device->setUser($this->security->getUser());
  75.                 $this->entityManager->persist($device);
  76.                 $this->entityManager->flush();
  77.             }
  79.         }
  80.     }
  82.     public function onRequest(RequestEvent $requestEvent)
  83.     {
  84.         $request = $requestEvent->getRequest();
  86.         if('api_login_check' === $request->attributes->get('_route')) {
  87.             $this->request = $request;
  88.         }
  89.     }
  90. }