Fix federation operator formatting

Author: enricopiovesan

crates/traverse-cli/src/federation_operator.rs

@@ -2,9 +2,9 @@ use serde::Deserialize;
 use std::fs;
 use std::path::{Path, PathBuf};
 use traverse_registry::{
-    export_peer_state, FederationFailure, FederationPeer, FederationRegistry,
-    FederationStatusSummary, FederationSyncOutcome, FederationSyncStatus, FederationTrustState,
-    RegistryScope, TrustRecord,
+    FederationFailure, FederationPeer, FederationRegistry, FederationStatusSummary,
+    FederationSyncOutcome, FederationSyncStatus, FederationTrustState, RegistryScope, TrustRecord,
+    export_peer_state,
 };
 
 #[derive(Debug, Clone, Deserialize)]
@@ -75,21 +75,32 @@ struct LoadedFederationContext {
 
 pub fn render_federation_peers(manifest_path: &Path) -> Result<String, String> {
     let context = load_context(manifest_path)?;
-    Ok(render_peer_listing(&context.federation.status_summary(), &context.federation))
+    Ok(render_peer_listing(
+        &context.federation.status_summary(),
+        &context.federation,
+    ))
 }
 
 pub fn render_federation_sync(manifest_path: &Path) -> Result<String, String> {
     let mut context = load_context(manifest_path)?;
     let outcome = sync_context(&mut context)?;
-    Ok(render_sync_report(&context.federation.status_summary(), &context.federation, &outcome))
+    Ok(render_sync_report(
+        &context.federation.status_summary(),
+        &context.federation,
+        &outcome,
+    ))
 }
 
 pub fn render_federation_status(manifest_path: &Path) -> Result<String, String> {
     let mut context = load_context(manifest_path)?;
     let outcome = sync_context(&mut context)?;
     Ok(format!(
         "{}\n{}",
-        render_sync_report(&context.federation.status_summary(), &context.federation, &outcome),
+        render_sync_report(
+            &context.federation.status_summary(),
+            &context.federation,
+            &outcome
+        ),
         render_peer_listing(&context.federation.status_summary(), &context.federation)
     ))
 }
@@ -136,14 +147,20 @@ fn sync_context(context: &mut LoadedFederationContext) -> Result<FederationSyncO
         .map_err(render_federation_failure)
 }
 
-fn render_peer_listing(summary: &FederationStatusSummary, federation: &FederationRegistry) -> String {
+fn render_peer_listing(
+    summary: &FederationStatusSummary,
+    federation: &FederationRegistry,
+) -> String {
     let mut lines = vec![
         format!("peer_count: {}", summary.peer_count),
         format!("trusted_peer_count: {}", summary.trusted_peer_count),
         format!("last_sync_outcome: {:?}", summary.last_sync_outcome).to_lowercase(),
         format!(
             "sync_age: {}",
-            summary.sync_age.clone().unwrap_or_else(|| "none".to_string())
+            summary
+                .sync_age
+                .clone()
+                .unwrap_or_else(|| "none".to_string())
         ),
         format!("conflict_count: {}", summary.conflict_count),
         format!("blocked_entries: {}", summary.blocked_entries),
@@ -153,19 +170,15 @@ fn render_peer_listing(summary: &FederationStatusSummary, federation: &Federatio
     for peer in federation.list_peers() {
         lines.push(format!("peer_id: {}", peer.peer_id));
         lines.push(format!("display_name: {}", peer.display_name));
-        lines.push(format!(
-            "trust_state: {:?}",
-            peer.trust_state
-        ).to_lowercase());
+        lines.push(format!("trust_state: {:?}", peer.trust_state).to_lowercase());
         lines.push(format!("sync_enabled: {}", peer.sync_enabled));
         lines.push(format!(
             "last_sync_at: {}",
-            peer.last_sync_at.clone().unwrap_or_else(|| "none".to_string())
+            peer.last_sync_at
+                .clone()
+                .unwrap_or_else(|| "none".to_string())
         ));
-        lines.push(format!(
-            "last_sync_status: {:?}",
-            peer.last_sync_status
-        ).to_lowercase());
+        lines.push(format!("last_sync_status: {:?}", peer.last_sync_status).to_lowercase());
         lines.push(format!(
             "visible_registry_scopes: {}",
             peer.visible_registry_scopes
@@ -376,11 +389,7 @@ impl TrustRecordManifest {
         Ok(TrustRecord {
             peer_id: self.peer_id,
             trust_model: self.trust_model,
-            allowed_scopes: self
-                .allowed_scopes
-                .into_iter()
-                .map(Into::into)
-                .collect(),
+            allowed_scopes: self.allowed_scopes.into_iter().map(Into::into).collect(),
             approved_spec_refs: self.approved_spec_refs,
             approved_at: self.approved_at,
             revoked_at: self.revoked_at,

crates/traverse-cli/src/main.rs

@@ -4,7 +4,9 @@ mod federation_operator;
 
 use agent_packages::load_agent_package;
 use browser_adapter::serve_local_browser_adapter;
-use federation_operator::{render_federation_peers, render_federation_status, render_federation_sync};
+use federation_operator::{
+    render_federation_peers, render_federation_status, render_federation_sync,
+};
 use serde_json::Value;
 use std::env;
 use std::fs;