Function TestRevocationsWithQueryLimitChangesLimit

rest/revocation_test.go:1162–1209

(t *testing.T)

}

func TestRevocationsWithQueryLimitChangesLimit(t *testing.T) {
	defer db.SuspendSequenceBatching()()

	revocationTester, rt := InitScenario(t, &RestTesterConfig{
		DatabaseConfig: &DatabaseConfig{DbConfig: DbConfig{
			QueryPaginationLimit: base.Ptr(2),
			CacheConfig: &CacheConfig{
				RevCacheConfig: &RevCacheConfig{
					MaxItemCount: base.Ptr(uint32(0)),
				},
				ChannelCacheConfig: &ChannelCacheConfig{
					MaxNumber: base.Ptr(0),
				},
			},
		}},
	})
	defer rt.Close()

	revocationTester.addRole("user", "foo")
	revocationTester.addRoleChannel("foo", "ch1")

	revocationTester.fillToSeq(9)
	_ = rt.PutDoc("doc1", `{"channels": ["ch1"]}`)
	_ = rt.PutDoc("doc2", `{"channels": ["ch1"]}`)
	_ = rt.PutDoc("doc3", `{"channels": ["ch1"]}`)

	changes := revocationTester.getChanges("0", 4)

	revocationTester.removeRole("user", "foo")

	rt.WaitForPendingChanges()
	waitForUserChangesWithLimit := func(sinceVal interface{}, limit int) ChangesResults {
		var changesRes ChangesResults
		err := rt.WaitForCondition(func() bool {
			changesRes = rt.GetChanges(fmt.Sprintf("/{{.keyspace}}/_changes?since=%v&revocations=true&limit=%d", sinceVal, limit), "user")
			return len(changesRes.Results) == limit
		})
		assert.NoError(t, err)
		return changesRes
	}

	sinceVal := changes.Last_Seq
	changes = waitForUserChangesWithLimit(sinceVal, 2)
	assert.Len(t, changes.Results, 2)

	changes = waitForUserChangesWithLimit(sinceVal, 3)
	assert.Len(t, changes.Results, 3)
}

func TestRevocationUserHasDocAccessDocNotFound(t *testing.T) {
	if !base.UnitTestUrlIsWalrus() {