Added support for client->request() for generic calls that are yet not supported (put mapping for instance)

Author: Raymond Julin

ElasticSearchClient.php

@@ -64,6 +64,21 @@ public function get($id, $verbose=false) {
             ? $response
             : $response['_source'];
     }
+    
+    /**
+     * Perform a request
+     *
+     * @return array
+     * @param mixed $id Optional
+     */
+    public function request($path, $method, $payload, $verbose=false) {
+        $path = array_merge((array) $this->type, (array) $path);
+
+        $response = $this->transport->request($path, $method, $payload);
+        return ($verbose)
+            ? $response
+            : $response['_source'];
+    }
 
     /**
      * Index a new document or update it if existing

lib/transport/ElasticSearchTransport.php

@@ -4,7 +4,7 @@ abstract class ElasticSearchTransport {
     protected $index, $type;
 
     abstract public function index($document, $id=false);
-    abstract public function request($path);
+    abstract public function request($path, $method="GET", $payload=false);
     abstract public function delete($id=false);
     abstract public function search($query);
 

lib/transport/ElasticSearchTransportHTTP.php

@@ -155,10 +155,10 @@ public function deleteByQuery($query) {
      * @return array
      * @param mixed $id Optional
      */
-    public function request($path, $method="GET") {
+    public function request($path, $method="GET", $payload=false) {
         $url = $this->buildUrl($path);
         try {
-            $result = $this->call($url, $method);
+            $result = $this->call($url, $method, $payload);
         }
         catch (Exception $e) {
             throw $e;

lib/transport/ElasticSearchTransportMemcached.php

@@ -95,7 +95,7 @@ public function deleteByQuery($query) {
      * @return array
      * @param mixed $id Optional
      */
-    public function request($path, $method="GET") {
+    public function request($path, $method="GET", $payload=false) {
         $url = $this->buildUrl($path);
         switch ($method) {
             case 'GET':