style: format rust server sources

Author: pallyoung

apps/server/src/services/agent.rs

@@ -1,5 +1,5 @@
-use crate::*;
 use crate::services::utf8_stream::Utf8StreamDecoder;
+use crate::*;
 
 const DEFAULT_PTY_COLS: u16 = 120;
 const DEFAULT_PTY_ROWS: u16 = 30;

apps/server/src/services/terminal.rs

@@ -1,5 +1,5 @@
-use crate::*;
 use crate::services::utf8_stream::Utf8StreamDecoder;
+use crate::*;
 
 const DEFAULT_PTY_COLS: u16 = 120;
 const DEFAULT_PTY_ROWS: u16 = 30;

apps/server/src/services/utf8_stream.rs

@@ -27,8 +27,8 @@ impl Utf8StreamDecoder {
                 Err(error) => {
                     let valid_up_to = error.valid_up_to();
                     if valid_up_to > 0 {
-                        let valid = std::str::from_utf8(&self.pending[..valid_up_to])
-                            .unwrap_or_default();
+                        let valid =
+                            std::str::from_utf8(&self.pending[..valid_up_to]).unwrap_or_default();
                         output.push_str(valid);
                         self.pending.drain(..valid_up_to);
                     }

apps/server/src/ws/protocol.rs

@@ -11,8 +11,12 @@ pub(crate) enum WsEnvelope {
 #[derive(Deserialize)]
 #[serde(tag = "type", rename_all = "snake_case")]
 pub(crate) enum WsClientEnvelope {
-    Ping { ts: i64 },
-    Pong { ts: i64 },
+    Ping {
+        ts: i64,
+    },
+    Pong {
+        ts: i64,
+    },
     AgentSend {
         workspace_id: String,
         session_id: String,

apps/server/src/ws/server.rs

@@ -189,8 +189,9 @@ fn handle_ws_client_envelope(
                 app,
             )
             .map_err(|error| ws_input_error_envelope(&workspace_id, "terminal_write", &error))?;
-            terminal_write(workspace_id.clone(), terminal_id, input, app.state())
-                .map_err(|error| ws_input_error_envelope(&workspace_id, "terminal_write", &error))?;
+            terminal_write(workspace_id.clone(), terminal_id, input, app.state()).map_err(
+                |error| ws_input_error_envelope(&workspace_id, "terminal_write", &error),
+            )?;
             Ok(None)
         }
         WsClientEnvelope::TerminalResize {
@@ -207,8 +208,9 @@ fn handle_ws_client_envelope(
                 app,
             )
             .map_err(|error| ws_input_error_envelope(&workspace_id, "terminal_resize", &error))?;
-            terminal_resize(workspace_id.clone(), terminal_id, cols, rows, app.state())
-                .map_err(|error| ws_input_error_envelope(&workspace_id, "terminal_resize", &error))?;
+            terminal_resize(workspace_id.clone(), terminal_id, cols, rows, app.state()).map_err(
+                |error| ws_input_error_envelope(&workspace_id, "terminal_resize", &error),
+            )?;
             Ok(None)
         }
         WsClientEnvelope::AgentResize {
@@ -242,8 +244,9 @@ fn handle_ws_client_envelope(
                 app,
             )
             .map_err(|error| ws_input_error_envelope(&workspace_id, "session_update", &error))?;
-            session_update(workspace_id.clone(), session_id, patch, app.state())
-                .map_err(|error| ws_input_error_envelope(&workspace_id, "session_update", &error))?;
+            session_update(workspace_id.clone(), session_id, patch, app.state()).map_err(
+                |error| ws_input_error_envelope(&workspace_id, "session_update", &error),
+            )?;
             Ok(None)
         }
         WsClientEnvelope::WorkspaceControllerHeartbeat { workspace_id } => {