src/EventListener/KernelEventListener.php line 72

  1. <?php
  3. namespace App\EventListener;
  5. use App\Entity\Channel;
  6. use App\Entity\Shop\Shop;
  7. use App\Entity\User;
  8. use App\Filter\ChannelFilter;
  9. use App\Helper\ApiMarker;
  10. use App\PortoContainers\Zapier\Helper\ZapierRequestMarker;
  11. use App\Service\ChannelService;
  12. use App\Service\Logger\RequestLoggerService;
  13. use App\ViewHandler\FormatterHandler;
  14. use Doctrine\ORM\EntityManagerInterface;
  15. use Exception;
  16. use Symfony\Component\HttpFoundation\Request;
  17. use Symfony\Component\HttpFoundation\Response;
  18. use Symfony\Component\HttpKernel\Event\ExceptionEvent;
  19. use Symfony\Component\HttpKernel\Event\RequestEvent;
  20. use Symfony\Component\HttpKernel\Event\ResponseEvent;
  21. use Symfony\Component\HttpKernel\Exception\HttpExceptionInterface;
  22. use Symfony\Component\Security\Core\Authentication\Token\Storage\TokenStorageInterface;
  23. use Symfony\Component\Security\Core\User\UserInterface;
  24. use App\PortoContainers\Zapier\Actions\IsApiRequestForZapierAction;
  25. use App\PortoContainers\Zapier\Actions\ValidateApiKeyInRequestAction;
  26. use App\PortoContainers\Global\DTO\RequestData;
  28. class KernelEventListener
  29. {
  30.     /**
  31.      * @param RequestLoggerService $loggerService
  32.      * @param FormatterHandler $formatterHandler
  33.      * @param TokenStorageInterface $tokenStorage
  34.      * @param ChannelService $channelService
  35.      * @param EntityManagerInterface $em
  36.      * @param IsApiRequestForZapierAction $isApiRequestForZapierAction
  37.      * @param ValidateApiKeyInRequestAction $validateApiKeyInRequestAction
  38.      */
  39.     public function __construct(
  40.         private readonly RequestLoggerService          $loggerService,
  41.         private readonly FormatterHandler              $formatterHandler,
  42.         private readonly TokenStorageInterface         $tokenStorage,
  43.         private readonly ChannelService                $channelService,
  44.         private readonly EntityManagerInterface        $em,
  45.         private readonly IsApiRequestForZapierAction   $isApiRequestForZapierAction,
  46.         private readonly ValidateApiKeyInRequestAction $validateApiKeyInRequestAction
  47.     )
  48.     {
  49.     }
  51.     /**
  52.      * @param RequestEvent $event
  53.      */
  54.     public function onKernelRequest(RequestEvent $event): void
  55.     {
  56.         if (ApiMarker::isApiRequest()) {
  57.             $this->convertApiJsonRequest($event);
  58.         } elseif ($this->isApiRequestForZapierAction->run(
  59.             $requestData = new RequestData($event->getRequest())
  60.         )) {
  61.             $this->validateApiKeyInRequestAction->run($requestData);
  62.         } elseif ($this->getUser() instanceof UserInterface) {
  63.             $this->checkCustomerShopToken($event->getRequest());
  64.         }
  65.     }
  67.     /**
  68.      * @param ResponseEvent $event
  69.      *
  70.      * @throws Exception
  71.      */
  72.     public function onKernelResponse(ResponseEvent $event): void
  73.     {
  74.         if (ApiMarker::isApiRequest() || ZapierRequestMarker::isRequest()) {
  75.             $this->logApiResponse($event);
  76.         }
  77.     }
  79.     /**
  80.      * @param ExceptionEvent $event
  81.      * @return void
  82.      */
  83.     public function onKernelException(ExceptionEvent $event): void
  84.     {
  85.         if (ApiMarker::isApiRequest() || ZapierRequestMarker::isRequest()) {
  86.             $this->formatExceptionResponse($event);
  87.         }
  88.     }
  90.     /**
  91.      * @param RequestEvent $event
  92.      * @return void
  93.      */
  94.     private function convertApiJsonRequest(RequestEvent $event): void
  95.     {
  96.         $request = $event->getRequest();
  98.         if (0 === strpos($request->headers->get('content-type'), 'application/json')) {
  99.             $data = json_decode($request->getContent(), true);
  100.             $request->request->replace(is_array($data) ? $data : []);
  101.         }
  102.     }
  104.     /**
  105.      * @param ResponseEvent $event
  106.      *
  107.      * @throws Exception
  108.      */
  109.     private function logApiResponse(ResponseEvent $event): void
  110.     {
  111.         $this->loggerService->addLog($event);
  112.         //try {
  113.         //    $this->loggerService->addLog($event);
  114.         //} catch (Exception $ex) {
  115.         //    # TODO send log to telegram
  116.         //}
  117.     }
  119.     /**
  120.      * @param ExceptionEvent $event
  121.      */
  122.     private function formatExceptionResponse(ExceptionEvent $event): void
  123.     {
  124.         $exception = $event->getThrowable();
  126.         if ($exception instanceof HttpExceptionInterface) {
  127.             $status = $exception->getStatusCode();
  128.         } else {
  129.             $status = $exception->getCode() ?: Response::HTTP_BAD_REQUEST;
  130.         }
  132.         $event->setResponse($this->formatterHandler->createResponse($exception, $status));
  133.     }
  135.     /**
  136.      * @return User|null
  137.      */
  138.     private function getUser(): ?UserInterface
  139.     {
  140.         $user = $this->tokenStorage->getToken() ? $this->tokenStorage->getToken()->getUser() : null;
  142.         return $user instanceof UserInterface ? $user : null;
  143.     }
  145.     /**
  146.      * @param Request $request
  147.      */
  148.     private function checkCustomerShopToken(Request $request): void
  149.     {
  150.         /** @var ChannelFilter $filter */
  151.         $filters = $this->em->getFilters();
  152.         $filter = $filters->getFilter('channelable');
  154.         $channel = $this->channelService->getCustomerChannel($this->getUser());
  155.         if ($channel instanceof Channel) {
  156.             $request->headers->set('authorization', 'bearer ' . $channel->getToken());
  158.             /**
  159.              * Parameter is setting for making queries unique,
  160.              * without this for client side with many shops queries will be load from previous shop
  161.              */
  162.             $filter->setParameter('shop_id', $channel->getShop()->getId());
  163.             $filter->setShop($channel->getShop());
  164.             $filter->disableForEntity(Shop::class);
  165.         } elseif ($request->getPathInfo() === '/shop/') {
  166.             $filter->setParameter('shop_id', 'unknown_shop');
  167.         } else {
  168.             /**
  169.              * For 'prod' environment with cache pools:
  170.              * Without this dashboard statistic won't work after switching to shop side and back
  171.              */
  172.             $filter->setParameter('shop_id', 'admin');
  173.         }
  174.     }
  175. }