Module: Excon

Defined in:
lib/excon.rb,
lib/excon/error.rb,
lib/excon/utils.rb,
lib/excon/socket.rb,
lib/excon/socks5.rb,
lib/excon/headers.rb,
lib/excon/version.rb,
lib/excon/response.rb,
lib/excon/constants.rb,
lib/excon/connection.rb,
lib/excon/ssl_socket.rb,
lib/excon/test/server.rb,
lib/excon/unix_socket.rb,
lib/excon/socks5_socket.rb,
lib/excon/pretty_printer.rb,
lib/excon/middlewares/base.rb,
lib/excon/middlewares/mock.rb,
lib/excon/resolver_factory.rb,
lib/excon/socks5_ssl_socket.rb,
lib/excon/middlewares/expects.rb,
lib/excon/middlewares/decompress.rb,
lib/excon/middlewares/idempotent.rb,
lib/excon/middlewares/escape_path.rb,
lib/excon/test/plugin/server/exec.rb,
lib/excon/test/plugin/server/puma.rb,
lib/excon/middlewares/instrumentor.rb,
lib/excon/test/plugin/server/unicorn.rb,
lib/excon/test/plugin/server/webrick.rb,
lib/excon/middlewares/capture_cookies.rb,
lib/excon/middlewares/response_parser.rb,
lib/excon/middlewares/redirect_follower.rb,
lib/excon/instrumentors/logging_instrumentor.rb,
lib/excon/instrumentors/standard_instrumentor.rb

Overview

Define defaults first so they will be available to other files

Defined Under Namespace

Modules: Errors, Middleware, SOCKS5, Test, Utils Classes: Connection, Error, Headers, LoggingInstrumentor, PrettyPrinter, ResolverFactory, Response, SOCKS5SSLSocket, SOCKS5Socket, SSLSocket, Socket, StandardInstrumentor, UnixSocket

Constant Summary collapse

VERSION = 
'1.4.2'
CR_NL = 
"\r\n"
DEFAULT_CA_FILE = 
File.expand_path(File.join(File.dirname(__FILE__), '..', '..', 'data', 'cacert.pem'))
DEFAULT_CHUNK_SIZE =

1 megabyte

1_048_576
CHUNK_SIZE =

avoid overwrite if somebody has redefined

DEFAULT_CHUNK_SIZE
DEFAULT_REDIRECT_LIMIT = 
10
DEFAULT_RETRY_LIMIT = 
4
DEFAULT_RETRY_ERRORS = 
[
  Excon::Error::RequestTimeout,
  Excon::Error::Server,
  Excon::Error::Socket,
  Excon::Error::Timeout,
  Excon::Error::TooManyRequests
].freeze
FORCE_ENC = 
CR_NL.respond_to?(:force_encoding)
HTTP_1_1 = 
" HTTP/1.1\r\n"
HTTP_VERBS = 
%w[connect delete get head options patch post put trace].freeze
HTTPS = 
'https'
NO_ENTITY = 
[204, 205, 304].freeze
REDACTED = 
'REDACTED'
UNIX = 
'unix'
USER_AGENT = 
"excon/#{VERSION}".freeze
VERSIONS = 
"#{USER_AGENT} (#{RUBY_PLATFORM}) ruby/#{RUBY_VERSION}".freeze
VALID_REQUEST_KEYS =

FIXME: should be frozen, but with a way to change them, similar to defaults

%i[
  allow_unstubbed_requests
  body
  chunk_size
  debug_request
  debug_response
  dns_timeouts
  headers
  instrumentor
  logger
  method
  middlewares
  password
  path
  persistent
  pipeline
  query
  read_timeout
  request_block
  resolv_resolver
  resolver_factory
  response_block
  stubs
  timeout
  user
  versions
  write_timeout
]
VALID_CONNECTION_KEYS =

FIXME: should be frozen, but with a way to change them, similar to defaults

(VALID_REQUEST_KEYS + %i[
  ciphers
  client_key
  client_key_data
  client_key_pass
  client_cert
  client_cert_data
  client_chain
  client_chain_data
  certificate
  certificate_path
  disable_proxy
  private_key
  private_key_path
  connect_timeout
  family
  keepalive
  host
  hostname
  ignore_unexpected_eof
  include_default_port
  omit_default_port
  nonblock
  reuseaddr
  port
  proxy
  scheme
  socket
  socks5_proxy
  ssl_ca_file
  ssl_ca_path
  ssl_cert_store
  ssl_verify_callback
  ssl_verify_peer
  ssl_verify_peer_host
  ssl_verify_hostname
  ssl_version
  ssl_min_version
  ssl_max_version
  ssl_security_level
  ssl_proxy_headers
  ssl_uri_schemes
  tcp_nodelay
  thread_safe_sockets
  uri_parser
])
DEPRECATED_VALID_REQUEST_KEYS = 
{
  captures: 'Mock',
  expects: 'Expects',
  idempotent: 'Idempotent',
  instrumentor_name: 'Instrumentor',
  mock: 'Mock',
  retries_remaining: 'Idempotent', # referenced in Instrumentor, but only relevant with Idempotent
  retry_errors: 'Idempotent',
  retry_interval: 'Idempotent',
  retry_limit: 'Idempotent' # referenced in Instrumentor, but only relevant with Idempotent
}.freeze
DEFAULTS = 
if defined? TEST_SUITE_DEFAULTS
  base_defaults.merge(TEST_SUITE_DEFAULTS).freeze
else
  base_defaults.freeze
end

Class Attribute Summary collapse

Class Method Summary collapse

Class Attribute Details

.defaults ⇒ Hash

Returns defaults for Excon connections.

Returns:

  • (Hash) —

    defaults for Excon connections



54
55
56
 
# File 'lib/excon.rb', line 54

def defaults
  @defaults ||= DEFAULTS.dup
end

Class Method Details

.display_warning(warning) ⇒ Object

Raises:



62
63
64
65
66
67
68
69
 
# File 'lib/excon.rb', line 62

def display_warning(warning)
  # Show warning if $VERBOSE or ENV['EXCON_DEBUG'] is set
  ($VERBOSE || ENV['EXCON_DEBUG']) && Warning.warn("[excon][WARNING] #{warning}\n#{caller.join("\n")}")

  return unless @raise_on_warnings

  raise(Error::Warning, warning)
end

.mock ⇒ Object

Status of mocking



76
77
78
79
 
# File 'lib/excon.rb', line 76

def mock
  display_warning('Excon#mock is deprecated, use Excon.defaults[:mock] instead.')
  self.defaults[:mock]
end

.mock=(new_mock) ⇒ Object

Change the status of mocking false is the default and works as expected true returns a value from stubs or raises



84
85
86
87
 
# File 'lib/excon.rb', line 84

def mock=(new_mock)
  display_warning('Excon#mock is deprecated, use Excon.defaults[:mock]= instead.')
  self.defaults[:mock] = new_mock
end

.new(url, params = {}) ⇒ Connection

Initializes a new keep-alive session for a given remote host

Parameters:

  • url (String) —

    The destination URL

  • params (Hash<Symbol, >) (defaults to: {}) —

    One or more option params to set on the Connection instance

Returns:

  • (Connection) —

    A new Excon::Connection instance

Raises:

  • (ArgumentError)

See Also:



120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
 
# File 'lib/excon.rb', line 120

def new(url, params = {})
  uri_parser = params[:uri_parser] || defaults[:uri_parser]
  uri = uri_parser.parse(url)
  params[:path] && uri_parser.parse(params[:path])
  raise(ArgumentError, "Invalid URI: #{uri}") unless uri.scheme

  params = {
    host: uri.host,
    hostname: uri.hostname,
    path: uri.path,
    port: uri.port,
    query: uri.query,
    scheme: uri.scheme
  }.merge(params)
  uri.password && params[:password] = Utils.unescape_uri(uri.password)
  uri.user && params[:user] = Utils.unescape_uri(uri.user)
  Excon::Connection.new(params)
end

.set_raise_on_warnings!(should_raise) ⇒ Object 



71
72
73
 
# File 'lib/excon.rb', line 71

def set_raise_on_warnings!(should_raise)
  @raise_on_warnings = should_raise
end

.ssl_ca_path ⇒ String

Returns The filesystem path to the SSL Certificate Authority.

Returns:

  • (String) —

    The filesystem path to the SSL Certificate Authority



90
91
92
93
 
# File 'lib/excon.rb', line 90

def ssl_ca_path
  display_warning('Excon#ssl_ca_path is deprecated, use Excon.defaults[:ssl_ca_path] instead.')
  self.defaults[:ssl_ca_path]
end

.ssl_ca_path=(new_ssl_ca_path) ⇒ String

Change path to the SSL Certificate Authority

Returns:

  • (String) —

    The filesystem path to the SSL Certificate Authority



97
98
99
100
 
# File 'lib/excon.rb', line 97

def ssl_ca_path=(new_ssl_ca_path)
  display_warning('Excon#ssl_ca_path= is deprecated, use Excon.defaults[:ssl_ca_path]= instead.')
  self.defaults[:ssl_ca_path] = new_ssl_ca_path
end

.ssl_verify_peer ⇒ true, false

Returns Whether or not to verify the peer’s SSL certificate / chain.

Returns:

  • (true, false) —

    Whether or not to verify the peer’s SSL certificate / chain



103
104
105
106
 
# File 'lib/excon.rb', line 103

def ssl_verify_peer
  display_warning('Excon#ssl_verify_peer is deprecated, use Excon.defaults[:ssl_verify_peer] instead.')
  self.defaults[:ssl_verify_peer]
end

.ssl_verify_peer=(new_ssl_verify_peer) ⇒ Object

Change the status of ssl peer verification

See Also:



110
111
112
113
 
# File 'lib/excon.rb', line 110

def ssl_verify_peer=(new_ssl_verify_peer)
  display_warning('Excon#ssl_verify_peer= is deprecated, use Excon.defaults[:ssl_verify_peer]= instead.')
  self.defaults[:ssl_verify_peer] = new_ssl_verify_peer
end

.stub(request_params = {}, response_params = nil, &block) ⇒ Object

push an additional stub onto the list to check for mock requests

Parameters:

  • request_params (Hash<Symbol, >) (defaults to: {}) —

    request params to match against, omitted params match all

  • response_params (Hash<Symbol, >) (defaults to: nil) —

    response params to return or block to call with matched params



142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
 
# File 'lib/excon.rb', line 142

def stub(request_params = {}, response_params = nil, &block)
  if (method = request_params.delete(:method))
    request_params[:method] = method.to_s.downcase.to_sym
  end
  if (url = request_params.delete(:url))
    uri = URI.parse(url)
    request_params = {
      host: uri.host,
      path: uri.path.empty? ? '/' : uri.path,
      port: uri.port,
      query: uri.query,
      scheme: uri.scheme
    }.merge!(request_params)
    if uri.user || uri.password
      request_params[:headers] ||= {}
      user = Utils.unescape_form(uri.user.to_s)
      pass = Utils.unescape_form(uri.password.to_s)
      request_params[:headers]['Authorization'] ||= 'Basic ' + ["#{user}:#{pass}"].pack('m').delete(Excon::CR_NL)
    end
  end
  if request_params.key?(:headers)
    headers = Excon::Headers.new
    request_params[:headers].each do |key, value|
      headers[key] = value
    end
    request_params[:headers] = headers
  end
  request_params[:query] = Utils.query_string(request_params)[1...] if request_params.key?(:query)
  if block_given?
    raise(ArgumentError, 'stub requires either response_params OR a block') if response_params

    stub = [request_params, block]
  elsif response_params
    stub = [request_params, response_params]
  else
    raise(ArgumentError, 'stub requires either response_params OR a block')
  end
  stubs.unshift(stub)
  stub
end

.stub_for(request_params = {}) ⇒ Hash<Symbol, >

get a stub matching params or nil

Parameters:

  • request_params (Hash<Symbol, >) (defaults to: {}) —

    request params to match against, omitted params match all

Returns:

  • (Hash<Symbol, >) —

    response params to return from matched request or block to call with params



186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
 
# File 'lib/excon.rb', line 186

def stub_for(request_params={})
  if (method = request_params.delete(:method))
    request_params[:method] = method.to_s.downcase.to_sym
  end
  request_params[:query] = Utils.query_string(request_params)[1...] if request_params.key?(:query)
  Excon.stubs.each do |stub, response_params|
    captures = { headers: {} }
    headers_match = !stub.key?(:headers) || stub[:headers].keys.all? do |key|
      case value = stub[:headers][key]
      when Regexp
        case request_params[:headers][key]
        when String
          if (match = value.match(request_params[:headers][key]))
            captures[:headers][key] = match.captures
          end
        when Regexp # for unstub on regex params
          match = (value == request_params[:headers][key])
        end
        match
      else
        value == request_params[:headers][key]
      end
    end
    non_headers_match = (stub.keys - [:headers]).all? do |key|
      case value = stub[key]
      when Regexp
        case request_params[key]
        when String
          if (match = value.match(request_params[key]))
            captures[key] = match.captures
          end
        when Regexp # for unstub on regex params
          match = (value == request_params[key])
        end
        match
      else
        value == request_params[key]
      end
    end
    if headers_match && non_headers_match
      request_params[:captures] = captures
      return [stub, response_params]
    end
  end
  nil
end

.stubs ⇒ Object

get a list of defined stubs



234
235
236
237
238
239
240
241
 
# File 'lib/excon.rb', line 234

def stubs
  case Excon.defaults[:stubs]
  when :global
    @stubs ||= []
  when :local
    Thread.current[:_excon_stubs] ||= []
  end
end

.unstub(request_params = {}) ⇒ Hash<Symbol, >

remove first/oldest stub matching request_params or nil if none match

Parameters:

  • request_params (Hash<Symbol, >) (defaults to: {}) —

    request params to match against, omitted params match all

Returns:

  • (Hash<Symbol, >) —

    response params from deleted stub



246
247
248
249
250
 
# File 'lib/excon.rb', line 246

def unstub(request_params = {})
  return unless (stub = stub_for(request_params))

  Excon.stubs.delete_at(Excon.stubs.index(stub))
end