Skip to content

Commit 2f5e02f

Browse files
committed
Update group account peers update tests to reflect correct behavior for unlinked groups
1 parent 92430d6 commit 2f5e02f

File tree

1 file changed

+14
-14
lines changed

1 file changed

+14
-14
lines changed

management/server/group_test.go

Lines changed: 14 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -447,11 +447,11 @@ func TestGroupAccountPeersUpdate(t *testing.T) {
447447
manager.peersUpdateManager.CloseChannel(context.Background(), peer1.ID)
448448
})
449449

450-
// Saving a group that is not linked to any resource should not update account peers
450+
// Saving a group that is not linked to any resource should update account peers
451451
t.Run("saving unlinked group", func(t *testing.T) {
452452
done := make(chan struct{})
453453
go func() {
454-
peerShouldNotReceiveUpdate(t, updMsg)
454+
peerShouldReceiveUpdate(t, updMsg)
455455
close(done)
456456
}()
457457

@@ -465,16 +465,16 @@ func TestGroupAccountPeersUpdate(t *testing.T) {
465465
select {
466466
case <-done:
467467
case <-time.After(time.Second):
468-
t.Error("timeout waiting for peerShouldNotReceiveUpdate")
468+
t.Error("timeout waiting for peerShouldReceiveUpdate")
469469
}
470470
})
471471

472-
// Adding a peer to a group that is not linked to any resource should not update account peers
473-
// and not send peer update
472+
// Adding a peer to a group that is not linked to any resource should update account peers
473+
// and send peer update
474474
t.Run("adding peer to unlinked group", func(t *testing.T) {
475475
done := make(chan struct{})
476476
go func() {
477-
peerShouldNotReceiveUpdate(t, updMsg)
477+
peerShouldReceiveUpdate(t, updMsg)
478478
close(done)
479479
}()
480480

@@ -484,16 +484,16 @@ func TestGroupAccountPeersUpdate(t *testing.T) {
484484
select {
485485
case <-done:
486486
case <-time.After(time.Second):
487-
t.Error("timeout waiting for peerShouldNotReceiveUpdate")
487+
t.Error("timeout waiting for peerShouldReceiveUpdate")
488488
}
489489
})
490490

491-
// Removing a peer from a group that is not linked to any resource should not update account peers
492-
// and not send peer update
491+
// Removing a peer from a group that is not linked to any resource should update account peers
492+
// and send peer update
493493
t.Run("removing peer from unliked group", func(t *testing.T) {
494494
done := make(chan struct{})
495495
go func() {
496-
peerShouldNotReceiveUpdate(t, updMsg)
496+
peerShouldReceiveUpdate(t, updMsg)
497497
close(done)
498498
}()
499499

@@ -503,15 +503,15 @@ func TestGroupAccountPeersUpdate(t *testing.T) {
503503
select {
504504
case <-done:
505505
case <-time.After(time.Second):
506-
t.Error("timeout waiting for peerShouldNotReceiveUpdate")
506+
t.Error("timeout waiting for peerShouldReceiveUpdate")
507507
}
508508
})
509509

510-
// Deleting group should not update account peers and not send peer update
510+
// Deleting group should update account peers and send peer update
511511
t.Run("deleting group", func(t *testing.T) {
512512
done := make(chan struct{})
513513
go func() {
514-
peerShouldNotReceiveUpdate(t, updMsg)
514+
peerShouldReceiveUpdate(t, updMsg)
515515
close(done)
516516
}()
517517

@@ -521,7 +521,7 @@ func TestGroupAccountPeersUpdate(t *testing.T) {
521521
select {
522522
case <-done:
523523
case <-time.After(time.Second):
524-
t.Error("timeout waiting for peerShouldNotReceiveUpdate")
524+
t.Error("timeout waiting for peerShouldReceiveUpdate")
525525
}
526526
})
527527

0 commit comments

Comments
 (0)