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

chore: remove log

This commit is contained in:
nathan 2023-11-08 17:33:47 +08:00
parent f1dad07caa
commit b4b8303bae
2 changed files with 12 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
libs/client-api/src/ws/client.rs
View File

@ -137,7 +137,6 @@ impl WSClient {
match msg { match msg {
RealtimeMessage::Collab(collab_msg) => { RealtimeMessage::Collab(collab_msg) => {
if let Some(channels) = weak_channels.upgrade() { if let Some(channels) = weak_channels.upgrade() {
info!("subscribe get: {}", collab_msg.object_id());
if let Some(channel) = channels.read().get(collab_msg.object_id()) { if let Some(channel) = channels.read().get(collab_msg.object_id()) {
match channel.upgrade() { match channel.upgrade() {
None => { None => {
@ -198,13 +197,14 @@ impl WSClient {
tokio::select! { tokio::select! {
_ = &mut stop_rx => break, _ = &mut stop_rx => break,
Ok(msg) = rx.recv() => { Ok(msg) = rx.recv() => {
trace!("[websocket]: send message with size:{}", msg.len());
// The maximum size allowed for a WebSocket message is 65,536 bytes. If the message exceeds // The maximum size allowed for a WebSocket message is 65,536 bytes. If the message exceeds
// 40,960 bytes (to avoid occupying the entire space), it should be sent over HTTP instead. // 40,960 bytes (to avoid occupying the entire space), it should be sent over HTTP instead.
if msg.is_binary() && msg.len() > 40960 { if msg.is_binary() && msg.len() > 40960 {
let len = msg.len();
trace!("[websocket]: send message with size:{}", len);
if let Some(http_sender) = weak_http_sender.upgrade() { if let Some(http_sender) = weak_http_sender.upgrade() {
match http_sender.send_ws_msg(&device_id, msg).await { match http_sender.send_ws_msg(&device_id, msg).await {
Ok(_) => debug!("WebSocket message sent via HTTP."), Ok(_) => debug!("WebSocket message sent via HTTP. len: {}", len),
Err(err) => error!("Failed to send WebSocket message over HTTP: {}", err), Err(err) => error!("Failed to send WebSocket message over HTTP: {}", err),
} }
} else { } else {

18
libs/realtime-entity/src/collab_msg.rs
View File

@ -163,38 +163,38 @@ impl Display for CollabMessage {
fn fmt(&self, f: &mut Formatter<'_>) -> std::fmt::Result { fn fmt(&self, f: &mut Formatter<'_>) -> std::fmt::Result {
match self { match self {
CollabMessage::ClientInit(value) => f.write_fmt(format_args!( CollabMessage::ClientInit(value) => f.write_fmt(format_args!(
"client init: [{}|oid:{}|msg_id:{}|payload_len:{}]", "client init: [{}|oid:{}|msg_id:{}|len:{}]",
value.origin, value.origin,
value.object_id, value.object_id,
value.msg_id, value.msg_id,
value.payload.len(), value.payload.len(),
)), )),
CollabMessage::ClientUpdateSync(value) => f.write_fmt(format_args!( CollabMessage::ClientUpdateSync(value) => f.write_fmt(format_args!(
"client update: [oid:{}|msg_id:{:?}|payload_len:{}]", "client update: [oid:{}|msg_id:{:?}|len:{}]",
value.object_id, value.object_id,
value.msg_id, value.msg_id,
value.payload.len(), value.payload.len(),
)), )),
CollabMessage::ClientUpdateAck(value) => f.write_fmt(format_args!( CollabMessage::ClientUpdateAck(value) => f.write_fmt(format_args!(
"ack: [oid:{}|msg_id:{:?}|payload_len:{}]", "ack: [oid:{}|msg_id:{:?}|len:{}]",
value.object_id, value.object_id,
value.msg_id, value.msg_id,
value.payload.len(), value.payload.len(),
)), )),
CollabMessage::ServerInit(value) => f.write_fmt(format_args!( CollabMessage::ServerInit(value) => f.write_fmt(format_args!(
"server init: [oid:{}|msg_id:{:?}|payload_len:{}]", "server init: [oid:{}|msg_id:{:?}|len:{}]",
value.object_id, value.object_id,
value.msg_id, value.msg_id,
value.payload.len(), value.payload.len(),
)), )),
CollabMessage::ServerBroadcast(value) => f.write_fmt(format_args!( CollabMessage::ServerBroadcast(value) => f.write_fmt(format_args!(
"server broadcast: [{}|oid:{}|payload_len:{}]", "server broadcast: [{}|oid:{}|len:{}]",
value.origin, value.origin,
value.object_id, value.object_id,
value.payload.len(), value.payload.len(),
)), )),
CollabMessage::ServerAwareness(value) => f.write_fmt(format_args!( CollabMessage::ServerAwareness(value) => f.write_fmt(format_args!(
"awareness: [oid:{}|payload_len:{}]", "awareness: [oid:{}|len:{}]",
value.object_id, value.object_id,
value.payload.len(), value.payload.len(),
)), )),
@ -324,7 +324,7 @@ impl From<ServerCollabInit> for CollabMessage {
impl Display for ServerCollabInit { impl Display for ServerCollabInit {
fn fmt(&self, f: &mut Formatter<'_>) -> std::fmt::Result { fn fmt(&self, f: &mut Formatter<'_>) -> std::fmt::Result {
f.write_fmt(format_args!( f.write_fmt(format_args!(
"server init: [uid:{:?}|oid:{}|msg_id:{:?}|payload_len:{}]", "server init: [uid:{:?}|oid:{}|msg_id:{:?}|len:{}]",
self.origin.client_user_id(), self.origin.client_user_id(),
self.object_id, self.object_id,
self.msg_id, self.msg_id,
@ -387,7 +387,7 @@ impl From<UpdateSync> for CollabMessage {
impl Display for UpdateSync { impl Display for UpdateSync {
fn fmt(&self, f: &mut Formatter<'_>) -> std::fmt::Result { fn fmt(&self, f: &mut Formatter<'_>) -> std::fmt::Result {
f.write_fmt(format_args!( f.write_fmt(format_args!(
"client update sync: [uid:{:?}|oid:{}|msg_id:{:?}|payload_len:{}]", "client update sync: [uid:{:?}|oid:{}|msg_id:{:?}|len:{}]",
self.origin.client_user_id(), self.origin.client_user_id(),
self.object_id, self.object_id,
self.msg_id, self.msg_id,
@ -424,7 +424,7 @@ impl From<UpdateAck> for CollabMessage {
impl Display for UpdateAck { impl Display for UpdateAck {
fn fmt(&self, f: &mut Formatter<'_>) -> std::fmt::Result { fn fmt(&self, f: &mut Formatter<'_>) -> std::fmt::Result {
f.write_fmt(format_args!( f.write_fmt(format_args!(
"client update ack: [uid:{:?}|oid:{}|msg_id:{:?}|payload_len:{}]", "client update ack: [uid:{:?}|oid:{}|msg_id:{:?}|len:{}]",
self.origin.client_user_id(), self.origin.client_user_id(),
self.object_id, self.object_id,
self.msg_id, self.msg_id,