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

algoliasearch/src/main/java/com/algolia/api/SearchClient.java

@@ -6572,24 +6572,6 @@ public <T> List<BatchResponse> chunkedBatch(
     return chunkedBatch(indexName, objects, action, waitForTasks, 1000, requestOptions);
   }
 
-  /**
-   * Push a new set of objects and remove all previous ones. Settings, synonyms and query rules are
-   * untouched. Replace all records in an index without any downtime. See
-   * https://api-clients-automation.netlify.app/docs/add-new-api-client#5-helpers for implementation
-   * details.
-   *
-   * @param indexName The `indexName` to replace `objects` in.
-   * @param objects The array of `objects` to store in the given Algolia `indexName`.
-   * @param batchSize The size of the chunk of `objects`. The number of `batch` calls will be equal
-   *     to `length(objects) / batchSize`.
-   * @throws AlgoliaRetryException When the retry has failed on all hosts
-   * @throws AlgoliaApiException When the API sends an http error code
-   * @throws AlgoliaRuntimeException When an error occurred during the serialization
-   */
-  public <T> ReplaceAllObjectsResponse replaceAllObjects(String indexName, Iterable<T> objects, int batchSize) {
-    return replaceAllObjects(indexName, objects, batchSize, null);
-  }
-
   /**
    * Helper: Saves the given array of objects in the given index. The `chunkedBatch` helper is used
    * under the hood, which creates a `batch` requests with at most 1000 objects in it.
@@ -6822,6 +6804,40 @@ public <T> List<BatchResponse> partialUpdateObjects(
     );
   }
 
+  /**
+   * Push a new set of objects and remove all previous ones. Settings, synonyms and query rules are
+   * untouched. Replace all records in an index without any downtime. See
+   * https://api-clients-automation.netlify.app/docs/add-new-api-client#5-helpers for implementation
+   * details.
+   *
+   * @param indexName The `indexName` to replace `objects` in.
+   * @param objects The array of `objects` to store in the given Algolia `indexName`.
+   * @throws AlgoliaRetryException When the retry has failed on all hosts
+   * @throws AlgoliaApiException When the API sends an http error code
+   * @throws AlgoliaRuntimeException When an error occurred during the serialization
+   */
+  public <T> ReplaceAllObjectsResponse replaceAllObjects(String indexName, Iterable<T> objects) {
+    return replaceAllObjects(indexName, objects, -1);
+  }
+
+  /**
+   * Push a new set of objects and remove all previous ones. Settings, synonyms and query rules are
+   * untouched. Replace all records in an index without any downtime. See
+   * https://api-clients-automation.netlify.app/docs/add-new-api-client#5-helpers for implementation
+   * details.
+   *
+   * @param indexName The `indexName` to replace `objects` in.
+   * @param objects The array of `objects` to store in the given Algolia `indexName`.
+   * @param batchSize The size of the chunk of `objects`. The number of `batch` calls will be equal
+   *     to `length(objects) / batchSize`.
+   * @throws AlgoliaRetryException When the retry has failed on all hosts
+   * @throws AlgoliaApiException When the API sends an http error code
+   * @throws AlgoliaRuntimeException When an error occurred during the serialization
+   */
+  public <T> ReplaceAllObjectsResponse replaceAllObjects(String indexName, Iterable<T> objects, int batchSize) {
+    return replaceAllObjects(indexName, objects, batchSize, null);
+  }
+
   /**
    * Push a new set of objects and remove all previous ones. Settings, synonyms and query rules are
    * untouched. Replace all records in an index without any downtime. See
@@ -6847,47 +6863,57 @@ public <T> ReplaceAllObjectsResponse replaceAllObjects(
     Random rnd = new Random();
     String tmpIndexName = indexName + "_tmp_" + rnd.nextInt(100);
 
-    // Copy settings, synonyms and rules
-    UpdatedAtResponse copyOperationResponse = operationIndex(
-      indexName,
-      new OperationIndexParams()
-        .setOperation(OperationType.COPY)
-        .setDestination(tmpIndexName)
-        .addScope(ScopeType.SETTINGS)
-        .addScope(ScopeType.RULES)
-        .addScope(ScopeType.SYNONYMS),
-      requestOptions
-    );
+    if (batchSize == -1) {
+      batchSize = 1000;
+    }
 
-    // Save new objects
-    List<BatchResponse> batchResponses = chunkedBatch(tmpIndexName, objects, Action.ADD_OBJECT, true, batchSize, requestOptions);
+    try {
+      // Copy settings, synonyms and rules
+      UpdatedAtResponse copyOperationResponse = operationIndex(
+        indexName,
+        new OperationIndexParams()
+          .setOperation(OperationType.COPY)
+          .setDestination(tmpIndexName)
+          .addScope(ScopeType.SETTINGS)
+          .addScope(ScopeType.RULES)
+          .addScope(ScopeType.SYNONYMS),
+        requestOptions
+      );
 
-    waitForTask(tmpIndexName, copyOperationResponse.getTaskID(), requestOptions);
+      // Save new objects
+      List<BatchResponse> batchResponses = chunkedBatch(tmpIndexName, objects, Action.ADD_OBJECT, true, batchSize, requestOptions);
 
-    copyOperationResponse = operationIndex(
-      indexName,
-      new OperationIndexParams()
-        .setOperation(OperationType.COPY)
-        .setDestination(tmpIndexName)
-        .addScope(ScopeType.SETTINGS)
-        .addScope(ScopeType.RULES)
-        .addScope(ScopeType.SYNONYMS),
-      requestOptions
-    );
-    waitForTask(tmpIndexName, copyOperationResponse.getTaskID(), requestOptions);
+      waitForTask(tmpIndexName, copyOperationResponse.getTaskID(), requestOptions);
 
-    // Move temporary index to source index
-    UpdatedAtResponse moveOperationResponse = operationIndex(
-      tmpIndexName,
-      new OperationIndexParams().setOperation(OperationType.MOVE).setDestination(indexName),
-      requestOptions
-    );
-    waitForTask(tmpIndexName, moveOperationResponse.getTaskID(), requestOptions);
+      copyOperationResponse = operationIndex(
+        indexName,
+        new OperationIndexParams()
+          .setOperation(OperationType.COPY)
+          .setDestination(tmpIndexName)
+          .addScope(ScopeType.SETTINGS)
+          .addScope(ScopeType.RULES)
+          .addScope(ScopeType.SYNONYMS),
+        requestOptions
+      );
+      waitForTask(tmpIndexName, copyOperationResponse.getTaskID(), requestOptions);
+
+      // Move temporary index to source index
+      UpdatedAtResponse moveOperationResponse = operationIndex(
+        tmpIndexName,
+        new OperationIndexParams().setOperation(OperationType.MOVE).setDestination(indexName),
+        requestOptions
+      );
+      waitForTask(tmpIndexName, moveOperationResponse.getTaskID(), requestOptions);
+
+      return new ReplaceAllObjectsResponse()
+        .setCopyOperationResponse(copyOperationResponse)
+        .setBatchResponses(batchResponses)
+        .setMoveOperationResponse(moveOperationResponse);
+    } catch (Exception e) {
+      deleteIndex(tmpIndexName);
 
-    return new ReplaceAllObjectsResponse()
-      .setCopyOperationResponse(copyOperationResponse)
-      .setBatchResponses(batchResponses)
-      .setMoveOperationResponse(moveOperationResponse);
+      throw e;
+    }
   }
 
   /**