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