ChunkById sanitation and fixed bridge bugs

Author: pdphilip

README.md

@@ -1281,6 +1281,44 @@ Schema::dsl('open',['index' => 'my_index'])
 Behind the scenes it uses the official elasticsearch PHP client, it will call `$client->indices()->{$method}($params);`
 
 
+Chunking
+--------
+
+If you need to run a query that will return a large number of results, you can use the `chunk()` method to retrieve the
+results in chunks. You can chunk as you normally do in Laravel:
+
+```php
+Product::chunk(1000, function ($products) use (&$prodIds) {
+    foreach ($products as $product) {
+        //Increase price by 10%
+        $currentPrice = $product->price;
+        $product->price = $currentPrice * 1.1;
+        $product->save();
+    }
+});
+```
+
+**Note**: Elasticsearch's default settings will fail when you try to chunk with the following
+error: `Fielddata access on the _id field is disallowed`
+
+To counter this you have two options:
+
+1. Update Elasticsearch's settings to allow fielddata access on the _id field: Set the value
+   of `indices.id_field_data.enable` to `true` in elasticsearch.yml
+2. Use the `chunkById()` method instead of `chunk()` - This will chunk on a field other than `_id`, but you would need a
+   field that's unique for each record.
+
+```php
+Product::chunkById(1000, function ($products) use (&$prodIds) {
+    foreach ($products as $product) {
+        //Increase price by 10%
+        $currentPrice = $product->price;
+        $product->price = $currentPrice * 1.1;
+        $product->save();
+    }
+}, 'product_sku.keyword');
+```
+
 Queues
 ----------
 _[Coming]_

src/DSL/Bridge.php

@@ -301,7 +301,8 @@ public function processDeleteAll($wheres, $options = []): Results
                 'id'    => $wheres['_id'],
             ];
             try {
-                $response = $this->client->delete($params);
+                $responseObject = $this->client->delete($params);
+                $response = $responseObject->asArray();
                 $response['deleteCount'] = $response['result'] === 'deleted' ? 1 : 0;
 
                 return $this->_return($response['deleteCount'], $response, $params, $this->_queryTag(__FUNCTION__));
@@ -311,13 +312,14 @@ public function processDeleteAll($wheres, $options = []): Results
         }
         try {
             $params = $this->buildParams($this->index, $wheres, $options);
-            $response = $this->client->deleteByQuery($params);
+            $responseObject = $this->client->deleteByQuery($params);
+            $response = $responseObject->asArray();
             $response['deleteCount'] = $response['deleted'] ?? 0;
 
             return $this->_return($response['deleteCount'], $response, $params, $this->_queryTag(__FUNCTION__));
         } catch (Exception $e) {
-            $result = $this->_returnError($e->getMessage(), $e->getCode(), [], $this->_queryTag(__FUNCTION__));
-            throw new Exception($result->errorMessage);
+            $error = $this->_returnError($e->getMessage(), $e->getCode(), [], $this->_queryTag(__FUNCTION__));
+            throw new Exception($error->errorMessage);
         }
 
     }
@@ -366,11 +368,11 @@ public function processIndexMappings($index): mixed
     {
         $params = ['index' => $index];
         try {
-            $response = $this->client->indices()->getMapping($params);
+            $responseObject = $this->client->indices()->getMapping($params);
+            $response = $responseObject->asArray();
             $result = $this->_return($response, $response, $params, $this->_queryTag(__FUNCTION__));
 
-            
-            return $result->data->asArray();
+            return $result->data;
         } catch (Exception $e) {
             $result = $this->_returnError($e->getMessage(), $e->getCode(), $params, $this->_queryTag(__FUNCTION__));
             throw new Exception($result->errorMessage);