pkg/resourcewatch/git/diff.go - main - githubmirror/origin

pkg/resourcewatch/git/diff.go
70 строк2 KB
Fabio Bertinatto
bump(k8s): react to Kubernetes bump
23 окт 2025, 22:21
23 окт 2025, 22:21e92d74c
package git

import (
	"encoding/json"
	"fmt"

	"k8s.io/apimachinery/pkg/api/meta"
	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
	"k8s.io/apimachinery/pkg/apis/meta/v1/unstructured"
	"k8s.io/apimachinery/pkg/runtime"
	"k8s.io/apimachinery/pkg/util/managedfields"
	"k8s.io/apimachinery/pkg/util/sets"
	"sigs.k8s.io/structured-merge-diff/v6/typed"
)

var typeConverter managedfields.TypeConverter = managedfields.NewDeducedTypeConverter()

func modifiedFields(oldRuntimeObject, newRuntimeObject *unstructured.Unstructured) (*typed.Comparison, error) {
	oldObject, err := typeConverter.ObjectToTyped(oldRuntimeObject)
	if err != nil {
		return nil, fmt.Errorf("failed to convert live object (%v) to smd typed: %v", objectGVKNN(oldRuntimeObject), err)
	}
	newObject, err := typeConverter.ObjectToTyped(newRuntimeObject)
	if err != nil {
		return nil, fmt.Errorf("failed to convert new object (%v) to smd typed: %v", objectGVKNN(newRuntimeObject), err)
	}

	compare, err := oldObject.Compare(newObject)
	if err != nil {
		return nil, fmt.Errorf("failed to compare objects: %v", err)
	}

	return compare, nil
}

func whichUsersOwnModifiedFields(obj *unstructured.Unstructured, comparison typed.Comparison) ([]string, error) {
	users := sets.NewString()

	managers, err := managedfields.DecodeManagedFields(obj.GetManagedFields())
	if err != nil {
		return nil, err
	}

	for manager, managerSet := range managers.Fields() {
		setByThisManager := managerSet.Set().Intersection(comparison.Modified.Union(comparison.Added).Union(comparison.Removed))
		if !setByThisManager.Empty() {
			// sometimes I'm seeing the entire manager json listed.  My guess is for subresources its tracked as a key.
			currManagerAsJSON := &metav1.ManagedFieldsEntry{}
			if err := json.Unmarshal([]byte(manager), currManagerAsJSON); err != nil {
				users.Insert(manager)
			} else {
				users.Insert(currManagerAsJSON.Manager)
			}
			continue
		}
	}

	return users.List(), nil
}

func objectGVKNN(obj runtime.Object) string {
	name := "<unknown>"
	namespace := "<unknown>"
	if accessor, err := meta.Accessor(obj); err == nil {
		name = accessor.GetName()
		namespace = accessor.GetNamespace()
	}

	return fmt.Sprintf("%v/%v; %v", namespace, name, obj.GetObjectKind().GroupVersionKind())
}