feat(specs): add v2 endpoints for ingestion

algolia/api-clients-automation#3416

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

Author: algolia-bot

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

@@ -2931,6 +2931,77 @@ public CompletableFuture<ListTransformationsResponse> listTransformationsAsync()
     return this.listTransformationsAsync(null, null, null);
   }
 
+  /**
+   * 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
+   *     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)
+    throws AlgoliaRuntimeException {
+    return LaunderThrowable.await(pushTaskAsync(taskID, batchWriteParams, 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
+   *     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);
+  }
+
+  /**
+   * (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
+   *     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,
+    RequestOptions requestOptions
+  ) throws AlgoliaRuntimeException {
+    Parameters.requireNonNull(taskID, "Parameter `taskID` is required when calling `pushTask`.");
+
+    Parameters.requireNonNull(batchWriteParams, "Parameter `batchWriteParams` is required when calling `pushTask`.");
+
+    HttpRequest request = HttpRequest.builder()
+      .setPath("/2/tasks/{taskID}/push", taskID)
+      .setMethod("POST")
+      .setBody(batchWriteParams)
+      .build();
+    return executeAsync(request, requestOptions, new TypeReference<RunResponse>() {});
+  }
+
+  /**
+   * (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
+   *     Connectors pipeline. (required)
+   * @throws AlgoliaRuntimeException If it fails to process the API call
+   */
+  public CompletableFuture<RunResponse> pushTaskAsync(@Nonnull String taskID, @Nonnull BatchWriteParams batchWriteParams)
+    throws AlgoliaRuntimeException {
+    return this.pushTaskAsync(taskID, batchWriteParams, null);
+  }
+
   /**
    * Runs a task. You can check the status of task runs with the observability endpoints.
    *

algoliasearch/src/main/java/com/algolia/model/ingestion/Action.java

@@ -0,0 +1,50 @@
+// Code generated by OpenAPI Generator (https://openapi-generator.tech), manual changes will be lost
+// - read more on https://github.com/algolia/api-clients-automation. DO NOT EDIT.
+
+package com.algolia.model.ingestion;
+
+import com.fasterxml.jackson.annotation.*;
+import com.fasterxml.jackson.databind.annotation.*;
+
+/** Type of indexing operation. */
+public enum Action {
+  ADD_OBJECT("addObject"),
+
+  UPDATE_OBJECT("updateObject"),
+
+  PARTIAL_UPDATE_OBJECT("partialUpdateObject"),
+
+  PARTIAL_UPDATE_OBJECT_NO_CREATE("partialUpdateObjectNoCreate"),
+
+  DELETE_OBJECT("deleteObject"),
+
+  DELETE("delete"),
+
+  CLEAR("clear");
+
+  private final String value;
+
+  Action(String value) {
+    this.value = value;
+  }
+
+  @JsonValue
+  public String getValue() {
+    return value;
+  }
+
+  @Override
+  public String toString() {
+    return String.valueOf(value);
+  }
+
+  @JsonCreator
+  public static Action fromValue(String value) {
+    for (Action b : Action.values()) {
+      if (b.value.equals(value)) {
+        return b;
+      }
+    }
+    throw new IllegalArgumentException("Unexpected value '" + value + "'");
+  }
+}

algoliasearch/src/main/java/com/algolia/model/ingestion/BatchRequest.java

@@ -0,0 +1,77 @@
+// Code generated by OpenAPI Generator (https://openapi-generator.tech), manual changes will be lost
+// - read more on https://github.com/algolia/api-clients-automation. DO NOT EDIT.
+
+package com.algolia.model.ingestion;
+
+import com.fasterxml.jackson.annotation.*;
+import com.fasterxml.jackson.databind.annotation.*;
+import java.util.Objects;
+
+/** BatchRequest */
+public class BatchRequest {
+
+  @JsonProperty("action")
+  private Action action;
+
+  @JsonProperty("body")
+  private Object body;
+
+  public BatchRequest setAction(Action action) {
+    this.action = action;
+    return this;
+  }
+
+  /** Get action */
+  @javax.annotation.Nonnull
+  public Action getAction() {
+    return action;
+  }
+
+  public BatchRequest setBody(Object body) {
+    this.body = body;
+    return this;
+  }
+
+  /** Operation arguments (varies with specified `action`). */
+  @javax.annotation.Nonnull
+  public Object getBody() {
+    return body;
+  }
+
+  @Override
+  public boolean equals(Object o) {
+    if (this == o) {
+      return true;
+    }
+    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);
+  }
+
+  @Override
+  public int hashCode() {
+    return Objects.hash(action, body);
+  }
+
+  @Override
+  public String toString() {
+    StringBuilder sb = new StringBuilder();
+    sb.append("class BatchRequest {\n");
+    sb.append("    action: ").append(toIndentedString(action)).append("\n");
+    sb.append("    body: ").append(toIndentedString(body)).append("\n");
+    sb.append("}");
+    return sb.toString();
+  }
+
+  /**
+   * Convert the given object to string with each line indented by 4 spaces (except the first line).
+   */
+  private String toIndentedString(Object o) {
+    if (o == null) {
+      return "null";
+    }
+    return o.toString().replace("\n", "\n    ");
+  }
+}

algoliasearch/src/main/java/com/algolia/model/ingestion/BatchWriteParams.java

@@ -0,0 +1,69 @@
+// Code generated by OpenAPI Generator (https://openapi-generator.tech), manual changes will be lost
+// - read more on https://github.com/algolia/api-clients-automation. DO NOT EDIT.
+
+package com.algolia.model.ingestion;
+
+import com.fasterxml.jackson.annotation.*;
+import com.fasterxml.jackson.databind.annotation.*;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Objects;
+
+/** Batch parameters. */
+public class BatchWriteParams {
+
+  @JsonProperty("requests")
+  private List<BatchRequest> requests = new ArrayList<>();
+
+  public BatchWriteParams setRequests(List<BatchRequest> requests) {
+    this.requests = requests;
+    return this;
+  }
+
+  public BatchWriteParams addRequests(BatchRequest requestsItem) {
+    this.requests.add(requestsItem);
+    return this;
+  }
+
+  /** Get requests */
+  @javax.annotation.Nonnull
+  public List<BatchRequest> getRequests() {
+    return requests;
+  }
+
+  @Override
+  public boolean equals(Object o) {
+    if (this == o) {
+      return true;
+    }
+    if (o == null || getClass() != o.getClass()) {
+      return false;
+    }
+    BatchWriteParams batchWriteParams = (BatchWriteParams) o;
+    return Objects.equals(this.requests, batchWriteParams.requests);
+  }
+
+  @Override
+  public int hashCode() {
+    return Objects.hash(requests);
+  }
+
+  @Override
+  public String toString() {
+    StringBuilder sb = new StringBuilder();
+    sb.append("class BatchWriteParams {\n");
+    sb.append("    requests: ").append(toIndentedString(requests)).append("\n");
+    sb.append("}");
+    return sb.toString();
+  }
+
+  /**
+   * Convert the given object to string with each line indented by 4 spaces (except the first line).
+   */
+  private String toIndentedString(Object o) {
+    if (o == null) {
+      return "null";
+    }
+    return o.toString().replace("\n", "\n    ");
+  }
+}