1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
|
# encoding: utf-8
# Copyright (c) Microsoft Corporation. All rights reserved.
# Licensed under the MIT License. See License.txt in the project root for license information.
module MsRest
#
# Class which represents the data received and deserialized from server.
#
class HttpOperationRequest
# @return [Hash] path parameters to be ERB::Util.url_encode encoded
attr_accessor :path_params
# @return [Hash] path parameters not to be ERB::Util.url_encode encoded
attr_accessor :skip_encoding_path_params
# @return [Hash] query parameters to be ERB::Util.url_encode encoded
attr_accessor :query_params
# @return [Hash] query parameters to be ERB::Util.url_encode encoded
attr_accessor :skip_encoding_query_params
# @return [String] base uri of the request
attr_accessor :base_uri
# @return [String] path template /{replace}/{url_param}
attr_accessor :path_template
# @return [Hash] request headers
attr_accessor :headers
# @return [String] http request method
attr_accessor :method
# @return [String] the HTTP response body.
attr_accessor :body
# @return [Array] the list of middlewares to apply to the Request
attr_accessor :middlewares
# @return [String] full - to log requests, responses and bodies, partial - just requests and responses without body
attr_accessor :log
# @return [Array] strings to be appended to the user agent in the request
attr_accessor :user_agent_extended
# Creates and initialize new instance of the HttpOperationResponse class.
# @param [String|URI] base uri for requests
# @param [String] path template /{replace}/{url_param}
# @param [String] http method for the request
# @param [Hash] body the HTTP response body.
def initialize(base_uri, path_template, method, options = {})
fail 'path_template must not be nil' if path_template.nil?
fail 'method must not be nil' if method.nil?
@base_uri = base_uri || ''
@path_template = path_template
@method = method
@headers = {}
@user_agent_extended = []
options.each do |k,v|
instance_variable_set("@#{k}", v) unless v.nil?
end
end
# Creates a promise which will execute the request. Block will yield the request for customization.
# @return [URI] body the HTTP response body.
def run_promise(&block)
Concurrent::Promise.new do
@connection ||= Faraday.new(:url => base_uri, :ssl => MsRest.ssl_options) do |faraday|
middlewares.each{ |args| faraday.use(*args) } unless middlewares.nil?
faraday.adapter Faraday.default_adapter
logging = ENV['AZURE_HTTP_LOGGING'] || log
if logging
faraday.response :logger, nil, { :bodies => logging == 'full' }
end
end
loop do
@response = @connection.run_request(:"#{method}", build_path, body, {'User-Agent' => user_agent}.merge(headers)) do |req|
req.params = req.params.merge(query_params.reject{|_, v| v.nil?}) unless query_params.nil?
yield(req) if block_given?
end
break if ((@response.status != 429) || (@response.status == 429 && @response.headers['retry-after'].nil?))
if(@response.status == 429 && !@response.headers['retry-after'].nil?)
sleep(@response.headers['retry-after'].to_i)
end
end
@response
end
end
# Creates a path from the path template and the path_params and skip_encoding_path_params
# @return [URI] body the HTTP response body.
def build_path
template = path_template.dup
path_params.each{ |key, value| template["{#{key}}"] = ERB::Util.url_encode(value) if template.include?("{#{key}}") } unless path_params.nil?
skip_encoding_path_params.each{ |key, value| template["{#{key}}"] = value } unless skip_encoding_path_params.nil?
path = URI.parse(template.gsub(/([^:]|\A)\/\//, '\1/'))
unless skip_encoding_query_params.nil?
path.query = [(path.query || ""), skip_encoding_query_params.reject{|_, v| v.nil?}.map{|k,v| "#{k}=#{v}"}].join('&')
end
path
end
def full_uri
URI.join(base_uri || '', build_path)
end
def user_agent
"Ruby/#{RUBY_VERSION} (#{RUBY_PLATFORM}) #{user_agent_extended.join(' ')}"
end
def to_json(*a)
{
base_uri: base_uri,
path_template: path_template,
method: method,
path_params: path_params,
skip_encoding_path_params: skip_encoding_path_params,
query_params: query_params,
skip_encoding_query_params: skip_encoding_query_params,
headers: headers,
body: body,
middlewares: middlewares,
log: log
}.to_json(*a)
end
end
end
|
