Function TestRebuildUserChannelsNamedCollection

auth/auth_test.go:433–458

(t *testing.T)

}

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

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

	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.TimedSet(nil), user2.Channels())
	assert.Equal(t, ch.AtSequence(ch.BaseSetOf(t, "explicit2", "derived3", "derived4", "!"), 1), user2.CollectionChannels("scope1", "collection1"))
}

// Test cases
//   multiple collections