diff --git a/pkg/rtc/room_test.go b/pkg/rtc/room_test.go index 7a565aba5..3c828ed6b 100644 --- a/pkg/rtc/room_test.go +++ b/pkg/rtc/room_test.go @@ -906,6 +906,7 @@ func newRoomWithParticipants(t *testing.T, opts testRoomOpts) *Room { telemetry.NewTelemetryService(n, &telemetryfakes.FakeAnalyticsService{}), nil, nil, nil, ) + t.Cleanup(func() { rm.Close(types.RoomCloseReasonUnknown) }) for i := 0; i < opts.num+opts.numHidden; i++ { identity := livekit.ParticipantIdentity(fmt.Sprintf("p%d", i)) participant := NewMockParticipant(identity, opts.protocol, i >= opts.num, true, rm.LocalParticipantListener()) diff --git a/pkg/rtc/testutils.go b/pkg/rtc/testutils.go index 085582113..253707c9c 100644 --- a/pkg/rtc/testutils.go +++ b/pkg/rtc/testutils.go @@ -23,6 +23,7 @@ import ( "github.com/livekit/livekit-server/pkg/rtc/types" "github.com/livekit/livekit-server/pkg/rtc/types/typesfakes" + "github.com/livekit/livekit-server/pkg/sfu/connectionquality" ) func NewMockParticipant( @@ -54,6 +55,11 @@ func NewMockParticipant( State: livekit.ParticipantInfo_JOINED, IsPublisher: publisher, }, utils.TimedVersion(0)) + p.GetConnectionQualityReturns(&livekit.ConnectionQualityInfo{ + ParticipantSid: sid, + Quality: livekit.ConnectionQuality_EXCELLENT, + Score: connectionquality.MaxMOS, + }) p.SetMetadataCalls(func(m string) { participantListener.OnParticipantUpdate(p)