Method Execute

pkg/tools/http.go:196–308

(config HTTPToolConfig, params map[string]interface{})

	h.AllowedDomains = append(h.AllowedDomains, domain)
}
func (h *HTTPExecutor) Execute(config HTTPToolConfig, params map[string]interface{}) (string, error) {
	reqURL := config.URL
	for key, val := range params {
		reqURL = strings.ReplaceAll(reqURL, "{"+key+"}", fmt.Sprintf("%v", val))
	}
	if err := h.checkDomain(reqURL); err != nil {
		return "", err
	}
	var bodyBytes []byte
	if len(config.RawBody) > 0 {
		bodyBytes = config.RawBody
	} else if config.Method != "GET" && config.Method != "DELETE" {
		if config.Body == "json" {
			var err error
			bodyBytes, err = json.Marshal(params)
			if err != nil {
				return "", fmt.Errorf("ark/tools/http: marshal body: %w", err)
			}
		} else if config.Body != "" {
			body := config.Body
			for key, val := range params {
				body = strings.ReplaceAll(body, "{"+key+"}", fmt.Sprintf("%v", val))
			}
			bodyBytes = []byte(body)
		}
	}
	headers := make(map[string]string)
	for k, v := range config.Headers {
		for pk, pv := range params {
			v = strings.ReplaceAll(v, "{"+pk+"}", fmt.Sprintf("%v", pv))
		}
		headers[k] = v
	}
	client := h.Client
	if config.Timeout > 0 {
		client = &http.Client{
			Timeout:   config.Timeout,
			Transport: h.Client.Transport,
		}
	}
	backoff := initialBackoff
	var lastErr error

	for attempt := 0; attempt <= maxRetries; attempt++ {
		if attempt > 0 {
			time.Sleep(backoff + jitter())
			backoff = time.Duration(float64(backoff) * backoffFactor)
		}

		if h.Debug {
			fmt.Printf("[ark/http] %s %s (attempt %d/%d)\n",
				config.Method, reqURL, attempt+1, maxRetries+1)
		}

		var bodyReader io.Reader
		if bodyBytes != nil {
			bodyReader = bytes.NewReader(bodyBytes)
		}