class Faraday::Adapter::Excon

def call(env)
  super
  opts = {}
  if env[:url].scheme == 'https' && ssl = env[:ssl]
    opts[:ssl_verify_peer] = !!ssl.fetch(:verify, true)
    opts[:ssl_ca_path] = ssl[:ca_path] if ssl[:ca_path]
    opts[:ssl_ca_file] = ssl[:ca_file] if ssl[:ca_file]
    # https://github.com/geemus/excon/issues/106
    # https://github.com/jruby/jruby-ossl/issues/19
    opts[:nonblock] = false
  end
  if ( req = env[:request] )
    if req[:timeout]
      opts[:read_timeout]      = req[:timeout]
      opts[:connect_timeout]   = req[:timeout]
      opts[:write_timeout]     = req[:timeout]
    end
    if req[:open_timeout]
      opts[:connect_timeout]   = req[:open_timeout]
      opts[:write_timeout]     = req[:open_timeout]
    end
  end
  conn = ::Excon.new(env[:url].to_s, opts.merge(@connection_options))
  resp = conn.request \
    :method  => env[:method].to_s.upcase,
    :headers => env[:request_headers],
    :body    => read_body(env)
  save_response(env, resp.status.to_i, resp.body, resp.headers)
  @app.call env
rescue ::Excon::Errors::SocketError => err
  if err.message =~ /\btimeout\b/
    raise Error::TimeoutError, err
  else
    raise Error::ConnectionFailed, err
  end
rescue ::Excon::Errors::Timeout => err
  raise Error::TimeoutError, err
end

def initialize(app, connection_options = {})
  @connection_options = connection_options
  super(app)
end

def read_body(env)
  env[:body].respond_to?(:read) ? env[:body].read : env[:body]
end