test(debug): wait for config entries before gateway tests (#5133)

* test(debug): wait for config entries before gateway tests

* update pr

Author: sanikachavan5

.github/workflows/pr.yml

@@ -6,6 +6,7 @@ on:
     branches:
       - main
       - "release/**"
+      - "sanikachavan**"
 
 # these should be the only settings that you will ever need to change
 env:

acceptance/tests/partitions/partitions_gateway_test.go

@@ -213,6 +213,25 @@ func TestPartitions_Gateway(t *testing.T) {
 		k8s.KubectlDeleteK(t, secondaryPartitionClusterContext.KubectlOptions(t), kustomizeDir)
 	})
 
+	// Ensure proxy-defaults config entries are created in Consul before proceeding.
+	// This is critical for mesh gateways to be properly configured for TLS.
+	logger.Log(t, "waiting for proxy-defaults config entries to be created in Consul")
+	retry.Run(t, func(r *retry.R) {
+		ceDefault, _, err := consulClient.ConfigEntries().Get(api.ProxyDefaults, api.ProxyConfigGlobal, serverQueryServerOpts)
+		require.NoError(r, err)
+		configEntryDefault, ok := ceDefault.(*api.ProxyConfigEntry)
+		require.True(r, ok)
+		require.Equal(r, configEntryDefault.GetName(), api.ProxyConfigGlobal)
+		logger.Log(t, "proxy-defaults config entry verified on default partition")
+
+		ceSecondary, _, err := consulClient.ConfigEntries().Get(api.ProxyDefaults, api.ProxyConfigGlobal, serverQueryClientOpts)
+		require.NoError(r, err)
+		configEntrySecondary, ok := ceSecondary.(*api.ProxyConfigEntry)
+		require.True(r, ok)
+		require.Equal(r, configEntrySecondary.GetName(), api.ProxyConfigGlobal)
+		logger.Log(t, "proxy-defaults config entry verified on secondary partition")
+	})
+
 	// We use the static-client pod so that we can make calls to the api gateway
 	// via kubectl exec without needing a route into the cluster from the test machine.
 	// Since we're deploying the gateway in the secondary cluster, we create the static client

acceptance/tests/sameness/sameness_test.go

@@ -349,6 +349,23 @@ func TestFailover_Connect(t *testing.T) {
 				}
 			}
 
+			// Ensure mesh config entries are created in Consul before proceeding with peering.
+			// This is critical for mesh gateways to be properly configured for TLS.
+			logger.Log(t, "waiting for mesh config entries to be created in Consul")
+			timer := &retry.Timer{Timeout: retryTimeout, Wait: 5 * time.Second}
+			for _, v := range testClusters {
+				if v.hasServer {
+					retry.RunWith(timer, t, func(r *retry.R) {
+						ce, _, err := v.client.ConfigEntries().Get(api.MeshConfig, "mesh", &api.QueryOptions{})
+						require.NoError(r, err)
+						configEntry, ok := ce.(*api.MeshConfigEntry)
+						require.True(r, ok)
+						require.Equal(r, configEntry.GetName(), "mesh")
+						logger.Logf(t, "mesh config entry verified on cluster %s", v.name)
+					})
+				}
+			}
+
 			// Apply locality to clusters
 			for _, v := range testClusters {
 				setK8sNodeLocality(t, v.context, v)