fix(specs): ingestion push task payload [skip-bc] (generated)

algolia/api-clients-automation#3607

Co-authored-by: algolia-bot <[email protected]>
Co-authored-by: Clément Vannicatte <[email protected]>
Co-authored-by: Pierre Millot <[email protected]>

Author: 3 people

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

@@ -3074,54 +3074,54 @@ public CompletableFuture<ListTransformationsResponse> listTransformationsAsync()
    * with the observability endpoints.
    *
    * @param taskID Unique identifier of a task. (required)
-   * @param batchWriteParams Request body of a Search API `batch` request that will be pushed in the
+   * @param pushTaskPayload Request body of a Search API `batch` request that will be pushed in the
    *     Connectors pipeline. (required)
    * @param requestOptions The requestOptions to send along with the query, they will be merged with
    *     the transporter requestOptions.
    * @throws AlgoliaRuntimeException If it fails to process the API call
    */
-  public RunResponse pushTask(@Nonnull String taskID, @Nonnull BatchWriteParams batchWriteParams, RequestOptions requestOptions)
+  public RunResponse pushTask(@Nonnull String taskID, @Nonnull PushTaskPayload pushTaskPayload, RequestOptions requestOptions)
     throws AlgoliaRuntimeException {
-    return LaunderThrowable.await(pushTaskAsync(taskID, batchWriteParams, requestOptions));
+    return LaunderThrowable.await(pushTaskAsync(taskID, pushTaskPayload, requestOptions));
   }
 
   /**
    * Push a `batch` request payload through the Pipeline. You can check the status of task pushes
    * with the observability endpoints.
    *
    * @param taskID Unique identifier of a task. (required)
-   * @param batchWriteParams Request body of a Search API `batch` request that will be pushed in the
+   * @param pushTaskPayload Request body of a Search API `batch` request that will be pushed in the
    *     Connectors pipeline. (required)
    * @throws AlgoliaRuntimeException If it fails to process the API call
    */
-  public RunResponse pushTask(@Nonnull String taskID, @Nonnull BatchWriteParams batchWriteParams) throws AlgoliaRuntimeException {
-    return this.pushTask(taskID, batchWriteParams, null);
+  public RunResponse pushTask(@Nonnull String taskID, @Nonnull PushTaskPayload pushTaskPayload) throws AlgoliaRuntimeException {
+    return this.pushTask(taskID, pushTaskPayload, null);
   }
 
   /**
    * (asynchronously) Push a `batch` request payload through the Pipeline. You can check the status
    * of task pushes with the observability endpoints.
    *
    * @param taskID Unique identifier of a task. (required)
-   * @param batchWriteParams Request body of a Search API `batch` request that will be pushed in the
+   * @param pushTaskPayload Request body of a Search API `batch` request that will be pushed in the
    *     Connectors pipeline. (required)
    * @param requestOptions The requestOptions to send along with the query, they will be merged with
    *     the transporter requestOptions.
    * @throws AlgoliaRuntimeException If it fails to process the API call
    */
   public CompletableFuture<RunResponse> pushTaskAsync(
     @Nonnull String taskID,
-    @Nonnull BatchWriteParams batchWriteParams,
+    @Nonnull PushTaskPayload pushTaskPayload,
     RequestOptions requestOptions
   ) throws AlgoliaRuntimeException {
     Parameters.requireNonNull(taskID, "Parameter `taskID` is required when calling `pushTask`.");
 
-    Parameters.requireNonNull(batchWriteParams, "Parameter `batchWriteParams` is required when calling `pushTask`.");
+    Parameters.requireNonNull(pushTaskPayload, "Parameter `pushTaskPayload` is required when calling `pushTask`.");
 
     HttpRequest request = HttpRequest.builder()
       .setPath("/2/tasks/{taskID}/push", taskID)
       .setMethod("POST")
-      .setBody(batchWriteParams)
+      .setBody(pushTaskPayload)
       .build();
     return executeAsync(request, requestOptions, new TypeReference<RunResponse>() {});
   }
@@ -3131,13 +3131,13 @@ public CompletableFuture<RunResponse> pushTaskAsync(
    * of task pushes with the observability endpoints.
    *
    * @param taskID Unique identifier of a task. (required)
-   * @param batchWriteParams Request body of a Search API `batch` request that will be pushed in the
+   * @param pushTaskPayload Request body of a Search API `batch` request that will be pushed in the
    *     Connectors pipeline. (required)
    * @throws AlgoliaRuntimeException If it fails to process the API call
    */
-  public CompletableFuture<RunResponse> pushTaskAsync(@Nonnull String taskID, @Nonnull BatchWriteParams batchWriteParams)
+  public CompletableFuture<RunResponse> pushTaskAsync(@Nonnull String taskID, @Nonnull PushTaskPayload pushTaskPayload)
     throws AlgoliaRuntimeException {
-    return this.pushTaskAsync(taskID, batchWriteParams, null);
+    return this.pushTaskAsync(taskID, pushTaskPayload, null);
   }
 
   /**

algoliasearch/src/main/java/com/algolia/model/ingestion/BatchRequest.java renamed to algoliasearch/src/main/java/com/algolia/model/ingestion/PushTaskPayload.java

@@ -5,18 +5,20 @@
 
 import com.fasterxml.jackson.annotation.*;
 import com.fasterxml.jackson.databind.annotation.*;
+import java.util.ArrayList;
+import java.util.List;
 import java.util.Objects;
 
-/** BatchRequest */
-public class BatchRequest {
+/** PushTaskPayload */
+public class PushTaskPayload {
 
   @JsonProperty("action")
   private Action action;
 
-  @JsonProperty("body")
-  private Object body;
+  @JsonProperty("records")
+  private List<PushTaskRecords> records = new ArrayList<>();
 
-  public BatchRequest setAction(Action action) {
+  public PushTaskPayload setAction(Action action) {
     this.action = action;
     return this;
   }
@@ -27,15 +29,20 @@ public Action getAction() {
     return action;
   }
 
-  public BatchRequest setBody(Object body) {
-    this.body = body;
+  public PushTaskPayload setRecords(List<PushTaskRecords> records) {
+    this.records = records;
     return this;
   }
 
-  /** Operation arguments (varies with specified `action`). */
+  public PushTaskPayload addRecords(PushTaskRecords recordsItem) {
+    this.records.add(recordsItem);
+    return this;
+  }
+
+  /** Get records */
   @javax.annotation.Nonnull
-  public Object getBody() {
-    return body;
+  public List<PushTaskRecords> getRecords() {
+    return records;
   }
 
   @Override
@@ -46,21 +53,21 @@ public boolean equals(Object o) {
     if (o == null || getClass() != o.getClass()) {
       return false;
     }
-    BatchRequest batchRequest = (BatchRequest) o;
-    return Objects.equals(this.action, batchRequest.action) && Objects.equals(this.body, batchRequest.body);
+    PushTaskPayload pushTaskPayload = (PushTaskPayload) o;
+    return Objects.equals(this.action, pushTaskPayload.action) && Objects.equals(this.records, pushTaskPayload.records);
   }
 
   @Override
   public int hashCode() {
-    return Objects.hash(action, body);
+    return Objects.hash(action, records);
   }
 
   @Override
   public String toString() {
     StringBuilder sb = new StringBuilder();
-    sb.append("class BatchRequest {\n");
+    sb.append("class PushTaskPayload {\n");
     sb.append("    action: ").append(toIndentedString(action)).append("\n");
-    sb.append("    body: ").append(toIndentedString(body)).append("\n");
+    sb.append("    records: ").append(toIndentedString(records)).append("\n");
     sb.append("}");
     return sb.toString();
   }

algoliasearch/src/main/java/com/algolia/model/ingestion/BatchWriteParams.java renamed to algoliasearch/src/main/java/com/algolia/model/ingestion/PushTaskRecords.java

@@ -5,30 +5,38 @@
 
 import com.fasterxml.jackson.annotation.*;
 import com.fasterxml.jackson.databind.annotation.*;
-import java.util.ArrayList;
-import java.util.List;
+import java.util.HashMap;
+import java.util.Map;
 import java.util.Objects;
 
-/** Batch parameters. */
-public class BatchWriteParams {
+/** PushTaskRecords */
+public class PushTaskRecords {
 
-  @JsonProperty("requests")
-  private List<BatchRequest> requests = new ArrayList<>();
+  @JsonProperty("objectID")
+  private String objectID;
 
-  public BatchWriteParams setRequests(List<BatchRequest> requests) {
-    this.requests = requests;
+  private Map<String, Object> additionalProperties = new HashMap<>();
+
+  @JsonAnyGetter
+  public Map<String, Object> getAdditionalProperties() {
+    return this.additionalProperties;
+  }
+
+  @JsonAnySetter
+  public PushTaskRecords setAdditionalProperty(String name, Object value) {
+    this.additionalProperties.put(name, value);
     return this;
   }
 
-  public BatchWriteParams addRequests(BatchRequest requestsItem) {
-    this.requests.add(requestsItem);
+  public PushTaskRecords setObjectID(String objectID) {
+    this.objectID = objectID;
     return this;
   }
 
-  /** Get requests */
+  /** Unique record identifier. */
   @javax.annotation.Nonnull
-  public List<BatchRequest> getRequests() {
-    return requests;
+  public String getObjectID() {
+    return objectID;
   }
 
   @Override
@@ -39,20 +47,21 @@ public boolean equals(Object o) {
     if (o == null || getClass() != o.getClass()) {
       return false;
     }
-    BatchWriteParams batchWriteParams = (BatchWriteParams) o;
-    return Objects.equals(this.requests, batchWriteParams.requests);
+    PushTaskRecords pushTaskRecords = (PushTaskRecords) o;
+    return Objects.equals(this.objectID, pushTaskRecords.objectID) && super.equals(o);
   }
 
   @Override
   public int hashCode() {
-    return Objects.hash(requests);
+    return Objects.hash(objectID, super.hashCode());
   }
 
   @Override
   public String toString() {
     StringBuilder sb = new StringBuilder();
-    sb.append("class BatchWriteParams {\n");
-    sb.append("    requests: ").append(toIndentedString(requests)).append("\n");
+    sb.append("class PushTaskRecords {\n");
+    sb.append("    ").append(toIndentedString(super.toString())).append("\n");
+    sb.append("    objectID: ").append(toIndentedString(objectID)).append("\n");
     sb.append("}");
     return sb.toString();
   }