ARCO-209: replace mocks

internal/callbacker/callbacker.go

@@ -4,7 +4,7 @@ import (
 	"time"
 )
 
-type SendInterface interface {
+type SendCallbackInterface interface {
 	Send(url, token string, callback *Callback) bool
 	SendBatch(url, token string, callbacks []*Callback) bool
 }

internal/callbacker/callbacker_mocks.go

@@ -1,4 +1,4 @@
 package callbacker
 
 // from callbacker.go
-//go:generate moq -out ./callbacker_mock.go ./ SendInterface
+//go:generate moq -out ./callbacker_mock.go ./ SendCallbackInterface

internal/callbacker/dispatcher.go

@@ -6,7 +6,7 @@ package callbacker
 The CallbackDispatcher is responsible for routing and dispatching callbacks to appropriate sendManager based on the callback URL.
 
 Key components:
-- SendInterface Interface: the CallbackDispatcher decorates this interface, enhancing its functionality by managing the actual dispatch logic
+- SendCallbackInterface Interface: the CallbackDispatcher decorates this interface, enhancing its functionality by managing the actual dispatch logic
 - sendManager: each sendManager handles specific types of callbacks, determined by the URL
 
 Dispatch Logic: the CallbackDispatcher ensures that callbacks are sent to the correct sendManager, maintaining efficient processing and delivery.
@@ -23,7 +23,7 @@ import (
 )
 
 type CallbackDispatcher struct {
-	c SendInterface
+	c SendCallbackInterface
 	s store.CallbackerStore
 	l *slog.Logger
 
@@ -41,7 +41,7 @@ type CallbackEntry struct {
 	postponedUntil *time.Time
 }
 
-func NewCallbackDispatcher(callbacker SendInterface, store store.CallbackerStore, logger *slog.Logger,
+func NewCallbackDispatcher(callbacker SendCallbackInterface, store store.CallbackerStore, logger *slog.Logger,
 	singleSendPause, batchSendInterval, quarantineBaseDuration, permQuarantineAfterDuration time.Duration) *CallbackDispatcher {
 
 	return &CallbackDispatcher{

internal/callbacker/dispatcher_test.go

@@ -39,7 +39,7 @@ func TestCallbackDispatcher(t *testing.T) {
 	for _, tc := range tcs {
 		t.Run(tc.name, func(t *testing.T) {
 			// given
-			cMq := &CallbackerIMock{
+			cMq := &SendCallbackInterfaceMock{
 				SendFunc: func(_, _ string, _ *Callback) bool { return true },
 			}
 

internal/callbacker/send_manager.go

@@ -14,7 +14,7 @@ The manager operates in various modes:
 It processes callbacks from two channels, ensuring either single or batch dispatch, and manages retries based on a quarantine policy.
 
 Key components:
-- SendInterface : responsible for sending callbacks
+- SendCallbackInterface : responsible for sending callbacks
 - quarantine policy: the duration for quarantining a URL are governed by a configurable policy, determining how long the URL remains inactive before retry attempts
 
 Sending logic: callbacks are sent to the designated URL one at a time, ensuring sequential and orderly processing.
@@ -40,7 +40,7 @@ type sendManager struct {
 	url string
 
 	// dependencies
-	c SendInterface
+	c SendCallbackInterface
 	s store.CallbackerStore
 	l *slog.Logger
 	q *quarantinePolicy
@@ -68,7 +68,7 @@ const (
 	StoppingMode
 )
 
-func runNewSendManager(u string, c SendInterface, s store.CallbackerStore, l *slog.Logger, q *quarantinePolicy,
+func runNewSendManager(u string, c SendCallbackInterface, s store.CallbackerStore, l *slog.Logger, q *quarantinePolicy,
 	singleSendSleep, batchSendInterval time.Duration) *sendManager {
 
 	const defaultBatchSendInterval = time.Duration(5 * time.Second)

internal/callbacker/send_manager_test.go

@@ -62,7 +62,7 @@ func TestSendManager(t *testing.T) {
 	for _, tc := range tcs {
 		t.Run(tc.name, func(t *testing.T) {
 			// given
-			cMq := &CallbackerIMock{
+			cMq := &SendCallbackInterfaceMock{
 				SendFunc:      func(_, _ string, _ *Callback) bool { return true },
 				SendBatchFunc: func(_, _ string, _ []*Callback) bool { return true },
 			}
@@ -163,7 +163,7 @@ func TestSendManager_Quarantine(t *testing.T) {
 
 			// given
 			sendOK := true
-			senderMq := &CallbackerIMock{
+			senderMq := &SendCallbackInterfaceMock{
 				SendFunc:      func(_, _ string, _ *Callback) bool { return sendOK },
 				SendBatchFunc: func(_, _ string, _ []*Callback) bool { return sendOK },
 			}

internal/k8s_watcher/watcher_test.go

@@ -69,7 +69,7 @@ func TestStartMetamorphWatcher(t *testing.T) {
 					return 3, nil
 				},
 			}
-			blocktxMock := &btxMocks.BlocktxClientMock{}
+			blocktxMock := &btxMocks.BlockClientMock{}
 
 			iteration := 0
 			getPodNamesErrTest := tc.getPodNamesErr
@@ -157,7 +157,7 @@ func TestStartBlocktxWatcher(t *testing.T) {
 	for _, tc := range tt {
 		t.Run(tc.name, func(t *testing.T) {
 			metamorphMock := &mtmMocks.TransactionMaintainerMock{}
-			blocktxMock := &btxMocks.BlocktxClientMock{
+			blocktxMock := &btxMocks.BlockClientMock{
 				DelUnfinishedBlockProcessingFunc: func(_ context.Context, _ string) (int64, error) { return 0, nil },
 			}