Function TestDeltaSyncWhenFromRevIsChannelRemoval

db/database_test.go:1363–1471

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

(t *testing.T)

// Test delta sync behavior when the fromRevision is a channel removal.
func TestDeltaSyncWhenFromRevIsChannelRemoval(t *testing.T) {
	if !base.IsEnterpriseEdition() {
		t.Skip("Delta sync only supported in EE")
	}

	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 := SetupTestDBWithOptions(t, DatabaseContextOptions{DeltaSyncOptions: DeltaSyncOptions{Enabled: true, RevMaxAgeSeconds: 300}})
			defer db.Close(ctx)
			collection, ctx := GetSingleDatabaseCollectionWithUser(ctx, t, db)

			// 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()
			if testCase.versionVector {
				cvStr := docRev2.HLV.GetCurrentVersionString()
				err = collection.PurgeOldRevisionJSON(ctx, "doc1", base.Crc32cHashString([]byte(cvStr)))
				require.NoError(t, err, "Error purging old revision JSON")
			} else {