Function TestDeltaSyncWhenFromRevIsLegacyRevTreeID

db/database_test.go:1033–1066

(t *testing.T)

}

func TestDeltaSyncWhenFromRevIsLegacyRevTreeID(t *testing.T) {
	base.SetUpTestLogging(t, base.LevelDebug, base.KeyAll)

	if !base.IsEnterpriseEdition() {
		t.Skip("Delta sync only supported in EE")
	}

	db, ctx := SetupTestDBWithOptions(t, DatabaseContextOptions{
		DeltaSyncOptions: DeltaSyncOptions{
			Enabled:          true,
			RevMaxAgeSeconds: 300,
		},
		StoreLegacyRevTreeData: base.Ptr(true),
	})

	defer db.Close(ctx)
	collection, ctx := GetSingleDatabaseCollectionWithUser(ctx, t, db)
	require.NoError(t, db.DbStats.InitDeltaSyncStats())

	rev1, _, err := collection.Put(ctx, "doc1", Body{"foo": "bar", "bar": "buzz", "quux": "quax"})
	require.NoError(t, err, "Error creating doc1")
	rev2, _, err := collection.Put(ctx, "doc1", Body{"foo": "bar", "quux": "fuzz", BodyRev: rev1})
	require.NoError(t, err, "Error updating doc1")

	// force retrieval from backing store
	db.FlushRevisionCacheForTest()

	// get delta using legacy RevTree IDs - this should force a lookup for CV1 via the pointer backup revision doc
	delta, _, err := collection.GetDelta(ctx, "doc1", rev1, rev2)
	require.NoErrorf(t, err, "Error getting delta for doc %q from rev %q to %q", "doc1", rev1, rev2)
	require.NotNil(t, delta)
	assert.Equal(t, rev2, delta.ToRevID)
	assert.Equal(t, []byte(`{"bar":[],"quux":"fuzz"}`), delta.DeltaBytes)
}

func TestFetchCurrentRevAfterFetchBackupRevByCV(t *testing.T) {
	base.SetUpTestLogging(t, base.LevelDebug, base.KeyAll)