style: apply rustfmt to http + cli modules

Pure formatting normalization (line wrapping, trailing blank lines) of
pre-existing drift, surfaced when rustfmt resolved these submodules. No
behavior change.

Author: radicalkjax

crates/transport-cli/src/commands/oauth.rs

@@ -428,7 +428,10 @@ pub async fn run(
                 // HTTP config endpoint serves). Secret VALUES are
                 // deliberately omitted — `configured` already conveys
                 // their presence.
-                let summaries = registry.oauth.provider_summaries(&std::collections::HashMap::new()).await;
+                let summaries = registry
+                    .oauth
+                    .provider_summaries(&std::collections::HashMap::new())
+                    .await;
                 out.emit(&serde_json::json!({ "providers": summaries }))?;
                 Ok(())
             }
@@ -437,19 +440,16 @@ pub async fn run(
                 client_id,
                 client_secret_from,
             } => {
-                let secret = crate::secret_input::read_optional_secret(
-                    client_secret_from,
-                    "client secret",
-                )?;
+                let secret =
+                    crate::secret_input::read_optional_secret(client_secret_from, "client secret")?;
                 registry
                     .oauth
-                    .set_provider_credentials(
-                        &provider,
-                        client_id,
-                        secret.map(|s| s.to_string()),
-                    )
+                    .set_provider_credentials(&provider, client_id, secret.map(|s| s.to_string()))
                     .await?;
-                let summaries = registry.oauth.provider_summaries(&std::collections::HashMap::new()).await;
+                let summaries = registry
+                    .oauth
+                    .provider_summaries(&std::collections::HashMap::new())
+                    .await;
                 out.emit(&serde_json::json!({ "providers": summaries }))?;
                 Ok(())
             }

crates/transport-cli/src/commands/system.rs

@@ -242,8 +242,7 @@ pub async fn run(
             url,
             stream_key_from,
         } => {
-            let stream_key =
-                crate::secret_input::read_secret(stream_key_from, "Stream key")?;
+            let stream_key = crate::secret_input::read_secret(stream_key_from, "Stream key")?;
             let result =
                 spiritstream_core::commands::test_rtmp_target(url, stream_key.to_string())?;
             out.emit(&result)?;

crates/transport-http/src/chat_lifecycle/reconnect.rs

@@ -13,7 +13,9 @@
 //! activation) passes `false` so a genuinely-dead sign-in doesn't churn the
 //! connection on every save.
 
-use spiritstream_core::models::{ChatConnectionStatus, ChatPlatform, ChatSettings, ProfileSettings};
+use spiritstream_core::models::{
+    ChatConnectionStatus, ChatPlatform, ChatSettings, ProfileSettings,
+};
 
 use crate::AppState;
 

crates/transport-http/src/chat_lifecycle/youtube.rs

@@ -200,8 +200,7 @@ pub(crate) async fn connect_youtube_chat(
                 // is the actionable message ("go live first" / "quota
                 // exhausted"), not the opaque "internal error".
                 let reason = connect_failure_reason(&e);
-                let calm =
-                    youtube_status(state).await == Some(ChatConnectionStatus::Disconnected);
+                let calm = youtube_status(state).await == Some(ChatConnectionStatus::Disconnected);
                 let quota = reason.to_lowercase().contains("quota");
                 // Only the not-live registration lag is worth a bounded retry;
                 // retrying an exhausted quota just burns more of it.

crates/transport-http/src/lib/static_ui.rs

@@ -111,7 +111,6 @@ pub(crate) fn loading_page_style_csp_hash() -> String {
     )
 }
 
-
 /// Mount `/`, `/index.html`, and the asset fallback when UI serving is
 /// enabled and the bundle directory exists.
 pub(crate) fn mount_static_ui(

crates/transport-http/src/middleware.rs

@@ -114,10 +114,7 @@ pub(crate) fn client_ip(
     if trusted.is_empty() || !trusted.iter().any(|net| net.contains(&peer)) {
         return peer;
     }
-    let Some(xff) = headers
-        .get("x-forwarded-for")
-        .and_then(|v| v.to_str().ok())
-    else {
+    let Some(xff) = headers.get("x-forwarded-for").and_then(|v| v.to_str().ok()) else {
         return peer;
     };
     for entry in xff.split(',').rev() {
@@ -349,11 +346,7 @@ mod client_ip_tests {
     #[test]
     fn xff_from_untrusted_peer_is_ignored() {
         let trusted = nets(&["172.18.0.0/16"]);
-        let got = client_ip(
-            ip("203.0.113.9"),
-            &headers_with_xff("10.0.0.1"),
-            &trusted,
-        );
+        let got = client_ip(ip("203.0.113.9"), &headers_with_xff("10.0.0.1"), &trusted);
         assert_eq!(got, ip("203.0.113.9"));
     }
 

crates/transport-http/src/v1/chat/log.rs

@@ -94,11 +94,11 @@ pub async fn v1_chat_export_log_proxy(
                         context: format!("Failed to write export file: {e}"),
                     }
                 })?;
-                writer.write_all(b"\n").map_err(|e| {
-                    spiritstream_core::CoreError::Internal {
+                writer
+                    .write_all(b"\n")
+                    .map_err(|e| spiritstream_core::CoreError::Internal {
                         context: format!("Failed to write export file: {e}"),
-                    }
-                })?;
+                    })?;
             }
         }
     }

crates/transport-http/src/v1/chat_message_wire/atoms.rs

@@ -87,4 +87,3 @@ impl From<TextStyle> for TextStyleWire {
         }
     }
 }
-

crates/transport-http/src/v1/chat_message_wire/author.rs

@@ -78,4 +78,3 @@ impl From<ReplyContext> for ReplyContextWire {
         }
     }
 }
-

crates/transport-http/src/v1/chat_message_wire/events.rs

@@ -281,4 +281,3 @@ impl From<ChatEvent> for ChatEventWire {
         }
     }
 }
-