Module: Faraday::Adapter::EMHttp::Options

Included in:
Faraday::Adapter::EMHttp, Faraday::Adapter::EMSynchrony
Defined in:
lib/puppet/feature/faraday/adapter/em_http.rb

Instance Method Summary collapse

Instance Method Details

#configure_compression(options, env) ⇒ Object 



67
68
69
70
71
 
# File 'lib/puppet/feature/faraday/adapter/em_http.rb', line 67

def configure_compression(options, env)
  if env[:method] == :get and not options[:head].key? 'accept-encoding'
    options[:head]['accept-encoding'] = 'gzip, compressed'
  end
end

#configure_proxy(options, env) ⇒ Object 



33
34
35
36
37
38
39
40
41
 
# File 'lib/puppet/feature/faraday/adapter/em_http.rb', line 33

def configure_proxy(options, env)
  if proxy = request_options(env)[:proxy]
    options[:proxy] = {
      :host => proxy[:uri].host,
      :port => proxy[:uri].port,
      :authorization => [proxy[:user], proxy[:password]]
    }
  end
end

#configure_socket(options, env) ⇒ Object 



43
44
45
46
47
48
49
50
 
# File 'lib/puppet/feature/faraday/adapter/em_http.rb', line 43

def configure_socket(options, env)
  if bind = request_options(env)[:bind]
    options[:bind] = {
      :host => bind[:host],
      :port => bind[:port]
    }
  end
end

#configure_ssl(options, env) ⇒ Object 



52
53
54
55
56
57
58
59
 
# File 'lib/puppet/feature/faraday/adapter/em_http.rb', line 52

def configure_ssl(options, env)
  if env[:url].scheme == 'https' && env[:ssl]
    options[:ssl] = {
      :cert_chain_file => env[:ssl][:ca_file],
      :verify_peer => env[:ssl].fetch(:verify, true)
    }
  end
end

#configure_timeout(options, env) ⇒ Object 



61
62
63
64
65
 
# File 'lib/puppet/feature/faraday/adapter/em_http.rb', line 61

def configure_timeout(options, env)
  timeout, open_timeout = request_options(env).values_at(:timeout, :open_timeout)
  options[:connect_timeout] = options[:inactivity_timeout] = timeout
  options[:connect_timeout] = open_timeout if open_timeout
end

#connection_config(env) ⇒ Object 



8
9
10
11
12
13
14
15
 
# File 'lib/puppet/feature/faraday/adapter/em_http.rb', line 8

def connection_config(env)
  options = {}
  configure_proxy(options, env)
  configure_timeout(options, env)
  configure_socket(options, env)
  configure_ssl(options, env)
  options
end

#read_body(env) ⇒ Object 



28
29
30
31
 
# File 'lib/puppet/feature/faraday/adapter/em_http.rb', line 28

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

#request_config(env) ⇒ Object 



17
18
19
20
21
22
23
24
25
26
 
# File 'lib/puppet/feature/faraday/adapter/em_http.rb', line 17

def request_config(env)
  options = {
    :body => read_body(env),
    :head => env[:request_headers],
    # :keepalive => true,
    # :file => 'path/to/file', # stream data off disk
  }
  configure_compression(options, env)
  options
end

#request_options(env) ⇒ Object 



73
74
75
 
# File 'lib/puppet/feature/faraday/adapter/em_http.rb', line 73

def request_options(env)
  env[:request]
end