fix: unit tests

kubeshop · Jun 20, 2024 · 70f46b2 · 70f46b2
1 parent 1ce800d
commit 70f46b2
Show file tree

Hide file tree

Showing 2 changed files with 14 additions and 0 deletions.
diff --git a/pkg/triggers/matcher_test.go b/pkg/triggers/matcher_test.go
@@ -11,6 +11,7 @@ import (
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 
 	testtriggersv1 "github.com/kubeshop/testkube-operator/api/testtriggers/v1"
+	"github.com/kubeshop/testkube/internal/app/api/metrics"
 	"github.com/kubeshop/testkube/pkg/log"
 )
 
@@ -89,6 +90,7 @@ func TestService_matchConditionsRetry(t *testing.T) {
 		},
 		triggerStatus: map[statusKey]*triggerStatus{statusKey1: triggerStatus1},
 		logger:        log.DefaultLogger,
+		metrics:       metrics.NewMetrics(),
 	}
 
 	err := s.match(context.Background(), e)
@@ -165,6 +167,7 @@ func TestService_matchConditionsTimeout(t *testing.T) {
 		},
 		triggerStatus: map[statusKey]*triggerStatus{statusKey1: triggerStatus1},
 		logger:        log.DefaultLogger,
+		metrics:       metrics.NewMetrics(),
 	}
 
 	err := s.match(context.Background(), e)
@@ -238,6 +241,7 @@ func TestService_matchProbesMultiple(t *testing.T) {
 		triggerStatus: map[statusKey]*triggerStatus{statusKey1: triggerStatus1},
 		logger:        log.DefaultLogger,
 		httpClient:    http.DefaultClient,
+		metrics:       metrics.NewMetrics(),
 	}
 
 	err = s.match(context.Background(), e)
@@ -304,6 +308,7 @@ func TestService_matchProbesTimeout(t *testing.T) {
 		triggerStatus: map[statusKey]*triggerStatus{statusKey1: triggerStatus1},
 		logger:        log.DefaultLogger,
 		httpClient:    http.DefaultClient,
+		metrics:       metrics.NewMetrics(),
 	}
 
 	err = s.match(context.Background(), e)
@@ -409,6 +414,7 @@ func TestService_match(t *testing.T) {
 		triggerStatus: map[statusKey]*triggerStatus{statusKey1: triggerStatus1},
 		logger:        log.DefaultLogger,
 		httpClient:    http.DefaultClient,
+		metrics:       metrics.NewMetrics(),
 	}
 
 	err = s.match(context.Background(), e)
@@ -459,6 +465,7 @@ func TestService_matchRegex(t *testing.T) {
 		triggerStatus: map[statusKey]*triggerStatus{statusKey1: triggerStatus1},
 		logger:        log.DefaultLogger,
 		httpClient:    http.DefaultClient,
+		metrics:       metrics.NewMetrics(),
 	}
 
 	err := s.match(context.Background(), e)
@@ -500,6 +507,7 @@ func TestService_noMatch(t *testing.T) {
 		triggerExecutor: testExecutorF,
 		triggerStatus:   map[statusKey]*triggerStatus{statusKey1: triggerStatus1},
 		logger:          log.DefaultLogger,
+		metrics:         metrics.NewMetrics(),
 	}
 
 	err := s.match(context.Background(), e)

diff --git a/pkg/triggers/watcher_test.go b/pkg/triggers/watcher_test.go
@@ -12,6 +12,7 @@ import (
 
 	testtriggersv1 "github.com/kubeshop/testkube-operator/api/testtriggers/v1"
 	faketestkube "github.com/kubeshop/testkube-operator/pkg/clientset/versioned/fake"
+	"github.com/kubeshop/testkube/internal/app/api/metrics"
 	"github.com/kubeshop/testkube/pkg/event/bus"
 	"github.com/kubeshop/testkube/pkg/log"
 )
@@ -35,6 +36,7 @@ func TestService_runWatcher_lease(t *testing.T) {
 			logger:            log.DefaultLogger,
 			informers:         newK8sInformers(clientset, testKubeClientset, "", []string{}),
 			eventsBus:         &bus.EventBusMock{},
+			metrics:           metrics.NewMetrics(),
 		}
 
 		leaseChan := make(chan bool)
@@ -94,6 +96,7 @@ func TestService_runWatcher_lease(t *testing.T) {
 			logger:            log.DefaultLogger,
 			informers:         newK8sInformers(clientset, testKubeClientset, "", []string{}),
 			eventsBus:         &bus.EventBusMock{},
+			metrics:           metrics.NewMetrics(),
 		}
 
 		leaseChan := make(chan bool)
@@ -156,6 +159,7 @@ func TestService_runWatcher_noLease(t *testing.T) {
 			logger:            log.DefaultLogger,
 			informers:         newK8sInformers(clientset, testKubeClientset, "", []string{}),
 			eventsBus:         &bus.EventBusMock{},
+			metrics:           metrics.NewMetrics(),
 		}
 
 		leaseChan := make(chan bool)
@@ -197,6 +201,7 @@ func TestService_runWatcher_noLease(t *testing.T) {
 			logger:            log.DefaultLogger,
 			informers:         newK8sInformers(clientset, testKubeClientset, "", []string{}),
 			eventsBus:         &bus.EventBusMock{},
+			metrics:           metrics.NewMetrics(),
 		}
 
 		leaseChan := make(chan bool)
@@ -240,6 +245,7 @@ func TestService_runWatcher_noLease(t *testing.T) {
 			logger:            log.DefaultLogger,
 			informers:         newK8sInformers(clientset, testKubeClientset, "", []string{}),
 			eventsBus:         &bus.EventBusMock{},
+			metrics:           metrics.NewMetrics(),
 		}
 
 		leaseChan := make(chan bool)