Function TestRegisterSessionWithComplexModeString

server/topic_test.go:2978–3032

(t *testing.T)

}

func TestRegisterSessionWithComplexModeString(t *testing.T) {
	topicName := "grpTest"
	numUsers := 2
	helper := TopicTestHelper{}
	helper.setUp(t, numUsers, types.TopicCatGrp, topicName, false)
	defer helper.tearDown()

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

	// User with existing subscription wants to change mode
	pud := helper.topic.perUser[uid]
	pud.modeWant = types.ModeCPublic
	pud.modeGiven = types.ModeCPublic
	helper.topic.perUser[uid] = pud

	join := &ClientComMessage{
		Original: topicName,
		Sub: &MsgClientSub{
			Id:    "id456",
			Topic: topicName,
			Set: &MsgSetQuery{
				Sub: &MsgSetSub{
					Mode: "JRWPAS", // Complex mode string with multiple permissions
				},
			},
		},
		AsUser:  uid.UserId(),
		AuthLvl: int(auth.LevelAuth),
		sess:    s,
	}

	helper.ss.EXPECT().Update(topicName, uid, gomock.Any()).Return(nil)

	helper.topic.registerSession(join)
	helper.finish()

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

	if len(helper.topic.sessions) != 1 {
		t.Fatalf("Attached sessions: expected 1, found %d", len(helper.topic.sessions))
	}
	if len(s.subs) != 1 {
		t.Fatalf("Session subscriptions: expected 1, found %d", len(s.subs))
	}
	online := helper.topic.perUser[uid].online
	if online != 1 {
		t.Fatalf("Number of online sessions: expected 1, found %d", online)
	}
	registerSessionVerifyOutputs(t, r, []int{http.StatusOK})
}

func TestHandleBroadcastDataGroupWithMutedUser(t *testing.T) {
	topicName := "grp-test"