style: improve code formatting and readability across multiple files

Author: Theaxiom

cli/src/daemon/client.rs

@@ -18,9 +18,7 @@ use aegis_orchestrator_sdk::AgentManifest;
 #[derive(Deserialize)]
 #[serde(untagged)]
 enum WorkflowListResponse {
-    Wrapped {
-        workflows: Vec<serde_json::Value>,
-    },
+    Wrapped { workflows: Vec<serde_json::Value> },
     Bare(Vec<serde_json::Value>),
 }
 

cli/src/daemon/server.rs

@@ -122,8 +122,8 @@ pub async fn start_daemon(config_path: Option<PathBuf>, port: u16) -> Result<()>
         .context("Configuration validation failed")?;
 
     if let Some(smcp_gateway) = &config.spec.smcp_gateway {
-        let resolved_url = resolve_env_value(&smcp_gateway.url)
-            .unwrap_or_else(|_| smcp_gateway.url.clone());
+        let resolved_url =
+            resolve_env_value(&smcp_gateway.url).unwrap_or_else(|_| smcp_gateway.url.clone());
         tracing::info!(
             "Configured SMCP tooling gateway URL from node config: {}",
             resolved_url
@@ -1042,14 +1042,9 @@ pub async fn start_daemon(config_path: Option<PathBuf>, port: u16) -> Result<()>
             Arc::new(
                 aegis_orchestrator_core::infrastructure::web_tools::ReqwestWebToolAdapter::new(),
             ),
-            config
-                .spec
-                .smcp_gateway
-                .as_ref()
-                .map(|gateway| {
-                    resolve_env_value(&gateway.url)
-                        .unwrap_or_else(|_| gateway.url.clone())
-                }),
+            config.spec.smcp_gateway.as_ref().map(|gateway| {
+                resolve_env_value(&gateway.url).unwrap_or_else(|_| gateway.url.clone())
+            }),
         )
         .with_workflow_authoring(
             register_workflow_use_case.clone(),

orchestrator/core/src/application/tool_invocation_service.rs

@@ -130,7 +130,9 @@ impl ToolInvocationService {
             ))?;
 
         // 2. Middleware verifies signature and evaluates against SecurityContext
-        let args = self.smcp_middleware.verify_and_unwrap(&mut session, envelope)?;
+        let args = self
+            .smcp_middleware
+            .verify_and_unwrap(&mut session, envelope)?;
         let tool_name = envelope
             .extract_tool_name()
             .ok_or(SmcpSessionError::MalformedPayload(

orchestrator/core/src/domain/smcp_session.rs

@@ -241,7 +241,10 @@ impl SmcpSession {
     /// This is the **single enforcement point** for all SMCP policy checks. Every
     /// tool call from any agent must pass through this method before being forwarded
     /// to the MCP server. See ADR-035 §4 (Enforcement Architecture).
-    pub fn evaluate_call(&mut self, envelope: &impl EnvelopeVerifier) -> Result<(), SmcpSessionError> {
+    pub fn evaluate_call(
+        &mut self,
+        envelope: &impl EnvelopeVerifier,
+    ) -> Result<(), SmcpSessionError> {
         let now = Utc::now();
 
         // 1. Check session is active

orchestrator/core/src/infrastructure/repositories/postgres_execution.rs

@@ -303,13 +303,12 @@ impl ExecutionRepository for PostgresExecutionRepository {
                 ))),
             }?;
 
-            let input: ExecutionInput =
-                serde_json::from_value(input_val).map_err(|e| {
-                    RepositoryError::Serialization(format!(
-                        "Failed to deserialize execution input: {}",
-                        e
-                    ))
-                })?;
+            let input: ExecutionInput = serde_json::from_value(input_val).map_err(|e| {
+                RepositoryError::Serialization(format!(
+                    "Failed to deserialize execution input: {}",
+                    e
+                ))
+            })?;
             let iterations: Vec<Iteration> =
                 serde_json::from_value(iterations_val).map_err(|e| {
                     RepositoryError::Serialization(format!(
@@ -411,13 +410,12 @@ impl ExecutionRepository for PostgresExecutionRepository {
                 ))),
             }?;
 
-            let input: ExecutionInput =
-                serde_json::from_value(input_val).map_err(|e| {
-                    RepositoryError::Serialization(format!(
-                        "Failed to deserialize execution input: {}",
-                        e
-                    ))
-                })?;
+            let input: ExecutionInput = serde_json::from_value(input_val).map_err(|e| {
+                RepositoryError::Serialization(format!(
+                    "Failed to deserialize execution input: {}",
+                    e
+                ))
+            })?;
             let iterations: Vec<Iteration> =
                 serde_json::from_value(iterations_val).map_err(|e| {
                     RepositoryError::Serialization(format!(