format rust code

rust/agama-server/src/software/web.rs

@@ -14,7 +14,7 @@ use crate::{
 };
 use agama_lib::{
     error::ServiceError,
-    product::{Product, ProductClient, RegistrationRequirement, proxies::RegistrationProxy},
+    product::{proxies::RegistrationProxy, Product, ProductClient, RegistrationRequirement},
     software::{
         proxies::{Software1Proxy, SoftwareProductProxy},
         Pattern, SelectedBy, SoftwareClient, UnknownSelectedBy,
@@ -49,9 +49,7 @@ pub struct SoftwareConfig {
 /// It emits the Event::ProductChanged and Event::PatternsChanged events.
 ///
 /// * `connection`: D-Bus connection to listen for events.
-pub async fn software_streams(
-    dbus: zbus::Connection,
-) -> Result<Streams, Error> {
+pub async fn software_streams(dbus: zbus::Connection) -> Result<Streams, Error> {
     let result: Streams = vec![
         (
             "patterns_changed",
@@ -118,7 +116,8 @@ async fn patterns_changed_stream(
     Ok(stream)
 }
 
-async fn registration_requirement_changed_stream(dbus: zbus::Connection,
+async fn registration_requirement_changed_stream(
+    dbus: zbus::Connection,
 ) -> Result<impl Stream<Item = Event>, Error> {
     // TODO: move registration requirement to product in dbus and so just one event will be needed.
     let proxy = RegistrationProxy::new(&dbus).await?;
@@ -128,15 +127,18 @@ async fn registration_requirement_changed_stream(dbus: zbus::Connection,
         .then(|change| async move {
             if let Ok(id) = change.get().await {
                 // unwrap is safe as possible numbers is send by our controlled dbus
-                return Some(Event::RegistrationRequirementChanged { requirement: id.try_into().unwrap() });
+                return Some(Event::RegistrationRequirementChanged {
+                    requirement: id.try_into().unwrap(),
+                });
             }
             None
         })
         .filter_map(|e| e);
     Ok(stream)
 }
 
-async fn registration_email_changed_stream(dbus: zbus::Connection,
+async fn registration_email_changed_stream(
+    dbus: zbus::Connection,
 ) -> Result<impl Stream<Item = Event>, Error> {
     let proxy = RegistrationProxy::new(&dbus).await?;
     let stream = proxy
@@ -153,7 +155,8 @@ async fn registration_email_changed_stream(dbus: zbus::Connection,
     Ok(stream)
 }
 
-async fn registration_code_changed_stream(dbus: zbus::Connection,
+async fn registration_code_changed_stream(
+    dbus: zbus::Connection,
 ) -> Result<impl Stream<Item = Event>, Error> {
     let proxy = RegistrationProxy::new(&dbus).await?;
     let stream = proxy

rust/agama-server/src/users/web.rs

@@ -30,9 +30,7 @@ struct UsersState<'a> {
 /// It emits the Event::RootPasswordChange, Event::RootSSHKeyChanged and Event::FirstUserChanged events.
 ///
 /// * `connection`: D-Bus connection to listen for events.
-pub async fn users_streams(
-    dbus: zbus::Connection,
-) -> Result<Streams, Error> {
+pub async fn users_streams(dbus: zbus::Connection) -> Result<Streams, Error> {
     const FIRST_USER_ID: &str = "first_user";
     const ROOT_PASSWORD_ID: &str = "root_password";
     const ROOT_SSHKEY_ID: &str = "root_sshkey";

rust/agama-server/src/web/event.rs

@@ -1,7 +1,7 @@
 use crate::l10n::web::LocaleConfig;
 use agama_lib::{
-    manager::InstallationPhase, progress::Progress, software::SelectedBy, users::FirstUser,
-    product::RegistrationRequirement,
+    manager::InstallationPhase, product::RegistrationRequirement, progress::Progress,
+    software::SelectedBy, users::FirstUser,
 };
 use serde::Serialize;
 use std::collections::HashMap;
@@ -24,7 +24,7 @@ pub enum Event {
     ProductChanged {
         id: String,
     },
-    RegistrationRequirementChanged{
+    RegistrationRequirementChanged {
         requirement: RegistrationRequirement,
     },
     RegistrationChanged,