Function summarize

scripts/gotestsummary/main.go:154–253

(ctx context.Context, r io.Reader, maxOutputBytes int, stderr io.Writer)

}

func summarize(ctx context.Context, r io.Reader, maxOutputBytes int, stderr io.Writer) (summary, error) {
	reader := bufio.NewReader(r)
	buffers := map[testKey]*tailBuffer{}
	failures := map[testKey]failure{}
	packageFailures := map[string]struct{}{}
	var durationSeconds float64
	var malformedWarnings int

	for lineNumber := 1; ; lineNumber++ {
		if err := ctx.Err(); err != nil {
			return summary{}, err
		}
		line, err := reader.ReadString('\n')
		if errors.Is(err, io.EOF) && line == "" {
			break
		}
		if err != nil && !errors.Is(err, io.EOF) {
			return summary{}, xerrors.Errorf("read json line: %w", err)
		}
		line = strings.TrimSpace(line)
		if line == "" {
			if errors.Is(err, io.EOF) {
				break
			}
			continue
		}

		var raw map[string]json.RawMessage
		if err := json.Unmarshal([]byte(line), &raw); err != nil {
			malformedWarnings++
			writef(stderr, "warning: skipping malformed go test JSON line %d: %v\n", lineNumber, err)
			continue
		}
		if raw == nil {
			malformedWarnings++
			writef(stderr, "warning: skipping non-object go test JSON line %d\n", lineNumber)
			continue
		}
		var event testEvent
		if err := json.Unmarshal([]byte(line), &event); err != nil {
			malformedWarnings++
			writef(stderr, "warning: skipping malformed go test JSON line %d: %v\n", lineNumber, err)
			continue
		}

		key := testKey{pkg: event.Package, test: event.Test}
		switch event.Action {
		case "output":
			bufferFor(buffers, key, maxOutputBytes).Append(stripANSI(event.Output))
		case "pass", "skip":
			delete(buffers, key)
			delete(failures, key)
			if event.Test == "" {
				delete(packageFailures, event.Package)
				if event.Action == "pass" {
					durationSeconds += event.Elapsed
				}
			}