Generate code using new template with additional perform_request arg

Author: estolfo

elasticsearch-api/lib/elasticsearch/api/actions/async_search/delete.rb

@@ -30,6 +30,14 @@ module Actions
         # @see https://www.elastic.co/guide/en/elasticsearch/reference/current/async-search.html
         #
         def delete(arguments = {})
+          request_opts = { endpoint: arguments[:endpoint] || "async_search.delete" }
+
+          defined_params = [:id].inject({}) do |set_variables, variable|
+            set_variables[variable] = arguments[variable] if arguments.key?(variable)
+            set_variables
+          end
+          request_opts[:defined_params] = defined_params unless defined_params.empty?
+
           raise ArgumentError, "Required argument 'id' missing" unless arguments[:id]
 
           arguments = arguments.clone
@@ -44,7 +52,7 @@ def delete(arguments = {})
           params = {}
 
           Elasticsearch::API::Response.new(
-            perform_request(method, path, params, body, headers)
+            perform_request(method, path, params, body, headers, request_opts)
           )
         end
       end

elasticsearch-api/lib/elasticsearch/api/actions/async_search/get.rb

@@ -33,6 +33,14 @@ module Actions
         # @see https://www.elastic.co/guide/en/elasticsearch/reference/current/async-search.html
         #
         def get(arguments = {})
+          request_opts = { endpoint: arguments[:endpoint] || "async_search.get" }
+
+          defined_params = [:id].inject({}) do |set_variables, variable|
+            set_variables[variable] = arguments[variable] if arguments.key?(variable)
+            set_variables
+          end
+          request_opts[:defined_params] = defined_params unless defined_params.empty?
+
           raise ArgumentError, "Required argument 'id' missing" unless arguments[:id]
 
           arguments = arguments.clone
@@ -47,7 +55,7 @@ def get(arguments = {})
           params = Utils.process_params(arguments)
 
           Elasticsearch::API::Response.new(
-            perform_request(method, path, params, body, headers)
+            perform_request(method, path, params, body, headers, request_opts)
           )
         end
       end

elasticsearch-api/lib/elasticsearch/api/actions/async_search/status.rb

@@ -30,6 +30,14 @@ module Actions
         # @see https://www.elastic.co/guide/en/elasticsearch/reference/current/async-search.html
         #
         def status(arguments = {})
+          request_opts = { endpoint: arguments[:endpoint] || "async_search.status" }
+
+          defined_params = [:id].inject({}) do |set_variables, variable|
+            set_variables[variable] = arguments[variable] if arguments.key?(variable)
+            set_variables
+          end
+          request_opts[:defined_params] = defined_params unless defined_params.empty?
+
           raise ArgumentError, "Required argument 'id' missing" unless arguments[:id]
 
           arguments = arguments.clone
@@ -44,7 +52,7 @@ def status(arguments = {})
           params = {}
 
           Elasticsearch::API::Response.new(
-            perform_request(method, path, params, body, headers)
+            perform_request(method, path, params, body, headers, request_opts)
           )
         end
       end

elasticsearch-api/lib/elasticsearch/api/actions/async_search/submit.rb

@@ -72,6 +72,14 @@ module Actions
         # @see https://www.elastic.co/guide/en/elasticsearch/reference/current/async-search.html
         #
         def submit(arguments = {})
+          request_opts = { endpoint: arguments[:endpoint] || "async_search.submit" }
+
+          defined_params = [:index].inject({}) do |set_variables, variable|
+            set_variables[variable] = arguments[variable] if arguments.key?(variable)
+            set_variables
+          end
+          request_opts[:defined_params] = defined_params unless defined_params.empty?
+
           arguments = arguments.clone
           headers = arguments.delete(:headers) || {}
 
@@ -88,7 +96,7 @@ def submit(arguments = {})
           params = Utils.process_params(arguments)
 
           Elasticsearch::API::Response.new(
-            perform_request(method, path, params, body, headers)
+            perform_request(method, path, params, body, headers, request_opts)
           )
         end
       end

elasticsearch-api/lib/elasticsearch/api/actions/autoscaling/delete_autoscaling_policy.rb

@@ -30,6 +30,14 @@ module Actions
         # @see https://www.elastic.co/guide/en/elasticsearch/reference/current/autoscaling-delete-autoscaling-policy.html
         #
         def delete_autoscaling_policy(arguments = {})
+          request_opts = { endpoint: arguments[:endpoint] || "autoscaling.delete_autoscaling_policy" }
+
+          defined_params = [:name].inject({}) do |set_variables, variable|
+            set_variables[variable] = arguments[variable] if arguments.key?(variable)
+            set_variables
+          end
+          request_opts[:defined_params] = defined_params unless defined_params.empty?
+
           raise ArgumentError, "Required argument 'name' missing" unless arguments[:name]
 
           arguments = arguments.clone
@@ -44,7 +52,7 @@ def delete_autoscaling_policy(arguments = {})
           params = {}
 
           Elasticsearch::API::Response.new(
-            perform_request(method, path, params, body, headers)
+            perform_request(method, path, params, body, headers, request_opts)
           )
         end
       end

elasticsearch-api/lib/elasticsearch/api/actions/autoscaling/get_autoscaling_capacity.rb

@@ -29,6 +29,8 @@ module Actions
         # @see https://www.elastic.co/guide/en/elasticsearch/reference/current/autoscaling-get-autoscaling-capacity.html
         #
         def get_autoscaling_capacity(arguments = {})
+          request_opts = { endpoint: arguments[:endpoint] || "autoscaling.get_autoscaling_capacity" }
+
           arguments = arguments.clone
           headers = arguments.delete(:headers) || {}
 
@@ -39,7 +41,7 @@ def get_autoscaling_capacity(arguments = {})
           params = {}
 
           Elasticsearch::API::Response.new(
-            perform_request(method, path, params, body, headers)
+            perform_request(method, path, params, body, headers, request_opts)
           )
         end
       end

elasticsearch-api/lib/elasticsearch/api/actions/autoscaling/get_autoscaling_policy.rb

@@ -30,6 +30,14 @@ module Actions
         # @see https://www.elastic.co/guide/en/elasticsearch/reference/current/autoscaling-get-autoscaling-policy.html
         #
         def get_autoscaling_policy(arguments = {})
+          request_opts = { endpoint: arguments[:endpoint] || "autoscaling.get_autoscaling_policy" }
+
+          defined_params = [:name].inject({}) do |set_variables, variable|
+            set_variables[variable] = arguments[variable] if arguments.key?(variable)
+            set_variables
+          end
+          request_opts[:defined_params] = defined_params unless defined_params.empty?
+
           raise ArgumentError, "Required argument 'name' missing" unless arguments[:name]
 
           arguments = arguments.clone
@@ -44,7 +52,7 @@ def get_autoscaling_policy(arguments = {})
           params = {}
 
           Elasticsearch::API::Response.new(
-            perform_request(method, path, params, body, headers)
+            perform_request(method, path, params, body, headers, request_opts)
           )
         end
       end

elasticsearch-api/lib/elasticsearch/api/actions/autoscaling/put_autoscaling_policy.rb

@@ -31,6 +31,14 @@ module Actions
         # @see https://www.elastic.co/guide/en/elasticsearch/reference/current/autoscaling-put-autoscaling-policy.html
         #
         def put_autoscaling_policy(arguments = {})
+          request_opts = { endpoint: arguments[:endpoint] || "autoscaling.put_autoscaling_policy" }
+
+          defined_params = [:name].inject({}) do |set_variables, variable|
+            set_variables[variable] = arguments[variable] if arguments.key?(variable)
+            set_variables
+          end
+          request_opts[:defined_params] = defined_params unless defined_params.empty?
+
           raise ArgumentError, "Required argument 'body' missing" unless arguments[:body]
           raise ArgumentError, "Required argument 'name' missing" unless arguments[:name]
 
@@ -46,7 +54,7 @@ def put_autoscaling_policy(arguments = {})
           params = {}
 
           Elasticsearch::API::Response.new(
-            perform_request(method, path, params, body, headers)
+            perform_request(method, path, params, body, headers, request_opts)
           )
         end
       end

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

@@ -41,6 +41,14 @@ module Actions
       # @see https://www.elastic.co/guide/en/elasticsearch/reference/current/docs-bulk.html
       #
       def bulk(arguments = {})
+        request_opts = { endpoint: arguments[:endpoint] || "bulk" }
+
+        defined_params = [:index].inject({}) do |set_variables, variable|
+          set_variables[variable] = arguments[variable] if arguments.key?(variable)
+          set_variables
+        end
+        request_opts[:defined_params] = defined_params unless defined_params.empty?
+
         raise ArgumentError, "Required argument 'body' missing" unless arguments[:body]
 
         arguments = arguments.clone
@@ -66,7 +74,7 @@ def bulk(arguments = {})
 
         headers.merge!("Content-Type" => "application/x-ndjson")
         Elasticsearch::API::Response.new(
-          perform_request(method, path, params, payload, headers)
+          perform_request(method, path, params, payload, headers, request_opts)
         )
       end
     end

elasticsearch-api/lib/elasticsearch/api/actions/cat/aliases.rb

@@ -37,6 +37,14 @@ module Actions
         # @see https://www.elastic.co/guide/en/elasticsearch/reference/current/cat-alias.html
         #
         def aliases(arguments = {})
+          request_opts = { endpoint: arguments[:endpoint] || "cat.aliases" }
+
+          defined_params = [:name].inject({}) do |set_variables, variable|
+            set_variables[variable] = arguments[variable] if arguments.key?(variable)
+            set_variables
+          end
+          request_opts[:defined_params] = defined_params unless defined_params.empty?
+
           arguments = arguments.clone
           headers = arguments.delete(:headers) || {}
 
@@ -54,7 +62,7 @@ def aliases(arguments = {})
           params[:h] = Utils.__listify(params[:h]) if params[:h]
 
           Elasticsearch::API::Response.new(
-            perform_request(method, path, params, body, headers)
+            perform_request(method, path, params, body, headers, request_opts)
           )
         end
       end

elasticsearch-api/lib/elasticsearch/api/actions/cat/allocation.rb

@@ -38,6 +38,14 @@ module Actions
         # @see https://www.elastic.co/guide/en/elasticsearch/reference/current/cat-allocation.html
         #
         def allocation(arguments = {})
+          request_opts = { endpoint: arguments[:endpoint] || "cat.allocation" }
+
+          defined_params = [:node_id].inject({}) do |set_variables, variable|
+            set_variables[variable] = arguments[variable] if arguments.key?(variable)
+            set_variables
+          end
+          request_opts[:defined_params] = defined_params unless defined_params.empty?
+
           arguments = arguments.clone
           headers = arguments.delete(:headers) || {}
 
@@ -55,7 +63,7 @@ def allocation(arguments = {})
           params[:h] = Utils.__listify(params[:h]) if params[:h]
 
           Elasticsearch::API::Response.new(
-            perform_request(method, path, params, body, headers)
+            perform_request(method, path, params, body, headers, request_opts)
           )
         end
       end

elasticsearch-api/lib/elasticsearch/api/actions/cat/component_templates.rb

@@ -37,6 +37,14 @@ module Actions
         # @see https://www.elastic.co/guide/en/elasticsearch/reference/current/cat-component-templates.html
         #
         def component_templates(arguments = {})
+          request_opts = { endpoint: arguments[:endpoint] || "cat.component_templates" }
+
+          defined_params = [:name].inject({}) do |set_variables, variable|
+            set_variables[variable] = arguments[variable] if arguments.key?(variable)
+            set_variables
+          end
+          request_opts[:defined_params] = defined_params unless defined_params.empty?
+
           arguments = arguments.clone
           headers = arguments.delete(:headers) || {}
 
@@ -53,7 +61,7 @@ def component_templates(arguments = {})
           params = Utils.process_params(arguments)
 
           Elasticsearch::API::Response.new(
-            perform_request(method, path, params, body, headers)
+            perform_request(method, path, params, body, headers, request_opts)
           )
         end
       end

elasticsearch-api/lib/elasticsearch/api/actions/cat/count.rb

@@ -35,6 +35,14 @@ module Actions
         # @see https://www.elastic.co/guide/en/elasticsearch/reference/current/cat-count.html
         #
         def count(arguments = {})
+          request_opts = { endpoint: arguments[:endpoint] || "cat.count" }
+
+          defined_params = [:index].inject({}) do |set_variables, variable|
+            set_variables[variable] = arguments[variable] if arguments.key?(variable)
+            set_variables
+          end
+          request_opts[:defined_params] = defined_params unless defined_params.empty?
+
           arguments = arguments.clone
           headers = arguments.delete(:headers) || {}
 
@@ -52,7 +60,7 @@ def count(arguments = {})
           params[:h] = Utils.__listify(params[:h]) if params[:h]
 
           Elasticsearch::API::Response.new(
-            perform_request(method, path, params, body, headers)
+            perform_request(method, path, params, body, headers, request_opts)
           )
         end
       end

elasticsearch-api/lib/elasticsearch/api/actions/cat/fielddata.rb

@@ -36,6 +36,14 @@ module Actions
         # @see https://www.elastic.co/guide/en/elasticsearch/reference/current/cat-fielddata.html
         #
         def fielddata(arguments = {})
+          request_opts = { endpoint: arguments[:endpoint] || "cat.fielddata" }
+
+          defined_params = [:fields].inject({}) do |set_variables, variable|
+            set_variables[variable] = arguments[variable] if arguments.key?(variable)
+            set_variables
+          end
+          request_opts[:defined_params] = defined_params unless defined_params.empty?
+
           arguments = arguments.clone
           headers = arguments.delete(:headers) || {}
 
@@ -52,7 +60,7 @@ def fielddata(arguments = {})
           params = Utils.process_params(arguments)
 
           Elasticsearch::API::Response.new(
-            perform_request(method, path, params, body, headers)
+            perform_request(method, path, params, body, headers, request_opts)
           )
         end
       end

elasticsearch-api/lib/elasticsearch/api/actions/cat/health.rb

@@ -36,6 +36,8 @@ module Actions
         # @see https://www.elastic.co/guide/en/elasticsearch/reference/current/cat-health.html
         #
         def health(arguments = {})
+          request_opts = { endpoint: arguments[:endpoint] || "cat.health" }
+
           arguments = arguments.clone
           headers = arguments.delete(:headers) || {}
 
@@ -47,7 +49,7 @@ def health(arguments = {})
           params[:h] = Utils.__listify(params[:h]) if params[:h]
 
           Elasticsearch::API::Response.new(
-            perform_request(method, path, params, body, headers)
+            perform_request(method, path, params, body, headers, request_opts)
           )
         end
       end

elasticsearch-api/lib/elasticsearch/api/actions/cat/help.rb

@@ -31,6 +31,8 @@ module Actions
         # @see https://www.elastic.co/guide/en/elasticsearch/reference/current/cat.html
         #
         def help(arguments = {})
+          request_opts = { endpoint: arguments[:endpoint] || "cat.help" }
+
           arguments = arguments.clone
           headers = arguments.delete(:headers) || {}
 
@@ -41,7 +43,7 @@ def help(arguments = {})
           params = Utils.process_params(arguments)
 
           Elasticsearch::API::Response.new(
-            perform_request(method, path, params, body, headers)
+            perform_request(method, path, params, body, headers, request_opts)
           )
         end
       end

elasticsearch-api/lib/elasticsearch/api/actions/cat/indices.rb

@@ -42,6 +42,14 @@ module Actions
         # @see https://www.elastic.co/guide/en/elasticsearch/reference/current/cat-indices.html
         #
         def indices(arguments = {})
+          request_opts = { endpoint: arguments[:endpoint] || "cat.indices" }
+
+          defined_params = [:index].inject({}) do |set_variables, variable|
+            set_variables[variable] = arguments[variable] if arguments.key?(variable)
+            set_variables
+          end
+          request_opts[:defined_params] = defined_params unless defined_params.empty?
+
           arguments = arguments.clone
           headers = arguments.delete(:headers) || {}
 
@@ -59,7 +67,7 @@ def indices(arguments = {})
           params[:h] = Utils.__listify(params[:h]) if params[:h]
 
           Elasticsearch::API::Response.new(
-            perform_request(method, path, params, body, headers)
+            perform_request(method, path, params, body, headers, request_opts)
           )
         end
       end