chore: scheduled code-cleanup

crates/aether-cli/tests/integration/mcp_command.rs

@@ -55,7 +55,7 @@ impl ServerHandler for FakeGateway {
             .into()),
             "demo__fail" => Ok(CallToolResult::error(vec![]).into()),
             "demo__slow" => {
-                tokio::time::sleep(std::time::Duration::from_mins(1)).await;
+                std::future::pending::<()>().await;
                 Ok(CallToolResult::structured(json!({"done": true})).into())
             }
             "demo__text" => Ok(CallToolResult::success(vec![ContentBlock::text("plain")]).into()),

crates/aether-lspd/Cargo.toml

@@ -74,6 +74,7 @@ libc = { workspace = true }
 [dev-dependencies]
 aether-lspd = { path = ".", features = ["testing"] }
 tempfile = { workspace = true }
+tokio = { workspace = true, features = ["test-util"] }
 
 [[bin]]
 name = "aether-lspd"

crates/aether-lspd/src/daemon.rs

@@ -193,7 +193,7 @@ mod tests {
     use super::*;
     use tokio::time::timeout;
 
-    #[tokio::test]
+    #[tokio::test(start_paused = true)]
     async fn idle_timeout_none_never_completes() {
         let client_count = Arc::new(AtomicUsize::new(0));
         let last_activity = Arc::new(RwLock::new(Instant::now()));
@@ -207,7 +207,7 @@ mod tests {
         assert!(result.is_err(), "None timeout should not complete");
     }
 
-    #[tokio::test]
+    #[tokio::test(start_paused = true)]
     async fn idle_timeout_completes_when_idle_elapsed() {
         let client_count = Arc::new(AtomicUsize::new(0));
         let stale_activity = Instant::now()

crates/aether-lspd/src/diagnostics_store.rs

@@ -110,7 +110,7 @@ mod tests {
         }
     }
 
-    #[tokio::test]
+    #[tokio::test(start_paused = true)]
     async fn wait_for_uri_fresh_waits_for_settle_window() {
         let store = DiagnosticsStore::new();
         let uri: Uri = "file:///test.rs".parse().unwrap();
@@ -133,7 +133,7 @@ mod tests {
         assert_eq!(diags[0].diagnostics[0].message, "second");
     }
 
-    #[tokio::test]
+    #[tokio::test(start_paused = true)]
     async fn wait_for_uri_fresh_ignores_unrelated_publishes() {
         let store = DiagnosticsStore::new();
         let target: Uri = "file:///target.rs".parse().unwrap();

crates/aether-lspd/src/docs/daemon.md

@@ -13,6 +13,7 @@ use std::time::Duration;
 let daemon = LspDaemon::new(
     PathBuf::from("/tmp/aether-lspd-1000/lsp-rust-abc123.sock"),
     Some(Duration::from_secs(300)),
+    Duration::from_secs(120),
 );
 daemon.run().await?;
 # Ok(())

crates/mcp-utils/src/tool_gateway/transport.rs

@@ -244,7 +244,6 @@ mod tests {
     #[tokio::test]
     async fn dropping_server_cancels_in_flight_connections() {
         use rmcp::model::CallToolRequestParams;
-        use std::time::Duration;
         use tokio::sync::watch;
 
         #[derive(Clone)]
@@ -258,7 +257,7 @@ mod tests {
             #[tool(description = "Blocks until the connection is aborted")]
             async fn slow(&self) -> String {
                 let _ = self.started.send(true);
-                tokio::time::sleep(Duration::from_mins(10)).await;
+                std::future::pending::<()>().await;
                 "done".to_string()
             }
         }