in utils.go [11:60]
func send(client MNSClient, decoder MNSDecoder, method Method, headers map[string]string, message interface{}, resource string, v interface{}) (statusCode int, err error) {
var resp *fasthttp.Response
if resp, err = client.Send(method, headers, message, resource); err != nil {
return
}
if resp != nil {
statusCode = resp.Header.StatusCode()
if statusCode != fasthttp.StatusCreated &&
statusCode != fasthttp.StatusOK &&
statusCode != fasthttp.StatusNoContent {
// get the response body
// the body is set in error when decoding xml failed
bodyBytes := resp.Body()
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 {
buf := bytes.NewReader(resp.Body())
if e := decoder.Decode(buf, v); e != nil {
err = ERR_UNMARSHAL_RESPONSE_FAILED.New(errors.Params{"err": e})
return
}
if baseResponder, ok := v.(BaseResponder); ok {
hostId := ""
if resp.RemoteAddr() != nil {
hostId = resp.RemoteAddr().String()
}
baseResponder.SetBaseResponse(BaseResponse{
RequestId: string(resp.Header.Peek("x-mns-request-id")),
Code: strconv.Itoa(resp.StatusCode()),
HostId: hostId,
})
}
}
}
return
}