e2e: serial: config: get cluster topics at startup

cluster topics are expected not to change mid-run
of the serial tests, so collecting them once
at startup seems like a good compromise.

The topics will be available through the shared
serial config object.

Signed-off-by: Francesco Romani <fromani@redhat.com>

Author: ffromani

test/e2e/serial/config/fixture.go

@@ -24,6 +24,7 @@ import (
 	nrtv1alpha2 "github.com/k8stopologyawareschedwg/noderesourcetopology-api/pkg/apis/topology/v1alpha2"
 
 	nropv1 "github.com/openshift-kni/numaresources-operator/api/v1"
+	"github.com/openshift-kni/numaresources-operator/internal/api/features"
 	intnrt "github.com/openshift-kni/numaresources-operator/internal/noderesourcetopology"
 	e2efixture "github.com/openshift-kni/numaresources-operator/test/internal/fixture"
 	"github.com/openshift-kni/numaresources-operator/test/internal/objects"
@@ -35,6 +36,7 @@ type E2EConfig struct {
 	NROOperObj    *nropv1.NUMAResourcesOperator
 	NROSchedObj   *nropv1.NUMAResourcesScheduler
 	SchedulerName string
+	ClusterTopics features.TopicInfo
 	infraNRTList  nrtv1alpha2.NodeResourceTopologyList
 }
 
@@ -102,5 +104,10 @@ func NewFixtureWithOptions(ctx context.Context, nsName string, options e2efixtur
 	cfg.SchedulerName = cfg.NROSchedObj.Status.SchedulerName
 	klog.InfoS("detected scheduler name", "schedulerName", cfg.SchedulerName)
 
+	cfg.ClusterTopics, err = FetchClusterTopics(ctx, cfg.Fixture, cfg.NROOperObj)
+	if err != nil {
+		return nil, err
+	}
+
 	return &cfg, nil
 }

test/e2e/serial/config/infra.go

@@ -18,6 +18,7 @@ package config
 
 import (
 	"context"
+	"encoding/json"
 	"fmt"
 	"os"
 	"sync"
@@ -32,11 +33,14 @@ import (
 	nrtv1alpha2 "github.com/k8stopologyawareschedwg/noderesourcetopology-api/pkg/apis/topology/v1alpha2"
 
 	nropv1 "github.com/openshift-kni/numaresources-operator/api/v1"
+	"github.com/openshift-kni/numaresources-operator/internal/api/features"
 	"github.com/openshift-kni/numaresources-operator/internal/nodegroups"
+	"github.com/openshift-kni/numaresources-operator/internal/remoteexec"
 	"github.com/openshift-kni/numaresources-operator/internal/wait"
 	"github.com/openshift-kni/numaresources-operator/pkg/objectnames"
 	numacellapi "github.com/openshift-kni/numaresources-operator/test/deviceplugin/pkg/numacell/api"
 	numacellmanifests "github.com/openshift-kni/numaresources-operator/test/deviceplugin/pkg/numacell/manifests"
+	"github.com/openshift-kni/numaresources-operator/test/internal/deploy"
 	e2efixture "github.com/openshift-kni/numaresources-operator/test/internal/fixture"
 	"github.com/openshift-kni/numaresources-operator/test/internal/images"
 
@@ -211,3 +215,38 @@ func unlabelNodeByName(cli client.Client, nodeName string) {
 		g.Expect(err).ToNot(HaveOccurred())
 	}).WithTimeout(3*time.Minute).WithPolling(30*time.Second).Should(Succeed(), "failed to unlabel node %q: %v", nodeName, err)
 }
+
+func FetchClusterTopics(ctx context.Context, fxt *e2efixture.Fixture, nropObj *nropv1.NUMAResourcesOperator) (features.TopicInfo, error) {
+	pod, err := deploy.FindNUMAResourcesOperatorPod(ctx, fxt.Client, nropObj)
+	if err != nil {
+		return features.NewTopicInfo(), err
+	}
+
+	cmdline := []string{
+		"/bin/numaresources-operator",
+		"--inspect-features",
+	}
+	stdout, stderr, err := remoteexec.CommandOnPod(ctx, fxt.K8sClient, pod, cmdline...)
+	// older version may miss introspection support that's fine
+	if err != nil {
+		return features.NewTopicInfo(), nil
+	}
+
+	if len(stderr) > 0 {
+		klog.InfoS("while fetching cluster topics", "stderr", stderr)
+	}
+
+	var tp features.TopicInfo
+	err = json.Unmarshal(stdout, &tp)
+	if err != nil {
+		return features.NewTopicInfo(), err
+	}
+	klog.InfoS("active features from the deployed operator", "features", string(stdout))
+
+	tp.Metadata.Version = features.Version
+	err = tp.Validate()
+	if err != nil {
+		return features.NewTopicInfo(), err
+	}
+	return tp, nil
+}