cli

commit 1ba0dc0838b08d5072a8c16084f1cf18480592bc
parent d51fbded21c5663d58b9768985fba147d227783e
Author: triesap <tyson@radroots.org>
Date:   Thu, 16 Apr 2026 16:24:58 +0000

runtime: format runtime modules

Diffstat:
M
src/runtime/daemon.rs
 | 
23
+++++++++++++----------
M
src/runtime/find.rs
 | 
2
+-
M
src/runtime/provider.rs
 | 
23
++++++++++++-----------
M
src/runtime/sync.rs
 | 
2
+-

4 files changed, 27 insertions(+), 23 deletions(-)
diff --git a/src/runtime/daemon.rs b/src/runtime/daemon.rs
@@ -423,10 +423,10 @@ pub fn bridge_listing_publish(
         options = options.with_signer_authority(sdk_signer_authority(signer_authority));
     }
 
-    let receipt = block_on_sdk(sdk.listing().publish_listing_via_radrootsd_with_options(
-        listing,
-        &options,
-    ))?
+    let receipt = block_on_sdk(
+        sdk.listing()
+            .publish_listing_via_radrootsd_with_options(listing, &options),
+    )?
     .map_err(map_sdk_publish_error)?;
 
     map_listing_publish_receipt(receipt, idempotency_key)
@@ -513,9 +513,8 @@ pub fn bridge_order_request(
 
     let sdk = actor_write_sdk_client(config)?;
     let session = SdkRadrootsdSignerSessionRef::from_session_id(signer_session_id.to_owned());
-    let mut options = radroots_sdk::SdkRadrootsdOrderRequestPublishOptions::from_signer_session_ref(
-        &session,
-    );
+    let mut options =
+        radroots_sdk::SdkRadrootsdOrderRequestPublishOptions::from_signer_session_ref(&session);
     if let Some(idempotency_key) = idempotency_key {
         options = options.with_idempotency_key(idempotency_key.to_owned());
     }
@@ -588,7 +587,9 @@ fn default_target(config: &RuntimeConfig) -> RpcTarget {
     }
 }
 
-fn actor_write_sdk_client(config: &RuntimeConfig) -> Result<radroots_sdk::RadrootsSdkClient, DaemonRpcError> {
+fn actor_write_sdk_client(
+    config: &RuntimeConfig,
+) -> Result<radroots_sdk::RadrootsSdkClient, DaemonRpcError> {
     let target = actor_write_target(config)?;
     let mut sdk_config = RadrootsSdkConfig::custom();
     sdk_config.transport = SdkTransportMode::Radrootsd;
@@ -624,7 +625,8 @@ fn map_listing_publish_receipt(
     receipt: radroots_sdk::SdkPublishReceipt,
     idempotency_key: Option<&str>,
 ) -> Result<BridgeListingPublishResult, DaemonRpcError> {
-    let radroots_sdk::SdkTransportReceipt::Radrootsd(transport_receipt) = receipt.transport_receipt else {
+    let radroots_sdk::SdkTransportReceipt::Radrootsd(transport_receipt) = receipt.transport_receipt
+    else {
         return Err(DaemonRpcError::InvalidResponse(
             "sdk listing publish returned a non-radrootsd transport receipt".to_owned(),
         ));
@@ -700,7 +702,8 @@ fn map_order_request_receipt(
     receipt: radroots_sdk::SdkPublishReceipt,
     idempotency_key: Option<&str>,
 ) -> Result<BridgeOrderRequestResult, DaemonRpcError> {
-    let radroots_sdk::SdkTransportReceipt::Radrootsd(transport_receipt) = receipt.transport_receipt else {
+    let radroots_sdk::SdkTransportReceipt::Radrootsd(transport_receipt) = receipt.transport_receipt
+    else {
         return Err(DaemonRpcError::InvalidResponse(
             "sdk order publish returned a non-radrootsd transport receipt".to_owned(),
         ));
diff --git a/src/runtime/find.rs b/src/runtime/find.rs
@@ -6,10 +6,10 @@ use crate::domain::runtime::{
     FindHyfView, FindPriceView, FindQuantityView, FindResultHyfView, FindResultProvenanceView,
     FindResultView, FindView, SyncFreshnessView,
 };
+use crate::runtime::RuntimeError;
 use crate::runtime::config::RuntimeConfig;
 use crate::runtime::hyf::{self, HyfQueryRewriteRequest, HyfRequestContext};
 use crate::runtime::sync::freshness_from_executor;
-use crate::runtime::RuntimeError;
 
 const FIND_SOURCE: &str = "local replica · local first";
 const FIND_HYF_SOURCE: &str = "hyf query_rewrite · local first";
diff --git a/src/runtime/provider.rs b/src/runtime/provider.rs
@@ -616,8 +616,10 @@ fn workflow_identity_path(repo_local_root: &Path) -> Result<PathBuf, String> {
                 repo_local_root.display()
             )
         })?;
-    let worker_namespace = RadrootsRuntimeNamespace::worker(WORKFLOW_PROVIDER_RUNTIME_ID)
-        .map_err(|error| format!("resolve worker namespace `{WORKFLOW_PROVIDER_RUNTIME_ID}`: {error}"))?;
+    let worker_namespace =
+        RadrootsRuntimeNamespace::worker(WORKFLOW_PROVIDER_RUNTIME_ID).map_err(|error| {
+            format!("resolve worker namespace `{WORKFLOW_PROVIDER_RUNTIME_ID}`: {error}")
+        })?;
     Ok(base_paths
         .namespaced(&worker_namespace)
         .secrets
@@ -638,7 +640,9 @@ fn loopback_endpoint_matches(configured: &str, canonical: &str) -> bool {
 
 fn loopback_host_matches(left: Option<&str>, right: Option<&str>) -> bool {
     match (left, right) {
-        (Some(left), Some(right)) => normalize_loopback_host(left) == normalize_loopback_host(right),
+        (Some(left), Some(right)) => {
+            normalize_loopback_host(left) == normalize_loopback_host(right)
+        }
         _ => false,
     }
 }
@@ -843,10 +847,7 @@ mod tests {
         let binding = sample_workflow_binding();
         let view = resolve_workflow_provider(&sample_config(vec![binding], false));
         assert_eq!(view.state, "unavailable");
-        assert_eq!(
-            view.provenance,
-            ProviderProvenance::ManagedDefault.as_str()
-        );
+        assert_eq!(view.provenance, ProviderProvenance::ManagedDefault.as_str());
         assert!(
             view.detail()
                 .contains("RADROOTS_CLI_PATHS_PROFILE=repo_local")
@@ -879,11 +880,11 @@ mod tests {
 
         let view = resolve_workflow_provider(&config);
         assert_eq!(view.state, "ready");
-        assert_eq!(
-            view.provenance,
-            ProviderProvenance::ManagedDefault.as_str()
+        assert_eq!(view.provenance, ProviderProvenance::ManagedDefault.as_str());
+        assert!(
+            view.detail()
+                .contains("canonical repo-local localhost workflow progression")
         );
-        assert!(view.detail().contains("canonical repo-local localhost workflow progression"));
     }
 
     #[test]
diff --git a/src/runtime/sync.rs b/src/runtime/sync.rs
@@ -10,8 +10,8 @@ use crate::domain::runtime::{
     SyncActionView, SyncFreshnessView, SyncQueueView, SyncStatusView, SyncWatchFrameView,
     SyncWatchView,
 };
-use crate::runtime::config::RuntimeConfig;
 use crate::runtime::RuntimeError;
+use crate::runtime::config::RuntimeConfig;
 
 const SYNC_SOURCE: &str = "local replica · local first";
 const RELAY_SETUP_ACTION: &str = "radroots relay ls --relay wss://relay.example.com";