vendor/coreshop/resource-bundle/EventListener/BodyListener.php line 28

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. /*
  6.  * CoreShop
  7.  *
  8.  * This source file is available under two different licenses:
  9.  *  - GNU General Public License version 3 (GPLv3)
  10.  *  - CoreShop Commercial License (CCL)
  11.  * Full copyright and license information is available in
  12.  * LICENSE.md which is distributed with this source code.
  13.  *
  14.  * @copyright  Copyright (c) CoreShop GmbH (https://www.coreshop.org)
  15.  * @license    https://www.coreshop.org/license     GPLv3 and CCL
  16.  *
  17.  */
  19. namespace CoreShop\Bundle\ResourceBundle\EventListener;
  21. use Symfony\Component\HttpFoundation\InputBag;
  22. use Symfony\Component\HttpFoundation\Request;
  23. use Symfony\Component\HttpKernel\Event\RequestEvent;
  24. use Symfony\Component\HttpKernel\Exception\BadRequestHttpException;
  26. class BodyListener
  27. {
  28.     public function onKernelRequest(RequestEvent $event): void
  29.     {
  30.         $request = $event->getRequest();
  31.         $contentType = $request->headers->get('Content-Type');
  33.         $format = null === $contentType ? $request->getRequestFormat() : $request->getFormat($contentType);
  35.         $content = $request->getContent();
  37.         if ($this->isDecodeable($request)) {
  38.             if ($format === 'json') {
  39.                 if (!empty($content)) {
  40.                     $data = @json_decode($content, true);
  42.                     if (is_array($data)) {
  43.                         $request->request = new InputBag($data);
  44.                     } else {
  45.                         throw new BadRequestHttpException('Invalid ' . $format . ' message received');
  46.                     }
  47.                 }
  48.             }
  49.         }
  50.     }
  52.     protected function isDecodeable(Request $request): bool
  53.     {
  54.         if (!in_array($request->getMethod(), ['POST', 'PUT', 'PATCH', 'DELETE'])) {
  55.             return false;
  56.         }
  58.         return !$this->isFormRequest($request);
  59.     }
  61.     private function isFormRequest(Request $request): bool
  62.     {
  63.         if (null === $request->headers->get('Content-Type')) {
  64.             return false;
  65.         }
  67.         $contentTypeParts = explode(';', $request->headers->get('Content-Type'));
  69.         if (isset($contentTypeParts[0])) {
  70.             return in_array($contentTypeParts[0], ['multipart/form-data', 'application/x-www-form-urlencoded']);
  71.         }
  73.         return false;
  74.     }
  75. }