add unit tests to exception and certificatecleanup packages

Author: piyush-tiwari

pkg/exception/util_test.go

@@ -7,6 +7,37 @@ import (
 	"testing"
 )
 
+func TestNotFoundServiceError(t *testing.T) {
+	RegisterTestingT(t)
+
+	notfoundServiceError := NotFoundServiceError{}
+	Expect(notfoundServiceError.GetHTTPStatusCode()).To(Equal(404))
+	Expect(notfoundServiceError.GetMessage()).To(Equal("NotFound"))
+	Expect(notfoundServiceError.GetCode()).To(Equal("NotFound"))
+	Expect(notfoundServiceError.GetOpcRequestID()).To(Equal("fakeopcrequestid"))
+	Expect(notfoundServiceError.Error()).To(Equal("NotFound"))
+}
+
+func TestConflictServiceError(t *testing.T) {
+	RegisterTestingT(t)
+
+	conflictServiceError := ConflictServiceError{}
+	Expect(conflictServiceError.GetHTTPStatusCode()).To(Equal(409))
+	Expect(conflictServiceError.GetMessage()).To(Equal("Conflict"))
+	Expect(conflictServiceError.GetCode()).To(Equal("Conflict"))
+	Expect(conflictServiceError.GetOpcRequestID()).To(Equal("fakeopcrequestid"))
+	Expect(conflictServiceError.Error()).To(Equal("Conflict"))
+}
+
+func TestTransientError(t *testing.T) {
+	RegisterTestingT(t)
+
+	err := errors.New("test-error")
+	transientErr := NewTransientError(err)
+	Expect(transientErr.GetWrappedError()).To(Equal(err))
+	Expect(transientErr.Error()).To(Equal(err.Error()))
+}
+
 func TestHasTransientError(t *testing.T) {
 	RegisterTestingT(t)
 

pkg/task/certificatecleanup/certificate_cleanup_test.go

@@ -12,6 +12,10 @@ package certificatecleanup
 import (
 	"context"
 	"errors"
+	networkingv1 "k8s.io/api/networking/v1"
+	"k8s.io/client-go/informers"
+	fakeclientset "k8s.io/client-go/kubernetes/fake"
+	"k8s.io/client-go/tools/cache"
 	"net/http"
 	"testing"
 	"time"
@@ -147,6 +151,39 @@ func inits() (context.Context, *certificate.CertificatesClient) {
 	return ctx, certificatesClient
 }
 
+func TestRun(t *testing.T) {
+	RegisterTestingT(t)
+
+	controllerClass := "oci.oraclecloud.com/native-ingress-controller"
+	fakeClient := fakeclientset.NewSimpleClientset()
+	util.UpdateFakeClientCall(fakeClient, "list", "ingressclasses", &networkingv1.IngressClassList{
+		Items: []networkingv1.IngressClass{
+			*util.GetIngressClassResource("ingressClass1", true, controllerClass),
+			*util.GetIngressClassResource("ingressClass2", false, controllerClass),
+		},
+	})
+	informerFactory := informers.NewSharedInformerFactory(fakeClient, 0)
+	ingressClassInformer := informerFactory.Networking().V1().IngressClasses()
+	ingressClassInformer.Lister()
+	saInformer := informerFactory.Core().V1().ServiceAccounts()
+	saInformer.Lister()
+	informerFactory.Start(context.TODO().Done())
+	cache.WaitForCacheSync(context.TODO().Done(), ingressClassInformer.Informer().HasSynced)
+	cache.WaitForCacheSync(context.TODO().Done(), saInformer.Informer().HasSynced)
+
+	_, certClient := inits()
+	wrapperClient := client.NewWrapperClient(fakeClient, nil, nil, certClient, nil)
+	client := &client.ClientProvider{
+		K8sClient:           fakeClient,
+		DefaultConfigGetter: &MockConfigGetter{},
+		Cache:               NewMockCacheStore(wrapperClient),
+	}
+	cleanupTask := NewTask(controllerClass, ingressClassInformer, saInformer, true,
+		"compartmentId", time.Hour, client, nil)
+
+	cleanupTask.run()
+}
+
 func TestCleanupCompartment(t *testing.T) {
 	RegisterTestingT(t)
 	ctx, _ := inits()