class Faraday::Adapter::NetHttpPersistent

Net::HTTP::Persistent adapter.

Constants

SSL_CONFIGURATIONS

Private Instance Methods

configure_ssl(http, ssl) click to toggle source
# File lib/faraday/adapter/net_http_persistent.rb, line 94
def configure_ssl(http, ssl)
  return unless ssl

  http_set(http, :verify_mode, ssl_verify_mode(ssl))
  http_set(http, :cert_store, ssl_cert_store(ssl))

  SSL_CONFIGURATIONS
    .select { |_, key| ssl[key] }
    .each { |target, key| http_set(http, target, ssl[key]) }
end
http_set(http, attr, value) click to toggle source
# File lib/faraday/adapter/net_http_persistent.rb, line 105
def http_set(http, attr, value)
  http.send("#{attr}=", value) if http.send(attr) != value
end
net_http_connection(env) click to toggle source
# File lib/faraday/adapter/net_http_persistent.rb, line 11
def net_http_connection(env)
  @cached_connection ||=
    if Net::HTTP::Persistent.instance_method(:initialize)
        .parameters.first == %i[key name]
      options = {name: "Faraday"}
      if @connection_options.key?(:pool_size)
        options[:pool_size] = @connection_options[:pool_size]
      end
      Net::HTTP::Persistent.new(**options)
    else
      Net::HTTP::Persistent.new("Faraday")
    end

  proxy_uri = proxy_uri(env)
  if @cached_connection.proxy_uri != proxy_uri
    @cached_connection.proxy = proxy_uri
  end
  @cached_connection
end
perform_request(http, env) click to toggle source
# File lib/faraday/adapter/net_http_persistent.rb, line 52
def perform_request(http, env)
  if env[:request].stream_response?
    size = 0
    yielded = false

    http_response = http.request(env[:url], create_request(env)) do |response|
      response.read_body do |chunk|
        if chunk.bytesize.positive? || size.positive?
          yielded = true
          size += chunk.bytesize
          env[:request].on_data.call(chunk, size)
        end
      end
    end

    env[:request].on_data.call(+"", 0) unless yielded
    http_response.body = nil
    http_response
  else
    http.request(env[:url], create_request(env))
  end
rescue Errno::ETIMEDOUT, Net::OpenTimeout => e
  raise Faraday::TimeoutError, e
rescue Net::HTTP::Persistent::Error => e
  raise Faraday::TimeoutError, e if e.message.include? "Timeout"

  if e.message.include? "connection refused"
    raise Faraday::ConnectionFailed, e
  end

  raise
end
proxy_uri(env) click to toggle source
# File lib/faraday/adapter/net_http_persistent.rb, line 31
def proxy_uri(env)
  proxy_uri = nil
  if (proxy = env[:request][:proxy])
    proxy_uri = if proxy[:uri].is_a?(::URI::HTTP)
      proxy[:uri].dup
    else
      ::URI.parse(proxy[:uri].to_s)
    end
    proxy_uri.user = proxy_uri.password = nil
    # awful patch for net-http-persistent 2.8
    # not unescaping user/password
    if proxy[:user]
      (class << proxy_uri; self; end).class_eval do
        define_method(:user) { proxy[:user] }
        define_method(:password) { proxy[:password] }
      end
    end
  end
  proxy_uri
end