fix(specs): enable watcher for push [skip-bc] (generated)

algolia/api-clients-automation#4229

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

Author: algolia-bot

Sources/Ingestion/IngestionClient.swift

@@ -2424,15 +2424,15 @@ open class IngestionClient {
     /// Connectors pipeline.
     /// - parameter watch: (query) When provided, the push operation will be synchronous and the API will wait for the
     /// ingestion to be finished before responding. (optional)
-    /// - returns: RunResponse
+    /// - returns: WatchResponse
     @available(macOS 10.15, iOS 13.0, tvOS 13.0, watchOS 6.0, *)
     open func pushTask(
         taskID: String,
         pushTaskPayload: PushTaskPayload,
         watch: Bool? = nil,
         requestOptions: RequestOptions? = nil
-    ) async throws -> RunResponse {
-        let response: Response<RunResponse> = try await pushTaskWithHTTPInfo(
+    ) async throws -> WatchResponse {
+        let response: Response<WatchResponse> = try await pushTaskWithHTTPInfo(
             taskID: taskID,
             pushTaskPayload: pushTaskPayload,
             watch: watch,
@@ -2460,14 +2460,14 @@ open class IngestionClient {
     //
     // - parameter watch: (query) When provided, the push operation will be synchronous and the API will wait for the
     // ingestion to be finished before responding. (optional)
-    // - returns: RequestBuilder<RunResponse>
+    // - returns: RequestBuilder<WatchResponse>
 
     open func pushTaskWithHTTPInfo(
         taskID: String,
         pushTaskPayload: PushTaskPayload,
         watch: Bool? = nil,
         requestOptions userRequestOptions: RequestOptions? = nil
-    ) async throws -> Response<RunResponse> {
+    ) async throws -> Response<WatchResponse> {
         guard !taskID.isEmpty else {
             throw AlgoliaError.invalidArgument("taskID", "pushTask")
         }
@@ -2969,13 +2969,13 @@ open class IngestionClient {
     }
 
     /// - parameter sourceID: (path) Unique identifier of a source.
-    /// - returns: SourceWatchResponse
+    /// - returns: WatchResponse
     @available(macOS 10.15, iOS 13.0, tvOS 13.0, watchOS 6.0, *)
     open func triggerDockerSourceDiscover(
         sourceID: String,
         requestOptions: RequestOptions? = nil
-    ) async throws -> SourceWatchResponse {
-        let response: Response<SourceWatchResponse> = try await triggerDockerSourceDiscoverWithHTTPInfo(
+    ) async throws -> WatchResponse {
+        let response: Response<WatchResponse> = try await triggerDockerSourceDiscoverWithHTTPInfo(
             sourceID: sourceID,
             requestOptions: requestOptions
         )
@@ -2995,12 +2995,12 @@ open class IngestionClient {
     //  - editSettings
     //
     // - parameter sourceID: (path) Unique identifier of a source.
-    // - returns: RequestBuilder<SourceWatchResponse>
+    // - returns: RequestBuilder<WatchResponse>
 
     open func triggerDockerSourceDiscoverWithHTTPInfo(
         sourceID: String,
         requestOptions userRequestOptions: RequestOptions? = nil
-    ) async throws -> Response<SourceWatchResponse> {
+    ) async throws -> Response<WatchResponse> {
         guard !sourceID.isEmpty else {
             throw AlgoliaError.invalidArgument("sourceID", "triggerDockerSourceDiscover")
         }
@@ -3539,13 +3539,13 @@ open class IngestionClient {
     }
 
     /// - parameter sourceCreate: (body)  (optional)
-    /// - returns: SourceWatchResponse
+    /// - returns: WatchResponse
     @available(macOS 10.15, iOS 13.0, tvOS 13.0, watchOS 6.0, *)
     open func validateSource(
         sourceCreate: SourceCreate? = nil,
         requestOptions: RequestOptions? = nil
-    ) async throws -> SourceWatchResponse {
-        let response: Response<SourceWatchResponse> = try await validateSourceWithHTTPInfo(
+    ) async throws -> WatchResponse {
+        let response: Response<WatchResponse> = try await validateSourceWithHTTPInfo(
             sourceCreate: sourceCreate,
             requestOptions: requestOptions
         )
@@ -3564,12 +3564,12 @@ open class IngestionClient {
     //  - editSettings
     //
     // - parameter sourceCreate: (body)  (optional)
-    // - returns: RequestBuilder<SourceWatchResponse>
+    // - returns: RequestBuilder<WatchResponse>
 
     open func validateSourceWithHTTPInfo(
         sourceCreate: SourceCreate? = nil,
         requestOptions userRequestOptions: RequestOptions? = nil
-    ) async throws -> Response<SourceWatchResponse> {
+    ) async throws -> Response<WatchResponse> {
         let resourcePath = "/1/sources/validate"
         let body = sourceCreate
         let queryParameters: [String: Any?]? = nil
@@ -3588,14 +3588,14 @@ open class IngestionClient {
 
     /// - parameter sourceID: (path) Unique identifier of a source.
     /// - parameter sourceUpdate: (body)
-    /// - returns: SourceWatchResponse
+    /// - returns: WatchResponse
     @available(macOS 10.15, iOS 13.0, tvOS 13.0, watchOS 6.0, *)
     open func validateSourceBeforeUpdate(
         sourceID: String,
         sourceUpdate: SourceUpdate,
         requestOptions: RequestOptions? = nil
-    ) async throws -> SourceWatchResponse {
-        let response: Response<SourceWatchResponse> = try await validateSourceBeforeUpdateWithHTTPInfo(
+    ) async throws -> WatchResponse {
+        let response: Response<WatchResponse> = try await validateSourceBeforeUpdateWithHTTPInfo(
             sourceID: sourceID,
             sourceUpdate: sourceUpdate,
             requestOptions: requestOptions
@@ -3618,13 +3618,13 @@ open class IngestionClient {
     // - parameter sourceID: (path) Unique identifier of a source.
     //
     // - parameter sourceUpdate: (body)
-    // - returns: RequestBuilder<SourceWatchResponse>
+    // - returns: RequestBuilder<WatchResponse>
 
     open func validateSourceBeforeUpdateWithHTTPInfo(
         sourceID: String,
         sourceUpdate: SourceUpdate,
         requestOptions userRequestOptions: RequestOptions? = nil
-    ) async throws -> Response<SourceWatchResponse> {
+    ) async throws -> Response<WatchResponse> {
         guard !sourceID.isEmpty else {
             throw AlgoliaError.invalidArgument("sourceID", "validateSourceBeforeUpdate")
         }

Sources/Ingestion/Models/SourceWatchResponse.swift renamed to Sources/Ingestion/Models/WatchResponse.swift

@@ -6,10 +6,10 @@ import Foundation
     import Core
 #endif
 
-public struct SourceWatchResponse: Codable, JSONEncodable {
+public struct WatchResponse: Codable, JSONEncodable {
     /// Universally unique identifier (UUID) of a task run.
     public var runID: String?
-    /// depending on the source type, the validation returns sampling data of your source (JSON, CSV, BigQuery).
+    /// when used with discovering or validating sources, the sampled data of your source is returned.
     public var data: [AnyCodable]?
     /// in case of error, observability events will be added to the response, if any.
     public var events: [Event]?
@@ -41,16 +41,16 @@ public struct SourceWatchResponse: Codable, JSONEncodable {
     }
 }
 
-extension SourceWatchResponse: Equatable {
-    public static func ==(lhs: SourceWatchResponse, rhs: SourceWatchResponse) -> Bool {
+extension WatchResponse: Equatable {
+    public static func ==(lhs: WatchResponse, rhs: WatchResponse) -> Bool {
         lhs.runID == rhs.runID &&
             lhs.data == rhs.data &&
             lhs.events == rhs.events &&
             lhs.message == rhs.message
     }
 }
 
-extension SourceWatchResponse: Hashable {
+extension WatchResponse: Hashable {
     public func hash(into hasher: inout Hasher) {
         hasher.combine(self.runID?.hashValue)
         hasher.combine(self.data?.hashValue)