feat(specs): add subscriptionAction to ingestion specs (generated)

algolia/api-clients-automation#4587

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

Author: algolia-bot

Sources/Ingestion/Models/IngestionTask.swift

@@ -25,6 +25,7 @@ public struct IngestionTask: Codable, JSONEncodable {
     /// Maximum accepted percentage of failures for a task run to finish successfully.
     public var failureThreshold: Int?
     public var action: ActionType?
+    public var subscriptionAction: ActionType?
     /// Date of the last cursor in RFC 3339 format.
     public var cursor: String?
     public var notifications: Notifications?
@@ -45,6 +46,7 @@ public struct IngestionTask: Codable, JSONEncodable {
         enabled: Bool,
         failureThreshold: Int? = nil,
         action: ActionType? = nil,
+        subscriptionAction: ActionType? = nil,
         cursor: String? = nil,
         notifications: Notifications? = nil,
         policies: Policies? = nil,
@@ -61,6 +63,7 @@ public struct IngestionTask: Codable, JSONEncodable {
         self.enabled = enabled
         self.failureThreshold = failureThreshold
         self.action = action
+        self.subscriptionAction = subscriptionAction
         self.cursor = cursor
         self.notifications = notifications
         self.policies = policies
@@ -79,6 +82,7 @@ public struct IngestionTask: Codable, JSONEncodable {
         case enabled
         case failureThreshold
         case action
+        case subscriptionAction
         case cursor
         case notifications
         case policies
@@ -100,6 +104,7 @@ public struct IngestionTask: Codable, JSONEncodable {
         try container.encode(self.enabled, forKey: .enabled)
         try container.encodeIfPresent(self.failureThreshold, forKey: .failureThreshold)
         try container.encodeIfPresent(self.action, forKey: .action)
+        try container.encodeIfPresent(self.subscriptionAction, forKey: .subscriptionAction)
         try container.encodeIfPresent(self.cursor, forKey: .cursor)
         try container.encodeIfPresent(self.notifications, forKey: .notifications)
         try container.encodeIfPresent(self.policies, forKey: .policies)
@@ -120,6 +125,7 @@ extension IngestionTask: Equatable {
             lhs.enabled == rhs.enabled &&
             lhs.failureThreshold == rhs.failureThreshold &&
             lhs.action == rhs.action &&
+            lhs.subscriptionAction == rhs.subscriptionAction &&
             lhs.cursor == rhs.cursor &&
             lhs.notifications == rhs.notifications &&
             lhs.policies == rhs.policies &&
@@ -140,6 +146,7 @@ extension IngestionTask: Hashable {
         hasher.combine(self.enabled.hashValue)
         hasher.combine(self.failureThreshold?.hashValue)
         hasher.combine(self.action?.hashValue)
+        hasher.combine(self.subscriptionAction?.hashValue)
         hasher.combine(self.cursor?.hashValue)
         hasher.combine(self.notifications?.hashValue)
         hasher.combine(self.policies?.hashValue)

Sources/Ingestion/Models/TaskCreate.swift

@@ -13,6 +13,7 @@ public struct TaskCreate: Codable, JSONEncodable {
     /// Universally unique identifier (UUID) of a destination resource.
     public var destinationID: String
     public var action: ActionType
+    public var subscriptionAction: ActionType?
     /// Cron expression for the task's schedule.
     public var cron: String?
     /// Whether the task is enabled.
@@ -29,6 +30,7 @@ public struct TaskCreate: Codable, JSONEncodable {
         sourceID: String,
         destinationID: String,
         action: ActionType,
+        subscriptionAction: ActionType? = nil,
         cron: String? = nil,
         enabled: Bool? = nil,
         failureThreshold: Int? = nil,
@@ -40,6 +42,7 @@ public struct TaskCreate: Codable, JSONEncodable {
         self.sourceID = sourceID
         self.destinationID = destinationID
         self.action = action
+        self.subscriptionAction = subscriptionAction
         self.cron = cron
         self.enabled = enabled
         self.failureThreshold = failureThreshold
@@ -53,6 +56,7 @@ public struct TaskCreate: Codable, JSONEncodable {
         case sourceID
         case destinationID
         case action
+        case subscriptionAction
         case cron
         case enabled
         case failureThreshold
@@ -69,6 +73,7 @@ public struct TaskCreate: Codable, JSONEncodable {
         try container.encode(self.sourceID, forKey: .sourceID)
         try container.encode(self.destinationID, forKey: .destinationID)
         try container.encode(self.action, forKey: .action)
+        try container.encodeIfPresent(self.subscriptionAction, forKey: .subscriptionAction)
         try container.encodeIfPresent(self.cron, forKey: .cron)
         try container.encodeIfPresent(self.enabled, forKey: .enabled)
         try container.encodeIfPresent(self.failureThreshold, forKey: .failureThreshold)
@@ -84,6 +89,7 @@ extension TaskCreate: Equatable {
         lhs.sourceID == rhs.sourceID &&
             lhs.destinationID == rhs.destinationID &&
             lhs.action == rhs.action &&
+            lhs.subscriptionAction == rhs.subscriptionAction &&
             lhs.cron == rhs.cron &&
             lhs.enabled == rhs.enabled &&
             lhs.failureThreshold == rhs.failureThreshold &&
@@ -99,6 +105,7 @@ extension TaskCreate: Hashable {
         hasher.combine(self.sourceID.hashValue)
         hasher.combine(self.destinationID.hashValue)
         hasher.combine(self.action.hashValue)
+        hasher.combine(self.subscriptionAction?.hashValue)
         hasher.combine(self.cron?.hashValue)
         hasher.combine(self.enabled?.hashValue)
         hasher.combine(self.failureThreshold?.hashValue)

Sources/Ingestion/Models/TaskUpdate.swift

@@ -15,6 +15,7 @@ public struct TaskUpdate: Codable, JSONEncodable {
     public var input: TaskInput?
     /// Whether the task is enabled.
     public var enabled: Bool?
+    public var subscriptionAction: ActionType?
     /// Maximum accepted percentage of failures for a task run to finish successfully.
     public var failureThreshold: Int?
     public var notifications: Notifications?
@@ -25,6 +26,7 @@ public struct TaskUpdate: Codable, JSONEncodable {
         cron: String? = nil,
         input: TaskInput? = nil,
         enabled: Bool? = nil,
+        subscriptionAction: ActionType? = nil,
         failureThreshold: Int? = nil,
         notifications: Notifications? = nil,
         policies: Policies? = nil
@@ -33,6 +35,7 @@ public struct TaskUpdate: Codable, JSONEncodable {
         self.cron = cron
         self.input = input
         self.enabled = enabled
+        self.subscriptionAction = subscriptionAction
         self.failureThreshold = failureThreshold
         self.notifications = notifications
         self.policies = policies
@@ -43,6 +46,7 @@ public struct TaskUpdate: Codable, JSONEncodable {
         case cron
         case input
         case enabled
+        case subscriptionAction
         case failureThreshold
         case notifications
         case policies
@@ -56,6 +60,7 @@ public struct TaskUpdate: Codable, JSONEncodable {
         try container.encodeIfPresent(self.cron, forKey: .cron)
         try container.encodeIfPresent(self.input, forKey: .input)
         try container.encodeIfPresent(self.enabled, forKey: .enabled)
+        try container.encodeIfPresent(self.subscriptionAction, forKey: .subscriptionAction)
         try container.encodeIfPresent(self.failureThreshold, forKey: .failureThreshold)
         try container.encodeIfPresent(self.notifications, forKey: .notifications)
         try container.encodeIfPresent(self.policies, forKey: .policies)
@@ -68,6 +73,7 @@ extension TaskUpdate: Equatable {
             lhs.cron == rhs.cron &&
             lhs.input == rhs.input &&
             lhs.enabled == rhs.enabled &&
+            lhs.subscriptionAction == rhs.subscriptionAction &&
             lhs.failureThreshold == rhs.failureThreshold &&
             lhs.notifications == rhs.notifications &&
             lhs.policies == rhs.policies
@@ -80,6 +86,7 @@ extension TaskUpdate: Hashable {
         hasher.combine(self.cron?.hashValue)
         hasher.combine(self.input?.hashValue)
         hasher.combine(self.enabled?.hashValue)
+        hasher.combine(self.subscriptionAction?.hashValue)
         hasher.combine(self.failureThreshold?.hashValue)
         hasher.combine(self.notifications?.hashValue)
         hasher.combine(self.policies?.hashValue)