cluster-api: Create bootstrap FIP

This is created in the preprovision step, since we'll attach it during
creation of the bootstrap machine.

Signed-off-by: Stephen Finucane <stephenfin@redhat.com>

pkg/infrastructure/openstack/clusterapi/clusterapi.go

@@ -89,6 +89,15 @@ func (p Provider) InfraReady(ctx context.Context, in clusterapi.InfraReadyInput)
 		return fmt.Errorf("failed to get OSPCluster: %w", err)
 	}
 
+	bootstrapMachine := &capo.OpenStackMachine{}
+	key = client.ObjectKey{
+		Name:      capiutils.GenerateBoostrapMachineName(infraID),
+		Namespace: capiutils.Namespace,
+	}
+	if err := k8sClient.Get(ctx, key, bootstrapMachine); err != nil {
+		return fmt.Errorf("failed to get bootstrap Machine: %w", err)
+	}
+
 	networkClient, err := openstackdefaults.NewServiceClient("network", openstackdefaults.DefaultClientOpts(installConfig.Config.Platform.OpenStack.Cloud))
 	if err != nil {
 		return err
@@ -116,6 +125,21 @@ func (p Provider) InfraReady(ctx context.Context, in clusterapi.InfraReadyInput)
 		}
 	}
 
+	bootstrapPort, err := getPortForInstance(networkClient, *bootstrapMachine.Spec.InstanceID)
+	if err != nil {
+		return err
+	}
+
+	bootstrapFIP, err := createFIP(networkClient, "bootstrap", infraID, ospCluster.Status.Network.ID)
+	if err != nil {
+		return err
+	}
+
+	err = assignFIP(networkClient, bootstrapFIP.ID, bootstrapPort)
+	if err != nil {
+		return err
+	}
+
 	return nil
 }
 
@@ -142,7 +166,8 @@ func createPort(client *gophercloud.ServiceClient, role, infraID, networkID, sub
 			{
 				IPAddress: fixedIP,
 				SubnetID:  subnetID,
-			}},
+			},
+		},
 	}
 
 	port, err := ports.Create(client, createOpts).Extract()
@@ -158,6 +183,50 @@ func createPort(client *gophercloud.ServiceClient, role, infraID, networkID, sub
 	return port, err
 }
 
+// Get the first port associated with an instance.
+//
+// This is used to attach a FIP to the instance.
+func getPortForInstance(client *gophercloud.ServiceClient, instanceID string) (*ports.Port, error) {
+	listOpts := ports.ListOpts{
+		DeviceID: instanceID,
+	}
+	allPages, err := ports.List(client, listOpts).AllPages()
+	if err != nil {
+		return nil, fmt.Errorf("failed to list ports: %w", err)
+	}
+	allPorts, err := ports.ExtractPorts(allPages)
+	if err != nil {
+		return nil, fmt.Errorf("failed to extract ports: %w", err)
+	}
+
+	if len(allPorts) < 1 {
+		return nil, fmt.Errorf("bootstrap machine has no associated ports")
+	}
+
+	return &allPorts[0], nil
+}
+
+// Create a floating IP.
+func createFIP(client *gophercloud.ServiceClient, role, infraID, networkID string) (*floatingips.FloatingIP, error) {
+	createOpts := floatingips.CreateOpts{
+		Description:       fmt.Sprintf("%s-%s-fip", infraID, role),
+		FloatingNetworkID: networkID,
+	}
+
+	floatingIP, err := floatingips.Create(client, createOpts).Extract()
+	if err != nil {
+		return nil, err
+	}
+
+	tag := fmt.Sprintf("openshiftClusterID=%s", infraID)
+	err = attributestags.Add(client, "floatingips", floatingIP.ID, tag).ExtractErr()
+	if err != nil {
+		return nil, err
+	}
+
+	return floatingIP, err
+}
+
 func assignFIP(client *gophercloud.ServiceClient, address string, port *ports.Port) error {
 	listOpts := floatingips.ListOpts{
 		FloatingIP: address,