Method GetGroupVMs

pkg/api/grouped-cluster.go:205–269

GetGroupVMs retrieves VMs from all connected profiles in the group. Each VM's SourceProfile field is set to identify which profile it came from. Returns a combined list of all VMs across all profiles.

(ctx context.Context)

// Each VM's SourceProfile field is set to identify which profile it came from.
// Returns a combined list of all VMs across all profiles.
func (m *GroupClientManager) GetGroupVMs(ctx context.Context) ([]*VM, error) {
	operation := func(profileName string, client *Client) (interface{}, error) {
		// Get cluster status to retrieve nodes with their VMs
		cluster, err := client.GetClusterStatus()
		if err != nil {
			return nil, fmt.Errorf("failed to get cluster status: %w", err)
		}

		// Collect all VMs from all nodes
		var vms []*VM
		for _, node := range cluster.Nodes {
			if node != nil && node.VMs != nil {
				for _, vm := range node.VMs {
					if vm != nil {
						vm.SourceProfile = profileName
						vms = append(vms, vm)
					}
				}
			}
		}

		return vms, nil
	}

	groupFunc := func(results []ProfileResult) (interface{}, error) {
		var allVMs []*VM

		for _, result := range results {
			if vms, ok := result.Data.([]*VM); ok {
				allVMs = append(allVMs, vms...)
			}
		}
		allVMs = deduplicateGroupVMs(allVMs)

		// Sort VMs by profile name, then by node, then by ID
		sort.Slice(allVMs, func(i, j int) bool {
			if allVMs[i] == nil || allVMs[j] == nil {
				return allVMs[i] != nil
			}
			// Sort by profile name first
			if allVMs[i].SourceProfile != allVMs[j].SourceProfile {
				return allVMs[i].SourceProfile < allVMs[j].SourceProfile
			}
			// Then by node name
			if allVMs[i].Node != allVMs[j].Node {
				return allVMs[i].Node < allVMs[j].Node
			}
			// Finally by VM ID
			return allVMs[i].ID < allVMs[j].ID
		})

		return allVMs, nil
	}

	data, err := m.GetGroupData(ctx, operation, groupFunc)
	if err != nil {
		return nil, err
	}