src/Log/Service/RequestFactory.php line 49

Open in your IDE?
  1. <?php
  3. namespace App\Log\Service;
  6. use App\Log\Entity\Request;
  7. use App\Security\Entity\User;
  8. use Doctrine\ORM\EntityManagerInterface;
  9. use Symfony\Component\Security\Core\Authentication\Token\Storage\TokenStorageInterface;
  11. class RequestFactory {
  13.     /**
  14.      * @var EntityManagerInterface
  15.      */
  16.     protected EntityManagerInterface $entityManager;
  18.     /**
  19.      * @var TokenStorageInterface
  20.      */
  21.     protected TokenStorageInterface $tokenStorage;
  23.     public function __construct(EntityManagerInterface $logEntityManager, TokenStorageInterface $tokenStorage)
  24.     {
  25.         $this->entityManager = $logEntityManager;
  26.         $this->tokenStorage = $tokenStorage;
  27.     }
  29.     /**]
  30.      * @param string $url
  31.      * @param array $requestData
  32.      * @param string|null $ip
  33.      * @return Request
  34.      */
  35.     public function create(string $url, array $requestData, string $ip = null): Request
  36.     {
  37.         $request = new Request();
  38.         $request
  39.             ->setUrl($url)
  40.             ->setRequestData($requestData)
  41.             ->setIp($ip)
  42.         ;
  44.         $user = $this->tokenStorage->getToken() ? $this->tokenStorage->getToken()->getUser() : null;
  45.         if ($user instanceof User && $this->tokenStorage->getToken()){
  46.             $request->setUser($this->entityManager->getRepository(User::class)->find($user->getId()));
  47.         }
  49.         $this->entityManager->persist($request);
  50.         $this->entityManager->flush($request);
  52.         return $request;
  53.     }
  55.     /**
  56.      * @param Request $request
  57.      * @param $responseData
  58.      * @param $statusCode
  59.      * @param bool $complete
  60.      */
  61.     public function update(Request $request, $responseData, $statusCode, bool $complete = true): void
  62.     {
  63.         if(!$this->entityManager->isOpen()) {
  64.             // if entity manager is closed, do not try to update and send another exception
  65.             return;
  66.         }
  67.         $request
  68.             ->setResponseData($responseData ?: [])
  69.             ->setStatusCode($statusCode)
  70.             ->setFinishAt()
  71.             ->setComplete($complete);
  73.         $this->entityManager->persist($request);
  74.         $this->entityManager->flush($request);
  75.     }
  77.     /**
  78.      * @param Request $request
  79.      * @param $requestData
  80.      */
  81.     public function updateRequestData(Request $request, $requestData): void
  82.     {
  83.         if(!$this->entityManager->isOpen()) {
  84.             // if entity manager is closed, do not try to update and send another exception
  85.             return;
  86.         }
  87.         $request
  88.             ->setRequestData($requestData);
  90.         $this->entityManager->persist($request);
  91.         $this->entityManager->flush($request);
  92.     }
  93. }