Method requestURLWithLogger

http/client_impl.go:118–176

(
	method string,
	u string,
	requestBody interface{},
	responseBody interface{},
	logger log.Logger,
)

}

func (c *client) requestURLWithLogger(
	method string,
	u string,
	requestBody interface{},
	responseBody interface{},
	logger log.Logger,
) (int, error) {
	logger = logger.WithLabel("method", method).WithLabel("url", u)

	httpClient := c.createHTTPClient(logger)
	req, err := c.createRequestForURL(method, u, requestBody, logger)
	if err != nil {
		return 0, err
	}

	logger.Debug(message.NewMessage(message.MHTTPClientRequest, "HTTP %s request to %s", method, u))

	resp, err := httpClient.Do(req)
	if err != nil {
		var typedError message.Message
		if errors.As(err, &typedError) {
			return 0, err
		}
		err = message.Wrap(err,
			message.EHTTPFailureConnectionFailed, "HTTP %s request to %s failed", method, u)
		logger.Debug(err)
		return 0, err
	}
	defer func() { _ = resp.Body.Close() }()

	logger.Debug(
		message.NewMessage(
			message.MHTTPClientResponse,
			"HTTP response with status %d",
			resp.StatusCode,
		).Label("statusCode", resp.StatusCode))

	body, err := io.ReadAll(resp.Body)
	if err != nil {
		err = message.Wrap(err,
			message.EHTTPFailureConnectionFailed, "HTTP %s request to %s failed", method, u)
		logger.Debug(err)
		return 0, err
	}

	if responseBody == nil {
		return resp.StatusCode, nil
	}
	decoder := json.NewDecoder(bytes.NewReader(body))
	if !c.allowLaxDecoding {
		decoder.DisallowUnknownFields()
	}
	if err := decoder.Decode(responseBody); err != nil {
		err = message.Wrap(err, message.EHTTPFailureDecodeFailed, "Failed to decode HTTP response")
		logger.Debug(err)
		return resp.StatusCode, err
	}
	return resp.StatusCode, nil