Function TestRequireAccess

channels/sync_runner_test.go:50–62

(t *testing.T)

}

func TestRequireAccess(t *testing.T) {
	ctx := base.TestCtx(t)
	const funcSource = `function(doc, oldDoc) { requireAccess(oldDoc._access) }`
	runner, err := NewSyncRunner(ctx, funcSource, 0)
	require.NoError(t, err)
	var result interface{}
	result, _ = runner.Call(ctx, parse(t, `{}`), parse(t, `{"_access": ["alpha"]}`), emptyMetaMap(), parse(t, `{"name": "", "channels": ["alpha"]}`))
	assertNotRejected(t, result)
	result, _ = runner.Call(ctx, parse(t, `{}`), parse(t, `{"_access": ["beta", "gamma"]}`), emptyMetaMap(), parse(t, `{"name": "", "channels": ["beta"]}`))
	assertNotRejected(t, result)
	result, _ = runner.Call(ctx, parse(t, `{}`), parse(t, `{"_access": ["delta"]}`), emptyMetaMap(), parse(t, `{"name": "", "channels": ["beta"]}`))
	assertRejected(t, result, base.HTTPErrorf(http.StatusForbidden, base.SyncFnErrorMissingChannelAccess))
}

func TestRequireAdmin(t *testing.T) {
	ctx := base.TestCtx(t)