Method doRequest

client/gitSensor/GitSensorRestClient.go:261–310

(clientRequest *ClientRequest)

}

func (session *RestClientImpl) doRequest(clientRequest *ClientRequest) (resBody []byte, resCode *StatusCode, err error) {
	if clientRequest.ResponseBody == nil {
		return nil, nil, fmt.Errorf("response body cant be nil")
	}
	if reflect.ValueOf(clientRequest.ResponseBody).Kind() != reflect.Ptr {
		return nil, nil, fmt.Errorf("responsebody non pointer")
	}
	rel, err := session.baseUrl.Parse(clientRequest.Path)
	if err != nil {
		return nil, nil, err
	}
	var body io.Reader
	if clientRequest.RequestBody != nil {
		if req, err := json.Marshal(clientRequest.RequestBody); err != nil {
			return nil, nil, err
		} else {
			body = bytes.NewBuffer(req)
		}
	}
	httpReq, err := http.NewRequest(clientRequest.Method, rel.String(), body)
	if err != nil {
		return nil, nil, err
	}
	httpRes, err := session.httpClient.Do(httpReq)
	if err != nil {
		return nil, nil, err
	}
	defer httpRes.Body.Close()
	resBody, err = ioutil.ReadAll(httpRes.Body)
	if err != nil {
		session.logger.Errorw("error on git sensor request", "err", err)
		return nil, nil, err
	}
	status := StatusCode(httpRes.StatusCode)
	if status.IsSuccess() {
		apiRes := &GitSensorResponse{}
		err = json.Unmarshal(resBody, apiRes)
		if apiStatus := StatusCode(apiRes.Code); apiStatus.IsSuccess() {
			err = json.Unmarshal(apiRes.Result, clientRequest.ResponseBody)
			return resBody, &apiStatus, err
		} else {
			session.logger.Errorw("api err in git sensor response", "res", apiRes.Errors)
			return resBody, &apiStatus, fmt.Errorf("err in git-sensor communication api res")
		}
	} else {
		session.logger.Errorw("api err in git sensor response", "res", string(resBody))
		return resBody, &status, fmt.Errorf("res not success, Statuscode: %d ", status)
	}
	return resBody, &status, err
}

func NewGitSensorSession(config *ClientConfig, logger *zap.SugaredLogger) (session *RestClientImpl, err error) {
	baseUrl, err := url.Parse(config.Url)