Skip to content

Commit 0034d1f

Browse files
committed
Fix tests
1 parent 7506946 commit 0034d1f

File tree

3 files changed

+12
-7
lines changed

3 files changed

+12
-7
lines changed

client/internal/updatemanager/manager.go

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -57,6 +57,8 @@ type Manager struct {
5757

5858
// updateMutex protect update and expectedVersion fields
5959
updateMutex sync.Mutex
60+
61+
triggerUpdateFn func(string) error
6062
}
6163

6264
func NewManager(statusRecorder *peer.Status, stateManager *statemanager.Manager) *Manager {
@@ -68,6 +70,7 @@ func NewManager(statusRecorder *peer.Status, stateManager *statemanager.Manager)
6870
currentVersion: version.NetbirdVersion(),
6971
update: version.NewUpdate("nb/client"),
7072
}
73+
manager.triggerUpdateFn = manager.triggerUpdate
7174

7275
return manager
7376
}
@@ -246,7 +249,7 @@ func (m *Manager) handleUpdate(ctx context.Context) {
246249
}
247250
}
248251

249-
if err := m.triggerUpdate(updateVersion.String()); err != nil {
252+
if err := m.triggerUpdateFn(updateVersion.String()); err != nil {
250253
log.Errorf("Error triggering auto-update: %v", err)
251254
m.statusRecorder.PublishEvent(
252255
cProto.SystemEvent_ERROR,

client/internal/updatemanager/manager_test.go

Lines changed: 7 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -3,12 +3,14 @@ package updatemanager
33
import (
44
"context"
55
"fmt"
6-
v "github.com/hashicorp/go-version"
7-
"github.com/netbirdio/netbird/client/internal/peer"
8-
"github.com/netbirdio/netbird/client/internal/statemanager"
96
"path"
107
"testing"
118
"time"
9+
10+
v "github.com/hashicorp/go-version"
11+
12+
"github.com/netbirdio/netbird/client/internal/peer"
13+
"github.com/netbirdio/netbird/client/internal/statemanager"
1214
)
1315

1416
func (m *Manager) WithCustomVersionUpdate(versionUpdate UpdateInterface) *Manager {
@@ -71,7 +73,7 @@ func Test_LatestVersion(t *testing.T) {
7173

7274
targetVersionChan := make(chan string, 1)
7375

74-
m.updateFunc = func(ctx context.Context, targetVersion string) error {
76+
m.triggerUpdateFn = func(targetVersion string) error {
7577
targetVersionChan <- targetVersion
7678
return nil
7779
}
@@ -183,7 +185,7 @@ func Test_HandleUpdate(t *testing.T) {
183185
m := NewManager(peer.NewRecorder(""), statemanager.New(tmpFile)).WithCustomVersionUpdate(&versionUpdateMock{latestVersion: c.latestVersion})
184186
targetVersionChan := make(chan string, 1)
185187

186-
m.updateFunc = func(ctx context.Context, targetVersion string) error {
188+
m.triggerUpdateFn = func(targetVersion string) error {
187189
targetVersionChan <- targetVersion
188190
return nil
189191
}

client/server/server_test.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -108,7 +108,7 @@ func TestConnectWithRetryRuns(t *testing.T) {
108108
t.Setenv(maxRetryTimeVar, "5s")
109109
t.Setenv(retryMultiplierVar, "1")
110110

111-
s.connectWithRetryRuns(ctx, config, s.statusRecorder, nil, nil)
111+
s.connectWithRetryRuns(ctx, config, s.statusRecorder, false, nil, nil)
112112
if counter < 3 {
113113
t.Fatalf("expected counter > 2, got %d", counter)
114114
}

0 commit comments

Comments
 (0)