format

Author: ellie

backend/src/commands/blocks.rs

@@ -369,7 +369,9 @@ pub async fn notify_block_kv_value_changed(
     key: String,
     _value: serde_json::Value,
 ) -> Result<(), String> {
-    log::debug!("notify_block_kv_value_changed: document={document_id}, block={block_id}, key={key}");
+    log::debug!(
+        "notify_block_kv_value_changed: document={document_id}, block={block_id}, key={key}"
+    );
 
     let documents = state.documents.read().await;
     let document = documents.get(&document_id).ok_or("Document not found")?;

crates/atuin-desktop-runtime/src/blocks/ssh_connect.rs

@@ -1,7 +1,9 @@
 use crate::{
     blocks::{Block, BlockBehavior, FromDocument},
     client::LocalValueProvider,
-    context::{BlockContext, ContextResolver, DocumentSshConfig, DocumentSshHost, SshIdentityKeyConfig},
+    context::{
+        BlockContext, ContextResolver, DocumentSshConfig, DocumentSshHost, SshIdentityKeyConfig,
+    },
 };
 use async_trait::async_trait;
 use serde::{Deserialize, Serialize};
@@ -69,9 +71,7 @@ impl FromDocument for SshConnect {
             Some(v) => match v.as_u64() {
                 Some(0) => None, // 0 means "not set"
                 Some(p) if p <= 65535 => Some(p as u16),
-                Some(p) => {
-                    return Err(format!("Invalid SSH port: {} (must be 1-65535)", p).into())
-                }
+                Some(p) => return Err(format!("Invalid SSH port: {} (must be 1-65535)", p).into()),
                 None => return Err("Invalid SSH port: expected a number".into()),
             },
             None => None,
@@ -102,14 +102,18 @@ impl SshConnect {
                 if key_value.is_empty() {
                     None
                 } else {
-                    Some(SshIdentityKeyConfig::Paste { content: key_value.to_string() })
+                    Some(SshIdentityKeyConfig::Paste {
+                        content: key_value.to_string(),
+                    })
                 }
             }
             "path" => {
                 if key_value.is_empty() {
                     None
                 } else {
-                    Some(SshIdentityKeyConfig::Path { path: key_value.to_string() })
+                    Some(SshIdentityKeyConfig::Path {
+                        path: key_value.to_string(),
+                    })
                 }
             }
             _ => None,
@@ -241,11 +245,7 @@ impl BlockBehavior for SshConnect {
         let identity_key = if let Some(provider) = block_local_value_provider {
             match provider.get_block_local_value(self.id, "identityKey").await {
                 Ok(Some(value)) => {
-                    tracing::debug!(
-                        "Block {} read identityKey from KV: {}",
-                        self.id,
-                        value
-                    );
+                    tracing::debug!("Block {} read identityKey from KV: {}", self.id, value);
                     Self::parse_identity_key_from_local(&value)
                 }
                 Ok(None) => {
@@ -642,7 +642,8 @@ mod tests {
         assert!(result.is_none());
 
         // Unknown mode
-        let result = SshConnect::parse_identity_key_from_local(r#"{"mode": "unknown", "value": "test"}"#);
+        let result =
+            SshConnect::parse_identity_key_from_local(r#"{"mode": "unknown", "value": "test"}"#);
         assert!(result.is_none());
     }
 

crates/atuin-desktop-runtime/src/ssh/pool.rs

@@ -39,7 +39,8 @@ impl Pool {
         auth: Option<Authentication>,
         cancellation_rx: Option<oneshot::Receiver<()>>,
     ) -> Result<Arc<Session>> {
-        self.connect_with_config(host, username, auth, cancellation_rx, None).await
+        self.connect_with_config(host, username, auth, cancellation_rx, None)
+            .await
     }
 
     /// Connect to a host with optional block configuration overrides
@@ -78,8 +79,7 @@ impl Pool {
             }
         }
 
-        let identity_key_config = ssh_config_override
-            .and_then(|cfg| cfg.identity_key.as_ref());
+        let identity_key_config = ssh_config_override.and_then(|cfg| cfg.identity_key.as_ref());
         tracing::debug!(
             "Pool connect_with_config: ssh_config_override={:?}, identity_key_config={:?}",
             ssh_config_override,
@@ -88,7 +88,9 @@ impl Pool {
 
         let async_session = async {
             let mut session = Session::open_with_config(host, ssh_config_override).await?;
-            session.authenticate_with_config(auth, Some(&username), identity_key_config).await?;
+            session
+                .authenticate_with_config(auth, Some(&username), identity_key_config)
+                .await?;
             Ok::<_, eyre::Report>(session)
         };
 

crates/atuin-desktop-runtime/src/ssh/session.rs

@@ -485,7 +485,10 @@ impl Session {
 
     /// Open a new SSH session with optional configuration overrides from block settings.
     /// Block settings take precedence over SSH config file.
-    pub async fn open_with_config(host: &str, config_override: Option<&DocumentSshConfig>) -> Result<Self> {
+    pub async fn open_with_config(
+        host: &str,
+        config_override: Option<&DocumentSshConfig>,
+    ) -> Result<Self> {
         let mut ssh_config = Self::resolve_ssh_config(host);
 
         // Apply block-level overrides if provided
@@ -833,11 +836,16 @@ impl Session {
 
         // Step 0: Try block-provided identity key FIRST (overrides everything)
         // If an explicit key is configured and fails, we do NOT fall back to agent/defaults
-        tracing::debug!("authenticate_with_config called with identity_key_config: {:?}", identity_key_config);
+        tracing::debug!(
+            "authenticate_with_config called with identity_key_config: {:?}",
+            identity_key_config
+        );
         if let Some(key_config) = identity_key_config {
             match key_config {
                 SshIdentityKeyConfig::None => {
-                    tracing::debug!("Block identity key config is SshIdentityKeyConfig::None, using defaults");
+                    tracing::debug!(
+                        "Block identity key config is SshIdentityKeyConfig::None, using defaults"
+                    );
                 }
                 SshIdentityKeyConfig::Paste { content } => {
                     tracing::info!("Step 0: Trying block-provided pasted key");
@@ -907,7 +915,9 @@ impl Session {
                     remaining_methods,
                     partial_success
                 );
-                Err(eyre::eyre!("Pasted key authentication failed: server rejected key"))
+                Err(eyre::eyre!(
+                    "Pasted key authentication failed: server rejected key"
+                ))
             }
         }
     }

crates/atuin-desktop-runtime/src/ssh/ssh_pool.rs

@@ -201,7 +201,10 @@ impl SshPoolHandle {
 
     /// Disconnect all connections to a given host, regardless of username.
     pub async fn disconnect_by_host(&self, host: &str) -> Result<()> {
-        let connections = self.list_connections().await.map_err(|_| eyre::eyre!("Failed to list connections"))?;
+        let connections = self
+            .list_connections()
+            .await
+            .map_err(|_| eyre::eyre!("Failed to list connections"))?;
 
         for key in connections {
             // Connection keys are "username@host" - split and match host exactly
@@ -246,7 +249,17 @@ impl SshPoolHandle {
         output_stream: mpsc::Sender<OutputLine>,
         result_tx: oneshot::Sender<()>,
     ) -> Result<()> {
-        self.exec_with_config(host, username, interpreter, command, channel, output_stream, result_tx, None).await
+        self.exec_with_config(
+            host,
+            username,
+            interpreter,
+            command,
+            channel,
+            output_stream,
+            result_tx,
+            None,
+        )
+        .await
     }
 
     #[allow(clippy::too_many_arguments)]
@@ -307,7 +320,8 @@ impl SshPoolHandle {
         width: u16,
         height: u16,
     ) -> Result<(mpsc::Sender<Bytes>, mpsc::Sender<(u16, u16)>)> {
-        self.open_pty_with_config(host, username, channel, output_stream, width, height, None).await
+        self.open_pty_with_config(host, username, channel, output_stream, width, height, None)
+            .await
     }
 
     #[allow(clippy::too_many_arguments)]
@@ -703,7 +717,13 @@ impl SshPool {
                     .pool
                     .write()
                     .await
-                    .connect_with_config(&host, Some(username.as_str()), None, None, ssh_config.as_ref())
+                    .connect_with_config(
+                        &host,
+                        Some(username.as_str()),
+                        None,
+                        None,
+                        ssh_config.as_ref(),
+                    )
                     .await;
 
                 let session = match session {