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

chore: log (#258)

This commit is contained in:
Nathan.fooo 2024-01-15 04:04:09 +08:00 committed by GitHub
parent 615b402782
commit 5a353856af
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 7 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
libs/client-api/src/http.rs
View File

@ -806,6 +806,7 @@ impl Client {
.collect();
let mut framed_data = Vec::new();
let mut size_count = 0;
for task in compression_tasks {
let compressed = task.await??;
// The length of a u32 in bytes is 4. The server uses a u32 to read the size of each data frame,
@ -816,7 +817,13 @@ impl Client {
let size = compressed.len() as u32;
framed_data.extend_from_slice(&size.to_be_bytes());
framed_data.extend_from_slice(&compressed);
size_count += size;
}
event!(
tracing::Level::INFO,
"create batch collab with size: {}",
size_count
);
let body = Body::wrap_stream(stream::once(async { Ok::<_, AppError>(framed_data) }));
let resp = self
.http_client_with_auth_compress(Method::POST, &url)