style(acp-nats): apply rustfmt formatting

Run cargo fmt to fix formatting in client/mod.rs (match arm indentation
for long type annotation) and client/terminal_output.rs (closure
formatting and line length).

Author: yordis

rsworkspace/crates/acp-nats/src/client/mod.rs

@@ -211,119 +211,118 @@ async fn dispatch_client_method<
 
     Span::current().record("session_id", parsed.session_id.as_str());
 
-    let response_bytes: Option<Result<Vec<u8>, Box<dyn std::error::Error + Send + Sync>>> = match parsed.method {
-        ClientMethod::FsReadTextFile => {
-            fs_read_text_file::handle(
-                &payload,
-                ctx.client,
-                reply.as_deref(),
-                ctx.nats,
-                parsed.session_id.as_str(),
-                ctx.serializer,
-            )
-            .await;
-            None
-        }
-        ClientMethod::FsWriteTextFile => {
-            fs_write_text_file::handle(
-                &payload,
-                ctx.client,
-                reply.as_deref(),
-                ctx.nats,
-                parsed.session_id.as_str(),
-                ctx.serializer,
-            )
-            .await;
-            None
-        }
-        ClientMethod::SessionRequestPermission => {
-            request_permission::handle(
-                &payload,
-                ctx.client,
-                reply.as_deref(),
-                ctx.nats,
-                parsed.session_id.as_str(),
-                ctx.serializer,
-            )
-            .await;
-            None
-        }
-        ClientMethod::SessionUpdate => {
-            if reply.is_some() {
-                warn!(
-                    session_id = %parsed.session_id,
-                    method = ?parsed.method,
-                    "Unexpected reply subject on notification request"
-                );
+    let response_bytes: Option<Result<Vec<u8>, Box<dyn std::error::Error + Send + Sync>>> =
+        match parsed.method {
+            ClientMethod::FsReadTextFile => {
+                fs_read_text_file::handle(
+                    &payload,
+                    ctx.client,
+                    reply.as_deref(),
+                    ctx.nats,
+                    parsed.session_id.as_str(),
+                    ctx.serializer,
+                )
+                .await;
+                None
             }
-            session_update::handle(&payload, ctx.client).await;
-            None
-        }
-        ClientMethod::ExtSessionPromptResponse => {
-            ext_session_prompt_response::handle(
-                parsed.session_id.as_str(),
-                &payload,
-                reply.as_deref(),
-                ctx.bridge,
-            )
-            .await;
-            None
-        }
-        ClientMethod::TerminalCreate => {
-            terminal_create::handle(
-                &payload,
-                ctx.client,
-                reply.as_deref(),
-                ctx.nats,
-                parsed.session_id.as_str(),
-                ctx.serializer,
-            )
-            .await;
-            None
-        }
-        ClientMethod::TerminalKill => {
-            terminal_kill::handle(
-                &payload,
-                ctx.client,
-                reply.as_deref(),
-                ctx.nats,
-                parsed.session_id.as_str(),
-                ctx.serializer,
-            )
-            .await;
-            None
-        }
-        ClientMethod::TerminalOutput => {
-            Some(
+            ClientMethod::FsWriteTextFile => {
+                fs_write_text_file::handle(
+                    &payload,
+                    ctx.client,
+                    reply.as_deref(),
+                    ctx.nats,
+                    parsed.session_id.as_str(),
+                    ctx.serializer,
+                )
+                .await;
+                None
+            }
+            ClientMethod::SessionRequestPermission => {
+                request_permission::handle(
+                    &payload,
+                    ctx.client,
+                    reply.as_deref(),
+                    ctx.nats,
+                    parsed.session_id.as_str(),
+                    ctx.serializer,
+                )
+                .await;
+                None
+            }
+            ClientMethod::SessionUpdate => {
+                if reply.is_some() {
+                    warn!(
+                        session_id = %parsed.session_id,
+                        method = ?parsed.method,
+                        "Unexpected reply subject on notification request"
+                    );
+                }
+                session_update::handle(&payload, ctx.client).await;
+                None
+            }
+            ClientMethod::ExtSessionPromptResponse => {
+                ext_session_prompt_response::handle(
+                    parsed.session_id.as_str(),
+                    &payload,
+                    reply.as_deref(),
+                    ctx.bridge,
+                )
+                .await;
+                None
+            }
+            ClientMethod::TerminalCreate => {
+                terminal_create::handle(
+                    &payload,
+                    ctx.client,
+                    reply.as_deref(),
+                    ctx.nats,
+                    parsed.session_id.as_str(),
+                    ctx.serializer,
+                )
+                .await;
+                None
+            }
+            ClientMethod::TerminalKill => {
+                terminal_kill::handle(
+                    &payload,
+                    ctx.client,
+                    reply.as_deref(),
+                    ctx.nats,
+                    parsed.session_id.as_str(),
+                    ctx.serializer,
+                )
+                .await;
+                None
+            }
+            ClientMethod::TerminalOutput => Some(
                 terminal_output::handle(&payload, ctx.client, parsed.session_id.as_str()).await,
-            )
-        }
-        ClientMethod::TerminalRelease => {
-            terminal_release::handle(
-                &payload,
-                ctx.client,
-                reply.as_deref(),
-                ctx.nats,
-                parsed.session_id.as_str(),
-                ctx.serializer,
-            )
-            .await;
-            None
-        }
-        ClientMethod::TerminalWaitForExit => {
-            terminal_wait_for_exit::handle(
-                &payload,
-                ctx.client,
-                reply.as_deref(),
-                ctx.nats,
-                parsed.session_id.as_str(),
-                ctx.bridge.config.operation_timeout(),
-                ctx.serializer,
-            )
-            .await;
-            None
-        }
-    };
+            ),
+            ClientMethod::TerminalRelease => {
+                terminal_release::handle(
+                    &payload,
+                    ctx.client,
+                    reply.as_deref(),
+                    ctx.nats,
+                    parsed.session_id.as_str(),
+                    ctx.serializer,
+                )
+                .await;
+                None
+            }
+            ClientMethod::TerminalWaitForExit => {
+                terminal_wait_for_exit::handle(
+                    &payload,
+                    ctx.client,
+                    reply.as_deref(),
+                    ctx.nats,
+                    parsed.session_id.as_str(),
+                    ctx.bridge.config.operation_timeout(),
+                    ctx.serializer,
+                )
+                .await;
+                None
+            }
+        };
 
     if let (Some(reply_to), Some(result)) = (reply, response_bytes) {
         match result {

rsworkspace/crates/acp-nats/src/client/terminal_output.rs

@@ -42,9 +42,12 @@ fn parse_request(
     let envelope: Request<TerminalOutputRequest> = serde_json::from_value(value)
         .map_err(|e| (ErrorCode::InvalidParams, format!("Invalid request: {}", e)))?;
 
-    let request = envelope
-        .params
-        .ok_or_else(|| (ErrorCode::InvalidParams, "params is null or missing".to_string()))?;
+    let request = envelope.params.ok_or_else(|| {
+        (
+            ErrorCode::InvalidParams,
+            "params is null or missing".to_string(),
+        )
+    })?;
 
     let params_session_id = request.session_id.to_string();
     if params_session_id != expected_session_id {
@@ -88,7 +91,9 @@ mod tests {
             &self,
             _: RequestPermissionRequest,
         ) -> agent_client_protocol::Result<RequestPermissionResponse> {
-            Ok(RequestPermissionResponse::new(RequestPermissionOutcome::Cancelled))
+            Ok(RequestPermissionResponse::new(
+                RequestPermissionOutcome::Cancelled,
+            ))
         }
 
         async fn read_text_file(
@@ -214,7 +219,9 @@ mod tests {
         let client = MockClient;
         let payload = envelope_payload();
 
-        let bytes = super::handle(&payload, &client, "different-session").await.unwrap();
+        let bytes = super::handle(&payload, &client, "different-session")
+            .await
+            .unwrap();
         let response: serde_json::Value = serde_json::from_slice(&bytes).unwrap();
 
         assert_eq!(