src/WebserviceBundle/Event/RequestListener.php line 48

Open in your IDE?
  1. <?php
  2. /**
  3.  * Created by Notive.
  4.  * Project: wms.p
  5.  * User: Henny Krijnen
  6.  * Date: 30/09/16
  7.  * Time: 08:41
  8.  */
  10. namespace WebserviceBundle\Event;
  12. use Doctrine\ORM\EntityManager;
  13. use Doctrine\ORM\EntityManagerInterface;
  14. use Symfony\Component\HttpKernel\Event\GetResponseEvent;
  15. use Symfony\Component\Security\Core\Authentication\Token\Storage\TokenStorage;
  16. use WmsBundle\Entity\User;
  18. /**
  19.  * Class RequestListener
  20.  * @package WebserviceBundle\Event
  21.  */
  22. class RequestListener
  23. {
  24.     /**
  25.      * @var TokenStorage
  26.      */
  27.     protected $tokenStorage;
  29.     /**
  30.      * @var EntityManager
  31.      */
  32.     protected $entityManager;
  34.     /**
  35.      * RequestListener constructor.
  36.      * @param TokenStorage $tokenStorage
  37.      * @param EntityManager $entityManager
  38.      */
  39.     public function __construct(TokenStorage $tokenStorage, EntityManagerInterface $entityManager)
  40.     {
  41.         $this->tokenStorage = $tokenStorage;
  42.         $this->em = $entityManager;
  43.     }
  45.     /**
  46.      * @param GetResponseEvent $event
  47.      */
  48.     public function onRequest(GetResponseEvent $event)
  49.     {
  50.         $token = $this->tokenStorage->getToken();
  51.         if ($token) {
  52.             /** @var User $user */
  53.             $user = $token->getUser();
  54.             if ($user instanceof User) {
  55.                 if($user->getType() !== User::API_TYPE &&
  56.                     $user->getLastRequestAt() < (new \DateTime())->sub(new \DateInterval('PT1M'))
  57.                 ){
  58.                     $date = new \DateTime();
  59.                     $id = $user->getId();
  60.                     $sql = "
  61.                         UPDATE fos_user u
  62.                             SET u.last_request_at = :request
  63.                             WHERE u.id = :id";
  65.                     $stmt = $this->em->getConnection()->prepare($sql);
  66.                     $stmt->execute([
  67.                         'id' => $id,
  68.                         'request' => $date->format('Y-m-d H:i:s')
  69.                     ]);
  70.                 }
  71.             }
  72.         }
  73.     }
  74. }