Skip to content

Commit b33fe26

Browse files
authored
Revert "De duplication logic to NF Deploy Fn Param Ref" (#498)
Reverts #494
1 parent 83e0a69 commit b33fe26

File tree

11 files changed

+10
-309
lines changed

11 files changed

+10
-309
lines changed

krm-functions/nfdeploy-fn/fn/function.go

+5-7
Original file line numberDiff line numberDiff line change
@@ -259,11 +259,6 @@ func (f *NfDeployFn) UpdateResourceFn(nfDeploymentObj *fn.KubeObject, objs fn.Ku
259259
return nil, err
260260
}
261261

262-
// add all the existing param ref to the struct
263-
// we need to compare for deduplication logic
264-
// slice append is not ideal, it breaks the function idempotency requirement
265-
f.paramRef = nf.Spec.ParametersRefs
266-
267262
capObjs := objs.Where(fn.IsGroupVersionKind(nephioreqv1alpha1.CapacityGroupVersionKind))
268263
for _, o := range capObjs {
269264
if err := f.CapacityUpdate(o); err != nil {
@@ -276,7 +271,6 @@ func (f *NfDeployFn) UpdateResourceFn(nfDeploymentObj *fn.KubeObject, objs fn.Ku
276271
return nil, err
277272
}
278273
}
279-
280274
itfceObjs := objs.Where(fn.IsGroupVersionKind(nephioreqv1alpha1.InterfaceGroupVersionKind))
281275
for _, o := range itfceObjs {
282276
if err := f.InterfaceUpdate(o); err != nil {
@@ -293,7 +287,11 @@ func (f *NfDeployFn) UpdateResourceFn(nfDeploymentObj *fn.KubeObject, objs fn.Ku
293287

294288
f.FillCapacityDetails(nf)
295289

296-
nf.Spec.ParametersRefs = f.paramRef
290+
if len(nf.Spec.ParametersRefs) == 0 {
291+
nf.Spec.ParametersRefs = f.paramRef
292+
} else {
293+
nf.Spec.ParametersRefs = append(nf.Spec.ParametersRefs, f.paramRef...)
294+
}
297295

298296
//sort the paramRefs
299297
sort.Slice(nf.Spec.ParametersRefs, func(i, j int) bool {

krm-functions/nfdeploy-fn/fn/helper.go

+5-16
Original file line numberDiff line numberDiff line change
@@ -121,20 +121,9 @@ func (h *NfDeployFn) FillCapacityDetails(nf *workloadv1alpha1.NFDeployment) {
121121
}
122122

123123
func (h *NfDeployFn) AddDependencyRef(ref corev1.ObjectReference) {
124-
if !h.checkDependencyExist(ref) {
125-
h.paramRef = append(h.paramRef, workloadv1alpha1.ObjectReference{
126-
Name: &ref.Name,
127-
Kind: ref.Kind,
128-
APIVersion: ref.APIVersion,
129-
})
130-
}
131-
}
132-
133-
func (h *NfDeployFn) checkDependencyExist(ref corev1.ObjectReference) bool {
134-
for _, p := range h.paramRef {
135-
if *p.Name == ref.Name && p.Kind == ref.Kind && p.APIVersion == ref.APIVersion {
136-
return true
137-
}
138-
}
139-
return false
124+
h.paramRef = append(h.paramRef, workloadv1alpha1.ObjectReference{
125+
Name: &ref.Name,
126+
Kind: ref.Kind,
127+
APIVersion: ref.APIVersion,
128+
})
140129
}

krm-functions/nfdeploy-fn/fn/testdata/golden/nfdeployment_witthduplicatedependency/Kptfile

-34
This file was deleted.

krm-functions/nfdeploy-fn/fn/testdata/golden/nfdeployment_witthduplicatedependency/_expected.yaml

-156
This file was deleted.

krm-functions/nfdeploy-fn/fn/testdata/golden/nfdeployment_witthduplicatedependency/capacity.yaml

-11
This file was deleted.

krm-functions/nfdeploy-fn/fn/testdata/golden/nfdeployment_witthduplicatedependency/dependency.yaml

-18
This file was deleted.

krm-functions/nfdeploy-fn/fn/testdata/golden/nfdeployment_witthduplicatedependency/dependency_1.yaml

-18
This file was deleted.

krm-functions/nfdeploy-fn/fn/testdata/golden/nfdeployment_witthduplicatedependency/dnn.yaml

-10
This file was deleted.

krm-functions/nfdeploy-fn/fn/testdata/golden/nfdeployment_witthduplicatedependency/interface-n2.yaml

-18
This file was deleted.

krm-functions/nfdeploy-fn/fn/testdata/golden/nfdeployment_witthduplicatedependency/nfdeployment.yaml

-8
This file was deleted.

krm-functions/nfdeploy-fn/fn/testdata/golden/nfdeployment_witthduplicatedependency/workload_cluster.yaml

-13
This file was deleted.

0 commit comments

Comments
 (0)