src/Shared/Infrastructure/Symfony/EventListener/JsonToArrayRequestListener.php line 27

  1. <?php
  4. namespace App\Shared\Infrastructure\Symfony\EventListener;
  6. use App\Shared\Domain\Helper\Inflector;
  7. use App\Shared\Infrastructure\Service\Serializer\SerializerInterface;
  8. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  9. use Symfony\Component\HttpFoundation\ParameterBag;
  10. use Symfony\Component\HttpFoundation\Request;
  11. use Symfony\Component\HttpKernel\Event\RequestEvent;
  12. use Symfony\Component\HttpKernel\KernelEvents;
  14. final class JsonToArrayRequestListener implements EventSubscriberInterface
  15. {
  16.     public static function getSubscribedEvents()
  17.     {
  18.         return array(
  19.             KernelEvents::REQUEST => 'onKernelRequest'
  20.         );
  21.     }
  23.     public function __construct(private SerializerInterface $serializer)
  24.     {
  25.     }
  27.     public function onKernelRequest(RequestEvent $event): void
  28.     {
  29.         $request = $event->getRequest();
  31.         if ($request->getMethod() === Request::METHOD_GET) {
  32.             return;
  33.         }
  35.         $content = $request->getContent(false);
  37.         if (!$this->isJson($content)) {
  38.             return;
  39.         }
  41.         $content = new ParameterBag($this->deserialize($content));
  42.         $request->request = $content;
  43.     }
  45.     public function onKernelRequests(RequestEvent $event): void
  46.     {
  47.         $request = $event->getRequest();
  49.         if ($request->getMethod() !== Request::METHOD_GET) {
  50.             $content = $request->getContent(false);
  52.             if ($this->isJson($content)) {
  53.                 $content = new ParameterBag($this->deserialize($content));
  54.                 $request->request = $content;
  55.             }
  56.         }
  57.     }
  59.     private function isJson($string)
  60.     {
  61.         json_decode($string);
  62.         return (json_last_error() === JSON_ERROR_NONE);
  63.     }
  65.     private function deserialize(string $content)
  66.     {
  67.         $data = $this->serializer->deserialize($content);
  69.         return $this->decamelize($data);
  70.     }
  72.     private function decamelize(array $data)
  73.     {
  74.         $newArray = array();
  76.         foreach ($data as $k => $v) {
  77.             $value = $data[$k];
  79.             if (is_array($data[$k])) {
  80.                 $value = self::decamelize($data[$k]);
  81.             }
  83.             $key = Inflector::fromCamelCaseToSnakeCase($k);
  85.             $newArray[$key] = $value;
  86.         }
  88.         return $newArray;
  89.     }
  90. }