Function buildMissingDataSummary

pkg/cli/logs_report_errors.go:111–154

buildMissingDataSummary aggregates missing data across all runs

(processedRuns []ProcessedRun)

// buildMissingDataSummary aggregates missing data across all runs
func buildMissingDataSummary(processedRuns []ProcessedRun) []MissingDataSummary {
	reportLog.Printf("Building missing data summary from %d processed runs", len(processedRuns))
	result := aggregateSummaryItems(
		processedRuns,
		// getItems: extract missing data from each run
		func(pr ProcessedRun) []MissingDataReport {
			return pr.MissingData
		},
		// getKey: use data type as the aggregation key
		func(data MissingDataReport) string {
			return data.DataType
		},
		// createSummary: create new summary for first occurrence
		func(data MissingDataReport) *MissingDataSummary {
			return &MissingDataSummary{
				DataType: data.DataType,
				AggregatedSummaryBase: AggregatedSummaryBase{
					Count:       1,
					Workflows:   []string{data.WorkflowName},
					FirstReason: data.Reason,
					RunIDs:      []int64{data.RunID},
				},
			}
		},
		// updateSummary: update existing summary with new occurrence
		func(summary *MissingDataSummary, data MissingDataReport) {
			summary.Count++
			summary.Workflows = sliceutil.MergeUnique(summary.Workflows, data.WorkflowName)
			summary.RunIDs = append(summary.RunIDs, data.RunID)
		},
		// finalizeSummary: populate display fields for console rendering
		func(summary *MissingDataSummary) {
			summary.WorkflowsDisplay = strings.Join(summary.Workflows, ", ")
			summary.FirstReasonDisplay = summary.FirstReason
		},
	)

	// Sort by count descending
	slices.SortFunc(result, func(a, b MissingDataSummary) int {
		return cmp.Compare(b.Count, a.Count)
	})

	return result
}