github-mirrors/AppFlowy-Cloud
1
0
Fork 0
mirror of https://github.com/AppFlowy-IO/AppFlowy-Cloud.git synced 2025-04-19 03:24:42 -04:00
Code Issues Projects Releases Packages Wiki Activity

chore: add information about object id to log errors in apply update (#1315)

Browse source
This commit is contained in:
Bartosz Sypytkowski 2025-04-03 08:59:24 +02:00 • committed by GitHub
parent 0160be6ac6
commit ac834adc2f
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 6 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
services/appflowy-collaborate/src/group/group_init.rs
View file

@ -978,8 +978,9 @@ impl CollabPersister {
for (message_id, update) in updates {
i += 1;
let update: Update = update.into_update()?;
tx.apply_update(update)
.map_err(|err| RTProtocolError::YrsApplyUpdate(err.to_string()))?;
tx.apply_update(update).map_err(|err| {
RTProtocolError::YrsApplyUpdate(format!("collab {} - {}", self.object_id, err))
})?;
last_message_id = Some(message_id); //TODO: shouldn't this happen before decoding?
self.metrics.apply_update_count.inc();
}
@ -1030,10 +1031,9 @@ impl CollabPersister {
})
};
let collab = collab.as_mut().unwrap();
collab
.transact_mut()
.apply_update(update)
.map_err(|err| RTProtocolError::YrsApplyUpdate(err.to_string()))?;
collab.transact_mut().apply_update(update).map_err(|err| {
RTProtocolError::YrsApplyUpdate(format!("collab {} - {}", self.object_id, err))
})?;
last_message_id = Some(message_id); //TODO: shouldn't this happen before decoding?
self.metrics.apply_update_count.inc();
}