class ActiveUtils::Connection
Constants
- CA_FILE
allow using proxy for https calls by pointing to it’s certificate SSL_CERT_FILE is variable used by Ruby to look for certificate for net/http
- CA_PATH
- MAX_RETRIES
- OPEN_TIMEOUT
- PROXY_ADDRESS
- READ_TIMEOUT
- RETRY_SAFE
- RUBY_184_POST_HEADERS
- VERIFY_PEER
Attributes
ca_file[RW]
ca_path[RW]
endpoint[RW]
ignore_http_status[RW]
logger[RW]
max_retries[RW]
open_timeout[RW]
pem[RW]
pem_password[RW]
proxy_address[RW]
proxy_port[RW]
read_timeout[RW]
retry_safe[RW]
ssl_version[RW]
tag[RW]
verify_peer[RW]
wiredump_device[RW]
Public Class Methods
new(endpoint)
click to toggle source
# File lib/active_utils/connection.rb, line 40 def initialize(endpoint) @endpoint = endpoint.is_a?(URI) ? endpoint : URI.parse(endpoint) @open_timeout = OPEN_TIMEOUT @read_timeout = READ_TIMEOUT @retry_safe = RETRY_SAFE @verify_peer = VERIFY_PEER @ca_file = CA_FILE @ca_path = CA_PATH @max_retries = MAX_RETRIES @ignore_http_status = false @ssl_version = nil @proxy_address = PROXY_ADDRESS @proxy_port = nil end
Public Instance Methods
request(method, body, headers = {})
click to toggle source
# File lib/active_utils/connection.rb, line 55 def request(method, body, headers = {}) request_start = Time.now.to_f retry_exceptions(:max_retries => max_retries, :logger => logger, :tag => tag) do begin info "connection_http_method=#{method.to_s.upcase} connection_uri=#{endpoint}", tag result = nil realtime = Benchmark.realtime do result = case method when :get raise ArgumentError, "GET requests do not support a request body" if body http.get(endpoint.request_uri, headers) when :post debug body http.post(endpoint.request_uri, body, RUBY_184_POST_HEADERS.merge(headers)) when :put debug body http.put(endpoint.request_uri, body, headers) when :patch debug body http.patch(endpoint.request_uri, body, headers) when :delete # It's kind of ambiguous whether the RFC allows bodies # for DELETE requests. But Net::HTTP's delete method # very unambiguously does not. raise ArgumentError, "DELETE requests do not support a request body" if body http.delete(endpoint.request_uri, headers) else raise ArgumentError, "Unsupported request method #{method.to_s.upcase}" end end info "--> %d %s (%d %.4fs)" % [result.code, result.message, result.body ? result.body.length : 0, realtime], tag debug result.body result end end ensure info "connection_request_total_time=%.4fs" % [Time.now.to_f - request_start], tag end
Private Instance Methods
configure_cert(http)
click to toggle source
# File lib/active_utils/connection.rb, line 134 def configure_cert(http) return if pem.blank? http.cert = OpenSSL::X509::Certificate.new(pem) if pem_password http.key = OpenSSL::PKey::RSA.new(pem, pem_password) else http.key = OpenSSL::PKey::RSA.new(pem) end end
configure_debugging(http)
click to toggle source
# File lib/active_utils/connection.rb, line 109 def configure_debugging(http) http.set_debug_output(wiredump_device) end
configure_ssl(http)
click to toggle source
# File lib/active_utils/connection.rb, line 118 def configure_ssl(http) return unless endpoint.scheme == "https" http.use_ssl = true http.ssl_version = ssl_version if ssl_version if verify_peer http.verify_mode = OpenSSL::SSL::VERIFY_PEER http.ca_file = ca_file http.ca_path = ca_path else http.verify_mode = OpenSSL::SSL::VERIFY_NONE end end
configure_timeouts(http)
click to toggle source
# File lib/active_utils/connection.rb, line 113 def configure_timeouts(http) http.open_timeout = open_timeout http.read_timeout = read_timeout end
debug(message, tag = nil)
click to toggle source
# File lib/active_utils/connection.rb, line 159 def debug(message, tag = nil) log(:debug, message, tag) end
error(message, tag = nil)
click to toggle source
# File lib/active_utils/connection.rb, line 167 def error(message, tag = nil) log(:error, message, tag) end
handle_response(response)
click to toggle source
# File lib/active_utils/connection.rb, line 146 def handle_response(response) if @ignore_http_status then return response.body else case response.code.to_i when 200...300 response.body else raise ResponseError.new(response) end end end
http()
click to toggle source
# File lib/active_utils/connection.rb, line 100 def http http = Net::HTTP.new(endpoint.host, endpoint.port, proxy_address, proxy_port) configure_debugging(http) configure_timeouts(http) configure_ssl(http) configure_cert(http) http end
info(message, tag = nil)
click to toggle source
# File lib/active_utils/connection.rb, line 163 def info(message, tag = nil) log(:info, message, tag) end
log(level, message, tag)
click to toggle source
# File lib/active_utils/connection.rb, line 171 def log(level, message, tag) message = "[#{tag}] #{message}" if tag logger.send(level, message) if logger end