/usr/lib/ruby/vendor_ruby/ms_rest/service_client.rb is in ruby-ms-rest 0.6.2-1.
This file is owned by root:root, with mode 0o644.
The actual contents of the file can be viewed below.
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 | # 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 a point of access to the REST API.
#
class ServiceClient
# @return [MsRest::ServiceClientCredentials] the credentials object.
attr_accessor :credentials
# @return [Hash{String=>String}] default middlewares configuration for requests.
attr_accessor :middlewares
# @return [Hash{String=>String}] default request headers for requests.
attr_accessor :request_headers
# @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 ServiceClient class.
#
# @param credentials [MsRest::ServiceClientCredentials] credentials to authorize
# HTTP requests made by the service client.
# @param options additional parameters for the HTTP request (not implemented yet).
#
def initialize(credentials, options = nil)
@credentials = credentials
@request_headers = {}
@middlewares = {middlewares: [[MsRest::RetryPolicyMiddleware, times: 3, retry: 0.02], [:cookie_jar]]}
@user_agent_extended = []
@user_agent_extended.push("ms_rest/#{MsRest::VERSION}")
end
#
# @param base_url [String] the base url for the request.
# @param method [Symbol] with any of the following values :get, :put, :post, :patch, :delete.
# @param path [String] the path, relative to {base_url}.
# @param options [Hash{String=>String}] specifying any request options like :credentials, :body, etc.
# @return [Concurrent::Promise] Promise object which holds the HTTP response.
#
def make_request_async(base_url, method, path, options = {})
options = @middlewares.merge(options)
options[:credentials] = options[:credentials] || @credentials
options[:user_agent_extended] = @user_agent_extended
request = MsRest::HttpOperationRequest.new(base_url, path, method, options)
promise = request.run_promise do |req|
options[:credentials].sign_request(req) unless options[:credentials].nil?
end
promise = promise.then do |http_response|
response_content = http_response.body.to_s.empty? ? nil : http_response.body
# Create response
create_response(request, http_response, response_content)
end
promise.execute
end
#
# Add additional information into User-Agent header.
# @param [String] additional_user_agent_information additional product information for user agent string.
#
# Example:
# recommended format is Product/[version]
# please refer https://github.com/Azure/azure-sdk-for-ruby/issues/517 for more information.
#
# add_user_agent_information('fog-azure-rm/0.2.0')
#
def add_user_agent_information(additional_user_agent_information)
@user_agent_extended.push(additional_user_agent_information)
end
private
#
# Retrieves a new instance of the HttpOperationResponse class.
# @param [MsRest::HttpOperationRequest] request the HTTP request object.
# @param [Faraday::Response] response the HTTP response object.
# @param [String] body the HTTP response body.
# @return [MsRest::HttpOperationResponse] the operation response.
#
def create_response(request, http_response, body = nil)
HttpOperationResponse.new(request, http_response, body)
end
end
#
# Hash of SSL options for Faraday connection. Default is nil.
#
@@ssl_options = nil
#
# Stores the SSL options to be used for Faraday connections.
# ==== Examples
# MsRest.use_ssl_cert # => Uses bundled certificate for all the connections
# MsRest.use_ssl_cert({:ca_file => "path_to_ca_file"}) # => Uses supplied certificate for all the connections
#
# @param ssl_options [Hash] Hash of SSL options for Faraday connection. It defaults to the bundled certificate.
#
def self.use_ssl_cert(ssl_options = nil)
if ssl_options.nil?
@@ssl_options = {:ca_file => File.path("/etc/ssl/certs/ca-certificates.crt") }
else
@@ssl_options = ssl_options
end
end
#
# @return [Hash] Hash of SSL options to be used for Faraday connection.
#
def self.ssl_options
@@ssl_options
end
end
|