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

client/src/commonMain/kotlin/com/algolia/client/api/IngestionClient.kt

@@ -902,6 +902,30 @@ public class IngestionClient(
     )
   }
 
+  /**
+   * Push a `batch` request payload through the Pipeline. You can check the status of task pushes with the observability endpoints.
+   *
+   * Required API Key ACLs:
+   *   - addObject
+   *   - deleteIndex
+   *   - editSettings
+   * @param taskID Unique identifier of a task.
+   * @param batchWriteParams Request body of a Search API `batch` request that will be pushed in the Connectors pipeline.
+   * @param requestOptions additional request configuration.
+   */
+  public suspend fun pushTask(taskID: String, batchWriteParams: BatchWriteParams, requestOptions: RequestOptions? = null): RunResponse {
+    require(taskID.isNotBlank()) { "Parameter `taskID` is required when calling `pushTask`." }
+    val requestConfig = RequestConfig(
+      method = RequestMethod.POST,
+      path = listOf("2", "tasks", "$taskID", "push"),
+      body = batchWriteParams,
+    )
+    return requester.execute(
+      requestConfig = requestConfig,
+      requestOptions = requestOptions,
+    )
+  }
+
   /**
    * Runs a task. You can check the status of task runs with the observability endpoints.
    *

client/src/commonMain/kotlin/com/algolia/client/model/ingestion/Action.kt

@@ -0,0 +1,34 @@
+/** 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.client.model.ingestion
+
+import kotlinx.serialization.*
+
+/**
+ * Type of indexing operation.
+ */
+@Serializable
+public enum class Action(public val value: kotlin.String) {
+
+  @SerialName(value = "addObject")
+  AddObject("addObject"),
+
+  @SerialName(value = "updateObject")
+  UpdateObject("updateObject"),
+
+  @SerialName(value = "partialUpdateObject")
+  PartialUpdateObject("partialUpdateObject"),
+
+  @SerialName(value = "partialUpdateObjectNoCreate")
+  PartialUpdateObjectNoCreate("partialUpdateObjectNoCreate"),
+
+  @SerialName(value = "deleteObject")
+  DeleteObject("deleteObject"),
+
+  @SerialName(value = "delete")
+  Delete("delete"),
+
+  @SerialName(value = "clear")
+  Clear("clear");
+
+  override fun toString(): kotlin.String = value
+}

client/src/commonMain/kotlin/com/algolia/client/model/ingestion/BatchRequest.kt

@@ -0,0 +1,20 @@
+/** 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.client.model.ingestion
+
+import kotlinx.serialization.*
+import kotlinx.serialization.json.*
+
+/**
+ * BatchRequest
+ *
+ * @param action
+ * @param body Operation arguments (varies with specified `action`).
+ */
+@Serializable
+public data class BatchRequest(
+
+  @SerialName(value = "action") val action: Action,
+
+  /** Operation arguments (varies with specified `action`). */
+  @SerialName(value = "body") val body: JsonObject,
+)

client/src/commonMain/kotlin/com/algolia/client/model/ingestion/BatchWriteParams.kt

@@ -0,0 +1,16 @@
+/** 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.client.model.ingestion
+
+import kotlinx.serialization.*
+import kotlinx.serialization.json.*
+
+/**
+ * Batch parameters.
+ *
+ * @param requests
+ */
+@Serializable
+public data class BatchWriteParams(
+
+  @SerialName(value = "requests") val requests: List<BatchRequest>,
+)