Class: Async::HTTP::Faraday::Adapter

Inherits:
Faraday::Adapter
  • Object
show all
Defined in:
lib/async/http/faraday/adapter.rb

Instance Method Summary collapse

Instance Method Details

#call(env) ⇒ Object 



29
30
31
32
33
34
35
36
37
38
39
 
# File 'lib/async/http/faraday/adapter.rb', line 29

def call(env)
	super
	
	client = HTTP::Client.new(*endpoints_for(env).to_a)
	
	response = client.send(env[:method], env[:url].request_uri, env[:request_headers], env[:body] || [])
	
	save_response(env, response.status, response.body, response.headers, response.reason)
	
	@app.call env
end

#endpoints_for(env) ⇒ Object 



41
42
43
44
45
46
47
 
# File 'lib/async/http/faraday/adapter.rb', line 41

def endpoints_for(env)
	return to_enum(:endpoints_for, env) unless block_given?
	
	if url = env[:url]
		yield Async::HTTP::URLEndpoint.new(url)
	end
end

#ssl_context_for(options) ⇒ Object 



49
50
51
52
53
54
55
56
57
58
59
60
61
62
 
# File 'lib/async/http/faraday/adapter.rb', line 49

def ssl_context_for(options)
	OpenSSL::SSL::SSLContext.new.tap do |context|
		context.set_params(
			verify_mode: options.fetch(:verify, true) ? OpenSSL::SSL::VERIFY_PEER : OpenSSL::SSL::VERIFY_NONE,
			# cert_store: ssl_cert_store(ssl),
			# cert: options[:client_cert],
			# key: options[:client_key],
			# ca_file: ssl[:ca_file],
			# ca_path: ssl[:ca_path],
			# verify_depth: ssl[:verify_depth],
			# version: ssl[:version],
		)
	end
end