Function execHTTP

cmd/cli/cli.go:335–367

(ep Endpoint, reqURL string, body []byte)

}

func execHTTP(ep Endpoint, reqURL string, body []byte) error {
	var r io.Reader
	if body != nil {
		r = bytes.NewReader(body)
	}
	req, err := http.NewRequest(ep.Method, reqURL, r)
	if err != nil {
		return err
	}
	if body != nil {
		req.Header.Set("Content-Type", "application/json")
	}
	client := &http.Client{Timeout: 30 * time.Second}
	resp, err := client.Do(req)
	if err != nil {
		return err
	}
	defer resp.Body.Close()

	payload, err := io.ReadAll(resp.Body)
	if err != nil {
		return err
	}
	if resp.StatusCode < 200 || resp.StatusCode >= 300 {
		if len(payload) == 0 {
			return fmt.Errorf("%s %s failed: %s", ep.Method, ep.Path, resp.Status)
		}
		return fmt.Errorf("%s %s failed: %s: %s", ep.Method, ep.Path, resp.Status, strings.TrimSpace(string(payload)))
	}

	printJSON(payload)
	return nil
}

func execWebsocket(ep Endpoint, reqURL string) error {
	wsURL := strings.Replace(reqURL, "http://", "ws://", 1)