Function TestDoNotWriteBodyBackOnImport

rest/importtest/import_test.go:2430–2473

(t *testing.T)

}

func TestDoNotWriteBodyBackOnImport(t *testing.T) {
	base.SkipImportTestsIfNotEnabled(t)
	base.SetUpTestLogging(t, base.LevelDebug, base.KeyHTTP, base.KeyCRUD, base.KeyImport)

	rt := rest.NewRestTester(t, &rest.RestTesterConfig{
		AutoImport: base.Ptr(true),
	})
	defer rt.Close()

	docID := t.Name()

	collection, _ := rt.GetSingleTestDatabaseCollectionWithUser()
	ds := collection.GetCollectionDatastore()

	preImportDocBytes := rt.GetDatabase().DbStats.Database().DocWritesBytes.Value()
	preImportDocXattrBytes := rt.GetDatabase().DbStats.Database().DocWritesXattrBytes.Value()

	body := []byte(`{"test":"doc"}`)
	_, err := ds.WriteCas(docID, 0, 0, body, 0)
	require.NoError(t, err)

	base.RequireWaitForStat(t, func() int64 {
		return rt.GetDatabase().DbStats.SharedBucketImportStats.ImportCount.Value()
	}, 1)

	// ensure bytes for doc bodies is unchanged
	newDocBytes := rt.GetDatabase().DbStats.Database().DocWritesBytes.Value()
	assert.Equal(t, preImportDocBytes, newDocBytes)
	// assert that doc xattr bytes have been written
	newXattrBytes := rt.GetDatabase().DbStats.Database().DocWritesXattrBytes.Value()
	assert.Greater(t, newXattrBytes, preImportDocXattrBytes)

	err = collection.GetCollectionDatastore().Delete(docID)
	require.NoError(t, err)
	base.RequireWaitForStat(t, func() int64 {
		return rt.GetDatabase().DbStats.SharedBucketImport().ImportCount.Value()
	}, 2)

	newDocBytes = rt.GetDatabase().DbStats.Database().DocWritesBytes.Value()
	assert.Equal(t, preImportDocBytes, newDocBytes)
	// assert that doc xattr bytes have been written
	newXattrBytes = rt.GetDatabase().DbStats.Database().DocWritesXattrBytes.Value()
	assert.Greater(t, newXattrBytes, preImportDocXattrBytes)
}

// TestImportRollbackAllPartitions
// - start database (cbgt) with importPartitions