Function executeReplay

cmd/requester.go:1283–1317

(spec ReplaySpec)

}

func executeReplay(spec ReplaySpec) (ResponseInfo, error) {
	switch spec.kind {
	case "http":
		var proxyURL *url.URL
		if spec.proxy != "" {
			parsed, err := url.Parse(spec.proxy)
			if err != nil {
				return ResponseInfo{}, err
			}
			proxyURL = parsed
		}
		return requestWithRetryBody(spec.method, spec.uri, spec.headers, spec.body, proxyURL, false, spec.timeout, spec.redirect)
	case "raw":
		return rawRequest(spec.method, spec.uri, spec.requestTarget, spec.headers, spec.body, spec.timeout)
	case "curl":
		ctx, cancel := context.WithTimeout(context.Background(), time.Duration(spec.timeout)*time.Millisecond)
		defer cancel()
		cmd := exec.CommandContext(ctx, "curl", spec.curlArgs...)
		out, err := cmd.Output()
		if err != nil {
			return ResponseInfo{}, err
		}
		res := parseCurlOutput(string(out), "curl-replay")
		return ResponseInfo{
			statusCode:    res.statusCode,
			contentLength: res.contentLength,
			bodyHash:      res.bodyHash,
			location:      res.location,
			contentType:   res.contentType,
			server:        res.server,
		}, nil
	default:
		return ResponseInfo{}, fmt.Errorf("unsupported replay kind %q", spec.kind)
	}
}

func wrapText(text string, width int) []string {
	if len(text) <= width {