class Faraday::Adapter::Patron
Patron
adapter.
Constants
- CURL_TIMEOUT_MESSAGES
Public Instance Methods
Source
# File lib/faraday/adapter/patron.rb, line 9 def build_connection(env) session = ::Patron::Session.new @config_block&.call(session) if (env[:url].scheme == 'https') && env[:ssl] configure_ssl(session, env[:ssl]) end if (req = env[:request]) configure_timeouts(session, req) configure_proxy(session, req[:proxy]) end session end
Source
# File lib/faraday/adapter/patron.rb, line 24 def call(env) super # TODO: support streaming requests env[:body] = env[:body].read if env[:body].respond_to? :read response = connection(env) do |session| begin data = env[:body] ? env[:body].to_s : nil session.request(env[:method], env[:url].to_s, env[:request_headers], data: data) rescue Errno::ECONNREFUSED, ::Patron::ConnectionFailed raise Faraday::ConnectionFailed, $ERROR_INFO end end if (req = env[:request]).stream_response? warn "Streaming downloads for #{self.class.name} " \ 'are not yet implemented.' req.on_data.call(response.body, response.body.bytesize) end # Remove the "HTTP/1.1 200", leaving just the reason phrase reason_phrase = response.status_line.gsub(/^.* \d{3} /, '') save_response(env, response.status, response.body, response.headers, reason_phrase) @app.call env rescue ::Patron::TimeoutError => e if connection_timed_out_message?(e.message) raise Faraday::ConnectionFailed, e end raise Faraday::TimeoutError, e rescue ::Patron::Error => e if e.message.include?('code 407') raise Faraday::ConnectionFailed, %(407 "Proxy Authentication Required ") end raise Faraday::ConnectionFailed, e end
Calls superclass method
Faraday::Adapter#call
Source
# File lib/faraday/adapter/patron.rb, line 101 def configure_proxy(session, proxy) return unless proxy proxy_uri = proxy[:uri].dup proxy_uri.user = proxy[:user] && Utils.escape(proxy[:user]).gsub('+', '%20') proxy_uri.password = proxy[:password] && Utils.escape(proxy[:password]).gsub('+', '%20') session.proxy = proxy_uri.to_s end
Source
# File lib/faraday/adapter/patron.rb, line 81 def configure_ssl(session, ssl) if ssl.fetch(:verify, true) session.cacert = ssl[:ca_file] else session.insecure = true end end
Source
# File lib/faraday/adapter/patron.rb, line 89 def configure_timeouts(session, req) return unless req if (sec = request_timeout(:read, req)) session.timeout = sec end return unless (sec = request_timeout(:open, req)) session.connect_timeout = sec end
Private Instance Methods
Source
# File lib/faraday/adapter/patron.rb, line 125 def connection_timed_out_message?(message) CURL_TIMEOUT_MESSAGES.any? do |curl_message| message.include?(curl_message) end end