Class: Distelli::ClientBase

Inherits:

Object

• Object
• Distelli::ClientBase

Includes:

Logging

Defined in:

lib/distelli/clientframework.rb

Instance Method Summary

• #execute(request_info) ⇒ Object
• #initialize(credentials, endpoint = nil) ⇒ ClientBase constructor

  A new instance of ClientBase.

• #set_endpoint(endpoint) ⇒ Object

Methods included from Logging

#logger, logger

Constructor Details

#initialize(credentials, endpoint = nil) ⇒ ClientBase

Returns a new instance of ClientBase.

# File 'lib/distelli/clientframework.rb', line 115

def initialize(credentials, endpoint=nil)
  @credentials = credentials
  @endpoint = endpoint
  @json_marshaller = JsonMarshaller.new
  @xml_marshaller = XmlMarshaller.new
  @logger = nil
end

Instance Method Details

#execute(request_info) ⇒ Object

# File 'lib/distelli/clientframework.rb', line 135

def execute(request_info)
  if @endpoint == nil
    raise ClientException.new("Invalid endpoint: "+@endpoint.to_s)
  end
  logger.debug("Executing request to endpoint: "+@endpoint.to_s)
  # uri_str = @endpoint
  # if request_info.resource_uri != nil
  #   uri_str = uri_str+request_info.resource_uri
  # end

  request_info.add_header(ServiceConstants::OPERATION_HEADER, request_info.operation)
  request_info.add_header(ServiceConstants::CONTENT_TYPE_HEADER, request_info.content_type)

  if not request_info.contains_header(ServiceConstants::RESPONSE_TYPE_HEADER)
      request_info.add_header(ServiceConstants::RESPONSE_TYPE_HEADER, request_info.response_type)
  end

  request_info.remove_query_params(ServiceConstants::OPERATION_PARAM)
  request_info.remove_query_params(ServiceConstants::RESPONSE_TYPE_PARAM)

  if request_info.request_id == nil
      request_info.request_id = SecureRandom.uuid
  end

  request_info.add_header(ServiceConstants::REQUEST_ID_HEADER, request_info.request_id)
  request_info.remove_query_params(ServiceConstants::REQUEST_ID_PARAM)

  # Set the Date header
  cur_time = Time.now.utc
  request_info.add_header(ServiceConstants::DATE_HEADER, cur_time.strftime("%a, %d %b %Y %H:%M:%S %z"))

  # Create the URI
  uri = URI.parse(request_info.get_uri(@endpoint))

  # TODO: Set the Content-MD5 header

  # Set the authentication headers
  if @credentials != nil
    signer = RequestSigner.new
    signature = signer.get_signature(@credentials.secret_key, request_info)
    request_info.add_header(ServiceConstants::AUTHORIZATION_HEADER, "DWS "+@credentials.key_id+":"+signature)
  end

  response = nil

  http_method = request_info.http_method
  http_client = Net::HTTP.new(uri.host, uri.port)
  http_client.set_debug_output($stdout)
  if http_method == ServiceConstants::HTTP_METHOD_GET
    logger.debug("Executing GET: "+request_info.to_s)
    # Create the http request with the URI, Query Params and Headers
    http_request = Net::HTTP::Get.new(uri.request_uri, request_info.headers)
    # Execute the request to get the response
    response = http_client.request(http_request)
  elsif http_method == ServiceConstants::HTTP_METHOD_POST
    logger.debug("Executing POST: "+request_info.to_s)
    payload = get_payload(request_info)
    # Create the http request with the URI, Query Params and Headers
    http_request = Net::HTTP::Post.new(uri.request_uri, request_info.headers)
    # Set the body
    http_request.body = payload
    # Execute the request to get the response
    response = http_client.request(http_request)
  elsif http_method == ServiceConstants::HTTP_METHOD_PUT
    logger.debug("Executing PUT: "+request_info.to_s)
    payload = get_payload(request_info)
    # Create the http request with the URI, Query Params and Headers
    http_request = Net::HTTP::Put.new(uri.request_uri, request_info.headers)
    # Set the body
    http_request.body= payload
    # Execute the request to get the response
    response = http_client.request(http_request)
  elsif http_method == ServiceConstants::HTTP_METHOD_DELETE
    logger.debug("Executing DELETE: "+request_info.to_s)
    # Create the http request with the URI, Query Params and Headers
    http_request = Net::HTTP::Delete.new(uri.request_uri, request_info.headers)
    # Execute the request to get the response
    response = http_client.request(http_request)
  else
      raise ClientException.new("Invalid HTTP Method: "+http_method)
  end
  return handle_response(response)
end

#set_endpoint(endpoint) ⇒ Object

# File 'lib/distelli/clientframework.rb', line 123

def set_endpoint(endpoint)
  if endpoint == nil
    return
  end
  if endpoint.start_with?("http://") or endpoint.start_with?("https://")
    @endpoint = endpoint
  else
    @endpoint = "http://"+endpoint
  end

end