Function TestAttachmentProcessError

db/attachment_compaction_test.go:649–686

(t *testing.T)

}

func TestAttachmentProcessError(t *testing.T) {
	if base.UnitTestUrlIsWalrus() {
		t.Skip("This test only works against Couchbase Server")
	}

	b := base.GetTestBucket(t).LeakyBucketClone(base.LeakyBucketConfig{
		SetXattrCallback: func(key string) error {
			return fmt.Errorf("some error")
		},
	})
	defer b.Close(base.TestCtx(t))

	testDB1, ctx1 := setupTestDBForBucketDefaultCollection(t, b)
	defer testDB1.Close(ctx1)

	collection, ctx1 := GetSingleDatabaseCollectionWithUser(ctx1, t, testDB1)
	CreateLegacyAttachmentDoc(t, ctx1, collection, "docID", []byte("{}"), "attKey", []byte("{}"))

	err := testDB1.AttachmentCompactionManager.Start(ctx1, map[string]interface{}{"database": testDB1})
	assert.NoError(t, err)

	var status AttachmentManagerResponse
	err = WaitForConditionWithOptions(t, func() bool {
		rawStatus, err := testDB1.AttachmentCompactionManager.GetStatus(ctx1)
		assert.NoError(t, err)
		err = base.JSONUnmarshal(rawStatus, &status)
		assert.NoError(t, err)

		if status.State == BackgroundProcessStateError {
			return true
		}

		return false
	}, 200, 1000)
	require.NoError(t, err)

	assert.Equal(t, status.State, BackgroundProcessStateError)
}

func TestAttachmentDifferentVBUUIDsBetweenPhases(t *testing.T) {
	if base.UnitTestUrlIsWalrus() {