Function TestSyncFuncDryRun

rest/diagnostic_doc_api_test.go:933–1497

Tests the Diagnostic Endpoint to dry run Sync Function

(t *testing.T)

// Tests the Diagnostic Endpoint to dry run Sync Function
func TestSyncFuncDryRun(t *testing.T) {
	base.SkipImportTestsIfNotEnabled(t)
	base.SetUpTestLogging(t, base.LevelDebug, base.KeyAll)

	rt := NewRestTester(t, &RestTesterConfig{
		PersistentConfig: true,
	})
	defer rt.Close()

	dbConfig := rt.NewDbConfig()
	rt.CreateDatabase("db", dbConfig)

	// When the tests run with named scopes and collections, then the default
	// sync function is:
	// function(doc){channel("<collection_name>");}
	// when the tests run in default scope and collection then the default
	// sync function is:
	// function(doc){channel(doc.channels);}
	const docChannelName = "chanNew"
	var defaultChannelName string
	dbc, _ := rt.GetSingleTestDatabaseCollection()
	if dbc.IsDefaultCollection() {
		defaultChannelName = docChannelName
	} else {
		defaultChannelName = dbc.Name
	}

	tests := []struct {
		name            string
		dbSyncFunction  string
		existingDocBody string
		request         SyncFnDryRunPayload
		requestDocID    bool
		expectedOutput  SyncFnDryRun
		expectedStatus  int
	}{
		{
			name: "request sync function and doc body",
			request: SyncFnDryRunPayload{
				Function: `function(doc) {
					channel(doc.channel);
					access(doc.accessUser, doc.accessChannel);
					role(doc.accessUser, doc.role);
					expiry(doc.expiry);
				}`,
				Doc: db.Body{
					"accessChannel": []string{"dynamicChan5412"},
					"accessUser":    "user",
					"channel":       []string{"dynamicChan222"},
					"expiry":        10,
				},
			},
			expectedOutput: SyncFnDryRun{
				Channels: base.SetFromArray([]string{"dynamicChan222"}),
				Access:   channels.AccessMap{"user": channels.BaseSetOf(t, "dynamicChan5412")},
				Roles:    channels.AccessMap{},
				Expiry:   base.Ptr(uint32(10)),
				Logging: DryRunLogging{