share logic for getting the in-use MachineConfigs

go.mod

@@ -22,7 +22,7 @@ require (
 	github.com/opencontainers/selinux v1.11.0
 	github.com/openshift/api v0.0.0-20240527133614-ba11c1587003
 	github.com/openshift/build-machinery-go v0.0.0-20240419090851-af9c868bcf52
-	github.com/openshift/client-go v0.0.0-20240528061634-b054aa794d87
+	github.com/openshift/client-go v0.0.0-20240821135114-75c118605d5f
 	github.com/pkg/errors v0.9.1
 	github.com/pkg/profile v1.3.0
 	github.com/prometheus/client_golang v1.16.0

go.sum

@@ -198,6 +198,8 @@ github.com/openshift/build-machinery-go v0.0.0-20240419090851-af9c868bcf52 h1:bq
 github.com/openshift/build-machinery-go v0.0.0-20240419090851-af9c868bcf52/go.mod h1:b1BuldmJlbA/xYtdZvKi+7j5YGB44qJUJDZ9zwiNCfE=
 github.com/openshift/client-go v0.0.0-20240528061634-b054aa794d87 h1:JtLhaGpSEconE+1IKmIgCOof/Len5ceG6H1pk43yv5U=
 github.com/openshift/client-go v0.0.0-20240528061634-b054aa794d87/go.mod h1:3IPD4U0qyovZS4EFady2kqY32m8lGcbs/Wx+yprg9z8=
+github.com/openshift/client-go v0.0.0-20240821135114-75c118605d5f h1:iYIcy36QilP/1KeiVYeqXP9oLsP2gCytGIG5+doS7x8=
+github.com/openshift/client-go v0.0.0-20240821135114-75c118605d5f/go.mod h1:3IPD4U0qyovZS4EFady2kqY32m8lGcbs/Wx+yprg9z8=
 github.com/pkg/errors v0.8.0/go.mod h1:bwawxfHBFNV+L2hUp1rHADufV3IMtnDRdf1r5NINEl0=
 github.com/pkg/errors v0.9.1 h1:FEBLx1zS214owpjy7qsBeixbURkuhQAwrK5UwLGTwt4=
 github.com/pkg/errors v0.9.1/go.mod h1:bwawxfHBFNV+L2hUp1rHADufV3IMtnDRdf1r5NINEl0=

pkg/machineconfig/OWNERS

@@ -0,0 +1,3 @@
+reviewers:
+
+approvers:

pkg/machineconfig/in_use_machineconfigs.go

@@ -0,0 +1,58 @@
+package machineconfig
+
+import (
+	"context"
+	"fmt"
+
+	mcfgclientset "github.com/openshift/client-go/machineconfiguration/clientset/versioned"
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+	"k8s.io/apimachinery/pkg/util/sets"
+	"k8s.io/client-go/kubernetes"
+	"k8s.io/client-go/rest"
+)
+
+// GetInUseMachineConfigs filters in-use MachineConfig resources and returns set of their names.
+func GetInUseMachineConfigs(ctx context.Context, clientConfig *rest.Config, poolFilter string) (sets.Set[string], error) {
+	// Create a set to store in-use configs
+	inuseConfigs := sets.New[string]()
+
+	machineConfigClient, err := mcfgclientset.NewForConfig(clientConfig)
+	if err != nil {
+		return nil, err
+	}
+
+	poolList, err := machineConfigClient.MachineconfigurationV1().MachineConfigPools().List(ctx, metav1.ListOptions{})
+	if err != nil {
+		return nil, fmt.Errorf("getting MachineConfigPools failed: %w", err)
+	}
+
+	for _, pool := range poolList.Items {
+		// Check if the pool matches the specified pool name (if provided)
+		if poolFilter == "" || poolFilter == pool.Name {
+			// Get the rendered config name from the status section
+			inuseConfigs.Insert(pool.Status.Configuration.Name)
+			inuseConfigs.Insert(pool.Spec.Configuration.Name)
+		}
+	}
+
+	kubeClient, err := kubernetes.NewForConfig(clientConfig)
+	if err != nil {
+		return nil, err
+	}
+	nodeList, err := kubeClient.CoreV1().Nodes().List(ctx, metav1.ListOptions{})
+	if err != nil {
+		return nil, err
+	}
+	for _, node := range nodeList.Items {
+		current, ok := node.Annotations["machineconfiguration.openshift.io/currentConfig"]
+		if ok {
+			inuseConfigs.Insert(current)
+		}
+		desired, ok := node.Annotations["machineconfiguration.openshift.io/desiredConfig"]
+		if ok {
+			inuseConfigs.Insert(desired)
+		}
+	}
+
+	return inuseConfigs, nil
+}