Function TestHandleBroadcastInfoChannelWithMultipleReaders

server/topic_test.go:2920–2976

(t *testing.T)

}

func TestHandleBroadcastInfoChannelWithMultipleReaders(t *testing.T) {
	topicName := "grpTest"
	chanName := "chnTest"
	numUsers := 5
	helper := TopicTestHelper{}
	helper.setUp(t, numUsers, types.TopicCatGrp, topicName, true)
	helper.topic.isChan = true
	defer helper.tearDown()
	helper.topic.lastID = 15

	readId := 12
	from := helper.uids[0]

	// Set up multiple channel readers
	for i := 1; i < numUsers; i++ {
		uid := helper.uids[i]
		pud := helper.topic.perUser[uid]
		pud.modeGiven = types.ModeCChnReader
		pud.isChan = true
		helper.topic.perUser[uid] = pud
	}

	helper.ss.EXPECT().Update(chanName, from, map[string]any{"ReadSeqId": readId}).Return(nil)

	msg := &ClientComMessage{
		AsUser:   from.UserId(),
		Original: chanName,
		Note: &MsgClientNote{
			Topic: chanName,
			What:  "read",
			SeqId: readId,
		},
		sess: helper.sessions[0],
	}
	helper.topic.handleClientMsg(msg)
	helper.finish()

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

	// Channel topics don't forward note messages to other users
	for i, r := range helper.results {
		if numMessages := len(r.messages); numMessages != 0 {
			t.Errorf("User %d is not expected to receive any messages, %d received", i, numMessages)
		}
	}

	// Only sender gets presence notification
	if len(helper.hubMessages) != 1 {
		t.Fatalf("Hub expected exactly 1 recipient, got %d", len(helper.hubMessages))
	}
	if _, ok := helper.hubMessages[from.UserId()]; !ok {
		t.Fatal("Expected presence notification for sender")
	}
}