Function SimulateHTTP

pkg/util.go:708–779

(ctx context.Context, tc *models.TestCase, testSet string, logger *zap.Logger, cfg SimulationConfig)

}

func SimulateHTTP(ctx context.Context, tc *models.TestCase, testSet string, logger *zap.Logger, cfg SimulationConfig) (*models.HTTPResp, error) {
	templatedResponse := tc.HTTPResp // keep a copy of the original templatized response

	logger.Info("starting test for", zap.Any("test case", models.HighlightString(tc.Name)), zap.Any("test set", models.HighlightString(testSet)))

	// Prepare the HTTP request using the shared helper
	cfg.RequestTimeout = time.Second * time.Duration(cfg.APITimeout)
	prepared, err := prepareHTTPRequest(ctx, tc, testSet, logger, cfg)
	if err != nil {
		return nil, err
	}

	logger.Debug(fmt.Sprintf("Sending request to user app:%v", prepared.Request))

	// Execute the request (re-sending only on a pre-response connection-refused)
	httpResp, errHTTPReq := doRequestWithConnRefusedRetry(ctx, logger, prepared.Client, prepared.Request)
	if errHTTPReq != nil {
		utils.LogError(logger, errHTTPReq, "failed to send testcase request to app")
		return nil, errHTTPReq
	}

	defer func() {
		if httpResp != nil && httpResp.Body != nil {
			if err := httpResp.Body.Close(); err != nil {
				utils.LogError(logger, err, "failed to close response body")
			}
		}
	}()

	// Read full response body
	respBody, errReadRespBody := io.ReadAll(httpResp.Body)
	if errReadRespBody != nil {
		utils.LogError(logger, errReadRespBody, "failed reading response body")
		return nil, errReadRespBody
	}

	// Decompress if needed
	if httpResp.Header.Get("Content-Encoding") != "" {
		respBody, err = Decompress(logger, httpResp.Header.Get("Content-Encoding"), respBody)
		if err != nil {
			utils.LogError(logger, err, "failed to decode response body")
			return nil, err
		}
	}

	statusMessage := http.StatusText(httpResp.StatusCode)

	resp := &models.HTTPResp{
		StatusCode:    httpResp.StatusCode,
		StatusMessage: statusMessage,
		Body:          string(respBody),
		Header:        ToYamlHTTPHeader(httpResp.Header),
	}

	// Centralized template update: walk the response body and headers to refresh template values.
	// NOTE: header-only updates are important for e.g. listmonk where the login 302 has an empty
	// body but carries a fresh Set-Cookie: session=... that every subsequent test consumes.
	if len(respBody) > 0 || len(resp.Header) > 0 {