src/Component/AuditLog/EventSubscriber/AuditLogSubscriber.php line 32

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace App\Component\AuditLog\EventSubscriber;
  7. use App\Component\AuditLog\Action;
  8. use App\Component\AuditLog\Message\Command\AuditLogEntry;
  9. use App\Entity\User;
  10. use Scheb\TwoFactorBundle\Security\TwoFactor\Event\TwoFactorAuthenticationEvent;
  11. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  12. use Symfony\Component\Messenger\MessageBusInterface;
  13. use Symfony\Component\Security\Core\Authentication\Token\TokenInterface;
  14. use Symfony\Component\Security\Http\Event\LoginSuccessEvent;
  15. use Symfony\Component\Security\Http\Event\SwitchUserEvent;
  17. class AuditLogSubscriber implements EventSubscriberInterface
  18. {
  19.     public function __construct(private readonly MessageBusInterface $messageBus)
  20.     {
  21.     }
  23.     public static function getSubscribedEvents(): array
  24.     {
  25.         return [
  26.             SwitchUserEvent::class => 'onSecuritySwitchUser',
  27.             LoginSuccessEvent::class => 'onLoginSuccess',
  28.             'scheb_two_factor.authentication.complete' => 'onTwoFactorAuthenticationComplete',
  29.         ];
  30.     }
  32.     public function onTwoFactorAuthenticationComplete(TwoFactorAuthenticationEvent $event): void
  33.     {
  34.         $this->loginEntry($event->getToken());
  35.     }
  37.     public function onSecuritySwitchUser(SwitchUserEvent $event): void
  38.     {
  39.         $user = $event->getToken()?->getUser();
  41.         /** @var int $userId */
  42.         $userId = $user instanceof User ? $user->getId() : 0;
  44.         /** @var User $targetUser */
  45.         $targetUser = $event->getTargetUser();
  46.         $targetUserId = $targetUser->getId();
  48.         if ($userId !== $targetUserId) {
  49.             $this->messageBus->dispatch(new AuditLogEntry($userId, Action::USER_SWITCH->value, (string) $targetUserId));
  50.         }
  51.     }
  53.     public function onLoginSuccess(LoginSuccessEvent $event): void
  54.     {
  55.         $this->loginEntry($event->getAuthenticatedToken());
  56.     }
  58.     private function loginEntry(TokenInterface $token): void
  59.     {
  60.         $user = $token->getUser();
  62.         /** @var int $userId */
  63.         $userId = $user instanceof User ? $user->getId() : 0;
  65.         $this->messageBus->dispatch(new AuditLogEntry($userId, Action::USER_LOGIN->value));
  66.     }
  67. }