lib/elasticsearch/xpack/api/actions/watcher/ack_watch.rb in elasticsearch-xpack-7.4.0 vs lib/elasticsearch/xpack/api/actions/watcher/ack_watch.rb in elasticsearch-xpack-7.5.0.pre.pre

@@ -5,40 +5,39 @@
 module Elasticsearch
   module XPack
     module API
       module Watcher
         module Actions
+          # TODO: Description
 
-          # Acknowledge watch actions to throttle their executions
           #
-          # @option arguments [String] :watch_id Watch ID (*Required*)
-          # @option arguments [List] :action_id A comma-separated list of the action ids to be acked (default: all)
-          # @option arguments [Duration] :master_timeout Specify timeout for watch write operation
+          # @option arguments [String] :watch_id Watch ID
+          # @option arguments [List] :action_id A comma-separated list of the action ids to be acked
+
           #
-          # @see http://www.elastic.co/guide/en/x-pack/current/watcher-api-ack-watch.html
+          # @see http://www.elastic.co/guide/en/elasticsearch/reference/current/watcher-api-ack-watch.html
           #
-          def ack_watch(arguments={})
+          def ack_watch(arguments = {})
             raise ArgumentError, "Required argument 'watch_id' missing" unless arguments[:watch_id]
+
             arguments = arguments.clone
-            watch_id  = arguments.delete(:watch_id)
-            action_id  = arguments.delete(:action_id)
 
-            method = Elasticsearch::API::HTTP_PUT
+            _watch_id = arguments.delete(:watch_id)
 
-            path   = "_xpack/watcher/watch/#{watch_id}/_ack"
-            path << "/#{action_id}" if action_id
+            _action_id = arguments.delete(:action_id)
 
-            params = Elasticsearch::API::Utils.__validate_and_extract_params arguments, ParamsRegistry.get(__method__)
-            body   = nil
+            method = Elasticsearch::API::HTTP_PUT
+            path   = if _watch_id && _action_id
+                       "_watcher/watch/#{Elasticsearch::API::Utils.__listify(_watch_id)}/_ack/#{Elasticsearch::API::Utils.__listify(_action_id)}"
+                     else
+                       "_watcher/watch/#{Elasticsearch::API::Utils.__listify(_watch_id)}/_ack"
+  end
+            params = {}
 
+            body = nil
             perform_request(method, path, params, body).body
           end
-
-          # Register this action with its valid params when the module is loaded.
-          #
-          # @since 7.4.0
-          ParamsRegistry.register(:ack_watch, [ :master_timeout ].freeze)
-        end
       end
+    end
     end
   end
 end