From ba8ba596b1d23db78934a7f6f6024742a28ab681 Mon Sep 17 00:00:00 2001 From: Arthur Lu Date: Fri, 22 May 2026 18:49:34 +0000 Subject: [PATCH] add pool to instance mapping to sync --- app/model.go | 30 ++++++++++++++++++++++++++++++ proxmoxaas-common-lib | 2 +- 2 files changed, 31 insertions(+), 1 deletion(-) diff --git a/app/model.go b/app/model.go index d67044d..a320d16 100644 --- a/app/model.go +++ b/app/model.go @@ -1,6 +1,7 @@ package app import ( + "context" "fmt" "log" "strings" @@ -54,6 +55,35 @@ func (cluster *Cluster) Sync() error { log.Printf("[INFO] successfully synced node %s", hostName) } } + + //resolve pool membership + pools, err := cluster.pve.client.Pools(context.Background()) + if err != nil { + err_ch <- err + return + } + for _, pool := range pools { + pool, err = cluster.pve.client.Pool(context.Background(), pool.PoolID) + if err != nil { + err_ch <- err + return + } + for _, member := range pool.Members { + if member.Type == "lxc" || member.Type == "qemu" { + node, ok := cluster.Nodes[member.Node] + if !ok { + return + } + instance, ok := node.Instances[InstanceID(member.VMID)] + if !ok { + return + } + instance.Pool = pool.PoolID + log.Printf("[INFO] successfully resolved pool membership for vmid=%d pool=%s", member.VMID, pool.PoolID) + } + } + } + err_ch <- nil }() diff --git a/proxmoxaas-common-lib b/proxmoxaas-common-lib index cc53d7b..be50bf3 160000 --- a/proxmoxaas-common-lib +++ b/proxmoxaas-common-lib @@ -1 +1 @@ -Subproject commit cc53d7bdea6ead7ceba9bfd0c25e41392601094b +Subproject commit be50bf3428d32f35a2997274b8d9e269a3a5094f