package deployment import ( "github.com/google/go-cmp/cmp" appsv1 "k8s.io/api/apps/v1" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/client-go/informers" "k8s.io/client-go/kubernetes/fake" "kubesphere.io/kubesphere/pkg/api" "kubesphere.io/kubesphere/pkg/apiserver/query" "kubesphere.io/kubesphere/pkg/models/resources/v1alpha3" "testing" ) func TestListDeployments(t *testing.T) { tests := []struct { description string namespace string query *query.Query expected *api.ListResult expectedErr error }{ { "test name filter", "bar", &query.Query{ Pagination: &query.Pagination{ Limit: 1, Offset: 0, }, SortBy: query.FieldName, Ascending: false, Filters: []query.Filter{ { Field: query.FieldName, Value: query.Value("foo2"), }, }, }, &api.ListResult{ Items: []interface{}{ foo2, }, TotalItems: 1, }, nil, }, } getter := prepare() for _, test := range tests { t.Run(test.description, func(t *testing.T) { got, err := getter.List(test.namespace, test.query) if test.expectedErr != nil && err != test.expectedErr { t.Errorf("expected error, got nothing") } else if err != nil { t.Fatal(err) } if diff := cmp.Diff(got, test.expected); diff != "" { t.Errorf("%T differ (-got, +want): %s", test.expected, diff) } }) } } var ( foo1 = &appsv1.Deployment{ ObjectMeta: metav1.ObjectMeta{ Name: "foo1", Namespace: "bar", }, } foo2 = &appsv1.Deployment{ ObjectMeta: metav1.ObjectMeta{ Name: "foo2", Namespace: "bar", }, } bar1 = &appsv1.Deployment{ ObjectMeta: metav1.ObjectMeta{ Name: "bar1", Namespace: "bar", }, } deployments = []interface{}{foo1, foo2, bar1} ) func prepare() v1alpha3.Interface { client := fake.NewSimpleClientset() informer := informers.NewSharedInformerFactory(client, 0) for _, deployment := range deployments { informer.Apps().V1().Deployments().Informer().GetIndexer().Add(deployment) } return New(informer) }