refactor: unify backend k8s objects handler for UI

Author: AndrejsPon00

kof-operator/cmd/main.go

@@ -156,10 +156,13 @@ func main() {
 	httpServer.Router.GET("/api/targets", handlers.PrometheusHandler)
 	httpServer.Router.GET("/api/collectors/metrics", handlers.CollectorHandler)
 	httpServer.Router.GET("/api/victoria/metrics", handlers.VictoriaHandler)
-	httpServer.Router.GET("/api/cluster-deployments", handlers.ClusterDeploymentHandler)
-	httpServer.Router.GET("/api/cluster-summaries", handlers.ClusterSummariesHandler)
-	httpServer.Router.GET("/api/multi-cluster-services", handlers.MultiClusterServicesHandler)
-	httpServer.Router.GET("/api/state-management-providers", handlers.StateManagementProvidersHandler)
+	httpServer.Router.GET("/api/cluster-deployments", handlers.K8sObjectsHandler[*kcmv1beta1.ClusterDeploymentList])
+	httpServer.Router.GET("/api/cluster-summaries", handlers.K8sObjectsHandler[*sveltosv1beta1.ClusterSummaryList])
+	httpServer.Router.GET("/api/multi-cluster-services", handlers.K8sObjectsHandler[*kcmv1beta1.MultiClusterServiceList])
+	httpServer.Router.GET(
+		"/api/state-management-providers",
+		handlers.K8sObjectsHandler[*kcmv1beta1.StateManagementProviderList],
+	)
 	httpServer.Router.NotFound(handlers.NotFoundHandler)
 	setupLog.Info(fmt.Sprintf("Starting http server on :%s", httpServerPort))
 	var wg sync.WaitGroup

kof-operator/internal/k8s/cluster_summary.go

@@ -0,0 +1,21 @@
+package k8s
+
+import (
+	"context"
+	"fmt"
+	"reflect"
+
+	"sigs.k8s.io/controller-runtime/pkg/client"
+)
+
+func GetObjectsList[ObjListT client.ObjectList](ctx context.Context, c client.Client) (ObjListT, error) {
+	var objList ObjListT
+	objType := reflect.TypeOf(objList)
+	if objType.Kind() != reflect.Ptr || objType.Elem().Kind() != reflect.Struct {
+		var zero ObjListT
+		return zero, fmt.Errorf("ObjListT must be a pointer to a struct that implements client.ObjectList, got %v", objType)
+	}
+	listPtr := reflect.New(objType.Elem()).Interface().(client.ObjectList)
+	err := c.List(ctx, listPtr)
+	return listPtr.(ObjListT), err
+}

kof-operator/internal/k8s/multi_cluster_service.go

@@ -0,0 +1,55 @@
+package handlers
+
+import (
+	"fmt"
+	"net/http"
+
+	"github.com/k0rdent/kof/kof-operator/internal/k8s"
+	"github.com/k0rdent/kof/kof-operator/internal/server"
+	"k8s.io/apimachinery/pkg/api/meta"
+	"k8s.io/apimachinery/pkg/runtime"
+	"sigs.k8s.io/controller-runtime/pkg/client"
+)
+
+type K8sObjectsResponse struct {
+	Items map[string]client.Object `json:"items"`
+}
+
+func K8sObjectsHandler[ObjListT client.ObjectList](res *server.Response, req *http.Request) {
+	ctx := req.Context()
+
+	kubeClient, err := k8s.NewClient()
+	if err != nil {
+		res.Logger.Error(err, "Failed to create kube client")
+		res.Fail(server.BasicInternalErrorMessage, http.StatusInternalServerError)
+		return
+	}
+
+	objectList, err := k8s.GetObjectsList[ObjListT](ctx, kubeClient.Client)
+	if err != nil {
+		res.Logger.Error(err, "Failed to get objects list")
+		res.Fail(server.BasicInternalErrorMessage, http.StatusInternalServerError)
+		return
+	}
+
+	objectsMap := make(map[string]client.Object)
+
+	if err := meta.EachListItem(objectList, func(o runtime.Object) error {
+		obj, ok := o.(client.Object)
+		if !ok {
+			return fmt.Errorf("object is not a client.Object")
+		}
+
+		obj.SetManagedFields(nil)
+		objectsMap[string(obj.GetUID())] = obj
+		return nil
+	}); err != nil {
+		res.Logger.Error(err, "Failed to iterate over list items")
+		res.Fail(server.BasicInternalErrorMessage, http.StatusInternalServerError)
+		return
+	}
+
+	res.Send(&K8sObjectsResponse{
+		Items: objectsMap,
+	}, http.StatusOK)
+}