Method RunSteps

internal/route/route.go:392–611

(req *Request, rec recorder, log *zap.Logger)

}

func (r *Route) RunSteps(req *Request, rec recorder, log *zap.Logger) (*Response, error) {
	if len(r.Steps) == 0 {
		return nil, errors.New("steps are empty")
	}

	responses := []*http.Response{}
	cancelFuncs := []context.CancelFunc{}

	noResponses := false
	defer func() {
		for index, resp := range responses {
			if index != len(responses)-1 {
				if resp != nil {
					resp.Body.Close()
				}
			}
		}

		for index, cancel := range cancelFuncs {
			if index != len(cancelFuncs)-1 || noResponses {
				cancel()
			}
		}
	}()

	body, err := io.ReadAll(req.Forwarded.Body)
	if err != nil {
		return nil, err
	}

	var lastErr error
	stopStep := 0

	totalRetries := 0
	currentRetry := 0
	for _, step := range r.Steps {
		totalRetries += step.Retries
	}

	for idx, step := range r.Steps {
		resourceName := ""

		if step.Provider == "azure" {
			val, err := req.GetSettingValue("azure", "resourceName")
			if err != nil {
				return nil, err
			}

			resourceName = val
		}

		key, err := req.GetSettingValue(step.Provider, "apikey")
		if err != nil {
			return nil, err
		}

		parsed, err := time.ParseDuration(step.Timeout)
		if err != nil {