[openstack] Config drive auto-detection

Signed-off-by: Andrey Klimentyev <andrey.klimentyev@flant.com>

pkg/driver/driver_openstack.go

@@ -40,6 +40,7 @@ import (
 	"github.com/gophercloud/gophercloud/openstack/compute/v2/images"
 	"github.com/gophercloud/gophercloud/openstack/compute/v2/servers"
 	"github.com/gophercloud/gophercloud/openstack/networking/v2/ports"
+	"github.com/gophercloud/gophercloud/openstack/networking/v2/subnets"
 	"github.com/gophercloud/gophercloud/pagination"
 	"github.com/gophercloud/utils/client"
 	"github.com/gophercloud/utils/openstack/clientconfig"
@@ -160,6 +161,29 @@ func (d *OpenStackDriver) Create() (string, string, error) {
 
 	metrics.APIRequestCount.With(prometheus.Labels{"provider": "openstack", "service": "nova"}).Inc()
 
+	var useConfigDrive *bool
+	if len(serverNetworks) > 0 {
+		mainNetworkID := serverNetworks[0].UUID
+		allSubnetsPagesForMainNet, err := subnets.List(nwClient, subnets.ListOpts{NetworkID: mainNetworkID}).AllPages()
+		if err != nil {
+			metrics.APIFailedRequestCount.With(prometheus.Labels{"provider": "openstack", "service": "neutron"}).Inc()
+			return "", "", fmt.Errorf("failed to get subnets for networkID %q: %s", mainNetworkID, err)
+		}
+		metrics.APIRequestCount.With(prometheus.Labels{"provider": "openstack", "service": "neutron"}).Inc()
+
+		allSubnetsForMainNet, err := subnets.ExtractSubnets(allSubnetsPagesForMainNet)
+		if err != nil {
+			return "", "", fmt.Errorf("failed to extract subnets for networkID %q: %s", mainNetworkID, err)
+		}
+
+		for _, subnet := range allSubnetsForMainNet {
+			if !subnet.EnableDHCP {
+				trueVal := true
+				useConfigDrive = &trueVal
+			}
+		}
+	}
+
 	createOpts = &servers.CreateOpts{
 		ServiceClient:    client,
 		Name:             d.MachineName,
@@ -170,6 +194,7 @@ func (d *OpenStackDriver) Create() (string, string, error) {
 		Metadata:         metadata,
 		UserData:         []byte(d.UserData),
 		AvailabilityZone: availabilityZone,
+		ConfigDrive:      useConfigDrive,
 	}
 
 	createOpts = &keypairs.CreateOptsExt{
@@ -606,3 +631,13 @@ func resourceInstanceBlockDevicesV2(rootDiskSize int, imageID string) ([]bootfro
 	klog.V(2).Infof("[DEBUG] Block Device Options: %+v", blockDeviceOpts)
 	return blockDeviceOpts, nil
 }
+
+func dhcpDisabled(subnets []subnets.Subnet) bool {
+	for _, subnet := range subnets {
+		if !subnet.EnableDHCP {
+			return true
+		}
+	}
+
+	return false
+}