Initial implementation.

Author: tintoy

.gitignore

@@ -6,6 +6,7 @@
 # Folders
 _obj
 _test
+_bin
 
 # Architecture specific extensions/prefixes
 *.[568vq]
@@ -22,3 +23,6 @@ _testmain.go
 *.exe
 *.test
 *.prof
+
+# Version info
+version-info.go

.gitmodules

@@ -0,0 +1,3 @@
+[submodule "vendor/github.com/DimensionDataResearch/go-dd-cloud-compute"]
+	path = vendor/github.com/DimensionDataResearch/go-dd-cloud-compute
+	url = https://github.com/DimensionDataResearch/go-dd-cloud-compute.git

Makefile

@@ -0,0 +1,32 @@
+default: fmt build test
+
+fmt:
+	go fmt github.com/DimensionDataResearch/docker-machine-driver-ddcloud/...
+
+# Peform a development (current-platform-only) build.
+dev: version fmt
+	go build -o _bin/docker-machine-driver-ddcloud
+
+# Perform a full (all-platforms) build.
+build: version build-windows64 build-linux64 build-mac64
+
+build-windows64:
+	GOOS=windows GOARCH=amd64 go build -o _bin/windows-amd64/docker-machine-driver-ddcloud.exe
+
+build-linux64:
+	GOOS=linux GOARCH=amd64 go build -o _bin/linux-amd64/docker-machine-driver-ddcloud
+
+build-mac64:
+	GOOS=darwin GOARCH=amd64 go build -o _bin/darwin-amd64/docker-machine-driver-ddcloud
+
+# Produce archives for a GitHub release.
+dist: build
+	zip -9 _bin/windows-amd64.zip _bin/windows-amd64/docker-machine-driver-ddcloud.exe
+	zip -9 _bin/linux-amd64.zip _bin/linux-amd64/docker-machine-driver-ddcloud
+	zip -9 _bin/darwin-amd64.zip _bin/darwin-amd64/docker-machine-driver-ddcloud
+
+test: fmt
+	go test -v github.com/DimensionDataResearch/docker-machine-driver-ddcloud/...
+
+version:
+	echo "package main\n\n// ProviderVersion is the current version of the CloudControl driver for Docker Machine.\nconst ProviderVersion = \"v0.1 (`git rev-parse HEAD`)\"" > ./version-info.go

client.go

@@ -0,0 +1,204 @@
+package main
+
+import (
+	"errors"
+	"fmt"
+	"github.com/DimensionDataResearch/go-dd-cloud-compute/compute"
+	"github.com/docker/machine/libmachine/log"
+	"time"
+)
+
+// Get the CloudControl API client used by the driver.
+func (driver *Driver) getCloudControlClient() (client *compute.Client, err error) {
+	client = driver.client
+	if client != nil {
+		return
+	}
+
+	if driver.CloudControlUser == "" {
+		err = errors.New("Cannot connect to CloudControl API (user name has not been configured)")
+
+		return
+	}
+
+	if driver.CloudControlPassword == "" {
+		err = errors.New("Cannot connect to CloudControl API (password has not been configured)")
+
+		return
+	}
+
+	if driver.CloudControlRegion == "" {
+		err = errors.New("Cannot connect to CloudControl API (region not been configured)")
+
+		return
+	}
+
+	driver.client = compute.NewClient(driver.CloudControlRegion, driver.CloudControlUser, driver.CloudControlPassword)
+
+	return
+}
+
+// Determine whether the target server has been created.
+func (driver *Driver) isServerCreated() bool {
+	return driver.ServerID != ""
+}
+
+// Retrieve the target server (must have been created, or an error is returned).
+func (driver *Driver) getServer() (*compute.Server, error) {
+	if !driver.isServerCreated() {
+		return nil, errors.New("Server has not been created")
+	}
+
+	client, err := driver.getCloudControlClient()
+	if err != nil {
+		return nil, err
+	}
+
+	return client.GetServer(driver.ServerID)
+}
+
+// Retrieve the target network domain.
+func (driver *Driver) getNetworkDomain() (*compute.NetworkDomain, error) {
+	if driver.NetworkDomainID == "" {
+		return nil, errors.New("Network domain Id has not been configured")
+	}
+
+	client, err := driver.getCloudControlClient()
+	if err != nil {
+		return nil, err
+	}
+
+	return client.GetNetworkDomain(driver.ServerID)
+}
+
+// Retrieve the target VLAN.
+func (driver *Driver) getVLAN() (*compute.VLAN, error) {
+	if driver.VLANID == "" {
+		return nil, errors.New("VLAN Id has not been configured")
+	}
+
+	client, err := driver.getCloudControlClient()
+	if err != nil {
+		return nil, err
+	}
+
+	return client.GetVLAN(driver.VLANID)
+}
+
+// Resolve (find) the target OS image.
+func (driver *Driver) resolveOSImage() error {
+	if driver.ImageID != "" {
+		return nil
+	}
+
+	networkDomain, err := driver.getNetworkDomain()
+	if err != nil {
+		return err
+	}
+
+	client, err := driver.getCloudControlClient()
+	if err != nil {
+		return err
+	}
+
+	// Find target OS image.
+	log.Info("Searching for image '%s' in data centre '%s'...", driver.ImageName, networkDomain.DatacenterID)
+
+	image, err := client.FindOSImage(driver.ImageName, networkDomain.DatacenterID)
+	if err == nil {
+		return err
+	}
+	if image == nil {
+		log.Errorf("OS image '%s' was not found in data centre '%s'.", driver.ImageName, networkDomain.DatacenterID)
+
+		return fmt.Errorf("OS image '%s' was not found in data centre '%s'", driver.ImageName, networkDomain.DatacenterID)
+	}
+
+	driver.ImageID = image.ID
+
+	return nil
+}
+
+// Retrieve the target OS image.
+func (driver *Driver) getOSImage() (*compute.OSImage, error) {
+	if driver.ImageID == "" {
+		return nil, errors.New("Image Id has not been resolved")
+	}
+
+	client, err := driver.getCloudControlClient()
+	if err != nil {
+		return nil, err
+	}
+
+	return client.GetOSImage(driver.ImageID)
+}
+
+func (driver *Driver) deployServer() (*compute.Server, error) {
+	if driver.isServerCreated() {
+		return nil, fmt.Errorf("Server '%s' already exists (Id = '%s')", driver.MachineName, driver.ServerID)
+	}
+
+	serverConfiguration, err := driver.buildDeploymentConfiguration()
+	if err != nil {
+		return nil, err
+	}
+
+	client, err := driver.getCloudControlClient()
+	if err != nil {
+		return nil, err
+	}
+
+	driver.ServerID, err = client.DeployServer(serverConfiguration)
+	if err != nil {
+		return nil, err
+	}
+
+	log.Debug("Deploying server '%s' ('%s')...", driver.ServerID, driver.MachineName)
+
+	log.Info("Server '%s' is being provisioned...")
+	resource, err := client.WaitForDeploy(compute.ResourceTypeServer, driver.ServerID, 15*time.Minute)
+	if err != nil {
+		return nil, err
+	}
+	server := resource.(*compute.Server)
+	log.Debug("Server '%s' ('%s') has been successfully provisioned...", driver.ServerID, server.Name)
+
+	driver.IPAddress = *server.Network.PrimaryAdapter.PrivateIPv4Address
+	log.Info("Server '%s' has private IP '%s'.", server.Name, driver.IPAddress)
+
+	return server, nil
+}
+
+// Build a deployment configuration for the target server.
+func (driver *Driver) buildDeploymentConfiguration() (deploymentConfiguration compute.ServerDeploymentConfiguration, err error) {
+	var image *compute.OSImage
+	image, err = driver.getOSImage()
+	if err != nil {
+		return
+	}
+	if image == nil {
+		err = fmt.Errorf("OS image '%s' not found", driver.ImageID)
+
+		return
+	}
+
+	deploymentConfiguration = compute.ServerDeploymentConfiguration{
+		Name:                  driver.MachineName,
+		Description:           fmt.Sprintf("%s (created by Docker Machine).", driver.MachineName),
+		AdministratorPassword: driver.SSHBootstrapPassword,
+
+		Network: compute.VirtualMachineNetwork{
+			NetworkDomainID: driver.NetworkDomainID,
+			PrimaryAdapter: compute.VirtualMachineNetworkAdapter{
+				VLANID: &driver.VLANID,
+			},
+		},
+		PrimaryDNS:   "8.8.8.8",
+		SecondaryDNS: "8.8.4.4",
+
+		Start: true,
+	}
+	deploymentConfiguration.ApplyOSImage(image)
+
+	return
+}