Method sendWithRetries

utils/network/http_client.go:38–78

(request *HttpRequest, ctx context.Context)

}

func (c HttpClient) sendWithRetries(request *HttpRequest, ctx context.Context) (*HttpResponse, error) {
	request.Header.Set("User-Agent", UserAgent)
	request.Header.Set("x-request-id", c.settings.OperationId)
	if request.Authorization != nil {
		request.Header.Set("Authorization", fmt.Sprintf("%s %s", request.Authorization.Type, request.Authorization.Value))
	}

	if c.settings.Debug {
		request.Body = newResettableReader(request.Body, bufferLimit, func(body []byte) { c.logRequest(request, body) })
	} else if c.settings.MaxAttempts > 1 {
		request.Body = newResettableReader(request.Body, bufferLimit, func(body []byte) {})
	}

	var response *HttpResponse
	var err error
	err = resiliency.RetryN(c.settings.MaxAttempts, func(attempt int) error {
		if attempt > 1 && !c.resetReader(request.Body) {
			return err
		}

		response, err = c.send(request, ctx)
		if err != nil {
			return resiliency.Retryable(err)
		}

		if c.settings.Debug {
			response.Body = newResettableReader(response.Body, bufferLimit, func(body []byte) { c.logResponse(response, body) })
		}

		if response.StatusCode == 0 || response.StatusCode >= 500 {
			defer func() { _ = response.Body.Close() }()
			body, err := io.ReadAll(response.Body)
			if err != nil {
				return resiliency.Retryable(fmt.Errorf("Error reading response: %w", err))
			}
			return resiliency.Retryable(fmt.Errorf("Service returned status code '%v' and body '%v'", response.StatusCode, string(body)))
		}
		return nil
	})
	return response, err
}

func (c HttpClient) resetReader(reader io.Reader) bool {
	resettableReader, ok := reader.(*resettableReader)