Fix Rust code formatting using cargo fmt

Copilot · 0xrinegade · Copilot · commit ae6d45a46479 · 2025-06-21T11:49:12.000Z
Co-authored-by: 0xrinegade &lt;101195284+0xrinegade@users.noreply.github.com&gt;
diff --git a/rust/src/agent/mod.rs b/rust/src/agent/mod.rs
@@ -93,7 +93,7 @@ pub enum AgentRegistryInstruction {
 /// Maximum length constants (from the on-chain program)
 /// These limits are enforced by the Solana AI Registries program to ensure
 /// efficient storage and consistent behavior across the network.
-/// 
+///
 /// **References:**
 /// - On-chain program constraints: [Agent Registry Program Documentation](https://docs.solana-ai-registries.org/program/agent-registry)
 /// - Program source: `programs/agent-registry/src/lib.rs`
@@ -337,15 +337,15 @@ impl From<AgentPatch> for AgentUpdateDetailsInput {
             clear_provider_url: patch.clear_provider_url,
             documentation_url: patch.documentation_url,
             clear_documentation_url: patch.clear_documentation_url,
-            service_endpoints: patch.service_endpoints.map(|endpoints| {
-                endpoints.into_iter().map(|e| e.into()).collect()
-            }),
+            service_endpoints: patch
+                .service_endpoints
+                .map(|endpoints| endpoints.into_iter().map(|e| e.into()).collect()),
             capabilities_flags: patch.capabilities_flags,
             supported_input_modes: patch.supported_input_modes,
             supported_output_modes: patch.supported_output_modes,
-            skills: patch.skills.map(|skills| {
-                skills.into_iter().map(|s| s.into()).collect()
-            }),
+            skills: patch
+                .skills
+                .map(|skills| skills.into_iter().map(|s| s.into()).collect()),
             security_info_uri: patch.security_info_uri,
             clear_security_info_uri: patch.clear_security_info_uri,
             aea_address: patch.aea_address,
@@ -762,7 +762,11 @@ pub fn create_register_agent_instruction(
         provider_name: args.provider_name,
         provider_url: args.provider_url,
         documentation_url: args.documentation_url,
-        service_endpoints: args.service_endpoints.into_iter().map(|e| e.into()).collect(),
+        service_endpoints: args
+            .service_endpoints
+            .into_iter()
+            .map(|e| e.into())
+            .collect(),
         capabilities_flags: args.capabilities_flags,
         supported_input_modes: args.supported_input_modes,
         supported_output_modes: args.supported_output_modes,
@@ -775,8 +779,9 @@ pub fn create_register_agent_instruction(
         tags: args.tags,
     };
 
-    let data = instruction.try_to_vec()
-        .map_err(|e| SdkError::SerializationError(format!("Failed to serialize instruction: {}", e)))?;
+    let data = instruction.try_to_vec().map_err(|e| {
+        SdkError::SerializationError(format!("Failed to serialize instruction: {}", e))
+    })?;
 
     Ok(Instruction {
         program_id: *program_id,
@@ -803,8 +808,9 @@ pub fn create_update_agent_instruction(
         details: patch.into(),
     };
 
-    let data = instruction.try_to_vec()
-        .map_err(|e| SdkError::SerializationError(format!("Failed to serialize instruction: {}", e)))?;
+    let data = instruction.try_to_vec().map_err(|e| {
+        SdkError::SerializationError(format!("Failed to serialize instruction: {}", e))
+    })?;
 
     Ok(Instruction {
         program_id: *program_id,
@@ -827,12 +833,11 @@ pub fn create_update_agent_status_instruction(
         AccountMeta::new_readonly(*owner, true),
     ];
 
-    let instruction = AgentRegistryInstruction::UpdateAgentStatus {
-        new_status: status,
-    };
+    let instruction = AgentRegistryInstruction::UpdateAgentStatus { new_status: status };
 
-    let data = instruction.try_to_vec()
-        .map_err(|e| SdkError::SerializationError(format!("Failed to serialize instruction: {}", e)))?;
+    let data = instruction.try_to_vec().map_err(|e| {
+        SdkError::SerializationError(format!("Failed to serialize instruction: {}", e))
+    })?;
 
     Ok(Instruction {
         program_id: *program_id,
@@ -856,8 +861,9 @@ pub fn create_deregister_agent_instruction(
 
     let instruction = AgentRegistryInstruction::DeregisterAgent;
 
-    let data = instruction.try_to_vec()
-        .map_err(|e| SdkError::SerializationError(format!("Failed to serialize instruction: {}", e)))?;
+    let data = instruction.try_to_vec().map_err(|e| {
+        SdkError::SerializationError(format!("Failed to serialize instruction: {}", e))
+    })?;
 
     Ok(Instruction {
         program_id: *program_id,
diff --git a/rust/src/client.rs b/rust/src/client.rs
@@ -350,7 +350,7 @@ mod tests {
 }
 
 /// Centralized helper for deserializing account data with Anchor discriminator handling
-/// 
+///
 /// This function abstracts the common pattern of:
 /// 1. Validating minimum data length (8 bytes for discriminator)
 /// 2. Skipping the 8-byte Anchor discriminator  
@@ -367,7 +367,7 @@ where
 
     // Skip the 8-byte discriminator used by Anchor
     let account_data = &data[8..];
-    
+
     // Deserialize with type-specific error message
     T::try_from_slice(account_data).map_err(|e| {
         SdkError::DeserializationError(format!("Failed to deserialize {}: {}", type_name, e))
diff --git a/rust/src/mcp/mod.rs b/rust/src/mcp/mod.rs
@@ -92,7 +92,7 @@ pub enum McpServerRegistryInstruction {
 /// Maximum length constants (from the on-chain program)
 /// These limits are enforced by the Solana AI Registries program to ensure
 /// efficient storage and consistent behavior across the network.
-/// 
+///
 /// **References:**
 /// - On-chain program constraints: [MCP Server Registry Program Documentation](https://docs.solana-ai-registries.org/program/mcp-registry)
 /// - Program source: `programs/mcp-server-registry/src/lib.rs`
@@ -331,15 +331,15 @@ impl From<McpServerPatch> for McpServerUpdateDetailsInput {
             supports_resources: patch.supports_resources,
             supports_tools: patch.supports_tools,
             supports_prompts: patch.supports_prompts,
-            onchain_tool_definitions: patch.onchain_tool_definitions.map(|tools| {
-                tools.into_iter().map(|t| t.into()).collect()
-            }),
-            onchain_resource_definitions: patch.onchain_resource_definitions.map(|resources| {
-                resources.into_iter().map(|r| r.into()).collect()
-            }),
-            onchain_prompt_definitions: patch.onchain_prompt_definitions.map(|prompts| {
-                prompts.into_iter().map(|p| p.into()).collect()
-            }),
+            onchain_tool_definitions: patch
+                .onchain_tool_definitions
+                .map(|tools| tools.into_iter().map(|t| t.into()).collect()),
+            onchain_resource_definitions: patch
+                .onchain_resource_definitions
+                .map(|resources| resources.into_iter().map(|r| r.into()).collect()),
+            onchain_prompt_definitions: patch
+                .onchain_prompt_definitions
+                .map(|prompts| prompts.into_iter().map(|p| p.into()).collect()),
             full_capabilities_uri: patch.full_capabilities_uri,
             clear_full_capabilities_uri: patch.clear_full_capabilities_uri,
             tags: patch.tags,
@@ -726,15 +726,28 @@ pub fn create_register_mcp_server_instruction(
         supports_resources: args.supports_resources,
         supports_tools: args.supports_tools,
         supports_prompts: args.supports_prompts,
-        onchain_tool_definitions: args.onchain_tool_definitions.into_iter().map(|t| t.into()).collect(),
-        onchain_resource_definitions: args.onchain_resource_definitions.into_iter().map(|r| r.into()).collect(),
-        onchain_prompt_definitions: args.onchain_prompt_definitions.into_iter().map(|p| p.into()).collect(),
+        onchain_tool_definitions: args
+            .onchain_tool_definitions
+            .into_iter()
+            .map(|t| t.into())
+            .collect(),
+        onchain_resource_definitions: args
+            .onchain_resource_definitions
+            .into_iter()
+            .map(|r| r.into())
+            .collect(),
+        onchain_prompt_definitions: args
+            .onchain_prompt_definitions
+            .into_iter()
+            .map(|p| p.into())
+            .collect(),
         full_capabilities_uri: args.full_capabilities_uri,
         tags: args.tags,
     };
 
-    let data = instruction.try_to_vec()
-        .map_err(|e| SdkError::SerializationError(format!("Failed to serialize instruction: {}", e)))?;
+    let data = instruction.try_to_vec().map_err(|e| {
+        SdkError::SerializationError(format!("Failed to serialize instruction: {}", e))
+    })?;
 
     Ok(Instruction {
         program_id: *program_id,
@@ -761,8 +774,9 @@ pub fn create_update_mcp_server_instruction(
         details: patch.into(),
     };
 
-    let data = instruction.try_to_vec()
-        .map_err(|e| SdkError::SerializationError(format!("Failed to serialize instruction: {}", e)))?;
+    let data = instruction.try_to_vec().map_err(|e| {
+        SdkError::SerializationError(format!("Failed to serialize instruction: {}", e))
+    })?;
 
     Ok(Instruction {
         program_id: *program_id,
@@ -785,12 +799,11 @@ pub fn create_update_mcp_server_status_instruction(
         AccountMeta::new_readonly(*owner, true),
     ];
 
-    let instruction = McpServerRegistryInstruction::UpdateMcpServerStatus {
-        new_status: status,
-    };
+    let instruction = McpServerRegistryInstruction::UpdateMcpServerStatus { new_status: status };
 
-    let data = instruction.try_to_vec()
-        .map_err(|e| SdkError::SerializationError(format!("Failed to serialize instruction: {}", e)))?;
+    let data = instruction.try_to_vec().map_err(|e| {
+        SdkError::SerializationError(format!("Failed to serialize instruction: {}", e))
+    })?;
 
     Ok(Instruction {
         program_id: *program_id,
@@ -814,8 +827,9 @@ pub fn create_deregister_mcp_server_instruction(
 
     let instruction = McpServerRegistryInstruction::DeregisterMcpServer;
 
-    let data = instruction.try_to_vec()
-        .map_err(|e| SdkError::SerializationError(format!("Failed to serialize instruction: {}", e)))?;
+    let data = instruction.try_to_vec().map_err(|e| {
+        SdkError::SerializationError(format!("Failed to serialize instruction: {}", e))
+    })?;
 
     Ok(Instruction {
         program_id: *program_id,
diff --git a/rust/src/payments/common.rs b/rust/src/payments/common.rs
@@ -10,7 +10,7 @@ use solana_sdk::{
 
 /// Payment system constants and configuration
 /// These values define the economic parameters of the Solana AI Registries payment system.
-/// 
+///
 /// **References:**
 /// - Payment program constraints: [Payment System Documentation](https://docs.solana-ai-registries.org/payment-system)
 /// - Program source: `programs/payment-system/src/lib.rs`
diff --git a/rust/tests/integration.rs b/rust/tests/integration.rs
@@ -79,7 +79,8 @@ fn test_deserialize_helper_with_valid_data() {
     data_with_discriminator.extend_from_slice(&serialized);
 
     // Test deserialization
-    let result: SdkResult<TestData> = deserialize_account_data(&data_with_discriminator, "test data");
+    let result: SdkResult<TestData> =
+        deserialize_account_data(&data_with_discriminator, "test data");
     assert!(result.is_ok());
     let deserialized = result.unwrap();
     assert_eq!(deserialized.value, 12345);
@@ -127,15 +128,18 @@ fn test_service_endpoint_validation() {
     let builder = AgentBuilder::new("test-agent", "Test Agent");
 
     // Test valid endpoint
-    let result = builder
-        .add_service_endpoint("https", "https://example.com/api", true);
+    let result = builder.add_service_endpoint("https", "https://example.com/api", true);
     assert!(result.is_ok());
 
     // Test multiple default endpoints (should fail on build)
     let builder = AgentBuilder::new("test-agent", "Test Agent");
-    let builder = builder.add_service_endpoint("https", "https://example.com/api", true).unwrap();
-    let builder = builder.add_service_endpoint("http", "http://example.com/api", true).unwrap();
-    
+    let builder = builder
+        .add_service_endpoint("https", "https://example.com/api", true)
+        .unwrap();
+    let builder = builder
+        .add_service_endpoint("http", "http://example.com/api", true)
+        .unwrap();
+
     // The error should occur when we try to build, not when adding endpoints
     let result = builder.build();
     assert!(result.is_err());
@@ -163,7 +167,7 @@ fn test_skill_validation() {
         assert!(result.is_ok());
         builder = result.unwrap();
     }
-    
+
     // The error should occur when we try to build, not when adding skills
     let result = builder.build();
     assert!(result.is_err());
@@ -183,7 +187,9 @@ struct MockStruct {
 
 #[test]
 fn test_priority_multiplier_validation() {
-    use solana_ai_registries::payments::common::{MAX_PRIORITY_MULTIPLIER, MIN_PRIORITY_MULTIPLIER};
+    use solana_ai_registries::payments::common::{
+        MAX_PRIORITY_MULTIPLIER, MIN_PRIORITY_MULTIPLIER,
+    };
 
     // Test valid range
     assert!(MIN_PRIORITY_MULTIPLIER <= MAX_PRIORITY_MULTIPLIER);
@@ -233,4 +239,4 @@ fn test_constant_documentation_exists() {
     assert_eq!(A2AMPL_DECIMALS, 9);
     assert_eq!(A2AMPL_BASE_UNIT, 1_000_000_000);
     assert!(AGENT_REGISTRATION_FEE > MCP_REGISTRATION_FEE);
-}
+}
