src/Ui/Http/Rest/EventSubscriber/JsonBodyParserSubscriber.php line 24

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace Ui\Http\Rest\EventSubscriber;
  7. use const JSON_THROW_ON_ERROR;
  8. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  9. use Symfony\Component\HttpFoundation\Request;
  10. use Symfony\Component\HttpFoundation\Response;
  11. use Symfony\Component\HttpKernel\Event\RequestEvent;
  12. use Symfony\Component\HttpKernel\KernelEvents;
  13. use Throwable;
  15. class JsonBodyParserSubscriber implements EventSubscriberInterface
  16. {
  17.     public static function getSubscribedEvents() : array
  18.     {
  19.         return [
  20.             KernelEvents::REQUEST => 'onKernelRequest',
  21.         ];
  22.     }
  24.     public function onKernelRequest(RequestEvent $event) : void
  25.     {
  26.         $request = $event->getRequest();
  27.         if (!$this->isJsonRequest($request)) {
  28.             return;
  29.         }
  31.         $content = $request->getContent();
  32.         if (empty($content)) {
  33.             return;
  34.         }
  36.         if (!$this->transformJsonBody($request)) {
  37.             $response = new Response('Unable to parse json request.', Response::HTTP_BAD_REQUEST);
  38.             $event->setResponse($response);
  39.         }
  40.     }
  42.     private function isJsonRequest(Request $request) : bool
  43.     {
  44.         return 'json' === $request->getContentType();
  45.     }
  47.     private function transformJsonBody(Request $request) : bool
  48.     {
  49.         try {
  50.             $data = \json_decode(
  51.                 (string) $request->getContent(),
  52.                 true,
  53.                 512,
  54.                 JSON_THROW_ON_ERROR
  55.             );
  56.         } catch (Throwable $exception) {
  57.             return false;
  58.         }
  60.         if (null === $data) {
  61.             return true;
  62.         }
  64.         $request->request->replace($data);
  66.         return true;
  67.     }
  68. }