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

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. }