Function TestPreparePerms

rest_auth_test.go:362–588

(t *testing.T)

}

func TestPreparePerms(t *testing.T) {
	rest.RequestProxyStubFunc = func() bool {
		return false
	}
	emptyDir, _ := ioutil.TempDir("./tmp", "test")
	defer func() {
		os.RemoveAll(emptyDir)
		rest.RequestProxyStubFunc = nil
	}()

	cfg := cbgt.NewCfgMem()
	meh := &TestMEH{}
	mgr := cbgt.NewManager(cbgt.VERSION, cfg, cbgt.NewUUID(),
		nil, "", 1, "", ":1000", emptyDir, "some-datasource", meh)
	mgr.Start("wanted")
	mgr.Kick("test-start-kick")

	mr, _ := cbgt.NewMsgRing(os.Stderr, 1000)

	router, _, err := NewRESTRouter("v0", mgr, "static", "", mr, nil)
	if err != nil || router == nil {
		t.Errorf("no mux router")
	}
	router.KeepContext = true // so we can see the mux vars

	s := &stubDefinitionLookuper{
		pindexes: testPIndexesByName,
		defs: &cbgt.IndexDefs{
			IndexDefs: testIndexDefsByName,
		},
	}

	tests := []struct {
		method string
		uri    string
		body   []byte
		path   string
		vars   map[string]string
		perms  []string
		err    error
	}{
		// case with valid perm not containing source
		{
			method: http.MethodGet,
			uri:    "/api/index",
			path:   "/api/index",
			perms:  nil,
		},
		// case with valid index name
		{
			method: http.MethodGet,
			uri:    "/api/index/i1",
			path:   "/api/index/{indexName}",
			vars:   map[string]string{"indexName": "i1"},
			perms:  []string{"cluster.bucket[s1].fts!read"},
		},
		// case with valid index name on collection
		{