🐛 Make the work feedback rule jaonpath name unique (#346)

* Make the work feedback rule jaonpath name unique

Signed-off-by: zhujian <jiazhu@redhat.com>

* Update crds

Signed-off-by: zhujian <jiazhu@redhat.com>

* Address code review comments

Signed-off-by: zhujian <jiazhu@redhat.com>

* Add unit tests

Signed-off-by: zhujian <jiazhu@redhat.com>

---------

Signed-off-by: zhujian <jiazhu@redhat.com>

Author: zhujian7

addon/v1alpha1/0000_03_addon.open-cluster-management.io_addontemplates.crd.yaml

@@ -203,6 +203,9 @@ spec:
                                   - path
                                   type: object
                                 type: array
+                                x-kubernetes-list-map-keys:
+                                - name
+                                x-kubernetes-list-type: map
                               type:
                                 description: |-
                                   Type defines the option of how status can be returned.

test/integration/api/manifestwork_test.go

@@ -214,7 +214,7 @@ var _ = ginkgo.Describe("ManifestWork API test", func() {
 			gomega.Expect(err).To(gomega.HaveOccurred())
 		})
 
-		ginkgo.It("set feedback rule", func() {
+		ginkgo.It("set well known status feedback rule", func() {
 			work := &workv1.ManifestWork{
 				ObjectMeta: metav1.ObjectMeta{
 					Name: manifestWorkName,
@@ -239,5 +239,69 @@ var _ = ginkgo.Describe("ManifestWork API test", func() {
 				Create(context.TODO(), work, metav1.CreateOptions{})
 			gomega.Expect(err).ToNot(gomega.HaveOccurred())
 		})
+
+		ginkgo.It("set jsonpath feedback rule", func() {
+			work := &workv1.ManifestWork{
+				ObjectMeta: metav1.ObjectMeta{
+					Name: manifestWorkName,
+				},
+				Spec: workv1.ManifestWorkSpec{
+					ManifestConfigs: []workv1.ManifestConfigOption{
+						{
+							ResourceIdentifier: workv1.ResourceIdentifier{
+								Resource:  "foo",
+								Name:      "test",
+								Namespace: "testns",
+							},
+							FeedbackRules: []workv1.FeedbackRule{
+								{
+									Type: workv1.JSONPathsType,
+									JsonPaths: []workv1.JsonPath{
+										{Name: "Replica", Path: ".spec.replicas"},
+										{Name: "StatusReplica", Path: ".status.replicas"},
+									},
+								},
+							},
+						},
+					},
+				},
+			}
+
+			_, err := hubWorkClient.WorkV1().ManifestWorks(testNamespace).
+				Create(context.TODO(), work, metav1.CreateOptions{})
+			gomega.Expect(err).ToNot(gomega.HaveOccurred())
+		})
+
+		ginkgo.It("set feedback rule with same jsonpath name", func() {
+			work := &workv1.ManifestWork{
+				ObjectMeta: metav1.ObjectMeta{
+					Name: manifestWorkName,
+				},
+				Spec: workv1.ManifestWorkSpec{
+					ManifestConfigs: []workv1.ManifestConfigOption{
+						{
+							ResourceIdentifier: workv1.ResourceIdentifier{
+								Resource:  "foo",
+								Name:      "test",
+								Namespace: "testns",
+							},
+							FeedbackRules: []workv1.FeedbackRule{
+								{
+									Type: workv1.JSONPathsType,
+									JsonPaths: []workv1.JsonPath{
+										{Name: "Replica", Path: ".spec.replicas"},
+										{Name: "Replica", Path: ".status.replicas"},
+									},
+								},
+							},
+						},
+					},
+				},
+			}
+
+			_, err := hubWorkClient.WorkV1().ManifestWorks(testNamespace).
+				Create(context.TODO(), work, metav1.CreateOptions{})
+			gomega.Expect(err).To(gomega.HaveOccurred())
+		})
 	})
 })

work/v1/0000_00_work.open-cluster-management.io_manifestworks.crd.yaml

@@ -187,6 +187,9 @@ spec:
                               - path
                               type: object
                             type: array
+                            x-kubernetes-list-map-keys:
+                            - name
+                            x-kubernetes-list-type: map
                           type:
                             description: |-
                               Type defines the option of how status can be returned.

work/v1/types.go

@@ -226,6 +226,8 @@ type FeedbackRule struct {
 	Type FeedBackType `json:"type"`
 
 	// JsonPaths defines the json path under status field to be synced.
+	// +listType:=map
+	// +listMapKey:=name
 	// +optional
 	JsonPaths []JsonPath `json:"jsonPaths,omitempty"`
 }

work/v1alpha1/0000_00_work.open-cluster-management.io_manifestworkreplicasets.crd.yaml

@@ -210,6 +210,9 @@ spec:
                                   - path
                                   type: object
                                 type: array
+                                x-kubernetes-list-map-keys:
+                                - name
+                                x-kubernetes-list-type: map
                               type:
                                 description: |-
                                   Type defines the option of how status can be returned.