Function TestRebuildUserChannelsMultiCollection

auth/auth_test.go:404–431

(t *testing.T)

}

func TestRebuildUserChannelsMultiCollection(t *testing.T) {
	ctx := base.TestCtx(t)
	bucket := base.GetTestBucket(t)
	defer bucket.Close(ctx)
	dataStore := bucket.GetSingleDataStore()
	computer := mockComputer{}
	computer.AddChannelsForCollection(base.DefaultScope, base.DefaultCollection, ch.AtSequence(ch.BaseSetOf(t, "derived1", "derived2"), 1))
	computer.AddChannelsForCollection("scope1", "collection1", ch.AtSequence(ch.BaseSetOf(t, "derived3", "derived4"), 1))

	options := DefaultAuthenticatorOptions(ctx)
	options.Collections = map[string]map[string]struct{}{
		base.DefaultScope: {base.DefaultCollection: struct{}{}},
		"scope1":          {"collection1": struct{}{}},
	}
	auth := NewTestAuthenticator(t, dataStore, &computer, options)
	user, _ := auth.NewUser("testUser", "password", ch.BaseSetOf(t, "explicit1"))
	user.SetCollectionExplicitChannels("scope1", "collection1", ch.AtSequence(ch.BaseSetOf(t, "explicit2"), 1), 0)
	err := auth.Save(user)
	assert.NoError(t, err)

	err = auth.InvalidateChannels("testUser", true, base.ScopeAndCollectionNames{base.NewScopeAndCollectionName("scope1", "collection1")}, 2)
	assert.NoError(t, err)

	user2, err := auth.GetUser("testUser")
	assert.NoError(t, err)
	assert.Equal(t, ch.AtSequence(ch.BaseSetOf(t, "explicit1", "derived1", "derived2", "!"), 1), user2.Channels())
	assert.Equal(t, ch.AtSequence(ch.BaseSetOf(t, "explicit2", "derived3", "derived4", "!"), 1), user2.CollectionChannels("scope1", "collection1"))
}

func TestRebuildUserChannelsNamedCollection(t *testing.T) {
	ctx := base.TestCtx(t)