Add bulk method

Author: mmenozzi

src/Client.php

@@ -81,7 +81,7 @@ public function indexDocument(
         if ($options) {
             $uri .= '?' . http_build_query($options);
         }
-        return $this->doRequest($this->createJsonRequest($method, $uri, $body));
+        return $this->doRequest($this->createJsonRequest($method, $uri, json_encode($body)));
     }
 
     public function existsDocument(string $index, string $id, string $type = '_doc'): Promise
@@ -177,7 +177,7 @@ public function search(array $query, string $indexOrIndices = null, array $optio
         if ($options) {
             $uri .= '?' . http_build_query($options);
         }
-        return $this->doRequest($this->createJsonRequest($method, $uri, ['query' => $query]));
+        return $this->doRequest($this->createJsonRequest($method, $uri, json_encode(['query' => $query])));
     }
 
     public function count(string $index, array $options = [], array $query = null): Promise
@@ -189,20 +189,36 @@ public function count(string $index, array $options = [], array $query = null):
         if ($options) {
             $uri .= '?' . http_build_query($options);
         }
-        $body = null;
         if (null !== $query) {
-            $body = ['query' => $query];
+            return $this->doRequest($this->createJsonRequest($method, $uri, json_encode(['query' => $query])));
         }
-        return $this->doRequest($this->createJsonRequest($method, $uri, $body));
+        return $this->doRequest($this->createJsonRequest($method, $uri));
+    }
+
+    public function bulk(array $body, string $index = null, array $options = []): Promise
+    {
+        $method = 'POST';
+        $uri = [$this->baseUri];
+        if ($index) {
+            $uri[] = urlencode($index);
+        }
+        $uri[] = '_bulk';
+        $uri = implode('/', $uri);
+        if ($options) {
+            $uri .= '?' . http_build_query($options);
+        }
+        return $this->doRequest(
+            $this->createJsonRequest($method, $uri, implode(PHP_EOL, array_map('json_encode', $body)) . PHP_EOL)
+        );
     }
 
-    private function createJsonRequest(string $method, string $uri, array $body = null): Request
+    private function createJsonRequest(string $method, string $uri, string $body = null): Request
     {
         $request = (new Request($uri, $method))
             ->withHeader('Content-Type', 'application/json')
             ->withHeader('Accept', 'application/json');
         if ($body) {
-            $request = $request->withBody(json_encode($body));
+            $request = $request->withBody($body);
         }
         return $request;
     }

tests/Integration/ClientTest.php

@@ -272,4 +272,28 @@ public function testCountWithQuery(): void
         $this->assertIsArray($response);
         $this->assertEquals(1, $response['count']);
     }
+
+    public function testBulkIndex(): void
+    {
+        Promise\wait($this->client->createIndex(self::TEST_INDEX));
+        $body = [];
+        $responses = [];
+        for ($i = 1; $i <= 1234; $i++) {
+            $body[] = ['index' => ['_id' => '']];
+            $body[] = ['test' => 'bulk', 'my_field' => 'my_value_' .  $i];
+
+            // Every 100 documents stop and send the bulk request
+            if ($i % 100 === 0) {
+                $responses = Promise\wait($this->client->bulk($body, self::TEST_INDEX));
+                $body = [];
+                unset($responses);
+            }
+        }
+        if (!empty($body)) {
+            $responses = Promise\wait($this->client->bulk($body, self::TEST_INDEX));
+        }
+
+        $this->assertIsArray($responses);
+        $this->assertCount(34, $responses['items']);
+    }
 }