From b20055293e5f7f95df4509b7888904ab7a0bd3ae Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?m=C3=BCde?= Date: Fri, 15 May 2026 00:14:49 +0200 Subject: [PATCH] fmt --- hive-c0re/src/broker.rs | 4 ++-- hive-c0re/src/dashboard.rs | 5 +---- 2 files changed, 3 insertions(+), 6 deletions(-) diff --git a/hive-c0re/src/broker.rs b/hive-c0re/src/broker.rs index dbff019..78d2810 100644 --- a/hive-c0re/src/broker.rs +++ b/hive-c0re/src/broker.rs @@ -56,8 +56,8 @@ impl Broker { std::fs::create_dir_all(parent) .with_context(|| format!("create db parent {}", parent.display()))?; } - let conn = Connection::open(path) - .with_context(|| format!("open broker db {}", path.display()))?; + let conn = + Connection::open(path).with_context(|| format!("open broker db {}", path.display()))?; conn.execute_batch(SCHEMA).context("apply broker schema")?; let (events, _) = broadcast::channel(EVENT_CHANNEL); Ok(Self { diff --git a/hive-c0re/src/dashboard.rs b/hive-c0re/src/dashboard.rs index 5f24bfa..d8e89d0 100644 --- a/hive-c0re/src/dashboard.rs +++ b/hive-c0re/src/dashboard.rs @@ -81,10 +81,7 @@ async fn messages_stream( Sse::new(stream).keep_alive(KeepAlive::default()) } -async fn post_approve( - State(state): State, - AxumPath(id): AxumPath, -) -> Response { +async fn post_approve(State(state): State, AxumPath(id): AxumPath) -> Response { match actions::approve(&state.coord, id).await { Ok(()) => Redirect::to("/").into_response(), Err(e) => error_response(&format!("approve {id} failed: {e:#}")),