Class: Amazon::Coral::HttpHandler

Inherits:
Handler show all
Defined in:
lib/amazon/coral/httphandler.rb

Overview

Executes HTTP requests via the Net::HTTP library. Supports HTTP, HTTPS and client X509 certificates.

Instance Method Summary collapse

Methods inherited from Handler

#after

Constructor Details

#initialize(args = {}) ⇒ HttpHandler

Instantiate a new HttpHandler with the specified arguments. Possible arguments include:

:verbose

If true, the handler will output the URI it is requesting to STDOUT. This may be useful for debugging purposes.

:ca_file

This parameter’s value points to a valid .pem certificate file to enable the client to validate server certificates when using SSL. If this parameter is not specified, the client operates in insecure mode and does not validate that server certificates come from a trusted source.

:timeout

This value (in seconds) will be used for every socket operation during the request. Note that since a request can involve many socket operations, calls that timeout may actually take more time than this value. If unspecified, defaults to 5.0 seconds.

A value of zero will result in an infinite timeout.

:connect_timeout

This value (in seconds) will be used as the timeout for opening a connection to the service. If unspecified, defaults to 5.0 seconds. A value of zero will result in an infinite timeout.

Raises:

  • (ArgumentError) 


35
36
37
38
39
40
41
42
43
44
45
46
47
48
 
# File 'lib/amazon/coral/httphandler.rb', line 35

def initialize(args = {})
  @log = LogFactory.getLog('Amazon::Coral::HttpHandler')

  @verbose = args[:verbose]
  @ca_file = args[:ca_file]
  @connect_timeout = args[:connect_timeout]
  @timeout = args[:timeout]

  @connect_timeout = 5.0 if @connect_timeout.nil?
  @timeout = 120.0 if @timeout.nil?

  raise ArgumentError, "connect_timeout must be non-negative" if @connect_timeout < 0
  raise ArgumentError, "timeout must be non-negative" if @timeout < 0
end

Instance Method Details

#before(job) ⇒ Object 



50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
 
# File 'lib/amazon/coral/httphandler.rb', line 50

def before(job)
  identity = job.request[:identity]
  request_id = job.request[:id]
  uri = job.request[:http_uri]
  verb = job.request[:http_verb]
  query_map = job.request[:http_query_map]

  verb = 'GET' if verb.nil?

  headers = {}
  headers['x-amzn-RequestId'] = "#{request_id}"
  headers['x-amzn-Delegation'] = identity[:http_delegation] unless identity[:http_delegation].nil?
  headers['Authorization'] = identity[:http_authorization] unless identity[:http_authorization].nil?
  headers['Host'] = job.request[:http_host] unless job.request[:http_host].nil?
  headers['User-Agent'] = 'ruby-client'
  
  result = http_request(uri, headers, verb, query_map, identity[:http_client_x509], identity[:http_client_x509_key])

  @log.info "Response code: #{result.code}"

  job.reply[:response] = result
  job.reply[:value] = result.body
  job.reply[:http_status_code] = result.code
  job.reply[:http_status_message] = result.message
  job.reply[:http_content] = nil # TODO: get content-type header
end