|
@@ -149,7 +149,7 @@ where
|
|
pub async fn pong(&self, user: Arc<dyn RevisionUser>, client_rev_id: i64) -> Result<(), CollaborateError> {
|
|
pub async fn pong(&self, user: Arc<dyn RevisionUser>, client_rev_id: i64) -> Result<(), CollaborateError> {
|
|
let object_id = self.object_id.clone();
|
|
let object_id = self.object_id.clone();
|
|
let server_rev_id = self.rev_id();
|
|
let server_rev_id = self.rev_id();
|
|
- tracing::Span::current().record("server_rev_id", &server_rev_id);
|
|
|
|
|
|
+ tracing::Span::current().record("server_rev_id", server_rev_id);
|
|
match server_rev_id.cmp(&client_rev_id) {
|
|
match server_rev_id.cmp(&client_rev_id) {
|
|
Ordering::Less => {
|
|
Ordering::Less => {
|
|
tracing::trace!("Client should not send ping and the server should pull the revisions from the client")
|
|
tracing::trace!("Client should not send ping and the server should pull the revisions from the client")
|
|
@@ -171,7 +171,7 @@ where
|
|
#[tracing::instrument(level = "debug", skip(self, revisions), fields(object_id), err)]
|
|
#[tracing::instrument(level = "debug", skip(self, revisions), fields(object_id), err)]
|
|
pub async fn reset(&self, revisions: Vec<Revision>) -> Result<(), CollaborateError> {
|
|
pub async fn reset(&self, revisions: Vec<Revision>) -> Result<(), CollaborateError> {
|
|
let object_id = self.object_id.clone();
|
|
let object_id = self.object_id.clone();
|
|
- tracing::Span::current().record("object_id", &object_id.as_str());
|
|
|
|
|
|
+ tracing::Span::current().record("object_id", object_id.as_str());
|
|
let (_, rev_id) = pair_rev_id_from_revision_pbs(&revisions);
|
|
let (_, rev_id) = pair_rev_id_from_revision_pbs(&revisions);
|
|
let operations = make_operations_from_revisions(revisions.clone())?;
|
|
let operations = make_operations_from_revisions(revisions.clone())?;
|
|
self.persistence.reset_object(&object_id, revisions).await?;
|
|
self.persistence.reset_object(&object_id, revisions).await?;
|