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

src/main/scala/algoliasearch/extension/package.scala

@@ -366,50 +366,58 @@ package object extension {
     )(implicit ec: ExecutionContext): Future[ReplaceAllObjectsResponse] = {
       val tmpIndexName = s"${indexName}_tmp_${scala.util.Random.nextInt(100)}"
 
-      for {
-        copy <- client.operationIndex(
-          indexName = indexName,
-          operationIndexParams = OperationIndexParams(
-            operation = OperationType.Copy,
-            destination = tmpIndexName,
-            scope = Some(Seq(ScopeType.Settings, ScopeType.Rules, ScopeType.Synonyms))
-          ),
-          requestOptions = requestOptions
-        )
+      try {
+        for {
+          copy <- client.operationIndex(
+            indexName = indexName,
+            operationIndexParams = OperationIndexParams(
+              operation = OperationType.Copy,
+              destination = tmpIndexName,
+              scope = Some(Seq(ScopeType.Settings, ScopeType.Rules, ScopeType.Synonyms))
+            ),
+            requestOptions = requestOptions
+          )
 
-        batchResponses <- chunkedBatch(
-          indexName = tmpIndexName,
-          objects = objects,
-          action = Action.AddObject,
-          waitForTasks = true,
-          batchSize = batchSize,
-          requestOptions = requestOptions
-        )
+          batchResponses <- chunkedBatch(
+            indexName = tmpIndexName,
+            objects = objects,
+            action = Action.AddObject,
+            waitForTasks = true,
+            batchSize = batchSize,
+            requestOptions = requestOptions
+          )
 
-        _ <- client.waitTask(indexName = tmpIndexName, taskID = copy.taskID, requestOptions = requestOptions)
+          _ <- client.waitTask(indexName = tmpIndexName, taskID = copy.taskID, requestOptions = requestOptions)
 
-        copy <- client.operationIndex(
-          indexName = indexName,
-          operationIndexParams = OperationIndexParams(
-            operation = OperationType.Copy,
-            destination = tmpIndexName,
-            scope = Some(Seq(ScopeType.Settings, ScopeType.Rules, ScopeType.Synonyms))
-          ),
-          requestOptions = requestOptions
-        )
-        _ <- client.waitTask(indexName = tmpIndexName, taskID = copy.taskID, requestOptions = requestOptions)
+          copy <- client.operationIndex(
+            indexName = indexName,
+            operationIndexParams = OperationIndexParams(
+              operation = OperationType.Copy,
+              destination = tmpIndexName,
+              scope = Some(Seq(ScopeType.Settings, ScopeType.Rules, ScopeType.Synonyms))
+            ),
+            requestOptions = requestOptions
+          )
+          _ <- client.waitTask(indexName = tmpIndexName, taskID = copy.taskID, requestOptions = requestOptions)
 
-        move <- client.operationIndex(
-          indexName = tmpIndexName,
-          operationIndexParams = OperationIndexParams(operation = OperationType.Move, destination = indexName),
-          requestOptions = requestOptions
+          move <- client.operationIndex(
+            indexName = tmpIndexName,
+            operationIndexParams = OperationIndexParams(operation = OperationType.Move, destination = indexName),
+            requestOptions = requestOptions
+          )
+          _ <- client.waitTask(indexName = tmpIndexName, taskID = move.taskID, requestOptions = requestOptions)
+        } yield ReplaceAllObjectsResponse(
+          copyOperationResponse = copy,
+          batchResponses = batchResponses,
+          moveOperationResponse = move
         )
-        _ <- client.waitTask(indexName = tmpIndexName, taskID = move.taskID, requestOptions = requestOptions)
-      } yield ReplaceAllObjectsResponse(
-        copyOperationResponse = copy,
-        batchResponses = batchResponses,
-        moveOperationResponse = move
-      )
+      } catch {
+        case e: Throwable => {
+          client.deleteIndex(tmpIndexName)
+
+          throw e
+        }
+      }
     }
 
     /** Check if an index exists.