feat(clients): cleanup after replaceAllObjects failure [skip-bc] (generated)

algolia/api-clients-automation#3824

Co-authored-by: algolia-bot <[email protected]>
Co-authored-by: Pierre Millot <[email protected]>
Co-authored-by: Thomas Raffray <[email protected]>

Author: 3 people

.github/ISSUE_TEMPLATE/Bug_report.yml

@@ -27,7 +27,7 @@ body:
     id: client
     attributes:
       label: Client
-      description: Which API are you targetting?
+      description: Which API are you targeting?
       options:
         - All
         - AB testing

lib/Api/SearchClient.php

@@ -2896,48 +2896,54 @@ public function replaceAllObjects($indexName, $objects, $batchSize = 1000, $requ
     {
         $tmpIndexName = $indexName.'_tmp_'.rand(10000000, 99999999);
 
-        $copyOperationResponse = $this->operationIndex(
-            $indexName,
-            [
-                'operation' => 'copy',
-                'destination' => $tmpIndexName,
-                'scope' => ['settings', 'rules', 'synonyms'],
-            ],
-            $requestOptions
-        );
+        try {
+            $copyOperationResponse = $this->operationIndex(
+                $indexName,
+                [
+                    'operation' => 'copy',
+                    'destination' => $tmpIndexName,
+                    'scope' => ['settings', 'rules', 'synonyms'],
+                ],
+                $requestOptions
+            );
 
-        $batchResponses = $this->chunkedBatch($tmpIndexName, $objects, 'addObject', true, $batchSize, $requestOptions);
+            $batchResponses = $this->chunkedBatch($tmpIndexName, $objects, 'addObject', true, $batchSize, $requestOptions);
 
-        $this->waitForTask($tmpIndexName, $copyOperationResponse['taskID']);
+            $this->waitForTask($tmpIndexName, $copyOperationResponse['taskID']);
 
-        $copyOperationResponse = $this->operationIndex(
-            $indexName,
-            [
-                'operation' => 'copy',
-                'destination' => $tmpIndexName,
-                'scope' => ['settings', 'rules', 'synonyms'],
-            ],
-            $requestOptions
-        );
+            $copyOperationResponse = $this->operationIndex(
+                $indexName,
+                [
+                    'operation' => 'copy',
+                    'destination' => $tmpIndexName,
+                    'scope' => ['settings', 'rules', 'synonyms'],
+                ],
+                $requestOptions
+            );
 
-        $this->waitForTask($tmpIndexName, $copyOperationResponse['taskID']);
+            $this->waitForTask($tmpIndexName, $copyOperationResponse['taskID']);
 
-        $moveOperationResponse = $this->operationIndex(
-            $tmpIndexName,
-            [
-                'operation' => 'move',
-                'destination' => $indexName,
-            ],
-            $requestOptions
-        );
+            $moveOperationResponse = $this->operationIndex(
+                $tmpIndexName,
+                [
+                    'operation' => 'move',
+                    'destination' => $indexName,
+                ],
+                $requestOptions
+            );
 
-        $this->waitForTask($tmpIndexName, $moveOperationResponse['taskID']);
+            $this->waitForTask($tmpIndexName, $moveOperationResponse['taskID']);
 
-        return [
-            'copyOperationResponse' => $copyOperationResponse,
-            'batchResponses' => $batchResponses,
-            'moveOperationResponse' => $moveOperationResponse,
-        ];
+            return [
+                'copyOperationResponse' => $copyOperationResponse,
+                'batchResponses' => $batchResponses,
+                'moveOperationResponse' => $moveOperationResponse,
+            ];
+        } catch (\Throwable $e) {
+            $this->deleteIndex($tmpIndexName);
+
+            throw $e;
+        }
     }
 
     /**
@@ -3092,7 +3098,7 @@ public function indexExists($indexName)
             $this->getSettings($indexName);
         } catch (NotFoundException $e) {
             return false;
-        } catch (Exception $e) {
+        } catch (\Throwable $e) {
             throw $e;
         }