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
95
96
97
98
99
100
101
102
103
104
105
106
|
package route53
import (
"encoding/xml"
"fmt"
"github.com/aws/aws-sdk-go/aws/awserr"
"github.com/aws/aws-sdk-go/aws/request"
"github.com/aws/aws-sdk-go/private/protocol/xml/xmlutil"
)
const errorRespTag = "ErrorResponse"
const invalidChangeTag = "InvalidChangeBatch"
type standardXMLErrorResponse struct {
Code string `xml:"Error>Code"`
Message string `xml:"Error>Message"`
RequestID string `xml:"RequestId"`
}
func (e standardXMLErrorResponse) FillCommon(c *xmlErrorResponse) {
c.Code = e.Code
c.Message = e.Message
c.RequestID = e.RequestID
}
type invalidChangeBatchXMLErrorResponse struct {
Messages []string `xml:"Messages>Message"`
RequestID string `xml:"RequestId"`
}
func (e invalidChangeBatchXMLErrorResponse) FillCommon(c *xmlErrorResponse) {
c.Code = invalidChangeTag
c.Message = "ChangeBatch errors occurred"
c.Messages = e.Messages
c.RequestID = e.RequestID
}
type xmlErrorResponse struct {
Code string
Message string
Messages []string
RequestID string
}
func (e *xmlErrorResponse) UnmarshalXML(d *xml.Decoder, start xml.StartElement) error {
type commonFiller interface {
FillCommon(*xmlErrorResponse)
}
var errResp commonFiller
switch start.Name.Local {
case errorRespTag:
errResp = &standardXMLErrorResponse{}
case invalidChangeTag:
errResp = &invalidChangeBatchXMLErrorResponse{}
default:
return fmt.Errorf("unknown error message, %v", start.Name.Local)
}
if err := d.DecodeElement(errResp, &start); err != nil {
return err
}
errResp.FillCommon(e)
return nil
}
func unmarshalChangeResourceRecordSetsError(r *request.Request) {
defer r.HTTPResponse.Body.Close()
var errResp xmlErrorResponse
err := xmlutil.UnmarshalXMLError(&errResp, r.HTTPResponse.Body)
if err != nil {
r.Error = awserr.NewRequestFailure(
awserr.New(request.ErrCodeSerialization,
"failed to unmarshal error message", err),
r.HTTPResponse.StatusCode,
r.RequestID,
)
return
}
var baseErr awserr.Error
if len(errResp.Messages) != 0 {
var errs []error
for _, msg := range errResp.Messages {
errs = append(errs, awserr.New(invalidChangeTag, msg, nil))
}
baseErr = awserr.NewBatchError(errResp.Code, errResp.Message, errs)
} else {
baseErr = awserr.New(errResp.Code, errResp.Message, nil)
}
reqID := errResp.RequestID
if len(reqID) == 0 {
reqID = r.RequestID
}
r.Error = awserr.NewRequestFailure(
baseErr,
r.HTTPResponse.StatusCode,
reqID,
)
}
|
