Function TestRevocationWithAdminChannels

rest/revocation_test.go:881–905

(t *testing.T)

}

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

	rt := NewRestTester(t, &RestTesterConfig{SyncFn: channels.DocChannelsSyncFunction})
	defer rt.Close()
	dataStore := rt.GetSingleDataStore()

	rt.CreateUser("user", []string{"A"})

	resp := rt.SendAdminRequest("PUT", "/{{.keyspace}}/doc", `{"channels": ["A"]}`)
	RequireStatus(t, resp, http.StatusCreated)

	changes := rt.WaitForChanges(2, "/{{.keyspace}}/_changes?since=0&revocations=true", "user", false)

	assert.Equal(t, "doc", changes.Results[1].ID)
	assert.False(t, changes.Results[0].Revoked)

	resp = rt.SendAdminRequest("PUT", "/db/_user/user", GetUserPayload(t, "", "letmein", "", dataStore, []string{}, nil))
	RequireStatus(t, resp, http.StatusOK)

	changes = rt.WaitForChanges(2, fmt.Sprintf("/{{.keyspace}}/_changes?since=%d&revocations=true", 2), "user", false)

	assert.Equal(t, "doc", changes.Results[0].ID)
	assert.True(t, changes.Results[0].Revoked)
}

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