Function buildSafeOutputChainMetrics

pkg/cli/logs_safe_output_chains.go:40–102

(logsPath string)

}

func buildSafeOutputChainMetrics(logsPath string) SafeOutputChainMetrics {
	items := extractCreatedItemsFromManifest(logsPath)
	metrics := SafeOutputChainMetrics{
		ManifestEntryCount: len(items),
	}
	if logsPath == "" {
		return metrics
	}
	if !safeOutputArtifactsPresent(logsPath) {
		safeOutputChainsLog.Print("No safe output artifacts present, skipping chain metrics")
		return metrics
	}

	safeOutputChainsLog.Printf("Building safe output chain metrics: manifest_entries=%d", len(items))

	resolvedTargets, tempIDMapStatus := loadResolvedTemporaryIDTargets(logsPath)
	metrics.TemporaryIDMapStatus = tempIDMapStatus
	metrics.TemporaryIDMappings = len(resolvedTargets)
	safeOutputChainsLog.Printf("Temporary ID map status=%s, mappings=%d", tempIDMapStatus, len(resolvedTargets))
	if len(items) == 0 || len(resolvedTargets) == 0 {
		return metrics
	}

	itemCounts := make(map[string]int)
	delegatedTargets := make(map[string]struct {
	})
	closedTargets := make(map[string]struct {
	})
	for _, item := range items {
		if item.Repo == "" || item.Number <= 0 {
			continue
		}
		key := safeOutputTargetKey(item.Repo, item.Number)
		itemCounts[key]++
		switch item.Type {
		case "assign_to_agent", "create_agent_session":
			delegatedTargets[key] = struct {
			}{}
		case "close_issue", "close_pull_request", "close_discussion", "merge_pull_request":
			closedTargets[key] = struct {
			}{}
		}
	}

	for _, target := range resolvedTargets {
		key := safeOutputTargetKey(target.Repo, target.Number)
		count := itemCounts[key]
		if count > 1 {
			metrics.ChainedTargetCount++
			metrics.ChainedFollowupActionCount += count - 1
		}
		if setutil.Contains(delegatedTargets, key) {
			metrics.DelegatedTempTargetCount++
		}
		if setutil.Contains(closedTargets, key) {
			metrics.ClosedTempTargetCount++
		}
	}