Function comparePlainTextStream

pkg/util.go:1248–1307

(expectedResp models.HTTPResp, stream io.Reader, logger *zap.Logger)

}

func comparePlainTextStream(expectedResp models.HTTPResp, stream io.Reader, logger *zap.Logger) (bool, string, *StreamMismatchInfo, error) {
	expectedQueue := extractExpectedRawQueue(expectedResp, canonicalizePlainTextLine, false)
	actualQueue := make([]string, 0, len(expectedQueue))
	nextExpected := 0

	scanner := bufio.NewScanner(stream)
	scanner.Buffer(make([]byte, 0, 64*1024), maxStreamTokenSize)

	for scanner.Scan() {
		line := canonicalizePlainTextLine(scanner.Text())

		if nextExpected >= len(expectedQueue) {
			logger.Debug("received additional plain-text stream data after expected stream was fully matched; closing stream capture",
				zap.Int("expected_frames", len(expectedQueue)))
			break
		}

		actualQueue = append(actualQueue, line)
		expected := expectedQueue[nextExpected]
		if line != expected {
			logger.Debug("plain-text stream mismatch",
				zap.Int("frame_index", nextExpected),
				zap.String("expected", expected),
				zap.String("actual", line))
			mismatchInfo := &StreamMismatchInfo{
				FrameIndex:    nextExpected,
				ExpectedFrame: expected,
				ActualFrame:   line,
				Reason:        fmt.Sprintf("content mismatch at frame %d", nextExpected),
			}
			return false, strings.Join(actualQueue, "\n"), mismatchInfo, nil
		}

		nextExpected++
		if nextExpected == len(expectedQueue) {
			logger.Debug("all expected plain-text frames matched; closing stream capture early to avoid waiting for extra stream events",
				zap.Int("matched_frames", nextExpected))
			break
		}
	}

	if err := scanner.Err(); err != nil {
		return false, strings.Join(actualQueue, "\n"), nil, err
	}

	if nextExpected < len(expectedQueue) {
		logger.Debug("plain-text stream ended before all expected frames were received",
			zap.Int("expected_frames", len(expectedQueue)),
			zap.Int("matched_frames", nextExpected))
		mismatchInfo := &StreamMismatchInfo{
			FrameIndex:    nextExpected,
			ExpectedFrame: expectedQueue[nextExpected],
			ActualFrame:   "(stream ended - no more frames)",
			Reason:        fmt.Sprintf("expected %d frames but only received %d", len(expectedQueue), nextExpected),
		}
		return false, strings.Join(actualQueue, "\n"), mismatchInfo, nil
	}