cargo fmt

Author: calebbourg

service/src/lib.rs

@@ -32,7 +32,11 @@ pub struct AppState {
 }
 
 impl AppState {
-    pub fn new(app_config: Config, db: &Arc<DatabaseConnection>, sse_manager: Arc<sse::Manager>) -> Self {
+    pub fn new(
+        app_config: Config,
+        db: &Arc<DatabaseConnection>,
+        sse_manager: Arc<sse::Manager>,
+    ) -> Self {
         Self {
             database_connection: Arc::clone(db),
             config: app_config,

sse-test-client/src/api_client.rs

@@ -57,11 +57,7 @@ impl ApiClient {
         })
     }
 
-    async fn get_user_organizations(
-        &self,
-        session_cookie: &str,
-        user_id: &str,
-    ) -> Result<Value> {
+    async fn get_user_organizations(&self, session_cookie: &str, user_id: &str) -> Result<Value> {
         let url = format!("{}/users/{}/organizations", self.base_url, user_id);
 
         let response = self
@@ -75,8 +71,15 @@ impl ApiClient {
 
         if !response.status().is_success() {
             let status = response.status();
-            let body = response.text().await.unwrap_or_else(|_| "Unable to read response body".to_string());
-            anyhow::bail!("Failed to get organizations: {} - Response: {}", status, body);
+            let body = response
+                .text()
+                .await
+                .unwrap_or_else(|_| "Unable to read response body".to_string());
+            anyhow::bail!(
+                "Failed to get organizations: {} - Response: {}",
+                status,
+                body
+            );
         }
 
         let api_response: Value = response.json().await.context("Failed to parse response")?;

sse-test-client/src/auth.rs

@@ -63,7 +63,10 @@ pub async fn login(
 
     if !response.status().is_success() {
         let status = response.status();
-        let body = response.text().await.unwrap_or_else(|_| "Unable to read response body".to_string());
+        let body = response
+            .text()
+            .await
+            .unwrap_or_else(|_| "Unable to read response body".to_string());
         anyhow::bail!("Login failed: {} - Response: {}", status, body);
     }
 

sse-test-client/src/main.rs

@@ -151,30 +151,18 @@ async fn main() -> Result<()> {
 
     match cli.scenario {
         ScenarioChoice::ConnectionTest => {
-            results.push(
-                scenarios::test_connection(
-                    &user1,
-                    &user2,
-                    &mut sse1,
-                    &mut sse2,
-                )
-                .await?,
-            );
+            results.push(scenarios::test_connection(&user1, &user2, &mut sse1, &mut sse2).await?);
         }
         ScenarioChoice::ForceLogoutTest => {
             results.push(
-                scenarios::test_force_logout(
-                    &user1,
-                    &user2,
-                    &api_client,
-                    &mut sse1,
-                    &mut sse2,
-                )
-                .await?,
+                scenarios::test_force_logout(&user1, &user2, &api_client, &mut sse1, &mut sse2)
+                    .await?,
             );
         }
         ScenarioChoice::ActionCreate => {
-            let env = test_env.as_ref().expect("Test environment required for ActionCreate");
+            let env = test_env
+                .as_ref()
+                .expect("Test environment required for ActionCreate");
             results.push(
                 scenarios::test_action_create(
                     &user1,
@@ -188,7 +176,9 @@ async fn main() -> Result<()> {
             );
         }
         ScenarioChoice::ActionUpdate => {
-            let env = test_env.as_ref().expect("Test environment required for ActionUpdate");
+            let env = test_env
+                .as_ref()
+                .expect("Test environment required for ActionUpdate");
             results.push(
                 scenarios::test_action_update(
                     &user1,
@@ -202,7 +192,9 @@ async fn main() -> Result<()> {
             );
         }
         ScenarioChoice::ActionDelete => {
-            let env = test_env.as_ref().expect("Test environment required for ActionDelete");
+            let env = test_env
+                .as_ref()
+                .expect("Test environment required for ActionDelete");
             results.push(
                 scenarios::test_action_delete(
                     &user1,
@@ -216,26 +208,14 @@ async fn main() -> Result<()> {
             );
         }
         ScenarioChoice::All => {
+            results.push(scenarios::test_connection(&user1, &user2, &mut sse1, &mut sse2).await?);
             results.push(
-                scenarios::test_connection(
-                    &user1,
-                    &user2,
-                    &mut sse1,
-                    &mut sse2,
-                )
-                .await?,
-            );
-            results.push(
-                scenarios::test_force_logout(
-                    &user1,
-                    &user2,
-                    &api_client,
-                    &mut sse1,
-                    &mut sse2,
-                )
-                .await?,
+                scenarios::test_force_logout(&user1, &user2, &api_client, &mut sse1, &mut sse2)
+                    .await?,
             );
-            let env = test_env.as_ref().expect("Test environment required for All scenarios");
+            let env = test_env
+                .as_ref()
+                .expect("Test environment required for All scenarios");
             results.push(
                 scenarios::test_action_create(
                     &user1,

sse-test-client/src/scenarios.rs

@@ -300,7 +300,10 @@ pub async fn test_connection(
     );
 
     // Wait a bit to ensure connections are stable
-    println!("{} Waiting 2 seconds to verify connections stay alive...", "→".blue());
+    println!(
+        "{} Waiting 2 seconds to verify connections stay alive...",
+        "→".blue()
+    );
     tokio::time::sleep(Duration::from_secs(2)).await;
 
     println!("{} Connections remain stable", "✓".green());
@@ -313,4 +316,3 @@ pub async fn test_connection(
         duration: start.elapsed(),
     })
 }
-

sse/src/connection.rs

@@ -63,7 +63,10 @@ impl ConnectionRegistry {
         // Insert into primary storage
         self.connections.insert(
             connection_id.clone(),
-            ConnectionInfo { user_id: user_id.clone(), sender },
+            ConnectionInfo {
+                user_id: user_id.clone(),
+                sender,
+            },
         );
 
         // Update secondary index

sse/src/manager.rs

@@ -32,10 +32,7 @@ impl Manager {
 
     /// Unregister a connection by ID
     pub fn unregister_connection(&self, connection_id: &ConnectionId) {
-        debug!(
-            "Unregistering SSE connection {}",
-            connection_id.as_str()
-        );
+        debug!("Unregistering SSE connection {}", connection_id.as_str());
         self.registry.unregister(connection_id);
     }
 

web/src/sse/handler.rs

@@ -19,7 +19,9 @@ pub(crate) async fn sse_handler(
     let (tx, mut rx) = mpsc::unbounded_channel();
 
     // Register returns the connection_id (convert domain::Id to String)
-    let connection_id = app_state.sse_manager.register_connection(user.id.to_string(), tx);
+    let connection_id = app_state
+        .sse_manager
+        .register_connection(user.id.to_string(), tx);
 
     let manager = app_state.sse_manager.clone();
     let user_id = user.id;