src/EventSubscriber/EsEventLogSubscriber.php line 35

Open in your IDE?
  1. <?php
  3. namespace App\EventSubscriber;
  5. use App\Entity\EventLog;
  6. use App\Service\EsCache;
  7. use Psr\Log\LoggerInterface;
  8. use App\Event\EsEventLogEvent;
  9. use Doctrine\ORM\EntityManagerInterface;
  10. use Symfony\Component\Security\Core\Security;
  11. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  13. class EsEventLogSubscriber implements EventSubscriberInterface
  14. {
  15.     public function __construct(
  16.         private EntityManagerInterface $_em,
  17.         private LoggerInterface $esEventLogger,
  18.         private EsCache $esCache
  19.     ) {}
  21.     public static function getSubscribedEvents(): array
  22.     {
  23.         return [
  24.             EsEventLogEvent::EVENT_LOGIN => 'addToEventLog',
  25.             EsEventLogEvent::EVENT_ONBOARDING => 'addToEventLog',
  26.             EsEventLogEvent::EVENT_FORGOT_PASSWORD => 'addToEventLog',
  27.             EsEventLogEvent::EVENT_USER_ACTIVE => 'addToEventLog',
  28.             EsEventLogEvent::EVENT_USER_INACTIVE => 'addToEventLog',
  29.             EsEventLogEvent::EVENT_CHANGE_PROFILE => 'addToEventLog',
  30.             EsEventLogEvent::EVENT_USER_CREATE => 'addToEventLog',
  31.             EsEventLogEvent::EVENT_USER_DELETE => 'addToEventLog'
  32.         ];
  33.     }
  35.     public function addToEventLog(EsEventLogEvent $event)
  36.     {
  37.         $user = $event->getObject();
  38.         $container = $event->getContainer();
  39.         if (!$container) {
  40.             $container = $this->esCache->getContainer();
  41.         }
  42.         $isUserLogEnable = $container->getConfiguration('isUserLogEnable');
  43.         if ($isUserLogEnable === false) {
  44.             return;
  45.         }
  46.         
  47.         if ($user) {
  48.             /*
  49.             $info = [$event->getType(), $user->getId(), $user->getEmail(), $user->getFirstName(), $user->getLastName()];
  50.             $this->esEventLogger->info(implode(',', $info));
  51.             */
  53.             $now = new \DateTime();
  54.             $now = $now->format('Y-m-d H:i:s');
  55.             $query = "INSERT INTO event_log(`event_type`, `container_id`, `user_id`, `created_at`, `updated_at`) VALUES ('".$event->getType()."', '".$container->getId()."', '".$user->getId()."', '".$now."', '".$now."')";
  56.             $statement = $this->_em->getConnection()->prepare($query);
  57.             $statement->execute();
  58.         }
  59.     }
  60. }