/
build.go
72 lines (65 loc) · 2.54 KB
/
build.go
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
// Package computing provides serialization of NIFCLOUD Computing requests and responses.
package computing
import (
"fmt"
"net/url"
"reflect"
request "github.com/aws/aws-sdk-go-v2/aws"
"github.com/aws/aws-sdk-go-v2/aws/awserr"
"github.com/nifcloud/nifcloud-sdk-go/private/protocol/query/queryutil"
)
// BuildHandler is a named request handler for building computing protocol requests
var BuildHandler = request.NamedHandler{Name: "awssdk.computing.Build", Fn: Build}
// Build builds a request for the EC2 protocol.
func Build(r *request.Request) {
body := url.Values{
"Action": {r.Operation.Name},
"Version": {r.Metadata.APIVersion},
}
if err := queryutil.Parse(body, r.Params, true); err != nil {
r.Error = awserr.New("SerializationError", "failed encoding NIFCLOUD Computing Query request", err)
}
// Fix request parameters of DescribeLoadBalancers for NIFCLOUD
if r.Operation.Name == "DescribeLoadBalancers" {
parameterLength := reflect.ValueOf(r.Params).Elem().FieldByName("LoadBalancerNames").Len()
prefix := "LoadBalancerNames"
for i := 1; i <= parameterLength; i++ {
loadBalancerNameKey := fmt.Sprintf("%s.member.%d.LoadBalancerName", prefix, i)
loadBalancerPortKey := fmt.Sprintf("%s.member.%d.LoadBalancerPort", prefix, i)
instancePortKey := fmt.Sprintf("%s.member.%d.InstancePort", prefix, i)
loadBalancerName := body.Get(loadBalancerNameKey)
loadBalancerPort := body.Get(loadBalancerPortKey)
instancePort := body.Get(instancePortKey)
if loadBalancerName != "" {
body.Set(fmt.Sprintf("%s.member.%d", prefix, i), loadBalancerName)
body.Del(loadBalancerNameKey)
}
if loadBalancerPort != "" {
body.Set(fmt.Sprintf("%s.LoadBalancerPort.%d", prefix, i), loadBalancerPort)
body.Del(loadBalancerPortKey)
}
if instancePort != "" {
body.Set(fmt.Sprintf("%s.InstancePort.%d", prefix, i), instancePort)
body.Del(instancePortKey)
}
}
}
// Fix request parameters of RunInstances, StartInstances, RebootInstances for NIFCLOUD
if r.Operation.Name == "RunInstances" ||
r.Operation.Name == "StartInstances" ||
r.Operation.Name == "RebootInstances" {
userData := body.Get("UserData.Content")
if userData != "" {
body.Set("UserData", userData)
body.Del("UserData.Content")
}
}
if r.ExpireTime == 0 {
r.HTTPRequest.Method = "POST"
r.HTTPRequest.Header.Set("Content-Type", "application/x-www-form-urlencoded; charset=utf-8")
r.SetBufferBody([]byte(body.Encode()))
} else { // This is a pre-signed request
r.HTTPRequest.Method = "GET"
r.HTTPRequest.URL.RawQuery = body.Encode()
}
}