Try binding the clusterset

This still has some debug lines we can remove later.

Signed-off-by: Justin Kulikauskas <[email protected]>

Author: JustinKuli

test/common/gvr.go

@@ -127,4 +127,9 @@ var (
 		Version:  "v1beta2",
 		Resource: "managedclustersets",
 	}
+	GvrManagedClusterSetBinding = schema.GroupVersionResource{
+		Group:    "cluster.open-cluster-management.io",
+		Version:  "v1beta2",
+		Resource: "managedclustersetbindings",
+	}
 )

test/integration/policy_generator_acm_hardening_test.go

@@ -11,6 +11,7 @@ import (
 	k8serrors "k8s.io/apimachinery/pkg/api/errors"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	"k8s.io/apimachinery/pkg/apis/meta/v1/unstructured"
+	"open-cluster-management.io/governance-policy-propagator/test/utils"
 
 	"github.com/stolostron/governance-policy-framework/test/common"
 )
@@ -44,6 +45,46 @@ var _ = Describe("GRC: [P1][Sev1][policy-grc] Test the ACM Hardening "+
 			Expect(err).ToNot(HaveOccurred())
 		}
 
+		By("Verifying that the default ManagedClusterSet is bound to the policies namespace")
+		clusterbindings, err := clientHubDynamic.Resource(common.GvrManagedClusterSetBinding).
+			Namespace("policies").List(context.TODO(), metav1.ListOptions{})
+		Expect(err).ToNot(HaveOccurred())
+
+		found := false
+
+		for _, mcsb := range clusterbindings.Items {
+			clustersetName, ok, err := unstructured.NestedString(mcsb.Object, "spec", "clusterSet")
+			Expect(err).ToNot(HaveOccurred())
+			Expect(ok).To(BeTrue())
+
+			if clustersetName == "default" {
+				found = true
+				break
+			}
+		}
+
+		if !found {
+			By("Creating the ManagedClusterSetBinding")
+
+			defaultBinding := unstructured.Unstructured{
+				Object: map[string]interface{}{
+					"apiVersion": "cluster.open-cluster-management.io/v1beta2",
+					"kind":       "ManagedClusterSetBinding",
+					"metadata": map[string]interface{}{
+						"name":      "default",
+						"namespace": "policies",
+					},
+					"spec": map[string]interface{}{
+						"clusterSet": "default",
+					},
+				},
+			}
+
+			_, err := clientHubDynamic.Resource(common.GvrManagedClusterSetBinding).
+				Namespace("policies").Create(context.TODO(), &defaultBinding, metav1.CreateOptions{})
+			Expect(err).ToNot(HaveOccurred())
+		}
+
 		By("Creating the application subscription")
 		_, err = common.OcUser(
 			gitopsUser,
@@ -107,6 +148,8 @@ var _ = Describe("GRC: [P1][Sev1][policy-grc] Test the ACM Hardening "+
 			1,
 		).Should(BeNil())
 
+		eCounter := 0
+
 		By("Checking that the policy-managedclusteraddon-available policy " +
 			"was propagated to the local-cluster namespace")
 		Eventually(
@@ -117,6 +160,24 @@ var _ = Describe("GRC: [P1][Sev1][policy-grc] Test the ACM Hardening "+
 					metav1.GetOptions{},
 				)
 
+				if eCounter > 9 {
+					eCounter = 0
+
+					GinkgoWriter.Print("placement: ")
+					_, _ = utils.KubectlWithOutput("get", "placement", "-A", "-ojsonpath={@}",
+						"--kubeconfig="+kubeconfigHub)
+
+					GinkgoWriter.Print("managedclusterset: ")
+					_, _ = utils.KubectlWithOutput("get", "managedclusterset", "-A", "-ojsonpath={@}",
+						"--kubeconfig="+kubeconfigHub)
+
+					GinkgoWriter.Print("managedclustersetbinding: ")
+					_, _ = utils.KubectlWithOutput("get", "managedclustersetbinding", "-A", "-ojsonpath={@}",
+						"--kubeconfig="+kubeconfigHub)
+				}
+
+				eCounter++
+
 				return err
 			},
 			defaultTimeoutSeconds*2,