Function TestDeltaSyncWhenToRevIsChannelRemoval

db/database_test.go:1474–1573

Test delta sync behavior when the toRevision is a channel removal.

(t *testing.T)

// Test delta sync behavior when the toRevision is a channel removal.
func TestDeltaSyncWhenToRevIsChannelRemoval(t *testing.T) {
	t.Skip("Pending work for channel removal at rev cache CBG-3814")
	testCases := []struct {
		name          string
		versionVector bool
	}{
		{
			name:          "revTree test",
			versionVector: false,
		},
		{
			name:          "versionVector test",
			versionVector: true,
		},
	}
	for _, testCase := range testCases {
		t.Run(testCase.name, func(t *testing.T) {
			db, ctx := setupTestDB(t)
			defer db.Close(ctx)
			collection, ctx := GetSingleDatabaseCollectionWithUser(ctx, t, db)
			collection.ChannelMapper = channels.NewChannelMapper(ctx, channels.DocChannelsSyncFunction, db.Options.JavascriptTimeout)

			// Create the first revision of doc1.
			rev1Body := Body{
				"k1":       "v1",
				"channels": []string{"ABC", "NBC"},
			}
			rev1ID, _, err := collection.Put(ctx, "doc1", rev1Body)
			require.NoError(t, err, "Error creating doc")

			// Create the second revision of doc1 on channel ABC as removal from channel NBC.
			rev2Body := Body{
				"k2":       "v2",
				"channels": []string{"ABC"},
				BodyRev:    rev1ID,
			}
			rev2ID, docRev2, err := collection.Put(ctx, "doc1", rev2Body)
			require.NoError(t, err, "Error creating doc")

			// Create the third revision of doc1 on channel ABC.
			rev3Body := Body{
				"k3":       "v3",
				"channels": []string{"ABC"},
				BodyRev:    rev2ID,
			}
			rev3ID, docRev3, err := collection.Put(ctx, "doc1", rev3Body)
			require.NoError(t, err, "Error creating doc")
			require.NotEmpty(t, rev3ID, "Error creating doc")

			// Flush the revision cache and purge the old revision backup.
			db.FlushRevisionCacheForTest()
			err = collection.PurgeOldRevisionJSON(ctx, "doc1", rev2ID)
			require.NoError(t, err, "Error purging old revision JSON")

			// Request delta between rev1ID and rev2ID (toRevision "rev2ID" is channel removal)
			// as a user who doesn't have access to the removed revision via any other channel.
			authenticator := db.Authenticator(ctx)
			user, err := authenticator.NewUser("alice", "pass", base.SetOf("NBC"))