Function TestImportStampClusterUUID

db/import_test.go:823–870

(t *testing.T)

}

func TestImportStampClusterUUID(t *testing.T) {
	if !base.TestUseXattrs() {
		t.Skip("This test only works with XATTRS enabled")
	}
	if base.UnitTestUrlIsWalrus() {
		t.Skip("This test requires Couchbase Server") // no cluster UUIDs in Walrus
	}

	db, ctx := setupTestDB(t)
	defer db.Close(ctx)

	collection, ctx := GetSingleDatabaseCollectionWithUser(ctx, t, db)

	key := "doc1"
	bodyBytes := rawDocNoMeta()

	_, err := collection.dataStore.Add(key, 0, bodyBytes)
	require.NoError(t, err)

	_, cas, err := collection.dataStore.GetRaw(key)
	require.NoError(t, err)

	xattrs, _, err := collection.dataStore.GetXattrs(ctx, key, []string{base.VirtualXattrRevSeqNo})
	require.NoError(t, err)
	docXattr, ok := xattrs[base.VirtualXattrRevSeqNo]
	require.True(t, ok)
	revSeqNo := RetrieveDocRevSeqNo(t, docXattr)

	base.SetUpTestLogging(t, base.LevelDebug, base.KeyCRUD, base.KeyMigrate, base.KeyImport)

	body := Body{}
	err = body.Unmarshal(rawDocNoMeta())
	require.NoError(t, err)
	existingDoc := &sgbucket.BucketDocument{Body: bodyBytes, Cas: cas}

	importedDoc, err := collection.importDoc(ctx, key, body, nil, false, revSeqNo, existingDoc, ImportOnDemand)
	require.NoError(t, err)
	if assert.NotNil(t, importedDoc) {
		require.Len(t, importedDoc.ClusterUUID, 32)
	}

	xattrs, _, err = collection.dataStore.GetXattrs(ctx, key, []string{base.SyncXattrName})
	require.NoError(t, err)
	require.Contains(t, xattrs, base.SyncXattrName)
	var xattr map[string]any
	require.NoError(t, base.JSONUnmarshal(xattrs[base.SyncXattrName], &xattr))
	require.Len(t, xattr["cluster_uuid"].(string), 32)
}

// TestImporNonZeroStart makes sure docs written before sync gateway start get imported
func TestImportNonZeroStart(t *testing.T) {