Method validateRoute

internal/manager/route.go:263–481

(r *route.Route)

}

func (m *RouteManager) validateRoute(r *route.Route) error {
	fields := []string{}

	if len(r.Name) == 0 {
		fields = append(fields, "name")
	}

	if len(r.Path) == 0 {
		fields = append(fields, "path")
	}

	if len(r.KeyIds) == 0 {
		fields = append(fields, "keyIds")
	}

	if len(r.Steps) == 0 {
		fields = append(fields, "steps")
	}

	if len(r.RetryStrategy) != 0 && r.RetryStrategy != "exponential" && r.RetryStrategy != "constant" {
		fields = append(fields, "retryStrategy")
	}

	containAda := false

	for index, step := range r.Steps {
		if len(step.Provider) == 0 {
			fields = append(fields, fmt.Sprintf("steps.[%d].provider", index))
		}

		if len(step.RetryInterval) != 0 {
			_, err := time.ParseDuration(step.RetryInterval)
			if err != nil {
				fields = append(fields, fmt.Sprintf("steps.[%d].retryInterval", index))
			}

			if !strings.HasSuffix(step.RetryInterval, "s") && !strings.HasSuffix(step.RetryInterval, "ms") {
				fields = append(fields, fmt.Sprintf("steps.[%d].retryInterval", index))
			}
		}

		if !contains(step.Provider, supportedProviders) {
			return fmt.Errorf("steps.[%d].provider is not supported. Only azure and openai are supported", index)
		}

		if step.Provider == "azure" {
			apiVersion := step.Params["apiVersion"]
			if len(apiVersion) == 0 {
				fields = append(fields, fmt.Sprintf("steps.[%d].params.apiVersion", index))
			}

			deploymentId := step.Params["deploymentId"]
			if len(deploymentId) == 0 {
				fields = append(fields, fmt.Sprintf("steps.[%d].params.deploymentId", index))
			}
		}

		if len(step.Model) == 0 {