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

packages/ingestion/model/action.ts

@@ -0,0 +1,13 @@
+// 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.
+
+/**
+ * Type of indexing operation.
+ */
+export type Action =
+  | 'addObject'
+  | 'clear'
+  | 'delete'
+  | 'deleteObject'
+  | 'partialUpdateObject'
+  | 'partialUpdateObjectNoCreate'
+  | 'updateObject';

packages/ingestion/model/batchRequest.ts

@@ -0,0 +1,12 @@
+// 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.
+
+import type { Action } from './action';
+
+export type BatchRequest = {
+  action: Action;
+
+  /**
+   * Operation arguments (varies with specified `action`).
+   */
+  body: Record<string, any>;
+};

packages/ingestion/model/batchWriteParams.ts

@@ -0,0 +1,10 @@
+// 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.
+
+import type { BatchRequest } from './batchRequest';
+
+/**
+ * Batch parameters.
+ */
+export type BatchWriteParams = {
+  requests: BatchRequest[];
+};

packages/ingestion/model/clientMethodProps.ts

@@ -4,6 +4,7 @@ import type { ActionType } from './actionType';
 import type { AuthenticationSortKeys } from './authenticationSortKeys';
 import type { AuthenticationType } from './authenticationType';
 import type { AuthenticationUpdate } from './authenticationUpdate';
+import type { BatchWriteParams } from './batchWriteParams';
 import type { DestinationSortKeys } from './destinationSortKeys';
 import type { DestinationType } from './destinationType';
 import type { DestinationUpdate } from './destinationUpdate';
@@ -540,6 +541,20 @@ export type ListTransformationsProps = {
   order?: OrderKeys;
 };
 
+/**
+ * Properties for the `pushTask` method.
+ */
+export type PushTaskProps = {
+  /**
+   * Unique identifier of a task.
+   */
+  taskID: string;
+  /**
+   * Request body of a Search API `batch` request that will be pushed in the Connectors pipeline.
+   */
+  batchWriteParams: BatchWriteParams;
+};
+
 /**
  * Properties for the `runTask` method.
  */

packages/ingestion/model/index.ts

@@ -1,5 +1,6 @@
 // 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.
 
+export * from './action';
 export * from './actionType';
 export * from './authAPIKey';
 export * from './authAPIKeyPartial';
@@ -23,6 +24,8 @@ export * from './authenticationSortKeys';
 export * from './authenticationType';
 export * from './authenticationUpdate';
 export * from './authenticationUpdateResponse';
+export * from './batchRequest';
+export * from './batchWriteParams';
 export * from './bigCommerceChannel';
 export * from './bigCommerceMetafield';
 export * from './bigQueryDataType';

packages/ingestion/src/ingestionClient.ts

@@ -50,6 +50,7 @@ import type {
   ListTasksProps,
   ListTasksV1Props,
   ListTransformationsProps,
+  PushTaskProps,
   RunTaskProps,
   RunTaskV1Props,
   TriggerDockerSourceDiscoverProps,
@@ -1907,6 +1908,59 @@ export function createIngestionClient({
       return transporter.request(request, requestOptions);
     },
 
+    /**
+     * 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 pushTask - The pushTask object.
+     * @param pushTask.taskID - Unique identifier of a task.
+     * @param pushTask.batchWriteParams - Request body of a Search API `batch` request that will be pushed in the Connectors pipeline.
+     * @param requestOptions - The requestOptions to send along with the query, they will be merged with the transporter requestOptions.
+     */
+    pushTask(
+      { taskID, batchWriteParams }: PushTaskProps,
+      requestOptions?: RequestOptions
+    ): Promise<RunResponse> {
+      if (!taskID) {
+        throw new Error(
+          'Parameter `taskID` is required when calling `pushTask`.'
+        );
+      }
+
+      if (!batchWriteParams) {
+        throw new Error(
+          'Parameter `batchWriteParams` is required when calling `pushTask`.'
+        );
+      }
+
+      if (!batchWriteParams.requests) {
+        throw new Error(
+          'Parameter `batchWriteParams.requests` is required when calling `pushTask`.'
+        );
+      }
+
+      const requestPath = '/2/tasks/{taskID}/push'.replace(
+        '{taskID}',
+        encodeURIComponent(taskID)
+      );
+      const headers: Headers = {};
+      const queryParameters: QueryParameters = {};
+
+      const request: Request = {
+        method: 'POST',
+        path: requestPath,
+        queryParameters,
+        headers,
+        data: batchWriteParams,
+      };
+
+      return transporter.request(request, requestOptions);
+    },
+
     /**
      * Runs a task. You can check the status of task runs with the observability endpoints.
      *