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

chore: fix snapshot s3 read and write

This commit is contained in:
Bartosz Sypytkowski 2024-12-17 18:22:20 +01:00
parent 24deac35a1
commit 6c2ce8fc3c
1 changed files with 2 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
services/appflowy-collaborate/src/group/group_init.rs
View File

@ -1145,16 +1145,13 @@ impl CollabPersister {
let sv = tx.state_vector().encode_v1(); let sv = tx.state_vector().encode_v1();
let doc_state_full = tx.encode_state_as_update_v1(&StateVector::default()); let doc_state_full = tx.encode_state_as_update_v1(&StateVector::default());
let full_len = doc_state_full.len(); let full_len = doc_state_full.len();
let encoded_collab = EncodedCollab::new_v1(sv.clone(), doc_state_full)
.encode_to_bytes()
.map_err(|err| RealtimeError::Internal(err.into()))?;
self self
.metrics .metrics
.full_collab_size .full_collab_size
.observe(encoded_collab.len() as f64); .observe(doc_state_full.len() as f64);
let params = InsertSnapshotParams { let params = InsertSnapshotParams {
object_id: self.object_id.clone(), object_id: self.object_id.clone(),
data: encoded_collab.into(), data: doc_state_full.into(),
workspace_id: self.workspace_id.clone(), workspace_id: self.workspace_id.clone(),
collab_type: self.collab_type.clone(), collab_type: self.collab_type.clone(),
}; };