feat: cargo fmt

Author: Alex Holmberg

src/server/bridge.rs

@@ -364,10 +364,12 @@ impl EventBridge {
             .await
             .take()
             .unwrap_or_else(|| "unknown".to_string());
-        self.emit(Event::StepFinished(syncable_ag_ui_core::StepFinishedEvent {
-            base: BaseEvent::with_current_timestamp(),
-            step_name,
-        }));
+        self.emit(Event::StepFinished(
+            syncable_ag_ui_core::StepFinishedEvent {
+                base: BaseEvent::with_current_timestamp(),
+                step_name,
+            },
+        ));
     }
 
     // =========================================================================

src/server/mod.rs

@@ -45,11 +45,11 @@ pub mod routes;
 use std::net::SocketAddr;
 use std::sync::Arc;
 
-use syncable_ag_ui_core::{Event, JsonValue, RunId, ThreadId};
 use axum::{
     Router,
     routing::{get, post},
 };
+use syncable_ag_ui_core::{Event, JsonValue, RunId, ThreadId};
 use tokio::sync::{RwLock, broadcast, mpsc};
 use tower_http::cors::{Any, CorsLayer};
 

src/server/processor.rs

@@ -18,13 +18,13 @@ use std::collections::HashMap;
 use std::path::PathBuf;
 use std::time::Instant;
 
-use syncable_ag_ui_core::{Role, RunId, ThreadId};
 use rig::client::{CompletionClient, ProviderClient};
 use rig::completion::Message as RigMessage;
 use rig::completion::Prompt;
 use rig::completion::message::{AssistantContent, UserContent};
 use rig::one_or_many::OneOrMany;
 use rig::providers::{anthropic, openai};
+use syncable_ag_ui_core::{Role, RunId, ThreadId};
 use tokio::sync::mpsc;
 use tracing::{debug, error, info, warn};
 
@@ -60,12 +60,12 @@ use crate::agent::tools::{
     WriteFilesTool,
 };
 
-use syncable_ag_ui_core::ToolCallId;
-use syncable_ag_ui_core::state::StateManager;
 use rig::agent::CancelSignal;
 use rig::completion::{CompletionModel, CompletionResponse, Message as RigPromptMessage};
 use serde::{Deserialize, Serialize};
 use std::sync::Arc;
+use syncable_ag_ui_core::ToolCallId;
+use syncable_ag_ui_core::state::StateManager;
 use tokio::sync::Mutex;
 
 /// Step status for generative UI progress display.
@@ -635,7 +635,10 @@ impl AgentProcessor {
     /// Extracts the user message content from RunAgentInput messages.
     ///
     /// Returns the last user message content, or None if no user messages.
-    fn extract_user_input(&self, messages: &[syncable_ag_ui_core::types::Message]) -> Option<String> {
+    fn extract_user_input(
+        &self,
+        messages: &[syncable_ag_ui_core::types::Message],
+    ) -> Option<String> {
         // Find the last user message and extract its content
         messages
             .iter()

src/server/routes.rs

@@ -367,7 +367,9 @@ fn convert_tools(raw_tools: Vec<serde_json::Value>) -> Vec<syncable_ag_ui_core::
 }
 
 /// Convert JSON context to AG-UI Context type
-fn convert_context(raw_context: Vec<serde_json::Value>) -> Vec<syncable_ag_ui_core::types::Context> {
+fn convert_context(
+    raw_context: Vec<serde_json::Value>,
+) -> Vec<syncable_ag_ui_core::types::Context> {
     raw_context
         .into_iter()
         .filter_map(|ctx| {
@@ -477,9 +479,9 @@ async fn handle_websocket(socket: WebSocket, state: ServerState) {
 #[cfg(test)]
 mod tests {
     use super::*;
+    use axum::extract::State;
     use syncable_ag_ui_core::types::Message as AgUiProtocolMessage;
     use syncable_ag_ui_core::{RunId, ThreadId};
-    use axum::extract::State;
 
     #[tokio::test]
     async fn test_health_endpoint() {