Merge remote-tracking branch 'origin/main' into feat/go-refacto

Author: millotp

.github/actions/setup/action.yml

@@ -202,7 +202,7 @@ runs:
       if: ${{ inputs.language == 'swift' }}
       id: swiftformat-version
       shell: bash
-      run: echo "SWIFTFORMAT_VERSION=0.55.6" >> $GITHUB_OUTPUT
+      run: echo "SWIFTFORMAT_VERSION=0.56.1" >> $GITHUB_OUTPUT
 
     - name: Checkout swiftformat
       if: ${{ inputs.language == 'swift' }}

.nvmrc

@@ -1 +1 @@
-22.15.0
+22.16.0

clients/algoliasearch-client-csharp/.config/dotnet-tools.json

@@ -3,7 +3,7 @@
   "isRoot": true,
   "tools": {
     "csharpier": {
-      "version": "1.0.1",
+      "version": "1.0.2",
       "commands": [
         "csharpier"
       ]

clients/algoliasearch-client-csharp/algoliasearch/Clients/AbtestingClient.cs

@@ -767,7 +767,8 @@ public EstimateABTestResponse EstimateABTest(
     RequestOptions options = null,
     CancellationToken cancellationToken = default
   ) =>
-    AsyncHelper.RunSync(() => EstimateABTestAsync(estimateABTestRequest, options, cancellationToken)
+    AsyncHelper.RunSync(() =>
+      EstimateABTestAsync(estimateABTestRequest, options, cancellationToken)
     );
 
   /// <inheritdoc />

clients/algoliasearch-client-csharp/algoliasearch/Clients/CompositionClient.cs

@@ -228,7 +228,8 @@ public SearchResponse<T> Search<T>(
     RequestOptions options = null,
     CancellationToken cancellationToken = default
   ) =>
-    AsyncHelper.RunSync(() => SearchAsync<T>(compositionID, requestBody, options, cancellationToken)
+    AsyncHelper.RunSync(() =>
+      SearchAsync<T>(compositionID, requestBody, options, cancellationToken)
     );
 
   /// <inheritdoc />

clients/algoliasearch-client-csharp/algoliasearch/Clients/IngestionClient.cs

@@ -1685,15 +1685,65 @@ ListTransformationsResponse ListTransformations(
   );
 
   /// <summary>
-  /// Push a `batch` request payload through the Pipeline. You can check the status of task pushes with the observability endpoints.
+  /// Pushes records through the Pipeline, directly to an index. You can make the call synchronous by providing the `watch` parameter, for asynchronous calls, you can use the observability endpoints and/or debugger dashboard to see the status of your task. If you want to leverage the [pre-indexing data transformation](https://www.algolia.com/doc/guides/sending-and-managing-data/send-and-update-your-data/how-to/transform-your-data/), this is the recommended way of ingesting your records. This method is similar to `pushTask`, but requires an `indexName` instead of a `taskID`. If zero or many tasks are found, an error will be returned.
+  /// </summary>
+  ///
+  /// Required API Key ACLs:
+  ///   - addObject
+  ///   - deleteIndex
+  ///   - editSettings
+  /// <param name="indexName">Name of the index on which to perform the operation.</param>
+  /// <param name="pushTaskPayload"></param>
+  /// <param name="watch">When provided, the push operation will be synchronous and the API will wait for the ingestion to be finished before responding. (optional)</param>
+  /// <param name="options">Add extra http header or query parameters to Algolia.</param>
+  /// <param name="cancellationToken">Cancellation Token to cancel the request.</param>
+  /// <exception cref="ArgumentException">Thrown when arguments are not correct</exception>
+  /// <exception cref="Algolia.Search.Exceptions.AlgoliaApiException">Thrown when the API call was rejected by Algolia</exception>
+  /// <exception cref="Algolia.Search.Exceptions.AlgoliaUnreachableHostException">Thrown when the client failed to call the endpoint</exception>
+  /// <returns>Task of WatchResponse</returns>
+  Task<WatchResponse> PushAsync(
+    string indexName,
+    PushTaskPayload pushTaskPayload,
+    bool? watch = default,
+    RequestOptions options = null,
+    CancellationToken cancellationToken = default
+  );
+
+  /// <summary>
+  /// Pushes records through the Pipeline, directly to an index. You can make the call synchronous by providing the `watch` parameter, for asynchronous calls, you can use the observability endpoints and/or debugger dashboard to see the status of your task. If you want to leverage the [pre-indexing data transformation](https://www.algolia.com/doc/guides/sending-and-managing-data/send-and-update-your-data/how-to/transform-your-data/), this is the recommended way of ingesting your records. This method is similar to `pushTask`, but requires an `indexName` instead of a `taskID`. If zero or many tasks are found, an error will be returned.  (Synchronous version)
+  /// </summary>
+  ///
+  /// Required API Key ACLs:
+  ///   - addObject
+  ///   - deleteIndex
+  ///   - editSettings
+  /// <param name="indexName">Name of the index on which to perform the operation.</param>
+  /// <param name="pushTaskPayload"></param>
+  /// <param name="watch">When provided, the push operation will be synchronous and the API will wait for the ingestion to be finished before responding. (optional)</param>
+  /// <param name="options">Add extra http header or query parameters to Algolia.</param>
+  /// <param name="cancellationToken">Cancellation Token to cancel the request.</param>
+  /// <exception cref="ArgumentException">Thrown when arguments are not correct</exception>
+  /// <exception cref="Algolia.Search.Exceptions.AlgoliaApiException">Thrown when the API call was rejected by Algolia</exception>
+  /// <exception cref="Algolia.Search.Exceptions.AlgoliaUnreachableHostException">Thrown when the client failed to call the endpoint</exception>
+  /// <returns>WatchResponse</returns>
+  WatchResponse Push(
+    string indexName,
+    PushTaskPayload pushTaskPayload,
+    bool? watch = default,
+    RequestOptions options = null,
+    CancellationToken cancellationToken = default
+  );
+
+  /// <summary>
+  /// Pushes records through the Pipeline, directly to an index. You can make the call synchronous by providing the `watch` parameter, for asynchronous calls, you can use the observability endpoints and/or debugger dashboard to see the status of your task. If you want to leverage the [pre-indexing data transformation](https://www.algolia.com/doc/guides/sending-and-managing-data/send-and-update-your-data/how-to/transform-your-data/), this is the recommended way of ingesting your records. This method is similar to `push`, but requires a `taskID` instead of a `indexName`, which is useful when many `destinations` target the same `indexName`.
   /// </summary>
   ///
   /// Required API Key ACLs:
   ///   - addObject
   ///   - deleteIndex
   ///   - editSettings
   /// <param name="taskID">Unique identifier of a task.</param>
-  /// <param name="pushTaskPayload">Request body of a Search API `batch` request that will be pushed in the Connectors pipeline.</param>
+  /// <param name="pushTaskPayload"></param>
   /// <param name="watch">When provided, the push operation will be synchronous and the API will wait for the ingestion to be finished before responding. (optional)</param>
   /// <param name="options">Add extra http header or query parameters to Algolia.</param>
   /// <param name="cancellationToken">Cancellation Token to cancel the request.</param>
@@ -1710,15 +1760,15 @@ Task<WatchResponse> PushTaskAsync(
   );
 
   /// <summary>
-  /// Push a `batch` request payload through the Pipeline. You can check the status of task pushes with the observability endpoints. (Synchronous version)
+  /// Pushes records through the Pipeline, directly to an index. You can make the call synchronous by providing the `watch` parameter, for asynchronous calls, you can use the observability endpoints and/or debugger dashboard to see the status of your task. If you want to leverage the [pre-indexing data transformation](https://www.algolia.com/doc/guides/sending-and-managing-data/send-and-update-your-data/how-to/transform-your-data/), this is the recommended way of ingesting your records. This method is similar to `push`, but requires a `taskID` instead of a `indexName`, which is useful when many `destinations` target the same `indexName`.  (Synchronous version)
   /// </summary>
   ///
   /// Required API Key ACLs:
   ///   - addObject
   ///   - deleteIndex
   ///   - editSettings
   /// <param name="taskID">Unique identifier of a task.</param>
-  /// <param name="pushTaskPayload">Request body of a Search API `batch` request that will be pushed in the Connectors pipeline.</param>
+  /// <param name="pushTaskPayload"></param>
   /// <param name="watch">When provided, the push operation will be synchronous and the API will wait for the ingestion to be finished before responding. (optional)</param>
   /// <param name="options">Add extra http header or query parameters to Algolia.</param>
   /// <param name="cancellationToken">Cancellation Token to cancel the request.</param>
@@ -2738,7 +2788,8 @@ public DestinationCreateResponse CreateDestination(
     RequestOptions options = null,
     CancellationToken cancellationToken = default
   ) =>
-    AsyncHelper.RunSync(() => CreateDestinationAsync(destinationCreate, options, cancellationToken)
+    AsyncHelper.RunSync(() =>
+      CreateDestinationAsync(destinationCreate, options, cancellationToken)
     );
 
   /// <inheritdoc />
@@ -4105,6 +4156,52 @@ public ListTransformationsResponse ListTransformations(
       ListTransformationsAsync(itemsPerPage, page, sort, order, options, cancellationToken)
     );
 
+  /// <inheritdoc />
+  public async Task<WatchResponse> PushAsync(
+    string indexName,
+    PushTaskPayload pushTaskPayload,
+    bool? watch = default,
+    RequestOptions options = null,
+    CancellationToken cancellationToken = default
+  )
+  {
+    if (indexName == null)
+      throw new ArgumentException("Parameter `indexName` is required when calling `Push`.");
+
+    if (pushTaskPayload == null)
+      throw new ArgumentException("Parameter `pushTaskPayload` is required when calling `Push`.");
+
+    var requestOptions = new InternalRequestOptions(options);
+
+    requestOptions.PathParameters.Add("indexName", QueryStringHelper.ParameterToString(indexName));
+
+    requestOptions.AddQueryParameter("watch", watch);
+    requestOptions.Data = pushTaskPayload;
+    requestOptions.ReadTimeout ??= TimeSpan.FromMilliseconds(180000);
+    requestOptions.WriteTimeout ??= TimeSpan.FromMilliseconds(180000);
+    requestOptions.ConnectTimeout ??= TimeSpan.FromMilliseconds(180000);
+    return await _transport
+      .ExecuteRequestAsync<WatchResponse>(
+        new HttpMethod("POST"),
+        "/1/push/{indexName}",
+        requestOptions,
+        cancellationToken
+      )
+      .ConfigureAwait(false);
+  }
+
+  /// <inheritdoc />
+  public WatchResponse Push(
+    string indexName,
+    PushTaskPayload pushTaskPayload,
+    bool? watch = default,
+    RequestOptions options = null,
+    CancellationToken cancellationToken = default
+  ) =>
+    AsyncHelper.RunSync(() =>
+      PushAsync(indexName, pushTaskPayload, watch, options, cancellationToken)
+    );
+
   /// <inheritdoc />
   public async Task<WatchResponse> PushTaskAsync(
     string taskID,
@@ -4186,7 +4283,8 @@ public RunSourceResponse RunSource(
     RequestOptions options = null,
     CancellationToken cancellationToken = default
   ) =>
-    AsyncHelper.RunSync(() => RunSourceAsync(sourceID, runSourcePayload, options, cancellationToken)
+    AsyncHelper.RunSync(() =>
+      RunSourceAsync(sourceID, runSourcePayload, options, cancellationToken)
     );
 
   /// <inheritdoc />
@@ -4319,7 +4417,8 @@ public List<Destination> SearchDestinations(
     RequestOptions options = null,
     CancellationToken cancellationToken = default
   ) =>
-    AsyncHelper.RunSync(() => SearchDestinationsAsync(destinationSearch, options, cancellationToken)
+    AsyncHelper.RunSync(() =>
+      SearchDestinationsAsync(destinationSearch, options, cancellationToken)
     );
 
   /// <inheritdoc />
@@ -4488,7 +4587,8 @@ public WatchResponse TriggerDockerSourceDiscover(
     RequestOptions options = null,
     CancellationToken cancellationToken = default
   ) =>
-    AsyncHelper.RunSync(() => TriggerDockerSourceDiscoverAsync(sourceID, options, cancellationToken)
+    AsyncHelper.RunSync(() =>
+      TriggerDockerSourceDiscoverAsync(sourceID, options, cancellationToken)
     );
 
   /// <inheritdoc />
@@ -4522,7 +4622,8 @@ public TransformationTryResponse TryTransformation(
     RequestOptions options = null,
     CancellationToken cancellationToken = default
   ) =>
-    AsyncHelper.RunSync(() => TryTransformationAsync(transformationTry, options, cancellationToken)
+    AsyncHelper.RunSync(() =>
+      TryTransformationAsync(transformationTry, options, cancellationToken)
     );
 
   /// <inheritdoc />
@@ -4709,7 +4810,8 @@ public SourceUpdateResponse UpdateSource(
     RequestOptions options = null,
     CancellationToken cancellationToken = default
   ) =>
-    AsyncHelper.RunSync(() => UpdateSourceAsync(sourceID, sourceUpdate, options, cancellationToken)
+    AsyncHelper.RunSync(() =>
+      UpdateSourceAsync(sourceID, sourceUpdate, options, cancellationToken)
     );
 
   /// <inheritdoc />

clients/algoliasearch-client-csharp/algoliasearch/Clients/QuerySuggestionsClient.cs

@@ -555,7 +555,8 @@ public BaseResponse CreateConfig(
     RequestOptions options = null,
     CancellationToken cancellationToken = default
   ) =>
-    AsyncHelper.RunSync(() => CreateConfigAsync(configurationWithIndex, options, cancellationToken)
+    AsyncHelper.RunSync(() =>
+      CreateConfigAsync(configurationWithIndex, options, cancellationToken)
     );
 
   /// <inheritdoc />

clients/algoliasearch-client-csharp/algoliasearch/Models/Ingestion/Action.cs

@@ -41,22 +41,4 @@ public enum Action
   /// </summary>
   [JsonPropertyName("partialUpdateObjectNoCreate")]
   PartialUpdateObjectNoCreate = 4,
-
-  /// <summary>
-  /// Enum DeleteObject for value: deleteObject
-  /// </summary>
-  [JsonPropertyName("deleteObject")]
-  DeleteObject = 5,
-
-  /// <summary>
-  /// Enum Delete for value: delete
-  /// </summary>
-  [JsonPropertyName("delete")]
-  Delete = 6,
-
-  /// <summary>
-  /// Enum Clear for value: clear
-  /// </summary>
-  [JsonPropertyName("clear")]
-  Clear = 7,
 }

clients/algoliasearch-client-csharp/algoliasearch/Models/Ingestion/WatchResponse.cs

@@ -38,6 +38,13 @@ public WatchResponse(string runID)
   [JsonPropertyName("runID")]
   public string RunID { get; set; }
 
+  /// <summary>
+  /// Universally unique identifier (UUID) of an event.
+  /// </summary>
+  /// <value>Universally unique identifier (UUID) of an event.</value>
+  [JsonPropertyName("eventID")]
+  public string EventID { get; set; }
+
   /// <summary>
   /// when used with discovering or validating sources, the sampled data of your source is returned.
   /// </summary>
@@ -59,6 +66,13 @@ public WatchResponse(string runID)
   [JsonPropertyName("message")]
   public string Message { get; set; }
 
+  /// <summary>
+  /// Date of creation in RFC 3339 format.
+  /// </summary>
+  /// <value>Date of creation in RFC 3339 format.</value>
+  [JsonPropertyName("createdAt")]
+  public string CreatedAt { get; set; }
+
   /// <summary>
   /// Returns the string presentation of the object
   /// </summary>
@@ -68,9 +82,11 @@ public override string ToString()
     StringBuilder sb = new StringBuilder();
     sb.Append("class WatchResponse {\n");
     sb.Append("  RunID: ").Append(RunID).Append("\n");
+    sb.Append("  EventID: ").Append(EventID).Append("\n");
     sb.Append("  Data: ").Append(Data).Append("\n");
     sb.Append("  Events: ").Append(Events).Append("\n");
     sb.Append("  Message: ").Append(Message).Append("\n");
+    sb.Append("  CreatedAt: ").Append(CreatedAt).Append("\n");
     sb.Append("}\n");
     return sb.ToString();
   }
@@ -97,14 +113,16 @@ public override bool Equals(object obj)
     }
 
     return (RunID == input.RunID || (RunID != null && RunID.Equals(input.RunID)))
+      && (EventID == input.EventID || (EventID != null && EventID.Equals(input.EventID)))
       && (
         Data == input.Data || Data != null && input.Data != null && Data.SequenceEqual(input.Data)
       )
       && (
         Events == input.Events
         || Events != null && input.Events != null && Events.SequenceEqual(input.Events)
       )
-      && (Message == input.Message || (Message != null && Message.Equals(input.Message)));
+      && (Message == input.Message || (Message != null && Message.Equals(input.Message)))
+      && (CreatedAt == input.CreatedAt || (CreatedAt != null && CreatedAt.Equals(input.CreatedAt)));
   }
 
   /// <summary>
@@ -120,6 +138,10 @@ public override int GetHashCode()
       {
         hashCode = (hashCode * 59) + RunID.GetHashCode();
       }
+      if (EventID != null)
+      {
+        hashCode = (hashCode * 59) + EventID.GetHashCode();
+      }
       if (Data != null)
       {
         hashCode = (hashCode * 59) + Data.GetHashCode();
@@ -132,6 +154,10 @@ public override int GetHashCode()
       {
         hashCode = (hashCode * 59) + Message.GetHashCode();
       }
+      if (CreatedAt != null)
+      {
+        hashCode = (hashCode * 59) + CreatedAt.GetHashCode();
+      }
       return hashCode;
     }
   }

clients/algoliasearch-client-csharp/algoliasearch/Models/Search/FetchedIndex.cs

@@ -39,8 +39,8 @@ public FetchedIndex(
     string createdAt,
     string updatedAt,
     int entries,
-    int dataSize,
-    int fileSize,
+    long dataSize,
+    long fileSize,
     int lastBuildTimeS,
     int numberOfPendingTasks,
     bool pendingTask
@@ -90,14 +90,14 @@ bool pendingTask
   /// </summary>
   /// <value>Number of bytes of the index in minified format.</value>
   [JsonPropertyName("dataSize")]
-  public int DataSize { get; set; }
+  public long DataSize { get; set; }
 
   /// <summary>
   /// Number of bytes of the index binary file.
   /// </summary>
   /// <value>Number of bytes of the index binary file.</value>
   [JsonPropertyName("fileSize")]
-  public int FileSize { get; set; }
+  public long FileSize { get; set; }
 
   /// <summary>
   /// Last build time.