in bulk/job.go [277:307]
func (j *Job) infoResponse(request *http.Request) (Info, error) {
response, err := j.session.Client().Do(request)
if err != nil {
return Info{}, err
}
decoder := json.NewDecoder(response.Body)
defer response.Body.Close()
if response.StatusCode != http.StatusOK {
var errs []sfdc.Error
err = decoder.Decode(&errs)
var errMsg error
if err == nil {
for _, err := range errs {
errMsg = fmt.Errorf("job err: %s: %s", err.ErrorCode, err.Message)
}
} else {
errMsg = fmt.Errorf("job err: %d %s", response.StatusCode, response.Status)
}
return Info{}, errMsg
}
var value Info
err = decoder.Decode(&value)
if err != nil {
return Info{}, err
}
return value, nil
}