added vmware metadata provider

cloud-init data from vmware guest info as it described in the link below
https://github.com/vmware/cloud-init-vmware-guestinfo

Signed-off-by: Birol Bilgin <birolbilgin@gmail.com>

Author: Birol Bilgin

pkg/metadata/main.go

@@ -78,7 +78,7 @@ func main() {
 		log.SetLevel(log.DebugLevel)
 	}
 
-	providers := []string{"aws", "gcp", "hetzner", "openstack", "scaleway", "vultr", "digitalocean", "packet", "metaldata", "cdrom"}
+	providers := []string{"aws", "gcp", "hetzner", "openstack", "scaleway", "vultr", "digitalocean", "packet", "metaldata", "vmware", "cdrom"}
 	args := flag.Args()
 	if len(args) > 0 {
 		providers = args
@@ -103,8 +103,10 @@ func main() {
 			netProviders = append(netProviders, NewDigitalOcean())
 		case p == "metaldata":
 			netProviders = append(netProviders, NewMetalData())
+		case p == "vmware":
+			cdromProviders = append(cdromProviders, NewVMware())
 		case p == "cdrom":
-			cdromProviders = ListCDROMs()
+			cdromProviders = append(cdromProviders, ListCDROMs()...)
 		case strings.HasPrefix(p, "file="):
 			fileProviders = append(fileProviders, fileProvider(p[5:]))
 		default:

pkg/metadata/provider_vmware.go

@@ -0,0 +1,118 @@
+package main
+
+import (
+	"compress/gzip"
+	"encoding/base64"
+	"fmt"
+	"io/ioutil"
+	"path"
+	"strings"
+
+	log "github.com/sirupsen/logrus"
+	"github.com/vmware/vmw-guestinfo/rpcvmx"
+	"github.com/vmware/vmw-guestinfo/vmcheck"
+)
+
+const (
+	guestMetaData = "guestinfo.metadata"
+
+	guestUserData = "guestinfo.userdata"
+)
+
+// ProviderVMware is the type implementing the Provider interface for VMware
+type ProviderVMware struct{}
+
+// NewVMware returns a new ProviderVMware
+func NewVMware() *ProviderVMware {
+	return &ProviderVMware{}
+}
+
+func (p *ProviderVMware) String() string {
+	return "VMWARE"
+}
+
+// Probe checks if we are running on VMware
+func (p *ProviderVMware) Probe() bool {
+	isVM, err := vmcheck.IsVirtualWorld()
+	if err != nil || !isVM {
+		return false
+	}
+
+	b, err := p.vmwareGet(guestUserData)
+	return (err == nil) && len(b) > 0 && string(b) != " " && string(b) != "---"
+}
+
+// Extract gets both the host specific metadata and generic userdata
+func (p *ProviderVMware) Extract() ([]byte, error) {
+	// Get host name. This must not fail
+	metaData, err := p.vmwareGet(guestMetaData)
+	if err != nil {
+		return nil, err
+	}
+
+	err = ioutil.WriteFile(path.Join(ConfigPath, "metadata"), metaData, 0644)
+	if err != nil {
+		return nil, fmt.Errorf("VMWare: Failed to write metadata: %s", err)
+	}
+
+	// Generic userdata
+	userData, err := p.vmwareGet(guestUserData)
+	if err != nil {
+		log.Printf("VMware: Failed to get user-data: %s", err)
+		// This is not an error
+		return nil, nil
+	}
+
+	return userData, nil
+}
+
+// vmwareGet gets and extracts the guest data
+func (p *ProviderVMware) vmwareGet(name string) ([]byte, error) {
+	config := rpcvmx.NewConfig()
+
+	// get the gusest info value
+	out, err := config.String(name, "")
+	if err != nil {
+		log.Debugf("Getting guest info %s failed: error %s", name, err)
+		return nil, err
+	}
+
+	enc, err := config.String(name+".encoding", "")
+	if err != nil {
+		log.Debugf("Getting guest info %s.encoding failed: error %s", name, err)
+		return nil, err
+	}
+
+	switch strings.TrimSuffix(enc, "\n") {
+	case " ":
+		return []byte(strings.TrimSuffix(out, "\n")), nil
+	case "base64":
+		r := base64.NewDecoder(base64.StdEncoding, strings.NewReader(out))
+
+		dst, err := ioutil.ReadAll(r)
+		if err != nil {
+			log.Debugf("Decoding base64 of '%s' failed %v", name, err)
+			return nil, err
+		}
+
+		return dst, nil
+	case "gzip+base64":
+		r := base64.NewDecoder(base64.StdEncoding, strings.NewReader(out))
+
+		zr, err := gzip.NewReader(r)
+		if err != nil {
+			log.Debugf("New gzip reader from '%s' failed %v", name, err)
+			return nil, err
+		}
+
+		dst, err := ioutil.ReadAll(zr)
+		if err != nil {
+			log.Debugf("Read '%s' failed %v", name, err)
+			return nil, err
+		}
+
+		return dst, nil
+	default:
+		return nil, fmt.Errorf("Unknown encoding %s", string(enc))
+	}
+}