fix wait for webhook to be ready before running webhook tests

test/e2e/controller-manager/test_suite_test.go

@@ -122,3 +122,28 @@ func setupControllerManagerE2ETest(t *testing.T) (context.Context, *clientset.Cl
 	require.NoError(t, err, "Failed to create Kubernetes client")
 	return ctx, kthenaClient, kubeClient
 }
+
+func waitForWebhookReady(t *testing.T, kubeClient *kubernetes.Clientset, kthenaNamespace string) {
+	t.Helper()
+	t.Log("Waiting for webhook server to be ready")
+
+	ctx, cancel := context.WithTimeout(context.Background(), 1*time.Minute)
+	defer cancel()
+
+	err := wait.PollUntilContextCancel(ctx, 2*time.Second, true, func(ctx context.Context) (bool, error) {
+		ep, err := kubeClient.CoreV1().Endpoints(kthenaNamespace).Get(ctx, "kthena-controller-manager-webhook", metav1.GetOptions{})
+
+		if err != nil {
+			t.Logf("Webhook endpoint not ready yet: %v", err)
+			return false, nil
+		}
+		for _, subset := range ep.Subsets {
+			if len(subset.Addresses) > 0 {
+				return true, nil
+			}
+		}
+		t.Log("Webhook has no ready addresses yet")
+		return false, nil
+	})
+	require.NoError(t, err, "Webhook did not become ready in time")
+}

test/e2e/controller-manager/webhook_test.go

@@ -28,7 +28,10 @@ import (
 
 // TestWebhook tests that the webhooks (validation and mutation) work as expected.
 func TestWebhook(t *testing.T) {
-	ctx, kthenaClient, _ := setupControllerManagerE2ETest(t)
+	ctx, kthenaClient, kubeClient := setupControllerManagerE2ETest(t)
+
+	// waiting for webhook to be ready before running tests
+	waitForWebhookReady(t, kubeClient, kthenaNamespace)
 
 	testCases := []struct {
 		name          string