def run_request(method, url, headers={}, data=false, limit=nil, raw=false)
json_body = data ? Chef::JSONCompat.to_json(data) : nil
json_body.force_encoding(Encoding::BINARY) if json_body.respond_to?(:force_encoding)
headers = build_headers(method, url, headers, json_body, raw)
tf, response_body = nil, nil
retriable_rest_request(method, url, json_body, headers) do |rest_request|
res = rest_request.call do |response|
if raw
tf = stream_to_tempfile(url, response)
else
response_body = decompress_body(response)
end
end
case res
when Net::HTTPSuccess
if res['content-type'] =~ /json/
Chef::JSONCompat.from_json(response_body)
else
if method == :HEAD
true
elsif raw
tf
else
response_body
end
end
when Net::HTTPNotModified
false
when Net::HTTPRedirection
follow_redirect {run_request(method, create_url(res['location']), headers, false, nil, raw)}
else
if res['content-type'] =~ /json/
exception = Chef::JSONCompat.from_json(response_body)
msg = "HTTP Request Returned #{res.code} #{res.message}: "
msg << (exception["error"].respond_to?(:join) ? exception["error"].join(", ") : exception["error"].to_s)
Chef::Log.warn(msg)
end
res.error!
end
end
end