Class: Chef::HTTP
- Inherits:
-
Object
- Object
- Chef::HTTP
- Defined in:
- lib/chef/http.rb,
lib/chef/http/simple.rb,
lib/chef/http/cookie_jar.rb,
lib/chef/http/json_input.rb,
lib/chef/http/json_output.rb,
lib/chef/http/simple_json.rb,
lib/chef/http/api_versions.rb,
lib/chef/http/basic_client.rb,
lib/chef/http/decompressor.rb,
lib/chef/http/http_request.rb,
lib/chef/http/ssl_policies.rb,
lib/chef/http/authenticator.rb,
lib/chef/http/cookie_manager.rb,
lib/chef/http/auth_credentials.rb,
lib/chef/http/remote_request_id.rb,
lib/chef/http/json_to_model_output.rb,
lib/chef/http/validate_content_length.rb,
lib/chef/http/socketless_chef_zero_client.rb
Overview
Chef::HTTP
Basic HTTP client, with support for adding features via middleware
Direct Known Subclasses
Simple, SimpleJSON, Knife::Raw::RawInputServerAPI, ServerAPI
Defined Under Namespace
Classes: APISSLPolicy, APIVersions, AuthCredentials, Authenticator, BasicClient, CookieJar, CookieManager, Decompressor, DefaultSSLPolicy, HTTPRequest, JSONInput, JSONOutput, JSONToModelOutput, RemoteRequestID, Simple, SimpleJSON, SocketlessChefZeroClient, StreamHandler, ValidateContentLength
Instance Attribute Summary collapse
-
#keepalives ⇒ Object
readonly
- Boolean
-
if we’re doing keepalives or not.
-
#middlewares ⇒ Object
readonly
Returns the value of attribute middlewares.
-
#options ⇒ Object
readonly
Returns the value of attribute options.
-
#redirect_limit ⇒ Object
readonly
Returns the value of attribute redirect_limit.
-
#sign_on_redirect ⇒ Object
readonly
Returns the value of attribute sign_on_redirect.
-
#url ⇒ Object
readonly
Returns the value of attribute url.
Class Method Summary collapse
Instance Method Summary collapse
-
#delete(path, headers = {}) ⇒ Object
Send an HTTP DELETE request to the path.
-
#get(path, headers = {}) ⇒ Object
Send an HTTP GET request to the path.
-
#head(path, headers = {}) ⇒ Object
Send an HTTP HEAD request to the path.
- #http_client(base_url = nil) ⇒ Object
-
#initialize(url, options = {}) ⇒ HTTP
constructor
Create a HTTP client object.
-
#last_response ⇒ Object
DEPRECATED: This is only kept around to provide access to cache control data in lib/chef/provider/remote_file/http.rb FIXME: Find a better API.
-
#post(path, json, headers = {}) ⇒ Object
Send an HTTP POST request to the path.
-
#put(path, json, headers = {}) ⇒ Object
Send an HTTP PUT request to the path.
-
#request(method, path, headers = {}, data = false) ⇒ Object
Makes an HTTP request to
path
with the givenmethod
,headers
, anddata
(if applicable). -
#streaming_request(path, headers = {}, tempfile = nil) {|tempfile| ... } ⇒ Object
Makes a streaming download request, streaming the response body to a tempfile.
- #streaming_request_with_progress(path, headers = {}, tempfile = nil, &progress_block) ⇒ Object
Constructor Details
#initialize(url, options = {}) ⇒ HTTP
Create a HTTP client object. The supplied url
is used as the base for all subsequent requests. For example, when initialized with a base url localhost:4000, a call to get
with ‘nodes’ will make an HTTP GET request to localhost:4000/nodes
87 88 89 90 91 92 93 94 95 96 97 98 99 100 |
# File 'lib/chef/http.rb', line 87 def initialize(url, = {}) @url = url @default_headers = [:headers] || {} @sign_on_redirect = true @redirects_followed = 0 @redirect_limit = 10 @keepalives = [:keepalives] || false = @middlewares = [] self.class.middlewares.each do |middleware_class| @middlewares << middleware_class.new() end end |
Instance Attribute Details
#keepalives ⇒ Object (readonly)
- Boolean
-
if we’re doing keepalives or not
81 82 83 |
# File 'lib/chef/http.rb', line 81 def keepalives @keepalives end |
#middlewares ⇒ Object (readonly)
Returns the value of attribute middlewares.
78 79 80 |
# File 'lib/chef/http.rb', line 78 def middlewares @middlewares end |
#options ⇒ Object (readonly)
Returns the value of attribute options.
76 77 78 |
# File 'lib/chef/http.rb', line 76 def end |
#redirect_limit ⇒ Object (readonly)
Returns the value of attribute redirect_limit.
74 75 76 |
# File 'lib/chef/http.rb', line 74 def redirect_limit @redirect_limit end |
#sign_on_redirect ⇒ Object (readonly)
Returns the value of attribute sign_on_redirect.
73 74 75 |
# File 'lib/chef/http.rb', line 73 def sign_on_redirect @sign_on_redirect end |
#url ⇒ Object (readonly)
Returns the value of attribute url.
72 73 74 |
# File 'lib/chef/http.rb', line 72 def url @url end |
Class Method Details
.middlewares ⇒ Object
64 65 66 |
# File 'lib/chef/http.rb', line 64 def self.middlewares @middlewares ||= [] end |
.use(middleware_class) ⇒ Object
68 69 70 |
# File 'lib/chef/http.rb', line 68 def self.use(middleware_class) middlewares << middleware_class end |
Instance Method Details
#delete(path, headers = {}) ⇒ Object
Send an HTTP DELETE request to the path
Parameters
- path
-
path part of the request URL
138 139 140 |
# File 'lib/chef/http.rb', line 138 def delete(path, headers = {}) request(:DELETE, path, headers) end |
#get(path, headers = {}) ⇒ Object
Send an HTTP GET request to the path
Parameters
- path
-
The path to GET
114 115 116 |
# File 'lib/chef/http.rb', line 114 def get(path, headers = {}) request(:GET, path, headers) end |
#head(path, headers = {}) ⇒ Object
Send an HTTP HEAD request to the path
Parameters
- path
-
path part of the request URL
106 107 108 |
# File 'lib/chef/http.rb', line 106 def head(path, headers = {}) request(:HEAD, path, headers) end |
#http_client(base_url = nil) ⇒ Object
267 268 269 270 271 272 273 274 275 276 277 278 279 280 281 282 283 |
# File 'lib/chef/http.rb', line 267 def http_client(base_url = nil) base_url ||= url if keepalives && !base_url.nil? # only reuse the http_client if we want keepalives and have a base_url @http_client ||= {} # the per-host per-port cache here gets peristent connections correct when # redirecting to different servers if base_url.is_a?(String) # sigh, this kind of abuse can't happen with strongly typed languages @http_client[base_url] ||= build_http_client(base_url) else @http_client[base_url.host] ||= {} @http_client[base_url.host][base_url.port] ||= build_http_client(base_url) end else build_http_client(base_url) end end |
#last_response ⇒ Object
DEPRECATED: This is only kept around to provide access to cache control data in lib/chef/provider/remote_file/http.rb FIXME: Find a better API.
288 289 290 |
# File 'lib/chef/http.rb', line 288 def last_response @last_response end |
#post(path, json, headers = {}) ⇒ Object
Send an HTTP POST request to the path
Parameters
- path
-
path part of the request URL
130 131 132 |
# File 'lib/chef/http.rb', line 130 def post(path, json, headers = {}) request(:POST, path, headers, json) end |
#put(path, json, headers = {}) ⇒ Object
Send an HTTP PUT request to the path
Parameters
- path
-
path part of the request URL
122 123 124 |
# File 'lib/chef/http.rb', line 122 def put(path, json, headers = {}) request(:PUT, path, headers, json) end |
#request(method, path, headers = {}, data = false) ⇒ Object
Makes an HTTP request to path
with the given method
, headers
, and data
(if applicable).
144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 |
# File 'lib/chef/http.rb', line 144 def request(method, path, headers = {}, data = false) http_attempts ||= 0 url = create_url(path) processed_method, url, processed_headers, processed_data = apply_request_middleware(method, url, headers, data) response, rest_request, return_value = send_http_request(processed_method, url, processed_headers, processed_data) response, rest_request, return_value = apply_response_middleware(response, rest_request, return_value) response.error! unless success_response?(response) return_value rescue Net::HTTPClientException => e http_attempts += 1 response = e.response if response.is_a?(Net::HTTPNotAcceptable) && version_retries - http_attempts > 0 Chef::Log.trace("Negotiating protocol version with #{url}, retry #{http_attempts}/#{version_retries}") retry else raise end rescue Exception => exception log_failed_request(response, return_value) unless response.nil? if exception.respond_to?(:chef_rest_request=) exception.chef_rest_request = rest_request end raise end |
#streaming_request(path, headers = {}, tempfile = nil) {|tempfile| ... } ⇒ Object
Makes a streaming download request, streaming the response body to a tempfile. If a block is given, the tempfile is passed to the block and the tempfile will automatically be unlinked after the block is executed.
If no block is given, the tempfile is returned, which means it’s up to you to unlink the tempfile when you’re done with it.
220 221 222 223 224 225 226 227 228 229 230 231 232 233 234 235 236 237 238 239 240 241 242 243 244 245 246 247 248 249 250 251 252 253 254 255 256 257 258 259 260 261 262 263 264 265 |
# File 'lib/chef/http.rb', line 220 def streaming_request(path, headers = {}, tempfile = nil) http_attempts ||= 0 url = create_url(path) response, rest_request, return_value = nil, nil, nil data = nil method = :GET method, url, processed_headers, data = apply_request_middleware(method, url, headers, data) response, rest_request, return_value = send_http_request(method, url, processed_headers, data) do |http_response| if http_response.is_a?(Net::HTTPSuccess) tempfile = stream_to_tempfile(url, http_response, tempfile) end apply_stream_complete_middleware(http_response, rest_request, return_value) end return nil if response.is_a?(Net::HTTPRedirection) unless response.is_a?(Net::HTTPSuccess) response.error! end if block_given? begin yield tempfile ensure tempfile && tempfile.close! end end tempfile rescue Net::HTTPClientException => e http_attempts += 1 response = e.response if response.is_a?(Net::HTTPNotAcceptable) && version_retries - http_attempts > 0 Chef::Log.trace("Negotiating protocol version with #{url}, retry #{http_attempts}/#{version_retries}") retry else raise end rescue Exception => e log_failed_request(response, return_value) unless response.nil? if e.respond_to?(:chef_rest_request=) e.chef_rest_request = rest_request end raise end |
#streaming_request_with_progress(path, headers = {}, tempfile = nil, &progress_block) ⇒ Object
173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 195 196 197 198 199 200 201 202 203 204 205 206 207 208 209 |
# File 'lib/chef/http.rb', line 173 def streaming_request_with_progress(path, headers = {}, tempfile = nil, &progress_block) http_attempts ||= 0 url = create_url(path) response, rest_request, return_value = nil, nil, nil data = nil method = :GET method, url, processed_headers, data = apply_request_middleware(method, url, headers, data) response, rest_request, return_value = send_http_request(method, url, processed_headers, data) do |http_response| if http_response.is_a?(Net::HTTPSuccess) tempfile = stream_to_tempfile(url, http_response, tempfile, &progress_block) end apply_stream_complete_middleware(http_response, rest_request, return_value) end return nil if response.is_a?(Net::HTTPRedirection) unless response.is_a?(Net::HTTPSuccess) response.error! end tempfile rescue Net::HTTPClientException => e http_attempts += 1 response = e.response if response.is_a?(Net::HTTPNotAcceptable) && version_retries - http_attempts > 0 Chef::Log.trace("Negotiating protocol version with #{url}, retry #{http_attempts}/#{version_retries}") retry else raise end rescue Exception => e log_failed_request(response, return_value) unless response.nil? if e.respond_to?(:chef_rest_request=) e.chef_rest_request = rest_request end raise end |