class Aws::Json::Handler
def apply_request_id(context)
def apply_request_id(context) context[:request_id] = context.http_response.headers['x-amzn-requestid'] end
def build_body(context)
def build_body(context) if simple_json?(context) Json.dump(context.params) else Builder.new(context.operation.input).serialize(context.params) end end
def build_request(context)
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.body = build_body(context) end
def call(context)
-
(Seahorse::Client::Response)
-
Parameters:
-
context
(Seahorse::Client::RequestContext
) --
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) } response end
def content_type(context)
def content_type(context) CONTENT_TYPE % [context.config.api.metadata['jsonVersion']] end
def parse_body(context)
def parse_body(context) if simple_json?(context) Json.load(context.http_response.body_contents) elsif rules = context.operation.output json = context.http_response.body_contents 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 == '' ? '{}' : json) end else EmptyStructure.new end end
def parse_response(response)
def parse_response(response) response.data = parse_body(response.context) end
def query_compatible?(context)
def query_compatible?(context) context.config.api.metadata.key?('awsQueryCompatible') end
def simple_json?(context)
def simple_json?(context) context.config.simple_json end
def target(context)
def target(context) prefix = context.config.api.metadata['targetPrefix'] "#{prefix}.#{context.operation.name}" end