func()

in bulk/jobs.go [95:126]


func (j *Jobs) do(request *http.Request) (jobResponse, error) {
	response, err := j.session.Client().Do(request)
	if err != nil {
		return jobResponse{}, err
	}

	decoder := json.NewDecoder(response.Body)
	defer response.Body.Close()

	if response.StatusCode != http.StatusOK {
		var jobsErrs []sfdc.Error
		err = decoder.Decode(&jobsErrs)
		var errMsg error
		if err == nil {
			for _, jobErr := range jobsErrs {
				errMsg = fmt.Errorf("insert response err: %s: %s", jobErr.ErrorCode, jobErr.Message)
			}
		} else {
			errMsg = fmt.Errorf("insert response err: %d %s", response.StatusCode, response.Status)
		}

		return jobResponse{}, errMsg
	}

	var value jobResponse
	err = decoder.Decode(&value)
	if err != nil {
		return jobResponse{}, err
	}
	return value, nil

}