sriov-fec: add List method (#1054)

Author: ajaggapa

pkg/sriov-fec/nodeconfiglist.go

@@ -0,0 +1,73 @@
+package sriovfec
+
+import (
+	"context"
+	"fmt"
+
+	"github.com/golang/glog"
+	"github.com/openshift-kni/eco-goinfra/pkg/clients"
+	sriovfectypes "github.com/openshift-kni/eco-goinfra/pkg/schemes/fec/fectypes"
+	"sigs.k8s.io/controller-runtime/pkg/client"
+)
+
+// List returns SriovFecNodeConfigList from given namespace.
+func List(apiClient *clients.Settings, nsname string, options ...client.ListOptions) ([]*NodeConfigBuilder, error) {
+	if apiClient == nil {
+		glog.V(100).Infof("SriovFecNodeConfigList 'apiClient' parameter can not be empty")
+
+		return nil, fmt.Errorf("failed to list SriovFecNodeConfig, 'apiClient' parameter is empty")
+	}
+
+	err := apiClient.AttachScheme(sriovfectypes.AddToScheme)
+	if err != nil {
+		glog.V(100).Infof("Failed to add sriov-fec scheme to client schemes")
+
+		return nil, err
+	}
+
+	if nsname == "" {
+		glog.V(100).Infof("SriovFecNodeConfigList 'nsname' parameter can not be empty")
+
+		return nil, fmt.Errorf("failed to list SriovFecNodeConfig, 'nsname' parameter is empty")
+	}
+
+	passedOptions := client.ListOptions{}
+	logMessage := fmt.Sprintf("Listing SriovFecNodeConfig in the namespace %s", nsname)
+
+	if len(options) > 1 {
+		glog.V(100).Infof("'options' parameter must be empty or single-valued")
+
+		return nil, fmt.Errorf("error: more than one ListOptions was passed")
+	}
+
+	if len(options) == 1 {
+		passedOptions = options[0]
+		logMessage += fmt.Sprintf(" with the options %v", passedOptions)
+	}
+
+	glog.V(100).Infof(logMessage)
+
+	sfncList := new(sriovfectypes.SriovFecNodeConfigList)
+	err = apiClient.List(context.TODO(), sfncList, &passedOptions)
+
+	if err != nil {
+		glog.V(100).Infof("Failed to list SriovFecNodeConfigs in the namespace %s due to %s", nsname, err.Error())
+
+		return nil, err
+	}
+
+	var sfncBuilderList []*NodeConfigBuilder
+
+	for _, sfnc := range sfncList.Items {
+		copiedObject := sfnc
+		sfncBuilder := &NodeConfigBuilder{
+			apiClient:  apiClient.Client,
+			Object:     &copiedObject,
+			Definition: &copiedObject,
+		}
+
+		sfncBuilderList = append(sfncBuilderList, sfncBuilder)
+	}
+
+	return sfncBuilderList, nil
+}

pkg/sriov-fec/nodeconfiglist_test.go

@@ -0,0 +1,59 @@
+package sriovfec
+
+import (
+	"fmt"
+	"testing"
+
+	"github.com/openshift-kni/eco-goinfra/pkg/clients"
+	"github.com/stretchr/testify/assert"
+	"k8s.io/apimachinery/pkg/runtime"
+)
+
+func TestNodeConfigList(t *testing.T) {
+	testCases := []struct {
+		apiclient     bool
+		nsname        string
+		expectedError error
+	}{
+		{
+			apiclient:     false,
+			nsname:        defaultNodeConfigNamespace,
+			expectedError: fmt.Errorf("failed to list SriovFecNodeConfig, 'apiClient' parameter is empty"),
+		},
+		{
+			apiclient:     true,
+			nsname:        "",
+			expectedError: fmt.Errorf("failed to list SriovFecNodeConfig, 'nsname' parameter is empty"),
+		},
+		{
+			apiclient:     true,
+			nsname:        defaultNodeConfigNamespace,
+			expectedError: nil,
+		},
+	}
+
+	for _, testCase := range testCases {
+		var testSettings *clients.Settings
+
+		if testCase.apiclient {
+			testSettings = clients.GetTestClients(clients.TestClientParams{
+				K8sMockObjects:  buildDummyNodeConfigList(),
+				SchemeAttachers: testSchemes,
+			})
+		}
+
+		testBuilderList, err := List(testSettings, testCase.nsname)
+		assert.Equal(t, testCase.expectedError, err)
+
+		if testCase.expectedError == nil {
+			assert.Equal(t, len(buildDummyNodeConfigList()), len(testBuilderList))
+		}
+	}
+}
+
+func buildDummyNodeConfigList() []runtime.Object {
+	return []runtime.Object{
+		buildDummyNodeConfig("worker-0", "test-ns"),
+		buildDummyNodeConfig("worker-1", "test-ns"),
+	}
+}