From aa4df32f6d3b53bec5e3715f5abfe4fb9079021b Mon Sep 17 00:00:00 2001 From: nathan Date: Thu, 4 Apr 2024 09:47:40 +0800 Subject: [PATCH] chore: update logs --- libs/client-api/src/collab_sync/collab_stream.rs | 5 +---- libs/collab-rt/src/collaborate/group_cmd.rs | 2 +- libs/collab-rt/src/collaborate/group_persistence.rs | 7 ++----- 3 files changed, 4 insertions(+), 10 deletions(-) diff --git a/libs/client-api/src/collab_sync/collab_stream.rs b/libs/client-api/src/collab_sync/collab_stream.rs index e09ea218..ef34f346 100644 --- a/libs/client-api/src/collab_sync/collab_stream.rs +++ b/libs/client-api/src/collab_sync/collab_stream.rs @@ -91,10 +91,7 @@ where let msg = match collab_message_result { Ok(msg) => msg, Err(err) => { - warn!( - "Stream error: {}, stop receive incoming changes", - err.into() - ); + warn!("Stream error:{}, stop receive incoming changes", err.into()); break; }, }; diff --git a/libs/collab-rt/src/collaborate/group_cmd.rs b/libs/collab-rt/src/collaborate/group_cmd.rs index c7d7a4fc..8be494f5 100644 --- a/libs/collab-rt/src/collaborate/group_cmd.rs +++ b/libs/collab-rt/src/collaborate/group_cmd.rs @@ -223,7 +223,7 @@ pub async fn forward_message_to_group( .stream_tx .send(RealtimeMessage::ClientCollabV2([pair].into())); if let Err(err) = err { - warn!("Send user:{} message to group error: {}", user.uid, err,); + warn!("Send user:{} message to group:{}", user.uid, err); client_msg_router.remove(user); } } diff --git a/libs/collab-rt/src/collaborate/group_persistence.rs b/libs/collab-rt/src/collaborate/group_persistence.rs index 92a1f142..e114f036 100644 --- a/libs/collab-rt/src/collaborate/group_persistence.rs +++ b/libs/collab-rt/src/collaborate/group_persistence.rs @@ -88,7 +88,7 @@ where } }, Err(err) => { - warn!("fail to encode collab {} error:{:?}", self.object_id, err); + warn!("fail to encode collab {}=>{:?}", self.object_id, err); }, } } @@ -127,10 +127,7 @@ where } }, Err(err) => { - warn!( - "attempt to encode collab {} error:{:?}", - self.object_id, err - ); + warn!("attempt to encode collab {}=>{:?}", self.object_id, err); }, }