Function TestAuditDatabaseUpdate

rest/audit_test.go:626–683

(t *testing.T)

}

func TestAuditDatabaseUpdate(t *testing.T) {
	rt := createAuditLoggingRestTester(t)
	defer rt.Close()

	dbConfig := rt.NewDbConfig()
	dbConfig.Logging = &DbLoggingConfig{
		Audit: &DbAuditLoggingConfig{
			Enabled: base.Ptr(true),
			EnabledEvents: base.Ptr([]uint{
				uint(base.AuditIDUpdateDatabaseConfig),
			}),
		},
	}

	// initialize RestTester
	RequireStatus(t, rt.CreateDatabase("db", dbConfig), http.StatusCreated)

	testCases := []struct {
		name   string
		method string
		path   string
		body   string
	}{
		{
			name:   "update sync function",
			method: http.MethodPut,
			path:   "/{{.keyspace}}/_config/sync",
			body:   `function(doc){}`,
		},
		{
			name:   "update import filter",
			method: http.MethodPut,
			path:   "/{{.keyspace}}/_config/import_filter",
			body:   `function(doc){}`,
		},
		{
			name:   "delete sync function",
			method: http.MethodDelete,
			path:   "/{{.keyspace}}/_config/sync",
			body:   ``,
		},
		{
			name:   "delete import filter",
			method: http.MethodDelete,
			path:   "/{{.keyspace}}/_config/import_filter",
			body:   ``,
		},
	}
	for _, testCase := range testCases {
		rt.Run(testCase.name, func(t *testing.T) {
			output := base.AuditLogContents(t, func(t testing.TB) {
				resp := rt.SendAdminRequest(testCase.method, testCase.path, testCase.body)
				RequireStatus(t, resp, http.StatusOK)
			})
			requireValidDatabaseUpdatedEventPayload(rt, output)
		})
	}
}