Skip to content

Commit

Permalink
tests: unit test for list error for issuer mapper
Browse files Browse the repository at this point in the history
  • Loading branch information
KevFan committed Jul 2, 2024
1 parent 21e0a1c commit 7269fc5
Showing 1 changed file with 31 additions and 3 deletions.
34 changes: 31 additions & 3 deletions controllers/tlspolicy_mappers_test.go
Original file line number Diff line number Diff line change
@@ -1,7 +1,10 @@
//go:build unit

package controllers

import (
"context"
"errors"
"reflect"
"testing"

Expand All @@ -13,6 +16,7 @@ import (
"k8s.io/apimachinery/pkg/types"
"sigs.k8s.io/controller-runtime/pkg/client"
"sigs.k8s.io/controller-runtime/pkg/client/fake"
"sigs.k8s.io/controller-runtime/pkg/client/interceptor"
"sigs.k8s.io/controller-runtime/pkg/reconcile"

"github.com/kuadrant/kuadrant-operator/api/v1alpha1"
Expand Down Expand Up @@ -47,10 +51,22 @@ func Test_mapClusterIssuerToPolicy(t *testing.T) {
},
want: nil,
},
{
name: "list error",
args: args{
k8sClient: fake.NewClientBuilder().WithScheme(s).WithInterceptorFuncs(interceptor.Funcs{
List: func(ctx context.Context, client client.WithWatch, list client.ObjectList, opts ...client.ListOption) error {
return errors.New("list error")
},
}).Build(),
object: clusterIssuer,
},
want: nil,
},
{
name: "map cluster issuer to matching policies",
args: args{
k8sClient: fake.NewClientBuilder().WithScheme(s).WithObjects(clusterIssuer).WithLists(testInitPolicies(clusterIssuer.Name, certmanagerv1.ClusterIssuerKind)).Build(),
k8sClient: fake.NewClientBuilder().WithScheme(s).WithObjects(clusterIssuer).WithLists(testInitTLSPolicies(clusterIssuer.Name, certmanagerv1.ClusterIssuerKind)).Build(),
object: clusterIssuer,
},
want: []reconcile.Request{
Expand Down Expand Up @@ -104,10 +120,22 @@ func Test_mapIssuerToPolicy(t *testing.T) {
},
want: nil,
},
{
name: "list error",
args: args{
k8sClient: fake.NewClientBuilder().WithScheme(s).WithInterceptorFuncs(interceptor.Funcs{
List: func(ctx context.Context, client client.WithWatch, list client.ObjectList, opts ...client.ListOption) error {
return errors.New("list error")
},
}).Build(),
object: issuer,
},
want: nil,
},
{
name: "map issuer to matching policies",
args: args{
k8sClient: fake.NewClientBuilder().WithScheme(s).WithObjects(issuer).WithLists(testInitPolicies(issuer.Name, certmanagerv1.IssuerKind)).Build(),
k8sClient: fake.NewClientBuilder().WithScheme(s).WithObjects(issuer).WithLists(testInitTLSPolicies(issuer.Name, certmanagerv1.IssuerKind)).Build(),
object: issuer,
},
want: []reconcile.Request{
Expand All @@ -126,7 +154,7 @@ func Test_mapIssuerToPolicy(t *testing.T) {
}
}

func testInitPolicies(issuerName, issuerKind string) *v1alpha1.TLSPolicyList {
func testInitTLSPolicies(issuerName, issuerKind string) *v1alpha1.TLSPolicyList {
return &v1alpha1.TLSPolicyList{
Items: []v1alpha1.TLSPolicy{

Expand Down

0 comments on commit 7269fc5

Please sign in to comment.