Merge pull request #52 from vbcodeplicity/feature/add-support-for-es8-insert

Add support for insert method for ES8

Author: ppavlovic

src/Engine/Elasticsearch/ElasticsearchAdapter.php

@@ -79,7 +79,7 @@ public function insert(CollectionNameInterface $collectionName, MappingInterface
             ->setMethod(self::METHOD_POST)
             ->setId($data['id'])
             ->setBody($data)
-            ->execute();
+            ->insert();
     }
 
     /**

src/Engine/Elasticsearch/ElasticsearchClient.php

@@ -15,6 +15,8 @@ class ElasticsearchClient
     const SEARCH            = '_search';
     const TIMEOUT           = 5;
     const METHOD_GET        = 'GET';
+    const INSERT            = '_create';
+    const INSERT_METHOD     = 'insert';
     const UPDATE            = '_update';
     const UPDATE_METHOD     = 'update';
     const REFRESH           = '_refresh';
@@ -117,6 +119,19 @@ public function count()
 
         return $this;
     }
+    public function insert()
+    {
+        $this->url = ElasticsearchUrlPathBuilder::generateUrl(
+            $this->url,
+            $this->index,
+            $this->indexType,
+            $this->id,
+            self::INSERT_METHOD,
+            $this->version
+        );
+
+        $this->executeCurlRequest();
+    }
 
     public function update()
     {

src/Engine/Elasticsearch/ElasticsearchClientUrlPath.php

@@ -6,6 +6,11 @@
 
 class ElasticsearchClientUrlPath
 {
+    public static function insert(Url $url, $index, $indexType, $id)
+    {
+        return $url->path($index, $indexType, $id);
+    }
+
     public static function update(Url $url, $index, $indexType, $id)
     {
         return $url->path($index, $indexType, $id, ElasticsearchClient::UPDATE);

src/Engine/Elasticsearch/Version8/ElasticsearchClientUrlPath.php

@@ -7,6 +7,11 @@
 
 class ElasticsearchClientUrlPath
 {
+    public static function insert(Url $url, $index, $indexType, $id)
+    {
+        return $url->path($index, ElasticsearchClient::INSERT, $id);
+    }
+
     public static function update(Url $url, $index, $indexType, $id)
     {
         return $url->path($index, ElasticsearchClient::UPDATE, $id);