Function TestUnregisterSessionWithPendingCall

server/topic_test.go:3084–3176

(t *testing.T)

}

func TestUnregisterSessionWithPendingCall(t *testing.T) {
	numUsers := 2
	helper := TopicTestHelper{}
	helper.setUp(t, numUsers, types.TopicCatP2P, "p2p-test", true)
	defer helper.tearDown()

	uid := helper.uids[0]
	s := helper.sessions[0]
	r := helper.results[0]

	// Set up a pending call matching the actual videoCall structure
	helper.topic.currentCall = &videoCall{
		seq:     123,
		parties: make(map[string]callPartyData),
	}
	helper.topic.currentCall.parties[s.sid] = callPartyData{
		uid:          uid,
		isOriginator: true,
		sess:         s,
	}
	helper.mm.EXPECT().Save(gomock.Any(), gomock.Any(), gomock.Any()).Return(nil, true)

	leave := &ClientComMessage{
		Leave: &MsgClientLeave{
			Id:    "id456",
			Topic: "p2p-test",
		},
		AsUser: uid.UserId(),
		sess:   s,
		init:   true,
	}

	helper.topic.unregisterSession(leave)
	helper.finish()

	// Check for errors from testHubLoop
	if errorMsgs, hasError := helper.hubMessages["__ERROR__"]; hasError {
		t.Fatal(errorMsgs[0].Ctrl.Text)
	}

	// Verify session was unregistered
	if len(helper.topic.sessions) != 1 {
		t.Errorf("Attached sessions: expected 1, found %d", len(helper.topic.sessions))
	}
	if len(s.subs) != 0 {
		t.Errorf("Session subscriptions: expected 0, found %d", len(s.subs))
	}

	// Verify call party was removed (if the implementation handles this)
	if helper.topic.currentCall != nil && helper.topic.currentCall.parties != nil {
		if _, exists := helper.topic.currentCall.parties[s.sid]; exists {
			t.Error("Call party should have been removed when session unregistered")
		}
	}

	if len(r.messages) != 3 {
		t.Fatalf("`responses` expected to contain 3 elements, found %d", len(r.messages))
	}