class Aws::Json::Handler

Constants

CONTENT_TYPE

Public Instance Methods

call(context) click to toggle source

@param [Seahorse::Client::RequestContext] context @return [Seahorse::Client::Response]

# File lib/aws-sdk-core/json/handler.rb, line 11
def call(context)
  build_request(context)
  response = @handler.call(context)
  response.on(200..299) { |resp| parse_response(resp) }
  response.on(200..599) { |_resp| apply_request_id(context) }
end

Private Instance Methods

apply_request_id(context) click to toggle source
# File lib/aws-sdk-core/json/handler.rb, line 81
def apply_request_id(context)
  context[:request_id] = context.http_response.headers['x-amzn-requestid']
end
build_body(context) click to toggle source
# File lib/aws-sdk-core/json/handler.rb, line 28
def build_body(context)
  if simple_json?(context)
    Json.dump(context.params)
  else
    Builder.new(context.operation.input).serialize(context.params)
  end
end
build_request(context) click to toggle source
# File lib/aws-sdk-core/json/handler.rb, line 20
def build_request(context)
  context.http_request.http_method = 'POST'
  context.http_request.headers['Content-Type'] = content_type(context)
  context.http_request.headers['X-Amz-Target'] = target(context)
  context.http_request.headers['X-Amzn-Query-Mode'] = 'true' if query_compatible?(context)
  context.http_request.body = build_body(context)
end
content_type(context) click to toggle source
# File lib/aws-sdk-core/json/handler.rb, line 72
def content_type(context)
  CONTENT_TYPE % [context.config.api.metadata['jsonVersion']]
end
parse_body(context) click to toggle source
# File lib/aws-sdk-core/json/handler.rb, line 40
def parse_body(context)
  json = context.http_response.body_contents
  if simple_json?(context)
    Json.load(json)
  elsif (rules = context.operation.output)
    if json.is_a?(Array)
      # an array of emitted events
      if json[0].respond_to?(:response)
        # initial response exists
        # it must be the first event arrived
        resp_struct = json.shift.response
      else
        resp_struct = context.operation.output.shape.struct_class.new
      end

      rules.shape.members.each do |name, ref|
        if ref.eventstream
          resp_struct.send("#{name}=", json.to_enum)
        end
      end
      resp_struct
    else
      Parser.new(
        rules,
        query_compatible: query_compatible?(context)
      ).parse(json)
    end
  else
    EmptyStructure.new
  end
end
parse_response(response) click to toggle source
# File lib/aws-sdk-core/json/handler.rb, line 36
def parse_response(response)
  response.data = parse_body(response.context)
end
query_compatible?(context) click to toggle source
# File lib/aws-sdk-core/json/handler.rb, line 89
def query_compatible?(context)
  context.config.api.metadata.key?('awsQueryCompatible')
end
simple_json?(context) click to toggle source
# File lib/aws-sdk-core/json/handler.rb, line 85
def simple_json?(context)
  context.config.simple_json
end
target(context) click to toggle source
# File lib/aws-sdk-core/json/handler.rb, line 76
def target(context)
  prefix = context.config.api.metadata['targetPrefix']
  "#{prefix}.#{context.operation.name}"
end