diff --git a/core/archipelago/src/api/handler/mod.rs b/core/archipelago/src/api/handler/mod.rs index 5aa9d523..42c8f5c6 100644 --- a/core/archipelago/src/api/handler/mod.rs +++ b/core/archipelago/src/api/handler/mod.rs @@ -207,7 +207,11 @@ impl ApiHandler { hyper::Body::from(r#"{"error":"invalid backup id"}"#), )); } - let file = self.config.data_dir.join("backups").join(format!("{id}.bak")); + let file = self + .config + .data_dir + .join("backups") + .join(format!("{id}.bak")); match tokio::fs::read(&file).await { Ok(bytes) => Ok(Response::builder() .status(StatusCode::OK) diff --git a/core/archipelago/src/api/rpc/package/dependencies.rs b/core/archipelago/src/api/rpc/package/dependencies.rs index 7cb68cc2..6c0cd962 100644 --- a/core/archipelago/src/api/rpc/package/dependencies.rs +++ b/core/archipelago/src/api/rpc/package/dependencies.rs @@ -394,9 +394,9 @@ where // under any name variant AND no install in flight — waiting cannot // satisfy it. let some_dep_not_installed = missing.iter().any(|dep| { - !dep.containers.iter().any(|c| { - existing.iter().any(|e| e == c) || installing.iter().any(|i| i == c) - }) + !dep.containers + .iter() + .any(|c| existing.iter().any(|e| e == c) || installing.iter().any(|i| i == c)) }); if some_dep_not_installed { let msg = match check_install_deps(package_id, &running) { diff --git a/core/archipelago/src/api/rpc/package/install.rs b/core/archipelago/src/api/rpc/package/install.rs index 90245ae5..88a21eb4 100644 --- a/core/archipelago/src/api/rpc/package/install.rs +++ b/core/archipelago/src/api/rpc/package/install.rs @@ -1140,8 +1140,7 @@ impl RpcHandler { std::sync::atomic::Ordering::Relaxed, ); if let Some((downloaded, total)) = parse_pull_progress(&line) { - Self::update_install_progress(&state_mgr, &pkg_id, downloaded, total) - .await; + Self::update_install_progress(&state_mgr, &pkg_id, downloaded, total).await; } } }); diff --git a/core/archipelago/src/api/rpc/package/stacks.rs b/core/archipelago/src/api/rpc/package/stacks.rs index 3fa5f3ee..85e3f1aa 100644 --- a/core/archipelago/src/api/rpc/package/stacks.rs +++ b/core/archipelago/src/api/rpc/package/stacks.rs @@ -700,9 +700,7 @@ async fn install_stack_via_orchestrator( // Truthful end-of-install signal, mirroring the legacy stack installers: // the real readiness gate is the scanner's next sweep, this just settles // the bar at 95→100→done instead of leaving it mid-band. - handler - .set_install_progress(stack_name, total, total) - .await; + handler.set_install_progress(stack_name, total, total).await; handler .set_install_phase(stack_name, InstallPhase::PostInstall) .await; diff --git a/core/archipelago/src/backup/full.rs b/core/archipelago/src/backup/full.rs index 2eceef7b..06852f86 100644 --- a/core/archipelago/src/backup/full.rs +++ b/core/archipelago/src/backup/full.rs @@ -763,7 +763,9 @@ mod tests { let meta = create_full_backup(dir.path(), "pass", None).await.unwrap(); std::fs::remove_dir_all(dir.path().join("secrets")).unwrap(); - restore_full_backup(dir.path(), &meta.id, "pass").await.unwrap(); + restore_full_backup(dir.path(), &meta.id, "pass") + .await + .unwrap(); let pw = std::fs::read_to_string(dir.path().join("secrets/lnd-wallet-password")).unwrap(); assert_eq!(pw, "s3cret"); @@ -784,7 +786,9 @@ mod tests { std::fs::create_dir_all(dir.path().join("secrets")).unwrap(); std::fs::write(dir.path().join("secrets/lnd-wallet-password"), "keep-me").unwrap(); - restore_full_backup(dir.path(), &meta.id, "pass").await.unwrap(); + restore_full_backup(dir.path(), &meta.id, "pass") + .await + .unwrap(); let pw = std::fs::read_to_string(dir.path().join("secrets/lnd-wallet-password")).unwrap(); assert_eq!(pw, "keep-me");