Make OpenStack use Provider interface

Co-Authored-By: Maysa Macedo <[email protected]>

Author: mandre

pkg/infrastructure/openstack/clusterapi/clusterapi.go

@@ -0,0 +1,56 @@
+package clusterapi
+
+import (
+	"context"
+	"fmt"
+
+	capo "sigs.k8s.io/cluster-api-provider-openstack/api/v1alpha7"
+	"sigs.k8s.io/controller-runtime/pkg/client"
+
+	"github.com/gophercloud/gophercloud/openstack/networking/v2/ports"
+	"github.com/openshift/installer/pkg/asset/manifests/capiutils"
+	"github.com/openshift/installer/pkg/infrastructure/clusterapi"
+	openstackdefaults "github.com/openshift/installer/pkg/types/openstack/defaults"
+)
+
+// Provider defines the InfraProvider.
+type Provider struct {
+	clusterapi.InfraProvider
+}
+
+// func (p Provider) PreProvision(in clusterapi.PreProvisionInput) error {
+// 	return nil
+// }
+
+func (p Provider) ControlPlaneAvailable(in clusterapi.ControlPlaneAvailableInput) error {
+	ospCluster := &capo.OpenStackCluster{}
+	key := client.ObjectKey{
+		Name:      in.InfraID,
+		Namespace: capiutils.Namespace,
+	}
+	if err := in.Client.Get(context.Background(), key, ospCluster); err != nil {
+		return fmt.Errorf("failed to get OSPCluster: %w", err)
+	}
+
+	networkClient, err := openstackdefaults.NewServiceClient("network", openstackdefaults.DefaultClientOpts(in.InstallConfig.Config.Platform.OpenStack.Cloud))
+	if err != nil {
+		return err
+	}
+
+	createOtps := ports.CreateOpts{
+		Name:      "CAPO test",
+		NetworkID: ospCluster.Status.Network.ID,
+	}
+
+	_, err = ports.Create(networkClient, createOtps).Extract()
+	if err != nil {
+		return err
+	}
+
+	_, err = ports.Create(networkClient, createOtps).Extract()
+	if err != nil {
+		return err
+	}
+
+	return nil
+}

pkg/infrastructure/platform/platform.go

@@ -12,6 +12,7 @@ import (
 	awscapi "github.com/openshift/installer/pkg/infrastructure/aws/clusterapi"
 	"github.com/openshift/installer/pkg/infrastructure/clusterapi"
 	gcpcapi "github.com/openshift/installer/pkg/infrastructure/gcp/clusterapi"
+	openstackcapi "github.com/openshift/installer/pkg/infrastructure/openstack/clusterapi"
 	powervscapi "github.com/openshift/installer/pkg/infrastructure/powervs/clusterapi"
 	vspherecapi "github.com/openshift/installer/pkg/infrastructure/vsphere/clusterapi"
 	"github.com/openshift/installer/pkg/terraform"
@@ -76,6 +77,9 @@ func ProviderForPlatform(platform string, fg featuregates.FeatureGate) (infrastr
 		}
 		return terraform.InitializeProvider(powervs.PlatformStages), nil
 	case openstacktypes.Name:
+		if fg.Enabled(configv1.FeatureGateClusterAPIInstall) {
+			return clusterapi.InitializeProvider(openstackcapi.Provider{}), nil
+		}
 		return terraform.InitializeProvider(openstack.PlatformStages), nil
 	case ovirttypes.Name:
 		return terraform.InitializeProvider(ovirt.PlatformStages), nil

pkg/infrastructure/platform/platform_altinfra.go

@@ -12,12 +12,14 @@ import (
 	awscapi "github.com/openshift/installer/pkg/infrastructure/aws/clusterapi"
 	"github.com/openshift/installer/pkg/infrastructure/clusterapi"
 	gcpcapi "github.com/openshift/installer/pkg/infrastructure/gcp/clusterapi"
+	openstackcapi "github.com/openshift/installer/pkg/infrastructure/openstack/clusterapi"
 	powervscapi "github.com/openshift/installer/pkg/infrastructure/powervs/clusterapi"
 	vspherecapi "github.com/openshift/installer/pkg/infrastructure/vsphere/clusterapi"
 	awstypes "github.com/openshift/installer/pkg/types/aws"
 	azuretypes "github.com/openshift/installer/pkg/types/azure"
 	"github.com/openshift/installer/pkg/types/featuregates"
 	gcptypes "github.com/openshift/installer/pkg/types/gcp"
+	openstacktypes "github.com/openshift/installer/pkg/types/openstack"
 	powervstypes "github.com/openshift/installer/pkg/types/powervs"
 	vspheretypes "github.com/openshift/installer/pkg/types/vsphere"
 )
@@ -47,6 +49,10 @@ func ProviderForPlatform(platform string, fg featuregates.FeatureGate) (infrastr
 			return clusterapi.InitializeProvider(powervscapi.Provider{}), nil
 		}
 		return nil, nil
+	case openstacktypes.Name:
+		if fg.Enabled(configv1.FeatureGateClusterAPIInstall) {
+			return clusterapi.InitializeProvider(openstackcapi.Provider{}), nil
+		}
 	}
 	return nil, fmt.Errorf("platform %q is not supported in the altinfra Installer build", platform)
 }