Function TestCollectionSyncFunction

channels/channelmapper_test.go:611–640

(t *testing.T)

}

func TestCollectionSyncFunction(t *testing.T) {
	testCases := []struct {
		docBody string
		name    string
	}{
		{
			docBody: `{"channels": ["foo", "bar", "baz"]}`,
			name:    "legacyDocBody",
		},
		{
			docBody: `{"x": "y"}`,
			name:    "irrelevantData",
		},
		{
			docBody: `{"x": "y"}`,
			name:    "irrelevantData",
		},
	}

	for _, test := range testCases {
		t.Run(test.name, func(t *testing.T) {
			ctx := base.TestCtx(t)
			collectionName := "barcollection"
			mapper := NewChannelMapper(ctx, GetDefaultSyncFunction("fooscope", collectionName), 0)
			res, err := mapper.MapToChannelsAndAccess(ctx, parse(t, test.docBody), `{}`, emptyMetaMap(), noUser)
			require.NoError(t, err)
			require.Equal(t, BaseSetOf(t, collectionName), res.Channels)
		})
	}
}

func TestGetDefaultSyncFunction(t *testing.T) {
	testCases := []struct {