1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
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
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
|
# frozen_string_literal: true
module Aws
# @api private
module Query
class Handler < Seahorse::Client::Handler
include Seahorse::Model::Shapes
CONTENT_TYPE = 'application/x-www-form-urlencoded; charset=utf-8'
WRAPPER_STRUCT = ::Struct.new(:result, :response_metadata)
METADATA_STRUCT = ::Struct.new(:request_id)
METADATA_REF = begin
request_id = ShapeRef.new(
shape: StringShape.new,
location_name: 'RequestId')
response_metadata = StructureShape.new
response_metadata.struct_class = METADATA_STRUCT
response_metadata.add_member(:request_id, request_id)
ShapeRef.new(shape: response_metadata, location_name: 'ResponseMetadata')
end
# @param [Seahorse::Client::RequestContext] context
# @return [Seahorse::Client::Response]
def call(context)
build_request(context)
@handler.call(context).on_success do |response|
response.error = nil
parsed = parse_xml(context)
if parsed.nil? || parsed == EmptyStructure
response.data = EmptyStructure.new
else
response.data = parsed
end
end
end
private
def build_request(context)
context.http_request.http_method = 'POST'
context.http_request.headers['Content-Type'] = CONTENT_TYPE
param_list = ParamList.new
param_list.set('Version', context.config.api.version)
param_list.set('Action', context.operation.name)
if input_shape = context.operation.input
apply_params(param_list, context.params, input_shape)
end
context.http_request.body = param_list.to_io
end
def apply_params(param_list, params, rules)
ParamBuilder.new(param_list).apply(rules, params)
end
def parse_xml(context)
data = Xml::Parser.new(rules(context)).parse(xml(context))
remove_wrapper(data, context)
end
def xml(context)
context.http_response.body_contents
end
def rules(context)
shape = Seahorse::Model::Shapes::StructureShape.new
if context.operation.output
shape.add_member(:result, ShapeRef.new(
shape: context.operation.output.shape,
location_name: context.operation.name + 'Result'
))
end
shape.struct_class = WRAPPER_STRUCT
shape.add_member(:response_metadata, METADATA_REF)
ShapeRef.new(shape: shape)
end
def remove_wrapper(data, context)
if context.operation.output
if data.response_metadata
context[:request_id] = data.response_metadata.request_id
end
data.result || Structure.new(*context.operation.output.shape.member_names)
else
data
end
end
end
end
end
|
