vendor/nellapp/sdk-bundle/src/Auth/EventSubscriber/LoginSubscriber.php line 34

Open in your IDE?
  1. <?php
  3. namespace Nellapp\Bundle\SDKBundle\Auth\EventSubscriber;
  5. use Nellapp\Bundle\SDKBundle\Auth\Entity\UserInterface;
  6. use Nellapp\Bundle\SDKBundle\Routing\Utils\DomainsRoutingUtils;
  7. use Nellapp\Bundle\SDKBundle\Sync\ApiClient\Account\SsoClient;
  8. use Psr\Log\LoggerInterface;
  9. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  10. use Symfony\Component\Security\Http\Event\LoginSuccessEvent;
  11. use Symfony\Component\HttpKernel\KernelEvents;
  12. use Symfony\Component\HttpKernel\Event\TerminateEvent;
  14. class LoginSubscriber implements EventSubscriberInterface
  15. {
  16.     private ?array $pendingPayload = null;
  18.     public function __construct(
  19.         private DomainsRoutingUtils $domainsRoutingUtils,
  20.         private SsoClient           $ssoClient,
  21.         private LoggerInterface     $logger,
  22.     )
  23.     {
  24.     }
  26.     public static function getSubscribedEvents(): array
  27.     {
  28.         return [
  29.             LoginSuccessEvent::class => 'onLoginSuccess',
  30.             KernelEvents::TERMINATE => 'onTerminate',
  31.         ];
  32.     }
  34.     public function onLoginSuccess(LoginSuccessEvent $event): void
  35.     {
  36.         $request = $event->getRequest();
  37.         $user = $event->getUser();
  38.         $session = $request->getSession();
  39.         if (!$user instanceof UserInterface || !$session) {
  40.             return;
  41.         }
  43.         // DeviceId cookie should already been set through DeviceIdSubscriber on pre-oauth requests
  44.         $deviceId = $request->cookies->get('DEVICE_ID');
  45.         if (!$deviceId) {
  46.             return;
  47.         }
  49.         $this->pendingPayload = [
  50.             'appName' => $this->domainsRoutingUtils->getAppName(),
  51.             'userId' => $user->getId(),
  52.             'sessionId' => $session->getId(),
  53.             'deviceId' => $deviceId,
  54.             'userAgent' => $request->headers->get('User-Agent'),
  55.             'ipAddress' => $request->getClientIp(),
  56.         ];
  57.     }
  59.     public function onTerminate(TerminateEvent $event): void
  60.     {
  61.         if (!$this->pendingPayload) {
  62.             return;
  63.         }
  65.         try {
  66.             $this->ssoClient->postRegister($this->pendingPayload);
  67.         } catch (\Exception $e) {
  68.             $this->logger->error($e);
  69.         }
  71.         $this->pendingPayload = null;
  72.     }
  73. }