chore: format runtime shared layers

Author: dux-web

apps/desktop/runtime/src/ai_history_normalized/history_sources/mimo.rs

@@ -1,10 +1,7 @@
 use super::*;
 
-pub const DRIVER: HistorySourceDriver = file_history_source_driver(
-    "mimo",
-    mimo_history_paths,
-    parse_opencode_history_file,
-);
+pub const DRIVER: HistorySourceDriver =
+    file_history_source_driver("mimo", mimo_history_paths, parse_opencode_history_file);
 
 fn mimo_history_paths(_project: &AIHistoryProjectRequest, home: &Path) -> Vec<PathBuf> {
     [

apps/desktop/runtime/src/remote/crypto.rs

@@ -164,4 +164,3 @@ fn remote_e2e_private_key(value: &str) -> Option<StaticSecret> {
     let array: [u8; 32] = bytes.as_slice().try_into().ok()?;
     Some(StaticSecret::from(array))
 }
-

apps/desktop/runtime/src/remote/host.rs

@@ -3,17 +3,16 @@ use super::crypto::{remote_base64_url_decode, remote_host_name};
 use super::pairing::remote_summary_show_pending_pairing;
 use super::protocol::{
     REMOTE_AI_STATS, REMOTE_DEVICE_CONNECTED, REMOTE_DEVICE_DISCONNECTED, REMOTE_ERROR,
-    REMOTE_FILE_DELETE, REMOTE_FILE_DELETED, REMOTE_FILE_LIST, REMOTE_FILE_READ, REMOTE_FILE_RENAME,
-    REMOTE_FILE_RENAMED, REMOTE_FILE_WRITE, REMOTE_FILE_WRITTEN, REMOTE_GIT_STATUS,
-    REMOTE_HOST_INFO, REMOTE_HOST_OFFLINE, REMOTE_PAIRING_CONFIRMED, REMOTE_PAIRING_REJECTED,
-    REMOTE_PROJECT_ADD, REMOTE_PROJECT_EDIT,
-    REMOTE_PROJECT_LIST, REMOTE_PROJECT_REMOVE, REMOTE_PROJECT_SELECT, REMOTE_PROJECT_SELECTED,
-    REMOTE_PROJECT_UPDATED, REMOTE_RESOURCE_AI_STATS, REMOTE_RESOURCE_GIT_STATUS,
-    REMOTE_RESOURCE_PROJECTS, REMOTE_RESOURCE_SUBSCRIBE, REMOTE_RESOURCE_TERMINALS,
-    REMOTE_RESOURCE_UNSUBSCRIBE, REMOTE_RESOURCE_WORKTREES, REMOTE_TERMINAL_BUFFER,
-    REMOTE_TERMINAL_BUFFER_MAX_CHARS, REMOTE_TERMINAL_CLOSE, REMOTE_TERMINAL_CLOSED,
-    REMOTE_TERMINAL_CREATE, REMOTE_TERMINAL_CREATED, REMOTE_TERMINAL_INPUT,
-    REMOTE_TERMINAL_INPUT_ACK, REMOTE_TERMINAL_LIST, REMOTE_TERMINAL_OUTPUT,
+    REMOTE_FILE_DELETE, REMOTE_FILE_DELETED, REMOTE_FILE_LIST, REMOTE_FILE_READ,
+    REMOTE_FILE_RENAME, REMOTE_FILE_RENAMED, REMOTE_FILE_WRITE, REMOTE_FILE_WRITTEN,
+    REMOTE_GIT_STATUS, REMOTE_HOST_INFO, REMOTE_HOST_OFFLINE, REMOTE_PAIRING_CONFIRMED,
+    REMOTE_PAIRING_REJECTED, REMOTE_PROJECT_ADD, REMOTE_PROJECT_EDIT, REMOTE_PROJECT_LIST,
+    REMOTE_PROJECT_REMOVE, REMOTE_PROJECT_SELECT, REMOTE_PROJECT_SELECTED, REMOTE_PROJECT_UPDATED,
+    REMOTE_RESOURCE_AI_STATS, REMOTE_RESOURCE_GIT_STATUS, REMOTE_RESOURCE_PROJECTS,
+    REMOTE_RESOURCE_SUBSCRIBE, REMOTE_RESOURCE_TERMINALS, REMOTE_RESOURCE_UNSUBSCRIBE,
+    REMOTE_RESOURCE_WORKTREES, REMOTE_TERMINAL_BUFFER, REMOTE_TERMINAL_BUFFER_MAX_CHARS,
+    REMOTE_TERMINAL_CLOSE, REMOTE_TERMINAL_CLOSED, REMOTE_TERMINAL_CREATE, REMOTE_TERMINAL_CREATED,
+    REMOTE_TERMINAL_INPUT, REMOTE_TERMINAL_INPUT_ACK, REMOTE_TERMINAL_LIST, REMOTE_TERMINAL_OUTPUT,
     REMOTE_TERMINAL_OUTPUT_ACK, REMOTE_TERMINAL_RESIZE, REMOTE_TERMINAL_SIGNAL,
     REMOTE_TERMINAL_SUBSCRIBE, REMOTE_TERMINAL_UNSUBSCRIBE, REMOTE_TERMINAL_UPLOAD,
     REMOTE_TERMINAL_UPLOAD_ACK, REMOTE_TERMINAL_UPLOAD_CANCEL, REMOTE_TERMINAL_UPLOAD_CHUNK,
@@ -31,8 +30,8 @@ use super::relay::{remote_pairing_ticket_payload, remote_server_url, remote_stun
 use super::transport::RemoteTransport;
 use super::transport_factory::RemoteTransportFactory;
 use super::types::{
-    RemoteDeviceSettings, RemoteEnvelope, RemotePairingInfo, RemotePairingPollResult,
-    RemoteHostEvent, RemoteSummary, RemoteTerminalLayoutChanged, RemoteTransportCandidate,
+    RemoteDeviceSettings, RemoteEnvelope, RemoteHostEvent, RemotePairingInfo,
+    RemotePairingPollResult, RemoteSummary, RemoteTerminalLayoutChanged, RemoteTransportCandidate,
     RemoteTransportPairingRequest,
 };
 use crate::ai_history_indexer::{AIHistoryIndexer, AIHistoryProjectState};
@@ -237,7 +236,10 @@ impl RemoteHostRuntime {
     }
 
     fn publish_remote_terminal_layout_changed(&self) {
-        let generation = self.remote_terminal_layout_generation.fetch_add(1, Ordering::Relaxed) + 1;
+        let generation = self
+            .remote_terminal_layout_generation
+            .fetch_add(1, Ordering::Relaxed)
+            + 1;
         self.push_event(RemoteHostEvent::TerminalLayoutChanged(
             RemoteTerminalLayoutChanged { generation },
         ));
@@ -1089,7 +1091,12 @@ impl RemoteHostRuntime {
             return;
         };
         match remote_file_read(path) {
-            Ok(payload) => self.send(REMOTE_FILE_READ, envelope.device_id.as_deref(), None, payload),
+            Ok(payload) => self.send(
+                REMOTE_FILE_READ,
+                envelope.device_id.as_deref(),
+                None,
+                payload,
+            ),
             Err(error) => self.send_error(envelope, &error),
         }
     }
@@ -2455,7 +2462,12 @@ impl RemoteHostRuntime {
         }
         let payload = json!({ "terminals": self.remote_terminals() });
         for device_id in device_ids {
-            self.send(REMOTE_TERMINAL_LIST, Some(&device_id), None, payload.clone());
+            self.send(
+                REMOTE_TERMINAL_LIST,
+                Some(&device_id),
+                None,
+                payload.clone(),
+            );
         }
     }
 
@@ -4395,10 +4407,12 @@ mod tests {
             project_b.to_string_lossy(),
             worktree_b_path.to_string_lossy()
         );
-        assert!(runtime.drain_events().iter().any(|event| matches!(
-            event,
-            RemoteHostEvent::TerminalLayoutChanged(_)
-        )));
+        assert!(
+            runtime
+                .drain_events()
+                .iter()
+                .any(|event| matches!(event, RemoteHostEvent::TerminalLayoutChanged(_)))
+        );
 
         fs::remove_dir_all(support_dir).ok();
     }
@@ -5130,10 +5144,12 @@ mod tests {
         let layout_key = terminal_layout_storage_key("project-b", "worktree-b");
         let layout = TerminalLayoutService::new(support_dir.clone()).load(Some(&layout_key));
         assert_eq!(layout.tabs.len(), 1);
-        assert!(runtime.drain_events().iter().any(|event| matches!(
-            event,
-            RemoteHostEvent::TerminalLayoutChanged(_)
-        )));
+        assert!(
+            runtime
+                .drain_events()
+                .iter()
+                .any(|event| matches!(event, RemoteHostEvent::TerminalLayoutChanged(_)))
+        );
 
         fs::remove_dir_all(support_dir).ok();
     }
@@ -5204,10 +5220,12 @@ mod tests {
         assert_eq!(layout.top_panes.len(), 1);
         assert_eq!(layout.top_panes[0].terminal_id, session_a);
         assert!(terminals.snapshot(&session_b).is_err());
-        assert!(runtime.drain_events().iter().any(|event| matches!(
-            event,
-            RemoteHostEvent::TerminalLayoutChanged(_)
-        )));
+        assert!(
+            runtime
+                .drain_events()
+                .iter()
+                .any(|event| matches!(event, RemoteHostEvent::TerminalLayoutChanged(_)))
+        );
 
         runtime.handle_terminal_close(&RemoteEnvelope {
             kind: "terminal.close".to_string(),

apps/desktop/runtime/src/remote/tests.rs

@@ -300,18 +300,24 @@ fn remote_e2e_crypto_matches_tauri_envelope_shape() {
         encrypted.get("alg").and_then(serde_json::Value::as_str),
         Some("X25519-HKDF-SHA256-AES-256-GCM")
     );
-    assert!(encrypted
-        .get("nonce")
-        .and_then(serde_json::Value::as_str)
-        .is_some());
-    assert!(encrypted
-        .get("ciphertext")
-        .and_then(serde_json::Value::as_str)
-        .is_some());
-    assert!(encrypted
-        .get("tag")
-        .and_then(serde_json::Value::as_str)
-        .is_some());
+    assert!(
+        encrypted
+            .get("nonce")
+            .and_then(serde_json::Value::as_str)
+            .is_some()
+    );
+    assert!(
+        encrypted
+            .get("ciphertext")
+            .and_then(serde_json::Value::as_str)
+            .is_some()
+    );
+    assert!(
+        encrypted
+            .get("tag")
+            .and_then(serde_json::Value::as_str)
+            .is_some()
+    );
 
     let decrypted =
         remote_e2e_decrypt(&encrypted, &device_key, "host-1", "device-1").expect("decrypt");
@@ -674,11 +680,13 @@ fn remote_file_read_write_and_rename_match_tauri_mobile_limits() {
     );
     assert!(remote_file_read(dir.to_str().unwrap()).is_err());
 
-    assert!(remote_file_rename(
-        source.to_str().unwrap(),
-        other.join("note.txt").to_str().unwrap()
-    )
-    .is_err());
+    assert!(
+        remote_file_rename(
+            source.to_str().unwrap(),
+            other.join("note.txt").to_str().unwrap()
+        )
+        .is_err()
+    );
     remote_file_rename(source.to_str().unwrap(), renamed.to_str().unwrap()).expect("rename");
     assert!(renamed.exists());
 
@@ -715,21 +723,25 @@ fn remote_ai_stats_payload_matches_tauri_empty_snapshot_shape() {
             .and_then(serde_json::Value::as_str),
         Some("Project One")
     );
-    assert!(payload
-        .get("projectSummary")
-        .and_then(serde_json::Value::as_object)
-        .is_some());
+    assert!(
+        payload
+            .get("projectSummary")
+            .and_then(serde_json::Value::as_object)
+            .is_some()
+    );
     assert_eq!(
         payload
             .get("sessions")
             .and_then(serde_json::Value::as_array)
             .map(Vec::len),
         Some(0)
     );
-    assert!(payload
-        .get("updatedAt")
-        .and_then(serde_json::Value::as_str)
-        .is_some());
+    assert!(
+        payload
+            .get("updatedAt")
+            .and_then(serde_json::Value::as_str)
+            .is_some()
+    );
 }
 
 #[test]

apps/desktop/runtime/src/runtime_state/mod.rs

@@ -5,8 +5,8 @@ use crate::{
     },
     ai_history_indexer::{AIHistoryEvent, AIHistoryIndexer, AIHistoryProjectState},
     ai_history_normalized::{
-        global_today_normalized_tokens_at, indexed_sessions_since_at,
-        normalized_project_totals_since_at, AIGlobalHistorySnapshot, AIHistoryProjectRequest,
+        AIGlobalHistorySnapshot, AIHistoryProjectRequest, global_today_normalized_tokens_at,
+        indexed_sessions_since_at, normalized_project_totals_since_at,
     },
     ai_runtime::{
         AIRuntimeBridge, AIRuntimeBridgeSnapshot, AIRuntimeContextSnapshot, AIRuntimeProbeRequest,
@@ -51,10 +51,10 @@ use crate::{
     },
     performance::{PerformanceService, PerformanceSummary},
     pet::{
-        refresh_input_from_indexed_history, PetCatalog, PetClaimInput, PetCustomPet,
-        PetCustomPetInstallPreview, PetCustomPetInstallRequest, PetProjectTokenTotal,
-        PetRefreshInput, PetRenameRequest, PetRestoreRequest, PetService, PetSnapshot, PetStore,
-        PetSummary,
+        PetCatalog, PetClaimInput, PetCustomPet, PetCustomPetInstallPreview,
+        PetCustomPetInstallRequest, PetProjectTokenTotal, PetRefreshInput, PetRenameRequest,
+        PetRestoreRequest, PetService, PetSnapshot, PetStore, PetSummary,
+        refresh_input_from_indexed_history,
     },
     power::{PowerManager, PowerService, PowerSummary},
     project_activity::{ProjectActivityCoordinator, ProjectActivityEvent, ProjectActivitySnapshot},
@@ -73,12 +73,12 @@ use crate::{
     runtime_event::{RuntimeEventService, RuntimeEventSummary},
     runtime_paths,
     settings::{
-        sync_process_locale_preference, AppSettings, AppSettingsStore, SettingsService,
-        SettingsSummary,
+        AppSettings, AppSettingsStore, SettingsService, SettingsSummary,
+        sync_process_locale_preference,
     },
     ssh::{
-        render_ssh_launch_context_from_support_dir, SSHLaunchCommand, SSHProfileTestResult,
-        SSHProfileUpsertRequest, SSHProfilesSnapshot, SSHService, SSHStore, SSHSummary,
+        SSHLaunchCommand, SSHProfileTestResult, SSHProfileUpsertRequest, SSHProfilesSnapshot,
+        SSHService, SSHStore, SSHSummary, render_ssh_launch_context_from_support_dir,
     },
     terminal_layout::{TerminalLayoutService, TerminalLayoutSummary},
     terminal_pty::TerminalManager,
@@ -91,10 +91,10 @@ use crate::{
     },
 };
 use codux_terminal_core::{
-    runtime_scope_key, RuntimeModel, RuntimeProject, RuntimeWorktree, RuntimeWorktreeState,
+    RuntimeModel, RuntimeProject, RuntimeWorktree, RuntimeWorktreeState, runtime_scope_key,
 };
 use serde::Deserialize;
-use serde_json::{json, Value};
+use serde_json::{Value, json};
 use std::{
     collections::{HashMap, HashSet, VecDeque},
     path::{Path, PathBuf},

crates/codux-protocol-ffi/src/protocol_exports.rs

@@ -1,11 +1,11 @@
 use crate::common::{c_to_string, string_to_c};
 use codux_protocol::{
-    REMOTE_AI_STATS, REMOTE_ERROR, REMOTE_FILE_DELETE, REMOTE_FILE_DELETED, REMOTE_FILE_LIST,
-    REMOTE_FILE_READ, REMOTE_FILE_RENAME, REMOTE_FILE_RENAMED, REMOTE_FILE_WRITE,
-    REMOTE_DEVICE_CONNECTED, REMOTE_DEVICE_DISCONNECTED, REMOTE_DEVICE_INFO, REMOTE_FILE_WRITTEN,
-    REMOTE_GIT_STATUS, REMOTE_HELLO, REMOTE_HOST_INFO, REMOTE_HOST_OFFLINE, REMOTE_PROJECT_ADD,
-    REMOTE_PAIRING_CONFIRMED, REMOTE_PAIRING_REJECTED, REMOTE_PAIRING_REQUEST, REMOTE_PROJECT_EDIT,
-    REMOTE_PROJECT_LIST, REMOTE_PROJECT_REMOVE, REMOTE_PROJECT_SELECT,
+    REMOTE_AI_STATS, REMOTE_DEVICE_CONNECTED, REMOTE_DEVICE_DISCONNECTED, REMOTE_DEVICE_INFO,
+    REMOTE_ERROR, REMOTE_FILE_DELETE, REMOTE_FILE_DELETED, REMOTE_FILE_LIST, REMOTE_FILE_READ,
+    REMOTE_FILE_RENAME, REMOTE_FILE_RENAMED, REMOTE_FILE_WRITE, REMOTE_FILE_WRITTEN,
+    REMOTE_GIT_STATUS, REMOTE_HELLO, REMOTE_HOST_INFO, REMOTE_HOST_OFFLINE,
+    REMOTE_PAIRING_CONFIRMED, REMOTE_PAIRING_REJECTED, REMOTE_PAIRING_REQUEST, REMOTE_PROJECT_ADD,
+    REMOTE_PROJECT_EDIT, REMOTE_PROJECT_LIST, REMOTE_PROJECT_REMOVE, REMOTE_PROJECT_SELECT,
     REMOTE_PROJECT_SELECTED, REMOTE_PROJECT_UPDATED, REMOTE_PROTOCOL_VERSION, REMOTE_RELAY_ERROR,
     REMOTE_RESOURCE_AI_STATS, REMOTE_RESOURCE_FILES, REMOTE_RESOURCE_GIT_STATUS,
     REMOTE_RESOURCE_PROJECTS, REMOTE_RESOURCE_SUBSCRIBE, REMOTE_RESOURCE_TERMINALS,

crates/codux-remote-crypto/src/lib.rs

@@ -195,8 +195,7 @@ mod tests {
         let plaintext = b"{\"type\":\"hello\"}";
         // Host encrypts -> device decrypts.
         let payload = remote_e2e_encrypt(plaintext, &host_key, "host-1", "device-1").unwrap();
-        let recovered =
-            remote_e2e_decrypt(&payload, &device_key, "host-1", "device-1").unwrap();
+        let recovered = remote_e2e_decrypt(&payload, &device_key, "host-1", "device-1").unwrap();
         assert_eq!(recovered, plaintext);
     }
 

crates/codux-terminal-core/src/headless_screen.rs

@@ -1279,7 +1279,10 @@ mod tests {
         let replies = replies.take();
         let text = String::from_utf8_lossy(&replies);
         assert!(text.contains("\x1b[1;3R"), "missing CPR reply: {text:?}");
-        assert!(text.contains("\x1b[?2004;2$y"), "missing DECRQM reply: {text:?}");
+        assert!(
+            text.contains("\x1b[?2004;2$y"),
+            "missing DECRQM reply: {text:?}"
+        );
         assert!(text.contains("\x1b[?62;"), "missing DA1 reply: {text:?}");
     }