From 275d3e77918992cd3a4ace9ff5e0ccf8396992ef Mon Sep 17 00:00:00 2001 From: Chummy Date: Thu, 19 Feb 2026 14:47:08 +0800 Subject: [PATCH] style: apply rustfmt to async fs updates --- src/cron/scheduler.rs | 4 +++- src/skills/symlink_tests.rs | 8 ++++++-- src/tools/browser.rs | 6 +++--- src/tools/cron_add.rs | 8 ++++++-- src/tools/cron_list.rs | 4 +++- src/tools/cron_remove.rs | 4 +++- src/tools/cron_run.rs | 4 +++- src/tools/cron_runs.rs | 4 +++- src/tools/cron_update.rs | 8 ++++++-- src/tools/schedule.rs | 8 ++++++-- src/tools/shell.rs | 3 ++- 11 files changed, 44 insertions(+), 17 deletions(-) diff --git a/src/cron/scheduler.rs b/src/cron/scheduler.rs index 45bb38b..6bf1355 100644 --- a/src/cron/scheduler.rs +++ b/src/cron/scheduler.rs @@ -481,7 +481,9 @@ mod tests { config_path: tmp.path().join("config.toml"), ..Config::default() }; - tokio::fs::create_dir_all(&config.workspace_dir).await.unwrap(); + tokio::fs::create_dir_all(&config.workspace_dir) + .await + .unwrap(); config } diff --git a/src/skills/symlink_tests.rs b/src/skills/symlink_tests.rs index fa2c046..da50891 100644 --- a/src/skills/symlink_tests.rs +++ b/src/skills/symlink_tests.rs @@ -18,7 +18,9 @@ mod tests { { let source_dir = tmp.path().join("source_skill"); tokio::fs::create_dir_all(&source_dir).await.unwrap(); - tokio::fs::write(source_dir.join("SKILL.md"), "# Test Skill\nContent").await.unwrap(); + tokio::fs::write(source_dir.join("SKILL.md"), "# Test Skill\nContent") + .await + .unwrap(); let dest_link = skills_path.join("linked_skill"); @@ -94,7 +96,9 @@ mod tests { // Test case: Symlink outside workspace should be allowed (user responsibility) let outside_dir = tmp.path().join("outside_skill"); tokio::fs::create_dir_all(&outside_dir).await.unwrap(); - tokio::fs::write(outside_dir.join("SKILL.md"), "# Outside Skill\nContent").await.unwrap(); + tokio::fs::write(outside_dir.join("SKILL.md"), "# Outside Skill\nContent") + .await + .unwrap(); let dest_link = skills_path.join("outside_skill"); let result = std::os::unix::fs::symlink(&outside_dir, &dest_link); diff --git a/src/tools/browser.rs b/src/tools/browser.rs index 2c057ca..55251d7 100644 --- a/src/tools/browser.rs +++ b/src/tools/browser.rs @@ -1225,9 +1225,9 @@ mod native_backend { }); if let Some(path_str) = path { - tokio::fs::write(&path_str, &png).await.with_context(|| { - format!("Failed to write screenshot to {path_str}") - })?; + tokio::fs::write(&path_str, &png) + .await + .with_context(|| format!("Failed to write screenshot to {path_str}"))?; payload["path"] = Value::String(path_str); } else { payload["png_base64"] = diff --git a/src/tools/cron_add.rs b/src/tools/cron_add.rs index fda5edf..a0847b5 100644 --- a/src/tools/cron_add.rs +++ b/src/tools/cron_add.rs @@ -223,7 +223,9 @@ mod tests { config_path: tmp.path().join("config.toml"), ..Config::default() }; - tokio::fs::create_dir_all(&config.workspace_dir).await.unwrap(); + tokio::fs::create_dir_all(&config.workspace_dir) + .await + .unwrap(); Arc::new(config) } @@ -262,7 +264,9 @@ mod tests { }; config.autonomy.allowed_commands = vec!["echo".into()]; config.autonomy.level = AutonomyLevel::Supervised; - tokio::fs::create_dir_all(&config.workspace_dir).await.unwrap(); + tokio::fs::create_dir_all(&config.workspace_dir) + .await + .unwrap(); let cfg = Arc::new(config); let tool = CronAddTool::new(cfg.clone(), test_security(&cfg)); diff --git a/src/tools/cron_list.rs b/src/tools/cron_list.rs index 6ae1ac3..d83855f 100644 --- a/src/tools/cron_list.rs +++ b/src/tools/cron_list.rs @@ -69,7 +69,9 @@ mod tests { config_path: tmp.path().join("config.toml"), ..Config::default() }; - tokio::fs::create_dir_all(&config.workspace_dir).await.unwrap(); + tokio::fs::create_dir_all(&config.workspace_dir) + .await + .unwrap(); Arc::new(config) } diff --git a/src/tools/cron_remove.rs b/src/tools/cron_remove.rs index e19edab..5249212 100644 --- a/src/tools/cron_remove.rs +++ b/src/tools/cron_remove.rs @@ -82,7 +82,9 @@ mod tests { config_path: tmp.path().join("config.toml"), ..Config::default() }; - tokio::fs::create_dir_all(&config.workspace_dir).await.unwrap(); + tokio::fs::create_dir_all(&config.workspace_dir) + .await + .unwrap(); Arc::new(config) } diff --git a/src/tools/cron_run.rs b/src/tools/cron_run.rs index edfe402..ad77344 100644 --- a/src/tools/cron_run.rs +++ b/src/tools/cron_run.rs @@ -113,7 +113,9 @@ mod tests { config_path: tmp.path().join("config.toml"), ..Config::default() }; - tokio::fs::create_dir_all(&config.workspace_dir).await.unwrap(); + tokio::fs::create_dir_all(&config.workspace_dir) + .await + .unwrap(); Arc::new(config) } diff --git a/src/tools/cron_runs.rs b/src/tools/cron_runs.rs index eb5fdfb..649b10f 100644 --- a/src/tools/cron_runs.rs +++ b/src/tools/cron_runs.rs @@ -127,7 +127,9 @@ mod tests { config_path: tmp.path().join("config.toml"), ..Config::default() }; - tokio::fs::create_dir_all(&config.workspace_dir).await.unwrap(); + tokio::fs::create_dir_all(&config.workspace_dir) + .await + .unwrap(); Arc::new(config) } diff --git a/src/tools/cron_update.rs b/src/tools/cron_update.rs index 26ca21e..d8df72d 100644 --- a/src/tools/cron_update.rs +++ b/src/tools/cron_update.rs @@ -117,7 +117,9 @@ mod tests { config_path: tmp.path().join("config.toml"), ..Config::default() }; - tokio::fs::create_dir_all(&config.workspace_dir).await.unwrap(); + tokio::fs::create_dir_all(&config.workspace_dir) + .await + .unwrap(); Arc::new(config) } @@ -156,7 +158,9 @@ mod tests { ..Config::default() }; config.autonomy.allowed_commands = vec!["echo".into()]; - tokio::fs::create_dir_all(&config.workspace_dir).await.unwrap(); + tokio::fs::create_dir_all(&config.workspace_dir) + .await + .unwrap(); let cfg = Arc::new(config); let job = cron::add_job(&cfg, "*/5 * * * *", "echo ok").unwrap(); let tool = CronUpdateTool::new(cfg.clone(), test_security(&cfg)); diff --git a/src/tools/schedule.rs b/src/tools/schedule.rs index 9270e1c..fcf46fe 100644 --- a/src/tools/schedule.rs +++ b/src/tools/schedule.rs @@ -375,7 +375,9 @@ mod tests { config_path: tmp.path().join("config.toml"), ..Config::default() }; - tokio::fs::create_dir_all(&config.workspace_dir).await.unwrap(); + tokio::fs::create_dir_all(&config.workspace_dir) + .await + .unwrap(); let security = Arc::new(SecurityPolicy::from_config( &config.autonomy, &config.workspace_dir, @@ -489,7 +491,9 @@ mod tests { }, ..Config::default() }; - tokio::fs::create_dir_all(&config.workspace_dir).await.unwrap(); + tokio::fs::create_dir_all(&config.workspace_dir) + .await + .unwrap(); let security = Arc::new(SecurityPolicy::from_config( &config.autonomy, &config.workspace_dir, diff --git a/src/tools/shell.rs b/src/tools/shell.rs index 9574cd5..f06c543 100644 --- a/src/tools/shell.rs +++ b/src/tools/shell.rs @@ -363,7 +363,8 @@ mod tests { .unwrap(); assert!(allowed.success); - let _ = tokio::fs::remove_file(std::env::temp_dir().join("zeroclaw_shell_approval_test")).await; + let _ = + tokio::fs::remove_file(std::env::temp_dir().join("zeroclaw_shell_approval_test")).await; } // ── §5.2 Shell timeout enforcement tests ─────────────────