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
|
# 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
@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
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(/([^:])\/\//, '\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
|
