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
|
# frozen_string_literal: true
require 'base64'
module Aws
module Query
class EC2ParamBuilder
include Seahorse::Model::Shapes
def initialize(param_list)
@params = param_list
end
attr_reader :params
def apply(ref, params)
structure(ref, params, '')
end
private
def structure(ref, values, prefix)
shape = ref.shape
values.each_pair do |name, value|
unless value.nil?
member_ref = shape.member(name)
format(member_ref, value, prefix + query_name(member_ref))
end
end
end
def list(ref, values, prefix)
if values.empty?
set(prefix, '')
else
member_ref = ref.shape.member
values.each.with_index do |value, n|
format(member_ref, value, "#{prefix}.#{n+1}")
end
end
end
def format(ref, value, prefix)
case ref.shape
when StructureShape then structure(ref, value, prefix + '.')
when ListShape then list(ref, value, prefix)
when MapShape then raise NotImplementedError
when BlobShape then set(prefix, blob(value))
when TimestampShape then set(prefix, timestamp(ref, value))
else
set(prefix, value.to_s)
end
end
def query_name(ref)
ref['queryName'] || ucfirst(ref.location_name)
end
def set(name, value)
params.set(name, value)
end
def ucfirst(str)
str[0].upcase + str[1..-1]
end
def blob(value)
value = value.read unless String === value
Base64.strict_encode64(value)
end
def timestamp(ref, value)
case ref['timestampFormat'] || ref.shape['timestampFormat']
when 'unixTimestamp' then value.to_i
when 'rfc822' then value.utc.httpdate
else
# ec2 defaults to iso8601
value.utc.iso8601
end
end
end
end
end
|
