Cargo fmt

intent_brokering/examples/applications/cloud-object-detection/src/intent_provider.rs

@@ -13,8 +13,8 @@ use tracing::error;
 use crate::detection::DetectionLogic;
 
 use examples_common::{
-    intent_brokering::inspection::{fulfill, Entry},
     examples::detection::DetectRequest,
+    intent_brokering::inspection::{fulfill, Entry},
 };
 
 pub struct IntentProvider {

intent_brokering/examples/applications/dog-mode-logic/src/dog_mode_status.rs

@@ -5,11 +5,11 @@
 use anyhow::{anyhow, Error};
 use async_stream::try_stream;
 use examples_common::{
+    examples::proto::detection::{DetectRequest, DetectResponse},
     intent_brokering::{
-        api::{IntentBrokering, IntentBrokeringExt as _, GrpcIntentBrokering},
+        api::{GrpcIntentBrokering, IntentBrokering, IntentBrokeringExt as _},
         value::Value,
     },
-    examples::proto::detection::{DetectRequest, DetectResponse},
 };
 use futures::{stream::BoxStream, TryStreamExt};
 use intent_brokering_proto::common::Blob;
@@ -101,7 +101,10 @@ async fn detect_dog(
         }
     };
 
-    async fn image_contains_dog(intent_broker: &mut impl IntentBrokering, image: Value) -> Result<bool, Error> {
+    async fn image_contains_dog(
+        intent_broker: &mut impl IntentBrokering,
+        image: Value,
+    ) -> Result<bool, Error> {
         use prost::Message;
 
         let (media_type, bytes) = image

intent_brokering/examples/applications/dog-mode-logic/src/main.rs

@@ -10,7 +10,7 @@ use std::{
 use anyhow::{anyhow, Error};
 use dog_mode_status::stream_dog_mode_status;
 use examples_common::intent_brokering::{
-    api::{IntentBrokering, IntentBrokeringExt as _, GrpcIntentBrokering},
+    api::{GrpcIntentBrokering, IntentBrokering, IntentBrokeringExt as _},
     value::Value,
 };
 use tokio::{select, time::sleep_until};
@@ -165,7 +165,8 @@ pub async fn main() -> Result<(), Error> {
         )
         .await?;
 
-    let mut dog_mode_status_stream = stream_dog_mode_status(intent_broker.clone(), &mut state).await?;
+    let mut dog_mode_status_stream =
+        stream_dog_mode_status(intent_broker.clone(), &mut state).await?;
 
     let mut next_timer_wakeup = Instant::now() + TIMEOUT_EVALUATION_INTERVAL;
 
@@ -313,15 +314,19 @@ async fn run_dog_mode(
     // If the battery level fell below a threshold value, send a warning to the car owner.
     if previous_state.battery_level > LOW_BATTERY_LEVEL && state.battery_level <= LOW_BATTERY_LEVEL
     {
-        send_notification(intent_broker, "The battery is low, please return to the car.", state).await?;
-        set_ui_message(intent_broker, "The battery is low, the animal is in danger.", state).await?;
+        send_notification(intent_broker, "The battery is low, please return to the car.", state)
+            .await?;
+        set_ui_message(intent_broker, "The battery is low, the animal is in danger.", state)
+            .await?;
     }
 
     async fn activate_air_conditioning(
         intent_broker: &mut impl IntentBrokering,
         value: bool,
     ) -> Result<(), Error> {
-        _ = intent_broker.invoke(VDT_NAMESPACE, ACTIVATE_AIR_CONDITIONING_ID, [value.into()]).await?;
+        _ = intent_broker
+            .invoke(VDT_NAMESPACE, ACTIVATE_AIR_CONDITIONING_ID, [value.into()])
+            .await?;
         Ok(())
     }
 

intent_brokering/examples/applications/local-object-detection/src/intent_provider.rs

@@ -13,8 +13,8 @@ use tracing::error;
 use crate::detection::DetectionLogic;
 
 use examples_common::{
-    intent_brokering::inspection::{fulfill, Entry},
     examples::detection::DetectRequest,
+    intent_brokering::inspection::{fulfill, Entry},
 };
 
 pub struct IntentProvider {

intent_brokering/examples/applications/lt-consumer/src/main.rs

@@ -5,7 +5,7 @@
 use bollard::{container::StatsOptions, Docker};
 use examples_common::intent_brokering::{
     self,
-    api::{IntentBrokering, GrpcIntentBrokering},
+    api::{GrpcIntentBrokering, IntentBrokering},
     value::Value,
 };
 use futures_util::stream::StreamExt;
@@ -109,7 +109,8 @@ async fn wain() -> Result<(), Error> {
 
                 // Only the namespace matters when invoking. The load testing
                 // provider will not take action based on payload or command.
-                let sent_value = intent_broker.invoke(LT_PROVIDER_NAMESPACE, "foo", [Value::NULL]).await;
+                let sent_value =
+                    intent_broker.invoke(LT_PROVIDER_NAMESPACE, "foo", [Value::NULL]).await;
 
                 if let Some(request_instant) = now {
                     let latency = request_instant.elapsed().as_millis() as _;

intent_brokering/examples/applications/simple-provider/src/main.rs

@@ -40,10 +40,11 @@ async fn connect_intent_brokering_client(
     client: &mut Option<IntentBrokeringServiceClient<Channel>>,
     intent_brokering_url: String,
 ) -> Result<(), Error> {
-    *client = Some(IntentBrokeringServiceClient::connect(intent_brokering_url).await.map_err(|e| {
-        *client = None; // Set client back to None on error.
-        Error::from_error("Could not connect to client", Box::new(e))
-    })?);
+    *client =
+        Some(IntentBrokeringServiceClient::connect(intent_brokering_url).await.map_err(|e| {
+            *client = None; // Set client back to None on error.
+            Error::from_error("Could not connect to client", Box::new(e))
+        })?);
 
     Ok(())
 }
@@ -99,7 +100,9 @@ async fn register_and_announce_once(
             .expect("No client found")
             .register(register_req.clone())
             .await
-            .map_err(|e| Error::from_error("Error registering with IntentBrokering.", Box::new(e)))?;
+            .map_err(|e| {
+                Error::from_error("Error registering with IntentBrokering.", Box::new(e))
+            })?;
     }
 
     Ok(())

intent_brokering/examples/common/src/intent_brokering/api.rs

@@ -88,8 +88,8 @@ pub struct GrpcIntentBrokering {
 
 impl GrpcIntentBrokering {
     pub async fn connect() -> Result<Self, Error> {
-        let intent_brokering_url =
-            env::var(INTENT_BROKER_URL_KEY).unwrap_or_else(|_| DEFAULT_INTENT_BROKER_URL.to_string());
+        let intent_brokering_url = env::var(INTENT_BROKER_URL_KEY)
+            .unwrap_or_else(|_| DEFAULT_INTENT_BROKER_URL.to_string());
         let client = IntentBrokeringServiceClient::connect(intent_brokering_url)
             .await
             .map_err_with("Connecting to IntentBrokering failed.")?;

intent_brokering/examples/common/src/lib.rs

@@ -2,6 +2,6 @@
 // Licensed under the MIT license.
 // SPDX-License-Identifier: MIT
 
-pub mod intent_brokering;
 pub mod examples;
+pub mod intent_brokering;
 pub mod url;

intent_brokering/src/lib.rs

@@ -2,10 +2,10 @@
 // Licensed under the MIT license.
 // SPDX-License-Identifier: MIT
 
-pub mod intent_brokering_grpc;
 mod connection_provider;
 mod execution;
 mod intent_broker;
+pub mod intent_brokering_grpc;
 pub use intent_broker::IntentBroker;
 pub mod registry;
 pub mod streaming;

intent_brokering/tests/chariott_integration.rs

@@ -15,7 +15,9 @@ use intent_brokering::registry::{
     ExecutionLocality, IntentConfiguration, IntentKind, ServiceConfiguration, ServiceId,
 };
 use intent_brokering::streaming::StreamingEss;
-use intent_brokering::{intent_brokering_grpc::IntentBrokeringServer, registry::Registry, IntentBroker};
+use intent_brokering::{
+    intent_brokering_grpc::IntentBrokeringServer, registry::Registry, IntentBroker,
+};
 use intent_brokering_common::error::{Error, ResultExt as _};
 use intent_brokering_common::shutdown::RouterExt as _;
 use intent_brokering_proto::{

intent_brokering/tests/registry-e2e.rs

@@ -6,7 +6,7 @@ use std::time::Duration;
 
 use common::get_uuid;
 use examples_common::intent_brokering::{
-    api::{IntentBrokering, IntentBrokeringExt as _, GrpcIntentBrokering},
+    api::{GrpcIntentBrokering, IntentBrokering, IntentBrokeringExt as _},
     registration::Builder as RegistrationBuilder,
 };
 use intent_brokering_proto::runtime::{
@@ -37,7 +37,8 @@ async fn expired_registrations_are_pruned_after_ttl() -> Result<(), anyhow::Erro
     builder.register_once(&mut None, true).await?;
 
     let initial_entries = intent_broker.inspect("system.registry", namespace.clone()).await?;
-    let ttl = Duration::from_secs(env!("INTENT_BROKERING_REGISTRY_TTL_SECS").parse::<u64>().unwrap() + 1);
+    let ttl =
+        Duration::from_secs(env!("INTENT_BROKERING_REGISTRY_TTL_SECS").parse::<u64>().unwrap() + 1);
     sleep(ttl).await;
     let entries = intent_broker.inspect("system.registry", namespace).await?;
 

intent_brokering/tests/store-e2e.rs

@@ -6,7 +6,7 @@ use std::{collections::HashSet, error::Error as _, time::Duration};
 
 use common::get_uuid;
 use examples_common::intent_brokering::{
-    api::{IntentBrokering, IntentBrokeringExt, Event, GrpcIntentBrokering},
+    api::{Event, GrpcIntentBrokering, IntentBrokering, IntentBrokeringExt},
     value::Value,
 };
 use intent_brokering_common::error::Error;