From 27bdcf41b0f2ac4559322e7481860a0e71c0a158 Mon Sep 17 00:00:00 2001 From: Mikhail Mitrofanov Date: Mon, 5 Oct 2026 22:17:04 +0300 Subject: [PATCH] update compression level and logging compression time --- src/data_provider/web_api.rs | 10 +++++++--- 1 file changed, 7 insertions(+), 3 deletions(-) diff --git a/src/data_provider/web_api.rs b/src/data_provider/web_api.rs index 529a631..4a48c3a 100644 --- a/src/data_provider/web_api.rs +++ b/src/data_provider/web_api.rs @@ -3,8 +3,9 @@ use crate::notification::NotificationData::{ CompressError, OpenFileError, PermissionDenied, WebApiUnavailable, }; use crate::notification::{MaybeError, NotificationData}; -use log::info; +use log::{debug, info}; use std::io; +use std::time::Instant; use tokio::fs::{File, OpenOptions, remove_file}; use tokio::io::{AsyncReadExt, AsyncWriteExt}; use zstd::{DEFAULT_COMPRESSION_LEVEL, Decoder, Encoder}; @@ -37,10 +38,13 @@ pub async fn send_data(id: String) -> MaybeError { } fn compress(data: Vec) -> Result, NotificationData> { + let time = Instant::now(); let mut encoder = - Encoder::new(Vec::new(), DEFAULT_COMPRESSION_LEVEL).map_err(|_| CompressError)?; + Encoder::new(Vec::new(), 17).map_err(|_| CompressError)?; io::copy(&mut &data[..], &mut encoder).map_err(|_| PermissionDenied)?; - encoder.finish().map_err(|_| CompressError) + let result = encoder.finish().map_err(|_| CompressError); + debug!("Compress time: {:?}", time.elapsed()); + result } pub async fn load_data(id: String, temp: bool) -> MaybeError {