added batch process

Author: saimaz

Controller/AbstractCollectionController.php

@@ -11,13 +11,34 @@
 
 namespace ONGR\ApiBundle\Controller;
 
-use ONGR\ApiBundle\Service\Crud;
-use Symfony\Bundle\FrameworkBundle\Controller\Controller;
+use Symfony\Component\HttpFoundation\Request;
 use Symfony\Component\HttpFoundation\Response;
 
 /**
  * Batch controller
  */
-class BatchController extends Controller
+class BatchController extends AbstractRestController
 {
+    /**
+     * Main action to process batch call.
+     *
+     * @param Request $request
+     * @return Response
+     */
+    public function processAction(Request $request)
+    {
+        $crud = $this->getCrudService();
+        $repository = $this->getRequestRepository($request);
+        $documents = $this->get('ongr_api.request_serializer')->deserializeRequest($request);
+
+        try {
+            foreach ($documents as $document) {
+                $crud->create($repository, $document);
+            }
+            $crud->commit($repository);
+            return $this->renderRest($request, '', Response::HTTP_NO_CONTENT);
+        } catch (\Exception $e) {
+            return $this->renderError($request, $e->getMessage(), Response::HTTP_BAD_REQUEST);
+        }
+    }
 }

Controller/BatchController.php

@@ -138,6 +138,13 @@ public function getEndpointNode()
                     )
                     ->end()
 
+                    ->booleanNode('batch')
+                    ->defaultTrue()
+                    ->info(
+                        'If set to true user can sent documents in batch\'s.'
+                    )
+                    ->end()
+
                 ->end()
             ->end();
 

DependencyInjection/Configuration.php

@@ -78,7 +78,15 @@ private function processRestRoute(
             '_version' => $version,
             'repository' => $endpoint['repository'],
         ];
-        $requirements = [];
+
+        $pattern = $version.'/'.sprintf('%s/{documentId}', strtolower($document));
+
+        if ($endpoint['batch']) {
+            $defaults['_controller'] = 'ONGRApiBundle:Batch:Process';
+            $batchPattern = $version.'/'.sprintf('%s', strtolower($document)) . '/_batch';
+            $name = strtolower(sprintf('ongr_api_%s_%s_%s', $version, $document, Request::METHOD_POST));
+            $collection->add($name.'_batch', new Route($batchPattern, $defaults, [], [], "", [], [Request::METHOD_POST]));
+        }
 
         foreach ($endpoint['methods'] as $method) {
 
@@ -90,7 +98,6 @@ private function processRestRoute(
                 $collection->add($name.'_wi', new Route($postPattern, $defaults, [], [], "", [], [$method]));
             }
 
-            $pattern = $version.'/'.sprintf('%s/{documentId}', strtolower($document));
             $collection->add($name, new Route($pattern, $defaults, [], [], "", [], [$method]));
 
             if ($endpoint['variants']) {

Routing/ElasticsearchLoader.php

@@ -13,7 +13,6 @@
 
 use JMS\Serializer\SerializerInterface;
 use Symfony\Component\HttpFoundation\Request;
-use Symfony\Component\HttpFoundation\RequestStack;
 
 /**
  * This class provides all data for deserialization and serialization of API requests.
@@ -66,21 +65,22 @@ public function serializeRequest(Request $request, $data)
      */
     public function deserializeRequest(Request $request)
     {
-        $type = 'array';
         $format = $this->checkAcceptHeader($request);
 
         try {
-            return $this->serializer->deserialize($request->getContent(), $type, $format);
+            return $this->serializer->deserialize($request->getContent(), 'array', $format);
         } catch (\Exception $e) {
             throw new \RuntimeException(
-                'Could not deserialize content to object of \'' . $type . '\' type and \'' . $format . '\' format.'
+                'Could not deserialize content from the request.'
             );
         }
     }
 
     /**
      * Returns acceptance type based on given request.
      *
+     * @param Request $request
+     *
      * @return string
      */
     public function checkAcceptHeader(Request $request)

Service/RequestSerializer.php

@@ -0,0 +1,59 @@
+<?php
+
+/*
+ * This file is part of the ONGR package.
+ *
+ * (c) NFQ Technologies UAB <[email protected]>
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ */
+
+namespace ONGR\ApiBundle\Tests\Functional\Controller;
+
+use ONGR\ElasticsearchBundle\Result\Result;
+use ONGR\ElasticsearchDSL\Query\MatchAllQuery;
+use Symfony\Component\HttpFoundation\Request;
+
+class BatchControllerTest extends AbstractControllerTestCase
+{
+    private $data = [
+        [
+            'manufacturer' => 'diesel',
+        ],
+        [
+            'manufacturer' => 'levis',
+        ],
+        [
+            'manufacturer' => 'armani',
+        ],
+    ];
+
+    /**
+     * Test batch API by sending data batch.
+     */
+    public function testBatchRequest()
+    {
+        $this->getManager();
+        $data = json_encode($this->data);
+
+        $response = $this->sendApiRequest(
+            Request::METHOD_POST,
+            '/api/v3/jeans/_batch',
+            $data
+        );
+
+        $repo = $this->getManager()->getRepository('TestBundle:Jeans');
+        $search = $repo->createSearch()->addQuery(new MatchAllQuery());
+        $results = $repo->execute($search, Result::RESULTS_ARRAY);
+
+//        $resultsFromApi = [];
+//        foreach ($results as $result) {
+//            $resultsFromApi[] = $result['manufacturer'];
+//        }
+//
+//        $originalData = ['diesel']
+
+        $this->assertEquals(asort($this->data), asort($results));
+    }
+}