class Faraday::Adapter::NetHttpPersistent

Private Instance Methods

configure_ssl(http, ssl) click to toggle source
# File lib/faraday/adapter/net_http_persistent.rb, line 49
def configure_ssl(http, ssl)
  http_set(http, :verify_mode, ssl_verify_mode(ssl))
  http_set(http, :cert_store,  ssl_cert_store(ssl))

  http_set(http, :certificate, ssl[:client_cert]) if ssl[:client_cert]
  http_set(http, :private_key, ssl[:client_key])  if ssl[:client_key]
  http_set(http, :ca_file,     ssl[:ca_file])     if ssl[:ca_file]
  http_set(http, :ssl_version, ssl[:version])     if ssl[:version]
end
http_set(http, attr, value) click to toggle source
# File lib/faraday/adapter/net_http_persistent.rb, line 59
def http_set(http, attr, value)
  if http.send(attr) != value
    http.send("#{attr}=", value)
  end
end
net_http_connection(env) click to toggle source
# File lib/faraday/adapter/net_http_persistent.rb, line 8
def net_http_connection(env)
  @cached_connection ||=
    if Net::HTTP::Persistent.instance_method(:initialize).parameters.first == [:key, :name]
      Net::HTTP::Persistent.new(name: 'Faraday')
    else
      Net::HTTP::Persistent.new('Faraday')
    end

  proxy_uri = proxy_uri(env)
  @cached_connection.proxy = proxy_uri if @cached_connection.proxy_uri != proxy_uri
  @cached_connection
end
perform_request(http, env) click to toggle source
# File lib/faraday/adapter/net_http_persistent.rb, line 35
def perform_request(http, env)
  http.request env[:url], create_request(env)
rescue Errno::ETIMEDOUT => error
  raise Faraday::Error::TimeoutError, error
rescue Net::HTTP::Persistent::Error => error
  if error.message.include? 'Timeout'
    raise Faraday::Error::TimeoutError, error
  elsif error.message.include? 'connection refused'
    raise Faraday::Error::ConnectionFailed, error
  else
    raise
  end
end
proxy_uri(env) click to toggle source
# File lib/faraday/adapter/net_http_persistent.rb, line 21
def proxy_uri(env)
  proxy_uri = nil
  if (proxy = env[:request][:proxy])
    proxy_uri = ::URI::HTTP === proxy[:uri] ? proxy[:uri].dup : ::URI.parse(proxy[:uri].to_s)
    proxy_uri.user = proxy_uri.password = nil
    # awful patch for net-http-persistent 2.8 not unescaping user/password
    (class << proxy_uri; self; end).class_eval do
      define_method(:user) { proxy[:user] }
      define_method(:password) { proxy[:password] }
    end if proxy[:user]
  end
  proxy_uri
end