Function Test_getUpdatedDocument

db/database_test.go:4135–4197

(t *testing.T)

}

func Test_getUpdatedDocument(t *testing.T) {
	t.Run("Non Sync document is not processed", func(t *testing.T) {
		db, ctx := setupTestDB(t)
		defer db.Close(ctx)

		docID := "testDoc"

		body := `{"val": "nonsyncdoc"}`
		added, err := db.Bucket.DefaultDataStore().AddRaw(docID, 0, []byte(body))
		require.NoError(t, err)
		assert.True(t, added)

		raw, _, err := db.Bucket.DefaultDataStore().GetRaw(docID)
		require.NoError(t, err)
		doc, err := unmarshalDocument(docID, raw)
		require.NoError(t, err)

		collection, ctx := GetSingleDatabaseCollectionWithUser(ctx, t, db)
		_, _, _, _, _, err = collection.getResyncedDocument(ctx, doc, false, []uint64{})
		assert.Equal(t, base.ErrUpdateCancel, err)
	})

	t.Run("Sync Document", func(t *testing.T) {
		db, ctx := setupTestDB(t)
		defer db.Close(ctx)
		collection, ctx := GetSingleDatabaseCollectionWithUser(ctx, t, db)
		syncFn := `
	function sync(doc, oldDoc){
		channel("channel." + "ABC");
	}
`
		_, err := collection.UpdateSyncFun(ctx, syncFn)
		require.NoError(t, err)

		docID := uuid.NewString()
		updateBody := make(map[string]interface{})
		updateBody["val"] = "value"
		_, doc, err := collection.Put(ctx, docID, updateBody)
		require.NoError(t, err)
		assert.NotNil(t, doc)

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

		updatedDoc, shouldUpdate, _, highSeq, _, err := collection.getResyncedDocument(ctx, doc, false, []uint64{})
		require.NoError(t, err)
		assert.True(t, shouldUpdate)
		assert.Equal(t, doc.Sequence, highSeq)
		assert.Equal(t, 2, int(db.DbStats.Database().SyncFunctionCount.Value()))

		// Rerunning same resync function should mark doc not to be updated
		_, shouldUpdate, _, _, _, err = collection.getResyncedDocument(ctx, updatedDoc, false, []uint64{})
		require.NoError(t, err)