/
utils.go
51 lines (41 loc) · 1.18 KB
/
utils.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
package ali_mns
import (
"net/http"
"io/ioutil"
"github.com/gogap/errors"
)
func send(client MNSClient, decoder MNSDecoder, method Method, headers map[string]string, message interface{}, resource string, v interface{}) (statusCode int, err error) {
var resp *http.Response
if resp, err = client.Send(method, headers, message, resource); err != nil {
return
}
if resp != nil {
defer resp.Body.Close()
statusCode = resp.StatusCode
if resp.StatusCode != http.StatusCreated &&
resp.StatusCode != http.StatusOK &&
resp.StatusCode != http.StatusNoContent {
// get the response body
// the body is set in error when decoding xml failed
bodyBytes, e := ioutil.ReadAll(resp.Body)
if e != nil {
err = ERR_READ_RESPONSE_BODY_FAILED.New(errors.Params{"err": e})
return
}
var e2 error
err, e2 = decoder.DecodeError(bodyBytes, resource)
if e2 != nil {
err = ERR_UNMARSHAL_ERROR_RESPONSE_FAILED.New(errors.Params{"err": e2, "resp":string(bodyBytes)})
return
}
return
}
if v != nil {
if e := decoder.Decode(resp.Body, v); e != nil {
err = ERR_UNMARSHAL_RESPONSE_FAILED.New(errors.Params{"err": e})
return
}
}
}
return
}