chk
/
AppFlowy-Cloud
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

chore: fix build

This commit is contained in:
nathan 2024-09-12 00:46:20 +08:00
parent 1ccff73e49
commit 96896101d4
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
services/appflowy-history/src/biz/history.rs
View File

@ -1,13 +1,13 @@
use anyhow::anyhow; use anyhow::anyhow;
use collab::core::collab_plugin::CollabPluginType;
use collab::lock::RwLock; use collab::lock::RwLock;
use collab::preclude::updates::encoder::{Encoder, EncoderV2}; use collab::preclude::updates::encoder::{Encoder, EncoderV2};
use collab::preclude::{Collab, CollabPlugin, ReadTxn, Snapshot, StateVector, TransactionMut}; use collab::preclude::{Collab, CollabPlugin, ReadTxn, Snapshot, StateVector, TransactionMut};
use collab_entity::CollabType; use collab_entity::CollabType;
use database::history::ops::get_snapshot_meta_list;
use serde_json::Value; use serde_json::Value;
use sqlx::PgPool; use sqlx::PgPool;
use std::sync::Arc; use std::sync::Arc;
use database::history::ops::get_snapshot_meta_list;
use tonic_proto::history::{RepeatedSnapshotMetaPb, SnapshotMetaPb}; use tonic_proto::history::{RepeatedSnapshotMetaPb, SnapshotMetaPb};
use crate::biz::snapshot::{ use crate::biz::snapshot::{
@ -167,6 +167,10 @@ impl CollabPlugin for CountUpdatePlugin {
fn receive_update(&self, _object_id: &str, txn: &TransactionMut, _update: &[u8]) { fn receive_update(&self, _object_id: &str, txn: &TransactionMut, _update: &[u8]) {
self.snapshot_generator.did_apply_update(txn); self.snapshot_generator.did_apply_update(txn);
} }
fn plugin_type(&self) -> CollabPluginType {
CollabPluginType::Other("CountUpdatePlugin".to_string())
}
} }
pub async fn get_snapshots( pub async fn get_snapshots(