Function Test_resyncDocument

db/database_test.go:4035–4133

(t *testing.T)

}

func Test_resyncDocument(t *testing.T) {
	db, ctx := setupTestDB(t)
	defer db.Close(ctx)

	db.Options.EnableXattr = true
	collection, ctx := GetSingleDatabaseCollectionWithUser(ctx, t, db)

	testCases := []struct {
		name   string
		useHLV bool
	}{
		{
			name:   "pre 4.0",
			useHLV: false,
		},
		{
			name:   "has hlv",
			useHLV: true,
		},
	}

	for _, tc := range testCases {
		t.Run(tc.name, func(t *testing.T) {
			startingSyncFnCount := int(db.DbStats.Database().SyncFunctionCount.Value())
			syncFn := `
	function sync(doc, oldDoc){
		channel("channel." + "ABC");
	}
`
			_, err := collection.UpdateSyncFun(ctx, syncFn)
			require.NoError(t, err)

			docID := uuid.NewString()

			updateBody := make(map[string]any)
			updateBody["val"] = "value"
			if tc.useHLV {
				_, _, err := collection.Put(ctx, docID, updateBody)
				require.NoError(t, err)
			} else {
				collection.CreateDocNoHLV(t, ctx, docID, updateBody)
			}

			syncFn = `
		function sync(doc, oldDoc){
			channel("channel." + "ABC12332423234");
		}
	`
			_, err = collection.UpdateSyncFun(ctx, syncFn)
			require.NoError(t, err)

			preResyncDoc, err := collection.GetDocument(ctx, docID, DocUnmarshalAll)
			require.NoError(t, err)
			if !tc.useHLV {
				require.Nil(t, preResyncDoc.HLV)
			}
			_, _, err = collection.ResyncDocument(ctx, docID, realDocID(docID), false, []uint64{10})
			require.NoError(t, err)