Wait for the project's spec.{clusterName,displayName} to be set

There seems to be a bit of a delay between when a project is
created and when these values exist. This is more likely to
show up in CI than locally, sure sounds like a timing issue.

Author: ericpromislow

pkg/sqlcache/integration_test.go

@@ -540,6 +540,43 @@ func waitForObjectsBySchema(ctx context.Context, proxyStore *sqlproxy.Store, sch
 	})
 }
 
+// Do not call this if there are no projects -- the function will run until it times out.
+func waitForProjectsDisplayName(ctx context.Context, proxyStore *sqlproxy.Store, schema *types.APISchema) error {
+	return wait.PollUntilContextCancel(ctx, time.Second*10, true, func(ctx context.Context) (done bool, err error) {
+		req, err := http.NewRequest("GET", "http://localhost:8080", nil)
+		if err != nil {
+			return false, err
+		}
+		apiOp := &types.APIRequest{
+			Request: req,
+		}
+		partitions := []partition.Partition{defaultPartition}
+		list, total, _, err := proxyStore.ListByPartitions(apiOp, schema, partitions)
+		if err != nil || total == 0 {
+			// note that we don't return the error since that would stop the polling
+			return false, nil
+		}
+		// Moving on, if there are errors return them
+		for _, item := range list.Items {
+			displayName, ok, err := unstructured.NestedFieldNoCopy(item.Object, "spec", "displayName")
+			if !ok || displayName == "" || err != nil {
+				if err == nil && ok {
+					fmt.Printf("No displayName yet for mcio.project %q\n", item.GetName())
+				}
+				return false, err
+			}
+			clusterName, ok, err := unstructured.NestedFieldNoCopy(item.Object, "spec", "clusterName")
+			if !ok || clusterName == "" || err != nil {
+				if err == nil {
+					fmt.Printf("No clusterName yet for mcio.project %q\n", item.GetName())
+				}
+				return false, err
+			}
+		}
+		return true, nil
+	})
+}
+
 type ResetFunc func(k8sschema.GroupVersionKind) error
 
 func (f ResetFunc) Reset(gvk k8sschema.GroupVersionKind) error {
@@ -1131,6 +1168,8 @@ func (i *IntegrationSuite) TestNamespaceProjectDependencies() {
 	requireT.NoError(err)
 	err = waitForObjectsBySchema(ctx, proxyStore, nsSchema, labelTest, len(namespaceInfo))
 	requireT.NoError(err)
+	err = waitForProjectsDisplayName(ctx, proxyStore, mcioSchema)
+	requireT.NoError(err)
 
 	partitions := []partition.Partition{defaultPartition}
 	for _, test := range tests {
@@ -1211,12 +1250,14 @@ func (i *IntegrationSuite) TestSecretProjectDependencies() {
 	err = ctrl.Start(ctx)
 	requireT.NoError(err)
 	secretInfo := [][2]string{
+		// metadata.name, metadata.projects[management.cattle.io/project-scoped-secret]
 		{"morocco", "rabat"},
 		{"eritrea", "asmara"},
 		{"kenya", "nairobi"},
 		{"benin", "portonovo"},
 	}
 	projectInfo := [][3]string{
+		// metadata.name, spec.clusterName, spec.displayName
 		{"rabat", "arabic", "casablanca"},
 		{"asmara", "tigrinya", "keren"},
 		{"nairobi", "english", "mombasa"},
@@ -1308,6 +1349,8 @@ func (i *IntegrationSuite) TestSecretProjectDependencies() {
 	requireT.NoError(err)
 	err = waitForObjectsBySchema(ctx, proxyStore, secretSchema, labelTest, len(secretInfo))
 	requireT.NoError(err)
+	err = waitForProjectsDisplayName(ctx, proxyStore, mcioSchema)
+	requireT.NoError(err)
 
 	partitions := []partition.Partition{defaultPartition}
 	for _, test := range tests {