Files
argo-cd/util/argo/diff/normalize.go
github-actions[bot] 4d9835927d Bump major version to 3 (#21410)
Signed-off-by: github-actions[bot] <41898282+github-actions[bot]@users.noreply.github.com>
Co-authored-by: crenshaw-dev <350466+crenshaw-dev@users.noreply.github.com>
2025-01-10 16:14:00 -05:00

69 lines
2.0 KiB
Go

package diff
import (
"github.com/argoproj/argo-cd/v3/pkg/apis/application/v1alpha1"
"github.com/argoproj/argo-cd/v3/util/argo/normalizers"
"github.com/argoproj/gitops-engine/pkg/diff"
"k8s.io/apimachinery/pkg/apis/meta/v1/unstructured"
)
// Normalize applies the full normalization on the lives and configs resources based
// on the provided DiffConfig.
func Normalize(lives, configs []*unstructured.Unstructured, diffConfig DiffConfig) (*NormalizationResult, error) {
result, err := preDiffNormalize(lives, configs, diffConfig)
if err != nil {
return nil, err
}
diffNormalizer, err := newDiffNormalizer(diffConfig.Ignores(), diffConfig.Overrides(), diffConfig.IgnoreNormalizerOpts())
if err != nil {
return nil, err
}
for _, live := range result.Lives {
if live != nil {
err = diffNormalizer.Normalize(live)
if err != nil {
return nil, err
}
}
}
for _, target := range result.Targets {
if target != nil {
err = diffNormalizer.Normalize(target)
if err != nil {
return nil, err
}
}
}
return result, nil
}
// newDiffNormalizer creates normalizer that uses Argo CD and application settings to normalize the resource prior to diffing.
func newDiffNormalizer(ignore []v1alpha1.ResourceIgnoreDifferences, overrides map[string]v1alpha1.ResourceOverride, opts normalizers.IgnoreNormalizerOpts) (diff.Normalizer, error) {
ignoreNormalizer, err := normalizers.NewIgnoreNormalizer(ignore, overrides, opts)
if err != nil {
return nil, err
}
knownTypesNorm, err := normalizers.NewKnownTypesNormalizer(overrides)
if err != nil {
return nil, err
}
return &composableNormalizer{normalizers: []diff.Normalizer{ignoreNormalizer, knownTypesNorm}}, nil
}
type composableNormalizer struct {
normalizers []diff.Normalizer
}
// Normalize performs resource normalization.
func (n *composableNormalizer) Normalize(un *unstructured.Unstructured) error {
for i := range n.normalizers {
if err := n.normalizers[i].Normalize(un); err != nil {
return err
}
}
return nil
}