Add support for payload mapping

Author: luishdez

EventListener/RestListener.php

@@ -74,7 +74,7 @@ public function addNoCacheHeaders(Response $response)
      * @param Request $request
      * @param Array   $trigger
      *
-     * @return Mixed   false or content accepted
+     * @return Mixed false or content accepted
      */
     public function checkAcceptedContent(Request $request, $acceptedContent)
     {

EventListener/RestKernelSuscriber.php EventListener/RestSubscriber.phpEventListener/RestKernelSuscriber.php renamed to EventListener/RestSubscriber.php

@@ -15,18 +15,20 @@
 use Symfony\Component\HttpFoundation\Request;
 use Symfony\Component\HttpFoundation\Session\Flash\AutoExpireFlashBag;
 use Symfony\Component\HttpKernel\HttpKernelInterface;
-use Symfony\Component\HttpKernel\Event\FilterResponseEvent;
 use Symfony\Component\HttpKernel\KernelEvents;
+use Symfony\Component\HttpKernel\Event\FilterControllerEvent;
+use Symfony\Component\HttpKernel\Event\FilterResponseEvent;
+use Symfony\Component\HttpKernel\Event\GetResponseEvent;
 use Symfony\Component\EventDispatcher\EventSubscriberInterface;
 
-class RestKernelSuscriber implements EventSubscriberInterface
+class RestSubscriber implements EventSubscriberInterface
 {
     /**
      *
      * @param Request $request
      * @param Array   $trigger
      *
-     * @return Mixed   false or content accepted
+     * @return Mixed false or content accepted
      */
     public function checkAcceptedContent(Request $request, $acceptedContent)
     {
@@ -46,6 +48,24 @@ public function checkAcceptedContent(Request $request, $acceptedContent)
         return false;
     }
 
+    public function postAnnotations(FilterControllerEvent $event)
+    {
+        $request = $event->getRequest();
+        $restConfig = $request->attributes->get('_rest');
+
+        if ($restConfig == false) {
+            return;
+        }
+
+        if ($restConfig->getPayloadMapping()) {
+            $content = $request->getContent();
+            if (empty($content) == false) {
+                $payload = json_decode($content, true);
+                $request->request->add(array($restConfig->getPayloadMapping() => $payload));
+            }
+        }
+    }
+
     public function onKernelResponse(FilterResponseEvent $event)
     {
         if (HttpKernelInterface::MASTER_REQUEST !== $event->getRequestType()) {
@@ -127,7 +147,8 @@ public function onKernelResponse(FilterResponseEvent $event)
     public static function getSubscribedEvents()
     {
         return array(
-            KernelEvents::RESPONSE => array('onKernelResponse', 0),
+            KernelEvents::CONTROLLER => array('postAnnotations', 0),
+            KernelEvents::RESPONSE => array('onKernelResponse', 0)
         );
     }
 }

Resources/config/services.yml

@@ -19,7 +19,7 @@ services:
         tags:
             - { name: kernel.event_listener, event: kernel.view, method: onKernelView }
 
-    wobblecode.restbundle.kernel.suscriber:
-        class: WobbleCode\RestBundle\EventListener\RestKernelSuscriber
+    wobblecode.restbundle.rest_suscriber:
+        class: WobbleCode\RestBundle\EventListener\RestSubscriber
         tags:
             - { name: kernel.event_subscriber }