src/EventSubscriber/JSONRequestTransformer.php line 16

Open in your IDE?
  1. <?php declare(strict_types=1);
  4. namespace PPApi\EventSubscriber;
  7. use PPApi\Model\V1\APIError;
  8. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  9. use Symfony\Component\HttpFoundation\JsonResponse;
  10. use Symfony\Component\HttpFoundation\Request;
  11. use Symfony\Component\HttpKernel\Event\RequestEvent;
  12. use Symfony\Component\HttpKernel\KernelEvents;
  14. class JSONRequestTransformer implements EventSubscriberInterface
  15. {
  16.     public function onKernelRequest(RequestEvent $event)
  17.     {
  18.         if (!$event->isMainRequest()) {
  19.             return;
  20.         }
  22.         $request = $event->getRequest();
  23.         if (
  24.             // allow GET request with header `Content-Type`
  25.             $request->isMethod('GET') ||
  26.             $request->isMethod('DELETE') ||
  27.             (
  28.                 // for cases like: application/json; charset=UTF-8 etc
  29.                 !str_contains($request->headers->get('Content-Type'), 'application/json') &&
  30.                 // addon requesting '/authenticate' endpoint with missing content-type header
  31.                 !preg_match('~^/authenticate~', $event->getRequest()->getPathInfo())
  32.             )
  33.         ) {
  34.             return;
  35.         }
  38.         if (!$this->transformJsonBody($request)) {
  39.             $err = new APIError(JsonResponse::HTTP_INTERNAL_SERVER_ERROR, 'Invalid JSON format.');
  40.             $response = new JsonResponse($err, JsonResponse::HTTP_BAD_REQUEST);
  41.             $event->setResponse($response);
  42.         }
  43.     }
  45.     private function transformJsonBody(Request $request) {
  46.         $data = json_decode($request->getContent(), true);
  47.         if (json_last_error() !== JSON_ERROR_NONE) {
  48.             return false;
  49.         }
  51.         if ($data === null) {
  52.             return true;
  53.         }
  55.         $request->request->replace($data);
  56.         return true;
  57.     }
  59.     public static function getSubscribedEvents(): array
  60.     {
  61.         return [
  62.             KernelEvents::REQUEST => ['onKernelRequest', 100],
  63.         ];
  64.     }
  65. }