[API] Updates [delete/update]_by_query, transform APIs

Author: picandocodigo

elasticsearch-api/lib/elasticsearch/api/actions/delete_by_query.rb

@@ -41,9 +41,6 @@ module Actions
       # @option arguments [Number] :size Deprecated, please use `max_docs` instead
       # @option arguments [Number] :max_docs Maximum number of documents to process (default: all documents)
       # @option arguments [List] :sort A comma-separated list of <field>:<direction> pairs
-      # @option arguments [List] :_source True or false to return the _source field or not, or a list of fields to return
-      # @option arguments [List] :_source_excludes A list of fields to exclude from the returned _source field
-      # @option arguments [List] :_source_includes A list of fields to extract and return from the _source field
       # @option arguments [Number] :terminate_after The maximum number of documents to collect for each shard, upon reaching which the query execution will terminate early.
       # @option arguments [List] :stats Specific 'tag' of the request for logging and statistical purposes
       # @option arguments [Boolean] :version Specify whether to return document version as part of a hit
@@ -112,9 +109,6 @@ def delete_by_query(arguments = {})
         :size,
         :max_docs,
         :sort,
-        :_source,
-        :_source_excludes,
-        :_source_includes,
         :terminate_after,
         :stats,
         :version,

elasticsearch-api/lib/elasticsearch/api/actions/update_by_query.rb

@@ -43,9 +43,6 @@ module Actions
       # @option arguments [Number] :size Deprecated, please use `max_docs` instead
       # @option arguments [Number] :max_docs Maximum number of documents to process (default: all documents)
       # @option arguments [List] :sort A comma-separated list of <field>:<direction> pairs
-      # @option arguments [List] :_source True or false to return the _source field or not, or a list of fields to return
-      # @option arguments [List] :_source_excludes A list of fields to exclude from the returned _source field
-      # @option arguments [List] :_source_includes A list of fields to extract and return from the _source field
       # @option arguments [Number] :terminate_after The maximum number of documents to collect for each shard, upon reaching which the query execution will terminate early.
       # @option arguments [List] :stats Specific 'tag' of the request for logging and statistical purposes
       # @option arguments [Boolean] :version Specify whether to return document version as part of a hit
@@ -115,9 +112,6 @@ def update_by_query(arguments = {})
         :size,
         :max_docs,
         :sort,
-        :_source,
-        :_source_excludes,
-        :_source_includes,
         :terminate_after,
         :stats,
         :version,

elasticsearch-xpack/lib/elasticsearch/xpack/api/actions/transform/delete_transform.rb

@@ -24,6 +24,7 @@ module Actions
           #
           # @option arguments [String] :transform_id The id of the transform to delete
           # @option arguments [Boolean] :force When `true`, the transform is deleted regardless of its current state. The default value is `false`, meaning that the transform must be `stopped` before it can be deleted.
+          # @option arguments [Time] :timeout Controls the time to wait for the transform deletion
           # @option arguments [Hash] :headers Custom HTTP headers
           #
           # @see https://www.elastic.co/guide/en/elasticsearch/reference/7.16/delete-transform.html
@@ -49,7 +50,8 @@ def delete_transform(arguments = {})
           #
           # @since 6.2.0
           ParamsRegistry.register(:delete_transform, [
-            :force
+            :force,
+            :timeout
           ].freeze)
         end
       end

elasticsearch-xpack/lib/elasticsearch/xpack/api/actions/transform/preview_transform.rb

@@ -23,6 +23,7 @@ module Actions
           # Previews a transform.
           #
           # @option arguments [String] :transform_id The id of the transform to preview.
+          # @option arguments [Time] :timeout Controls the time to wait for the preview
           # @option arguments [Hash] :headers Custom HTTP headers
           # @option arguments [Hash] :body The definition for the transform to preview
           #
@@ -46,11 +47,18 @@ def preview_transform(arguments = {})
                      else
                        "_transform/_preview"
                      end
-            params = {}
+            params = Elasticsearch::API::Utils.__validate_and_extract_params arguments, ParamsRegistry.get(__method__)
 
             body = arguments[:body]
             perform_request(method, path, params, body, headers).body
           end
+
+          # Register this action with its valid params when the module is loaded.
+          #
+          # @since 6.2.0
+          ParamsRegistry.register(:preview_transform, [
+            :timeout
+          ].freeze)
         end
       end
     end

elasticsearch-xpack/lib/elasticsearch/xpack/api/actions/transform/put_transform.rb

@@ -24,6 +24,7 @@ module Actions
           #
           # @option arguments [String] :transform_id The id of the new transform.
           # @option arguments [Boolean] :defer_validation If validations should be deferred until transform starts, defaults to false.
+          # @option arguments [Time] :timeout Controls the time to wait for the transform to start
           # @option arguments [Hash] :headers Custom HTTP headers
           # @option arguments [Hash] :body The transform definition (*Required*)
           #
@@ -51,7 +52,8 @@ def put_transform(arguments = {})
           #
           # @since 6.2.0
           ParamsRegistry.register(:put_transform, [
-            :defer_validation
+            :defer_validation,
+            :timeout
           ].freeze)
         end
       end

elasticsearch-xpack/lib/elasticsearch/xpack/api/actions/transform/update_transform.rb

@@ -24,6 +24,7 @@ module Actions
           #
           # @option arguments [String] :transform_id The id of the transform. (*Required*)
           # @option arguments [Boolean] :defer_validation If validations should be deferred until transform starts, defaults to false.
+          # @option arguments [Time] :timeout Controls the time to wait for the update
           # @option arguments [Hash] :headers Custom HTTP headers
           # @option arguments [Hash] :body The update transform definition (*Required*)
           #
@@ -51,7 +52,8 @@ def update_transform(arguments = {})
           #
           # @since 6.2.0
           ParamsRegistry.register(:update_transform, [
-            :defer_validation
+            :defer_validation,
+            :timeout
           ].freeze)
         end
       end

elasticsearch-xpack/lib/elasticsearch/xpack/api/actions/transform/upgrade_transforms.rb

@@ -23,6 +23,7 @@ module Actions
           # Upgrades all transforms.
           #
           # @option arguments [Boolean] :dry_run Whether to only check for updates but don't execute
+          # @option arguments [Time] :timeout Controls the time to wait for the upgrade
           # @option arguments [Hash] :headers Custom HTTP headers
           #
           # @see https://www.elastic.co/guide/en/elasticsearch/reference/7.16/upgrade-transforms.html
@@ -44,7 +45,8 @@ def upgrade_transforms(arguments = {})
           #
           # @since 6.2.0
           ParamsRegistry.register(:upgrade_transforms, [
-            :dry_run
+            :dry_run,
+            :timeout
           ].freeze)
         end
       end