OCPCLOUD-3571: Add OTE e2e tests for ClusterAPIMachineManagementAWS feature gate

e2e/cluster_api_machine_management_aws.go

@@ -0,0 +1,90 @@
+// Copyright 2026 Red Hat, Inc.
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+// 	http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package e2e
+
+import (
+	. "github.com/onsi/ginkgo/v2"
+	. "github.com/onsi/gomega"
+
+	appsv1 "k8s.io/api/apps/v1"
+	corev1 "k8s.io/api/core/v1"
+	apiextensionsv1 "k8s.io/apiextensions-apiserver/pkg/apis/apiextensions/v1"
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+	clusterv1 "sigs.k8s.io/cluster-api/api/core/v1beta2"
+	"sigs.k8s.io/controller-runtime/pkg/envtest/komega"
+
+	configv1 "github.com/openshift/api/config/v1"
+	"github.com/openshift/api/features"
+	"github.com/openshift/cluster-capi-operator/e2e/framework"
+)
+
+var _ = Describe("[sig-cluster-lifecycle][OCPFeatureGate:ClusterAPIMachineManagementAWS] Cluster API Machine Management AWS",
+	Label("platform:aws"),
+	func() {
+		BeforeEach(func() {
+			if !framework.IsFeatureGateEnabled(ctx, cl, features.FeatureGateClusterAPIMachineManagementAWS) {
+				Skip("Feature gate ClusterAPIMachineManagementAWS is not enabled.")
+			}
+			if platform != configv1.AWSPlatformType {
+				Skip("Skipping AWS-specific tests on non-AWS platform.")
+			}
+		})
+
+		Context("AWS provider deployment", func() {
+			It("should have the capa-controller-manager deployment available", func() {
+				deployment := &appsv1.Deployment{ObjectMeta: metav1.ObjectMeta{Name: "capa-controller-manager", Namespace: framework.CAPINamespace}}
+				Eventually(komega.Object(deployment)).WithTimeout(framework.WaitMedium).WithPolling(framework.RetryMedium).Should(
+					HaveField("Status.Conditions", ContainElement(SatisfyAll(
+						HaveField("Type", Equal(appsv1.DeploymentAvailable)),
+						HaveField("Status", Equal(corev1.ConditionTrue)),
+					))),
+				)
+			})
+		})
+
+		Context("AWS infrastructure CRDs", func() {
+			DescribeTable("should have core AWS Cluster API CRDs installed and established",
+				func(name string) {
+					crd := &apiextensionsv1.CustomResourceDefinition{ObjectMeta: metav1.ObjectMeta{Name: name}}
+					Eventually(komega.Object(crd)).WithTimeout(framework.WaitMedium).WithPolling(framework.RetryMedium).Should(
+						HaveField("Status.Conditions", ContainElement(SatisfyAll(
+							HaveField("Type", Equal(apiextensionsv1.Established)),
+							HaveField("Status", Equal(apiextensionsv1.ConditionTrue)),
+						))),
+					)
+				},
+				Entry("awsclusters CRD", "awsclusters.infrastructure.cluster.x-k8s.io"),
+				Entry("awsmachines CRD", "awsmachines.infrastructure.cluster.x-k8s.io"),
+				Entry("awsmachinetemplates CRD", "awsmachinetemplates.infrastructure.cluster.x-k8s.io"),
+				Entry("awsclustercontrolleridentities CRD", "awsclustercontrolleridentities.infrastructure.cluster.x-k8s.io"),
+			)
+
+		})
+
+		Context("Management cluster AWS resources", func() {
+			It("should have the management Cluster object with InfrastructureReady=True", func() {
+				cluster := &clusterv1.Cluster{ObjectMeta: metav1.ObjectMeta{
+					Name:      clusterName,
+					Namespace: framework.CAPINamespace,
+				}}
+				Eventually(komega.Object(cluster)).WithTimeout(framework.WaitLong).WithPolling(framework.RetryMedium).Should(
+					HaveField("Status.Conditions", ContainElement(SatisfyAll(
+						HaveField("Type", Equal(clusterv1.ClusterInfrastructureReadyCondition)),
+						HaveField("Status", Equal(metav1.ConditionTrue)),
+					))),
+				)
+			})
+		})
+	})

openshift-tests-extension/cmd/main.go

@@ -19,10 +19,12 @@ package main
 import (
 	"fmt"
 	"os"
+	"strings"
 	"time"
 
 	"github.com/openshift-eng/openshift-tests-extension/pkg/cmd"
 	e "github.com/openshift-eng/openshift-tests-extension/pkg/extension"
+	et "github.com/openshift-eng/openshift-tests-extension/pkg/extension/extensiontests"
 	g "github.com/openshift-eng/openshift-tests-extension/pkg/ginkgo"
 	"github.com/spf13/cobra"
 
@@ -70,6 +72,15 @@ func main() {
 		e2e.InitCommonVariables()
 	})
 
+	// Auto-apply platform environment selectors from Ginkgo Label("platform:<name>") annotations.
+	specs.Walk(func(spec *et.ExtensionTestSpec) {
+		for label := range spec.Labels {
+			if platform, ok := strings.CutPrefix(label, "platform:"); ok {
+				spec.Include(et.PlatformEquals(platform))
+			}
+		}
+	})
+
 	ext.AddSpecs(specs)
 
 	extensionRegistry.Register(ext)