cargo fmt

Author: nikomatsakis

server/src/ipc.rs

@@ -149,7 +149,8 @@ impl IPCCommunicator {
         let mut payload = serde_json::to_value(params)?;
         {
             let inner = self.inner.lock().await;
-            payload["terminal_shell_pid"] = serde_json::Value::Number(serde_json::Number::from(inner.terminal_shell_pid));
+            payload["terminal_shell_pid"] =
+                serde_json::Value::Number(serde_json::Number::from(inner.terminal_shell_pid));
         }
 
         let message = IPCMessage {
@@ -253,7 +254,7 @@ impl IPCCommunicator {
 
         // Also send to VSCode extension via IPC for unified logging
         let log_params = LogParams { level, message };
-        
+
         // Create message payload with shell PID added for multi-window filtering
         let mut payload = match serde_json::to_value(log_params) {
             Ok(payload) => payload,
@@ -262,13 +263,14 @@ impl IPCCommunicator {
                 return;
             }
         };
-        
+
         // Add shell PID for filtering
         {
             let inner = self.inner.lock().await;
-            payload["terminal_shell_pid"] = serde_json::Value::Number(serde_json::Number::from(inner.terminal_shell_pid));
+            payload["terminal_shell_pid"] =
+                serde_json::Value::Number(serde_json::Number::from(inner.terminal_shell_pid));
         }
-        
+
         let ipc_message = IPCMessage {
             message_type: IPCMessageType::Log,
             payload,

server/src/main.rs

@@ -106,7 +106,7 @@ async fn main() -> Result<()> {
 
             // Create our server instance
             let server = DialecticServer::new().await?;
-            
+
             // Clone the IPC communicator for shutdown handling
             let ipc_for_shutdown = server.ipc().clone();
 
@@ -121,7 +121,7 @@ async fn main() -> Result<()> {
             service.waiting().await?;
 
             info!("Dialectic MCP Server shutting down");
-            
+
             // Send Goodbye discovery message before shutdown
             if let Err(e) = ipc_for_shutdown.shutdown().await {
                 error!("Error during IPC shutdown: {}", e);

server/src/server.rs

@@ -93,7 +93,7 @@ impl DialecticServer {
         &self,
         Parameters(params): Parameters<PresentReviewParams>,
     ) -> Result<CallToolResult, McpError> {
-    // ANCHOR_END: present_review_tool
+        // ANCHOR_END: present_review_tool
         // Log the tool call via IPC (also logs locally)
         self.ipc
             .send_log(

server/src/types.rs

@@ -1,25 +1,25 @@
 //! Shared types for Dialectic MCP Server
-//! 
+//!
 //! Mirrors the TypeScript types from server/src/types.ts to ensure
 //! protocol compatibility across the IPC boundary.
 
-use serde::{Deserialize, Serialize};
 use schemars::JsonSchema;
+use serde::{Deserialize, Serialize};
 
 /// Parameters for the present-review MCP tool
-/// 
+///
 /// Matches PresentReviewParams from TypeScript implementation
 #[derive(Debug, Clone, Deserialize, Serialize, JsonSchema)]
 pub struct PresentReviewParams {
     /// Markdown content of the review to display
     pub content: String,
-    
+
     /// How to handle the review content in the extension
     pub mode: ReviewMode,
-    
+
     /// Optional section name for update-section mode
     pub section: Option<String>,
-    
+
     /// Base directory path for resolving relative file references
     #[serde(rename = "baseUri")]
     pub base_uri: String,
@@ -45,7 +45,7 @@ impl Default for ReviewMode {
 pub struct PresentReviewResult {
     /// Whether the review was successfully presented
     pub success: bool,
-    
+
     /// Optional message about the operation
     pub message: Option<String>,
 }
@@ -55,7 +55,7 @@ pub struct PresentReviewResult {
 pub struct LogParams {
     /// Log level
     pub level: LogLevel,
-    
+
     /// Log message content
     pub message: String,
 }
@@ -75,39 +75,39 @@ pub struct GetSelectionResult {
     /// Currently selected text, null if no selection
     #[serde(rename = "selectedText")]
     pub selected_text: Option<String>,
-    
+
     /// File path of the active editor, if available
     #[serde(rename = "filePath")]
     pub file_path: Option<String>,
-    
+
     /// Starting line number (1-based)
     #[serde(rename = "startLine")]
     pub start_line: Option<u32>,
-    
+
     /// Starting column number (1-based)
     #[serde(rename = "startColumn")]
     pub start_column: Option<u32>,
-    
+
     /// Ending line number (1-based)
     #[serde(rename = "endLine")]
     pub end_line: Option<u32>,
-    
+
     /// Ending column number (1-based)
     #[serde(rename = "endColumn")]
     pub end_column: Option<u32>,
-    
+
     /// Single line number if selection is on one line
     #[serde(rename = "lineNumber")]
     pub line_number: Option<u32>,
-    
+
     /// Language ID of the document
     #[serde(rename = "documentLanguage")]
     pub document_language: Option<String>,
-    
+
     /// Whether the document is untitled
     #[serde(rename = "isUntitled")]
     pub is_untitled: Option<bool>,
-    
+
     /// Message explaining the selection state
     pub message: Option<String>,
 }
@@ -131,10 +131,10 @@ pub struct GoodbyePayload {
 pub struct ResponsePayload {
     /// Whether the operation succeeded
     pub success: bool,
-    
+
     /// Optional error message
     pub error: Option<String>,
-    
+
     /// Optional data payload for responses like get_selection
     pub data: Option<serde_json::Value>,
 }
@@ -145,10 +145,10 @@ pub struct IPCMessage {
     /// Message type identifier
     #[serde(rename = "type")]
     pub message_type: IPCMessageType,
-    
+
     /// Message payload
     pub payload: serde_json::Value,
-    
+
     /// Unique message ID for response tracking
     pub id: String,
 }
@@ -169,5 +169,3 @@ pub enum IPCMessageType {
     /// Response to any message (replaces IPCResponse struct)
     Response,
 }
-
-

server/tests/daemon_integration_tests.rs

@@ -9,21 +9,21 @@ async fn test_daemon_spawning_integration() {
 
     // This test verifies that the MCP server can spawn and connect to the daemon
     // We'll use the test mode to avoid requiring actual VSCode PID discovery
-    
+
     let _server = DialecticServer::new_test();
-    
+
     // Verify server was created successfully
     assert!(true, "Server created successfully in test mode");
-    
+
     // In test mode, IPC operations are mocked, so we can't test the actual daemon connection
     // But we can verify the server initializes without errors
 }
 
 #[tokio::test]
 async fn test_daemon_ensure_running_separate_process() {
     use dialectic_mcp_server::daemon::run_daemon_with_prefix;
-    use tokio::sync::Barrier;
     use std::sync::Arc;
+    use tokio::sync::Barrier;
     use uuid::Uuid;
 
     // Initialize tracing for test output
@@ -52,11 +52,17 @@ async fn test_daemon_ensure_running_separate_process() {
     ready_barrier.wait().await;
 
     // Verify socket was created
-    assert!(std::path::Path::new(&socket_path).exists(), "Daemon should create socket file");
+    assert!(
+        std::path::Path::new(&socket_path).exists(),
+        "Daemon should create socket file"
+    );
 
     // Verify we can connect to the daemon
     let connection_result = tokio::net::UnixStream::connect(&socket_path).await;
-    assert!(connection_result.is_ok(), "Should be able to connect to daemon");
+    assert!(
+        connection_result.is_ok(),
+        "Should be able to connect to daemon"
+    );
 
     // Clean up
     daemon_handle.abort();