Function CompareHTTPStream

pkg/util.go:945–960

CompareHTTPStream compares an expected HTTP response with a streaming response. It returns whether they match, the captured body content, mismatch details (if any), and any error.

(expectedResp models.HTTPResp, stream io.Reader, cfg HTTPStreamConfig, jsonNoiseKeys map[string]struct{}, logger *zap.Logger)

// CompareHTTPStream compares an expected HTTP response with a streaming response.
// It returns whether they match, the captured body content, mismatch details (if any), and any error.
func CompareHTTPStream(expectedResp models.HTTPResp, stream io.Reader, cfg HTTPStreamConfig, jsonNoiseKeys map[string]struct{}, logger *zap.Logger) (bool, string, *StreamMismatchInfo, error) {
	switch cfg.Mode {
	case HTTPStreamModeSSE:
		return compareSSEStream(expectedResp, stream, jsonNoiseKeys, logger)
	case HTTPStreamModeNDJSON:
		return compareNDJSONStream(expectedResp, stream, jsonNoiseKeys, logger)
	case HTTPStreamModeMultipart:
		return compareMultipartStream(expectedResp, stream, cfg.Boundary, jsonNoiseKeys, logger)
	case HTTPStreamModePlainText:
		return comparePlainTextStream(expectedResp, stream, logger)
	case HTTPStreamModeBinary:
		return compareBinaryStream(expectedResp, stream, logger)
	default:
		return false, "", nil, fmt.Errorf("unsupported HTTP stream mode: %s", cfg.Mode)
	}
}

func ComputeStreamingTimeoutSeconds(tc *models.TestCase, defaultSeconds uint64) uint64 {
	baseTimeout := defaultSeconds