fix: apply rustfmt formatting

Author: echobt

src/cortex-app-server/src/config.rs

@@ -86,7 +86,7 @@ pub struct ServerConfig {
 
 fn default_shutdown_timeout() -> u64 {
     30 // 30 seconds for graceful shutdown
-       // See cortex_common::http_client for timeout hierarchy documentation
+    // See cortex_common::http_client for timeout hierarchy documentation
 }
 
 fn default_listen_addr() -> String {

src/cortex-common/src/config_substitution.rs

@@ -15,8 +15,7 @@ use thiserror::Error;
 /// Group 1: variable name
 /// Group 2: optional default value (after second colon)
 static ENV_REGEX: LazyLock<Regex> = LazyLock::new(|| {
-    Regex::new(r"\{env:([^:}]+)(?::([^}]*))?\}")
-        .expect("env regex pattern is valid and tested")
+    Regex::new(r"\{env:([^:}]+)(?::([^}]*))?\}").expect("env regex pattern is valid and tested")
 });
 
 /// Static regex for file content substitution: {file:path}

src/cortex-tui/src/runner/event_loop/streaming.rs

@@ -183,11 +183,8 @@ impl EventLoop {
             };
 
             // Start the completion request with timeout
-            let stream_result = tokio::time::timeout(
-                STREAMING_CONNECTION_TIMEOUT,
-                client.complete(request),
-            )
-            .await;
+            let stream_result =
+                tokio::time::timeout(STREAMING_CONNECTION_TIMEOUT, client.complete(request)).await;
 
             let mut stream = match stream_result {
                 Ok(Ok(s)) => s,
@@ -222,11 +219,7 @@ impl EventLoop {
                 }
 
                 // Wait for next event with timeout
-                let event = tokio::time::timeout(
-                    STREAMING_CHUNK_TIMEOUT,
-                    stream.next(),
-                )
-                .await;
+                let event = tokio::time::timeout(STREAMING_CHUNK_TIMEOUT, stream.next()).await;
 
                 match event {
                     Ok(Some(Ok(ResponseEvent::Delta(delta)))) => {

src/cortex-tui/src/runner/event_loop/subagent.rs

@@ -218,7 +218,8 @@ impl EventLoop {
                 };
 
                 let stream_result =
-                    tokio::time::timeout(SUBAGENT_CONNECTION_TIMEOUT, client.complete(request)).await;
+                    tokio::time::timeout(SUBAGENT_CONNECTION_TIMEOUT, client.complete(request))
+                        .await;
 
                 let mut stream = match stream_result {
                     Ok(Ok(s)) => s,