src/EventSubscriber/RequestSubscriber.php line 45

Open in your IDE?
  1. <?php
  4. namespace App\EventSubscriber;
  7. use App\Entity\RouteConfig;
  8. use App\Entity\User;
  9. use App\Entity\UserActivity;
  10. use Doctrine\ORM\EntityManagerInterface;
  11. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  12. use Symfony\Component\Form\FormFactoryInterface;
  13. use Symfony\Component\HttpFoundation\RedirectResponse;
  14. use Symfony\Component\HttpKernel\Event\RequestEvent;
  15. use Symfony\Component\HttpKernel\Event\ResponseEvent;
  16. use Symfony\Component\Routing\Router;
  17. use Symfony\Component\Security\Core\Security;
  19. class RequestSubscriber implements EventSubscriberInterface
  20. {
  21.     /**
  22.      * @var EntityManagerInterface
  23.      */
  24.     private $em;
  25.     
  26.     /**
  27.      * @var Security
  28.      */
  29.     private $security;
  31.     public function __construct(EntityManagerInterface $em, Security $security)
  32.     {
  33.         $this->em = $em;
  34.         $this->security = $security;
  35.     }
  37.     public static function getSubscribedEvents(): array
  38.     {
  39.         return [
  40.             RequestEvent::class => 'onKernelRequest',
  41. //            ResponseEvent::class => 'onKernelResponse',
  42.         ];
  43.     }
  45.     public function onKernelRequest(RequestEvent $event): bool
  46.     {
  47.         $req = $event->getRequest();
  48.         
  49.         $controller = $req->attributes->get('_controller');
  50.         $ctrArr = explode('::', $controller);
  51.         
  52.         $controllerPath = $ctrArr[0] ?? '';
  53.         $actionName = $ctrArr[1] ?? '';
  54.         
  55.         if (!$controllerPath || !$actionName) {
  56.             return false;
  57.         }
  59.         // check first time login
  60.         if ($this->security->getUser()) {
  61.             /** @var User $user */
  62.             $user = $this->security->getUser();
  63.             if ('user_change_password' != $req->attributes->get('_route')) {
  64.                 if ($user->isIsNew()) {
  65.                     $event->setResponse(new RedirectResponse('/users/change-password'));
  66.                     return false;
  67.                 }
  68.             }
  69.         }
  70.         
  71.         if (strpos(strtolower($actionName), 'json')) {
  72.             return false;
  73.         }
  74.         
  75.         /** @var User $user */
  76.         $user = $this->security->getUser();
  77.         if ($user) {
  78.             $rRepo = $this->em->getRepository(RouteConfig::class);
  79.             /** @var RouteConfig $route */
  80.             $route = $rRepo->findOneBy([
  81.                 'name' => $req->attributes->get('_route'),
  82.                 'isTrack' => true,
  83.             ]);
  84.             
  85.             if ($route) {
  86.                 $activity = new UserActivity();
  87.                 $activity->setType('ACCESS');
  88.                 $activity->setUser($user);
  89.                 $activity->setName($route->getLabel() ?: $route->getName());
  90.                 $activity->setActiveAt(new \DateTime('now'));
  91.                 $activity->setRouteName($req->attributes->get('_route'));
  92.                 $activity->setRouteParams($req->attributes->get('_route_params'));
  93.                 $activity->setPathInfo($req->getPathInfo());
  94.                 $activity->setRequestUri($req->getRequestUri());
  95.                 $activity->setRequestMethod($req->getRealMethod());
  97.                 $activity->setCtrName($controllerPath);
  98.                 $activity->setActName($actionName);
  99.                 
  100.                 $options = [
  101.                     'platform' => $req->headers->get('sec-ch-ua-platform'),
  102.                     'user-agent' => $req->headers->get('user-agent'),
  103.                     'referer' => $req->headers->get('referer'),
  104.                 ];
  105.                 $activity->setOptions($options);
  107.                 $this->em->persist($activity);
  108.                 $this->em->flush();
  109.             }
  110.         }
  111.         
  112.         return true;
  113.     }
  115.     public function onKernelResponse(ResponseEvent $event)
  116.     {
  117.         
  118.     }
  119. }