Function computeMCPToolsDiff

pkg/cli/audit_diff.go:412–503

computeMCPToolsDiff computes the diff between two runs' MCP tool usage. run1 is the "before" (baseline) and run2 is the "after" (comparison target).

(run1, run2 *MCPToolUsageData)

// computeMCPToolsDiff computes the diff between two runs' MCP tool usage.
// run1 is the "before" (baseline) and run2 is the "after" (comparison target).
func computeMCPToolsDiff(run1, run2 *MCPToolUsageData) *MCPToolsDiff {
	run1Count, run2Count := 0, 0
	if run1 != nil {
		run1Count = len(run1.Summary)
	}
	if run2 != nil {
		run2Count = len(run2.Summary)
	}
	auditDiffLog.Printf("Computing MCP tools diff: run1_tools=%d, run2_tools=%d", run1Count, run2Count)
	run1Tools := make(map[string]MCPToolSummary)
	run2Tools := make(map[string]MCPToolSummary)

	if run1 != nil {
		for _, s := range run1.Summary {
			run1Tools[mcpToolKey(s.ServerName, s.ToolName)] = s
		}
	}
	if run2 != nil {
		for _, s := range run2.Summary {
			run2Tools[mcpToolKey(s.ServerName, s.ToolName)] = s
		}
	}

	allKeys := make(map[string]struct{})
	for k := range run1Tools {
		allKeys[k] = struct{}{}
	}
	for k := range run2Tools {
		allKeys[k] = struct{}{}
	}

	sortedKeys := sliceutil.SortedKeys(allKeys)

	diff := &MCPToolsDiff{}
	anomalyCount := 0

	for _, key := range sortedKeys {
		s1, inRun1 := run1Tools[key]
		s2, inRun2 := run2Tools[key]

		if !inRun1 && inRun2 {
			entry := MCPToolDiffEntry{
				ServerName:     s2.ServerName,
				ToolName:       s2.ToolName,
				Status:         "new",
				Run2CallCount:  s2.CallCount,
				Run2ErrorCount: s2.ErrorCount,
			}
			if s2.ErrorCount > 0 {
				entry.IsAnomaly = true
				entry.AnomalyNote = "new tool with errors"
				anomalyCount++
			}
			diff.NewTools = append(diff.NewTools, entry)
		} else if inRun1 && !inRun2 {
			diff.RemovedTools = append(diff.RemovedTools, MCPToolDiffEntry{
				ServerName:     s1.ServerName,
				ToolName:       s1.ToolName,