Function TestGetUserDocAccessMultiChannel

rest/diagnostic_doc_api_test.go:652–683

put doc in multiple channels, remove from some channels, assert response gets right sequences for each channels

(t *testing.T)

// put doc in multiple channels, remove from some channels, assert response gets right sequences for each channels
func TestGetUserDocAccessMultiChannel(t *testing.T) {
	rt := NewRestTester(t, &RestTesterConfig{SyncFn: `function(doc) {channel(doc.channel);}`})
	defer rt.Close()
	userGrant := userGrant{
		user: "alice",
		adminChannels: map[string][]string{
			"{{.keyspace}}": {"A", "B", "C"},
		},
	}
	userGrant.request(rt)

	version := rt.PutDoc("doc1", `{"channel":["A"]}`)
	updatedVersion := rt.UpdateDoc("doc1", version, `{"channel":["B", "A"]}`)
	updatedVersion = rt.UpdateDoc("doc1", updatedVersion, `{"channel":["C", "B"]}`)

	// assert sequences are registered correctly
	expectedOutput := `{"doc1": {"A": { "entries" : ["2-4"]}, "B": { "entries" : ["3-0"]},  "C": { "entries" : ["4-0"]} }}`
	response := rt.SendDiagnosticRequest(http.MethodGet,
		"/{{.keyspace}}/_user/alice?docids=doc1", ``)
	RequireStatus(rt.TB(), response, http.StatusOK)
	require.JSONEq(rt.TB(), rt.mustTemplateResource(expectedOutput), response.BodyString())

	// remove all channels
	_ = rt.UpdateDoc("doc1", updatedVersion, `{"channel":[]}`)

	// assert sequences spans end here
	expectedOutput = `{"doc1": {"A": { "entries" : ["2-4"]}, "B": { "entries" : ["3-5"]},  "C": { "entries" : ["4-5"]} }}`
	response = rt.SendDiagnosticRequest(http.MethodGet,
		"/{{.keyspace}}/_user/alice?docids=doc1", ``)
	RequireStatus(rt.TB(), response, http.StatusOK)
	require.JSONEq(rt.TB(), rt.mustTemplateResource(expectedOutput), response.BodyString())
}

// give user access to chanA through admin API and role, remove admin API assignment, and assert access span is admin assignment to 0
func TestGetUserDocAccessContinuousRoleAdminAPI(t *testing.T) {