Fetch Vlan IDs

Jira: https://issues.redhat.com/browse/ECOPROJECT-2359 Signed-off-by: Ondra Machacek <[email protected]>
kubev2v · Nov 28, 2024 · dabe1d1 · dabe1d1
1 parent 4d6a3f1
commit dabe1d1
Show file tree

Hide file tree

Showing 4 changed files with 25 additions and 2 deletions.
diff --git a/pkg/controller/provider/container/vsphere/collector.go b/pkg/controller/provider/container/vsphere/collector.go
@@ -87,8 +87,9 @@ const (
 	fTag     = "tag"
 	fSummary = "summary"
 	// PortGroup
-	fDVSwitch = "config.distributedVirtualSwitch"
-	fKey      = "key"
+	fDVSwitch     = "config.distributedVirtualSwitch"
+	fDVSwitchVlan = "config.defaultPortConfig"
+	fKey          = "key"
 	// DV Switch
 	fDVSwitchHost = "config.host"
 	// Datastore
@@ -688,6 +689,7 @@ func (r *Collector) propertySpec() []types.PropertySpec {
 			PathSet: []string{
 				fName,
 				fDVSwitch,
+				fDVSwitchVlan,
 				fTag,
 				fKey,
 			},

diff --git a/pkg/controller/provider/container/vsphere/model.go b/pkg/controller/provider/container/vsphere/model.go
@@ -1,6 +1,7 @@
 package vsphere
 
 import (
+	"fmt"
 	"net/url"
 	"sort"
 	"strconv"
@@ -306,6 +307,7 @@ func (v *HostAdapter) Apply(u types.ObjectUpdate) {
 								Key:    portGroup.Key,
 								Name:   portGroup.Spec.Name,
 								Switch: portGroup.Vswitch,
+								VlanId: portGroup.Spec.VlanId,
 							})
 					}
 				}
@@ -398,6 +400,21 @@ func (v *NetworkAdapter) Apply(u types.ObjectUpdate) {
 				if s, cast := p.Val.(types.OpaqueNetworkSummary); cast {
 					v.model.Key = s.OpaqueNetworkId
 				}
+			case fDVSwitchVlan:
+				if portSettings, cast := p.Val.(types.VMwareDVSPortSetting); cast {
+					switch vlanIdSpec := portSettings.Vlan.(type) {
+					case *types.VmwareDistributedVirtualSwitchVlanIdSpec:
+						if int(vlanIdSpec.VlanId) > 0 {
+							v.model.VlanId = strconv.Itoa(int(vlanIdSpec.VlanId))
+						}
+					case *types.VmwareDistributedVirtualSwitchTrunkVlanSpec:
+						refList := []string{}
+						for _, val := range vlanIdSpec.VlanId {
+							refList = append(refList, fmt.Sprintf("%d-%d", val.Start, val.End))
+						}
+						v.model.VlanId = strings.Join(refList, ",")
+					}
+				}
 			}
 		}
 	}

diff --git a/pkg/controller/provider/model/vsphere/model.go b/pkg/controller/provider/model/vsphere/model.go
@@ -201,6 +201,7 @@ type PortGroup struct {
 	Key    string `json:"key"`
 	Name   string `json:"name"`
 	Switch string `json:"vSwitch"`
+	VlanId int32  `json:"vlanId"`
 }
 
 type Switch struct {
@@ -216,6 +217,7 @@ type Network struct {
 	DVSwitch Ref       `sql:""`
 	Key      string    `sql:""`
 	Host     []DVSHost `sql:""`
+	VlanId   string    `sql:""`
 }
 
 type DVSHost struct {

diff --git a/pkg/controller/provider/web/vsphere/network.go b/pkg/controller/provider/web/vsphere/network.go
@@ -176,6 +176,7 @@ type Network struct {
 	Resource
 	Variant  string          `json:"variant"`
 	DVSwitch *model.Ref      `json:"dvSwitch,omitempty"`
+	VlanId   string          `json:"vlanId"`
 	Host     []model.DVSHost `json:"host"`
 	Tag      string          `json:"tag,omitempty"`
 	Key      string          `json:"key,omitempty"`
@@ -191,6 +192,7 @@ func (r *Network) With(m *model.Network) {
 	case model.NetDvPortGroup:
 		r.DVSwitch = &m.DVSwitch
 		r.Key = m.Key
+		r.VlanId = m.VlanId
 	case model.OpaqueNetwork:
 		r.Key = m.Key
 	case model.NetDvSwitch: