Ryan/drop-app
1
0
Fork 0
mirror of https://github.com/Drop-OSS/drop-app.git synced 2026-06-22 04:11:37 +10:00
Code Issues Packages Projects Releases Wiki Activity

add more log messages

Browse Source
This commit is contained in:
DecDuck
2026-04-16 15:42:32 +10:00
parent c9ceb3f50e
commit a836ea0454
1 changed files with 5 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src-tauri/download_manager/src/depot_manager.rs
+5
View File
@@ -62,11 +62,13 @@ impl DepotManager {
} }
async fn sync_depot(&self, depot: &mut Depot) -> Result<(), RemoteAccessError> { async fn sync_depot(&self, depot: &mut Depot) -> Result<(), RemoteAccessError> {
info!("requesting manifest.json");
let manifest_url = Url::parse(&depot.endpoint)?.join("manifest.json")?; let manifest_url = Url::parse(&depot.endpoint)?.join("manifest.json")?;
let manifest = DROP_CLIENT_ASYNC.get(manifest_url).send().await?; let manifest = DROP_CLIENT_ASYNC.get(manifest_url).send().await?;
let manifest: DepotManifest = manifest.json().await?; let manifest: DepotManifest = manifest.json().await?;
depot.manifest.replace(manifest); depot.manifest.replace(manifest);
info!("running speedtest...");
let speedtest_url = Url::parse(&depot.endpoint)?.join("speedtest")?; let speedtest_url = Url::parse(&depot.endpoint)?.join("speedtest")?;
let speedtest = DROP_CLIENT_ASYNC.get(speedtest_url).send().await?; let speedtest = DROP_CLIENT_ASYNC.get(speedtest_url).send().await?;
@@ -74,7 +76,9 @@ impl DepotManager {
let start = Instant::now(); let start = Instant::now();
let mut total_length = 0; let mut total_length = 0;
info!("streaming speedtest...");
while let Some(chunk) = stream.next().await { while let Some(chunk) = stream.next().await {
info!("total length: {}", total_length);
let length = chunk?.len(); let length = chunk?.len();
total_length += length; total_length += length;
if SPEEDTEST_TIMEOUT <= start.elapsed() { if SPEEDTEST_TIMEOUT <= start.elapsed() {
@@ -84,6 +88,7 @@ impl DepotManager {
let elapsed = start.elapsed().as_millis() as usize; let elapsed = start.elapsed().as_millis() as usize;
let speed = total_length.checked_div(elapsed).unwrap_or(usize::MAX); let speed = total_length.checked_div(elapsed).unwrap_or(usize::MAX);
info!("speed: {}", speed);
depot.latest_speed.replace(speed); depot.latest_speed.replace(speed);
Ok(()) Ok(())