From 8dfd9281a7ccdd7a8a202c20a1daacc7517b1dc0 Mon Sep 17 00:00:00 2001 From: Sam & Claude Date: Thu, 25 Jun 2026 18:37:33 +0200 Subject: [PATCH] =?UTF-8?q?chore:=20cargo=20fmt=20=E2=80=94=20fix=20pre-ex?= =?UTF-8?q?isting=20violations=20in=20store=20+=20multi-agent=20tests?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Pre-existing fmt violations from PRs #186 and #190: - crates/colibri-daemon/tests/multi_agent_board.rs (3 violations) - crates/colibri-store/src/lib.rs (1 violation) No code changes — pure formatting. (Sam & Claude) --- .../colibri-daemon/tests/multi_agent_board.rs | 17 ++++++++++------- crates/colibri-store/src/lib.rs | 9 +++++---- 2 files changed, 15 insertions(+), 11 deletions(-) diff --git a/crates/colibri-daemon/tests/multi_agent_board.rs b/crates/colibri-daemon/tests/multi_agent_board.rs index da162d4..7ab5052 100644 --- a/crates/colibri-daemon/tests/multi_agent_board.rs +++ b/crates/colibri-daemon/tests/multi_agent_board.rs @@ -279,11 +279,7 @@ async fn socket_rejects_double_claim_of_same_task() { .await; let b_id = b["data"]["id"].as_str().unwrap().to_string(); - let task = send_command( - &socket_path, - r#"{"cmd":"create-task","title":"contended"}"#, - ) - .await; + let task = send_command(&socket_path, r#"{"cmd":"create-task","title":"contended"}"#).await; let task_id = task["data"]["id"].as_str().unwrap().to_string(); // First claim wins. @@ -292,7 +288,10 @@ async fn socket_rejects_double_claim_of_same_task() { &format!(r#"{{"cmd":"claim-task","task_id":"{task_id}","agent_id":"{a_id}"}}"#), ) .await; - assert!(c1["ok"].as_bool().unwrap_or(false), "first claim should win: {c1}"); + assert!( + c1["ok"].as_bool().unwrap_or(false), + "first claim should win: {c1}" + ); // Second claim of the same task is rejected — not a silent steal. let c2 = send_command( @@ -300,7 +299,11 @@ async fn socket_rejects_double_claim_of_same_task() { &format!(r#"{{"cmd":"claim-task","task_id":"{task_id}","agent_id":"{b_id}"}}"#), ) .await; - assert_eq!(c2["ok"].as_bool(), Some(false), "second claim must be rejected: {c2}"); + assert_eq!( + c2["ok"].as_bool(), + Some(false), + "second claim must be rejected: {c2}" + ); // The task still belongs to the first agent. let claimed = send_command(&socket_path, r#"{"cmd":"list-tasks","status":"claimed"}"#).await; diff --git a/crates/colibri-store/src/lib.rs b/crates/colibri-store/src/lib.rs index 84c1f54..da86ae9 100644 --- a/crates/colibri-store/src/lib.rs +++ b/crates/colibri-store/src/lib.rs @@ -711,11 +711,12 @@ mod tests { #[test] fn test_claim_task_not_found() { let store = Store::open_memory().unwrap(); - let agent = store - .register_agent("a", serde_json::json!(["x"])) - .unwrap(); + let agent = store.register_agent("a", serde_json::json!(["x"])).unwrap(); let result = store.claim_task("nonexistent", &agent.id); - assert!(matches!(result, Err(StoreError::NotFound(_))), "got {result:?}"); + assert!( + matches!(result, Err(StoreError::NotFound(_))), + "got {result:?}" + ); } #[test]