Composer update and bulk ids on errors

Author: pdphilip

composer.json

@@ -82,11 +82,14 @@
       "@build",
       "@php vendor/bin/testbench serve"
     ],
-    "lint": [
-      "@php vendor/bin/phpstan analyse"
-    ],
+    "lint": "pint -v",
+    "test:lint": "pint --test -v",
+    "test:types": "phpstan analyse --ansi",
+    "test:unit": "pest --colors=always",
     "test": [
-      "@php vendor/bin/pest"
+      "@test:lint",
+      "@test:types",
+      "@test:unit"
     ]
   }
 }

src/DSL/Bridge.php

@@ -400,14 +400,17 @@ public function processInsertBulk(array $records, bool $returnData = false, stri
             $finalResponse['hasErrors'] = $response['errors'];
             $finalResponse['took'] = $response['took'];
             foreach ($response['items'] as $count => $hit) {
+
                 $finalResponse['total']++;
                 $payload = $params['body'][($count * 2) + 1];
+                $id = $hit['index']['_id'];
+                $record = ['_id' => $id] + $payload;
 
                 if (! empty($hit['index']['error'])) {
                     $finalResponse['failed']++;
                     $finalResponse['error_bag'][] = [
                         'error' => $hit['index']['error'],
-                        'payload' => $payload,
+                        'payload' => $record,
                     ];
                 } else {
                     $finalResponse['success']++;
@@ -419,8 +422,7 @@ public function processInsertBulk(array $records, bool $returnData = false, stri
                     }
 
                     if ($returnData) {
-                        $id = $hit['index']['_id'];
-                        $record = ['_id' => $id] + $payload;
+
                         $finalResponse['data'][] = $record;
                     }
                 }