implement instanceExists()

Author: sp-yduck

go.mod

@@ -4,7 +4,7 @@ go 1.20
 
 require (
 	github.com/pkg/errors v0.9.1
-	github.com/sp-yduck/proxmox-go v0.0.0-20230717071731-9fdab94cfe8d
+	github.com/sp-yduck/proxmox-go v0.0.0-alpha1
 	github.com/spf13/pflag v1.0.5
 	gopkg.in/yaml.v3 v3.0.1
 	k8s.io/api v0.27.3

go.sum

@@ -263,8 +263,8 @@ github.com/rogpeppe/go-internal v1.10.0 h1:TMyTOH3F/DB16zRVcYyreMH6GnZZrwQVAoYjR
 github.com/russross/blackfriday/v2 v2.1.0/go.mod h1:+Rmxgy9KzJVeS9/2gXHxylqXiyQDYRxCVz55jmeOWTM=
 github.com/sirupsen/logrus v1.9.0 h1:trlNQbNUG3OdDrDil03MCb1H2o9nJ1x4/5LYw7byDE0=
 github.com/soheilhy/cmux v0.1.5 h1:jjzc5WVemNEDTLwv9tlmemhC73tI08BNOIGwBOo10Js=
-github.com/sp-yduck/proxmox-go v0.0.0-20230717071731-9fdab94cfe8d h1:qCiXtxzEl9h5YLd9yOhLULnt7dCcEP5DS7PCGhmX3J0=
-github.com/sp-yduck/proxmox-go v0.0.0-20230717071731-9fdab94cfe8d/go.mod h1:hrQc1bUUCN71yn+in+LkfdpJstaaMv2nrn3+GeKFbkA=
+github.com/sp-yduck/proxmox-go v0.0.0-alpha1 h1:o7L6ua8fdgE0zXPNRs5apMDsodwKaCPQGWYPN4ywNoQ=
+github.com/sp-yduck/proxmox-go v0.0.0-alpha1/go.mod h1:hrQc1bUUCN71yn+in+LkfdpJstaaMv2nrn3+GeKFbkA=
 github.com/spaolacci/murmur3 v0.0.0-20180118202830-f09979ecbc72/go.mod h1:JwIasOWyU6f++ZhiEuf87xNszmSA2myDM2Kzu9HwQUA=
 github.com/spf13/cobra v1.6.0 h1:42a0n6jwCot1pUmomAp4T7DeMD+20LFv4Q54pxLf2LI=
 github.com/spf13/cobra v1.6.0/go.mod h1:IOw/AERYS7UzyrGinqmz6HLUo219MORXGxhbaJUqzrY=

pkg/cloudprovider/instances.go

@@ -3,15 +3,22 @@ package proxmox
 import (
 	"context"
 	"crypto/tls"
+	"errors"
 	"fmt"
 	"net/http"
+	"regexp"
+	"strings"
 
 	"github.com/sp-yduck/proxmox-go/rest"
 	v1 "k8s.io/api/core/v1"
 	cloudprovider "k8s.io/cloud-provider"
 	"k8s.io/klog/v2"
 )
 
+const (
+	UUIDFormat = `[a-f\d]{8}-[a-f\d]{4}-[a-f\d]{4}-[a-f\d]{4}-[a-f\d]{12}`
+)
+
 type instance struct {
 	compute *rest.RESTClient
 }
@@ -32,8 +39,43 @@ func newInstances(config proxmoxConfig) (cloudprovider.InstancesV2, error) {
 }
 
 func (i *instance) InstanceExists(ctc context.Context, node *v1.Node) (bool, error) {
-	klog.Info("checking if instance exists")
-	return true, nil
+	klog.Info("checking if instance exists (node=%s)", node.Name)
+
+	nodes, err := i.compute.GetNodes()
+	if err != nil {
+		return true, err
+	}
+	for _, n := range nodes {
+		vms, err := i.compute.GetVirtualMachines(n.Node)
+		if err != nil {
+			return true, err
+		}
+		for _, vm := range vms {
+			config, err := i.compute.GetVirtualMachineConfig(n.Node, vm.VMID)
+			if err != nil {
+				return true, err
+			}
+			smbios := config.SMBios1
+			uuid, err := convertSMBiosToUUID(smbios)
+			if err != nil {
+				return true, err
+			}
+			if uuid == node.Status.NodeInfo.SystemUUID {
+				return true, nil
+			}
+		}
+	}
+	return false, nil
+}
+
+func convertSMBiosToUUID(smbios string) (string, error) {
+	re := regexp.MustCompile(fmt.Sprintf("uuid=%s", UUIDFormat))
+	match := re.FindString(smbios)
+	if match == "" {
+		return "", errors.New("failed to fetch uuid form smbios")
+	}
+	// match: uuid=<uuid>
+	return strings.Split(match, "=")[1], nil
 }
 
 func (i *instance) InstanceShutdown(ctx context.Context, node *v1.Node) (bool, error) {