src: lib: Reformat

Author: joaoantoniocardoso

src/lib/controls/onvif/camera.rs

@@ -3,7 +3,7 @@ use std::sync::Arc;
 use onvif::soap;
 use onvif_schema::transport;
 
-use anyhow::{anyhow, Context, Result};
+use anyhow::{Context, Result, anyhow};
 use serde::{Deserialize, Serialize};
 use tokio::sync::RwLock;
 use tracing::*;

src/lib/controls/onvif/manager.rs

@@ -5,7 +5,7 @@ use std::{
     time::Duration,
 };
 
-use anyhow::{anyhow, Context, Result};
+use anyhow::{Context, Result, anyhow};
 use futures::StreamExt as _;
 use onvif::soap::client::Credentials;
 use serde::Serialize;
@@ -205,7 +205,9 @@ impl Manager {
                                 Ok::<(), onvif::discovery::Error>(()) // Indicate success (discovery part)
                             }
                             Err(error) => {
-                                warn!("Task failed: ONVIF discovery failed on interface IP '{ip_addr}': {error:?}");
+                                warn!(
+                                    "Task failed: ONVIF discovery failed on interface IP '{ip_addr}': {error:?}"
+                                );
                                 Err(error)
                             }
                         }
@@ -222,15 +224,21 @@ impl Manager {
             for (iface_name, ip_addr, task_handle) in discovery_tasks {
                 match task_handle.await {
                     Ok(Ok(())) => {
-                        trace!("Discovery task for interface '{iface_name}' (IP: {ip_addr}) completed successfully.");
+                        trace!(
+                            "Discovery task for interface '{iface_name}' (IP: {ip_addr}) completed successfully."
+                        );
                     }
                     Ok(Err(discovery_error)) => {
                         // The task ran, but the discovery itself failed
-                        warn!("Discovery task for interface '{iface_name}' (IP: {ip_addr}) reported failure: {discovery_error:?}");
+                        warn!(
+                            "Discovery task for interface '{iface_name}' (IP: {ip_addr}) reported failure: {discovery_error:?}"
+                        );
                     }
                     Err(join_error) => {
                         // The task itself panicked or was cancelled
-                        error!("Discovery task for interface '{iface_name}' (IP: {ip_addr}) panicked or was cancelled: {join_error:?}");
+                        error!(
+                            "Discovery task for interface '{iface_name}' (IP: {ip_addr}) panicked or was cancelled: {join_error:?}"
+                        );
                     }
                 }
             }
@@ -278,9 +286,7 @@ impl Manager {
                         let ip_addr = IpAddr::V4(ipv4_network.ip());
                         trace!(
                             "Found suitable IPv4 address on interface '{}': {} (Subnet: {})",
-                            interface.name,
-                            ip_addr,
-                            ipv4_network
+                            interface.name, ip_addr, ipv4_network
                         );
                         // Return Some tuple, which will be collected and deduplicated by the HashSet
                         Some((interface.name.clone(), ip_addr))
@@ -448,7 +454,10 @@ impl Manager {
         trace!("Device credentials lookup result for UUID={device_uuid:?}: {credentials:?}");
 
         // Iterate through the device's URLs (e.g., different service endpoints)
-        trace!("Attempting to create OnvifCamera instances for device UUID={device_uuid:?}, IP={device_ip}, found {} URL(s)", device.urls.len());
+        trace!(
+            "Attempting to create OnvifCamera instances for device UUID={device_uuid:?}, IP={device_ip}, found {} URL(s)",
+            device.urls.len()
+        );
         for (index, url) in device.urls.iter().enumerate() {
             trace!(
                 "Processing URL {}/{} for device UUID={device_uuid:?}: {url}",
@@ -486,7 +495,9 @@ impl Manager {
             );
 
             let Some(streams_informations) = streams_information_option else {
-                error!("Failed getting stream information (streams_information is None) for camera created from URL: {url}");
+                error!(
+                    "Failed getting stream information (streams_information is None) for camera created from URL: {url}"
+                );
                 continue; // Move to the next URL
             };
 

src/lib/helper/develop.rs

@@ -1,6 +1,6 @@
 use std::collections::HashMap;
 
-use anyhow::{anyhow, Result};
+use anyhow::{Result, anyhow};
 use thirtyfour::prelude::*;
 use tokio::{process::Command, runtime::Runtime, sync::RwLock};
 use tracing::*;
@@ -255,8 +255,8 @@ async fn task(session_cycles: i32) -> Result<()> {
             // Ignore first cycle
             if current_cycle > 0 {
                 return Err(anyhow!(
-                "Thread leak detected on cycle {current_cycle}:\n{new_tasks_since_last_cycle:#?}\n{tasks_alive_from_last_cycle:#?}"
-            ));
+                    "Thread leak detected on cycle {current_cycle}:\n{new_tasks_since_last_cycle:#?}\n{tasks_alive_from_last_cycle:#?}"
+                ));
             }
         };
 
@@ -274,8 +274,12 @@ async fn task(session_cycles: i32) -> Result<()> {
         info!("Tasks alive since last cycle: {number_of_tasks_alive_from_last_cycle}");
 
         if number_of_new_tasks_since_last_cycle > 0 || number_of_tasks_alive_from_last_cycle > 0 {
-            info!("The following tasks were created since last cycle:\n{new_tasks_since_last_cycle:#?}");
-            info!("The following tasks were alive since last cycle:\n{tasks_alive_from_last_cycle:#?}")
+            info!(
+                "The following tasks were created since last cycle:\n{new_tasks_since_last_cycle:#?}"
+            );
+            info!(
+                "The following tasks were alive since last cycle:\n{tasks_alive_from_last_cycle:#?}"
+            )
         }
     }
 

src/lib/helper/threads.rs

@@ -43,9 +43,11 @@ pub fn process_tasks() -> HashMap<u32, String> {
 }
 
 pub fn start_thread_counter_thread() {
-    thread::spawn(move || loop {
-        info!("Number of child processes: {}", process_task_counter());
-        thread::sleep(Duration::from_secs(1));
+    thread::spawn(move || {
+        loop {
+            info!("Number of child processes: {}", process_task_counter());
+            thread::sleep(Duration::from_secs(1));
+        }
     });
 }
 

src/lib/logger/manager.rs

@@ -8,9 +8,9 @@ use tokio::sync::broadcast::{Receiver, Sender};
 use tracing::{metadata::LevelFilter, *};
 use tracing_log::LogTracer;
 use tracing_subscriber::{
+    EnvFilter, Layer,
     fmt::{self, MakeWriter},
     layer::SubscriberExt,
-    EnvFilter, Layer,
 };
 
 use crate::cli;

src/lib/mavlink/manager.rs

@@ -3,7 +3,7 @@ use std::{
     sync::{Arc, Mutex, RwLock},
 };
 
-use mavlink::{common::MavMessage, MavConnection, MavHeader};
+use mavlink::{MavConnection, MavHeader, common::MavMessage};
 
 use anyhow::{Context, Result};
 use tokio::sync::broadcast;
@@ -155,7 +155,9 @@ impl Manager {
                         );
                     }
                     Err(broadcast::error::RecvError::Lagged(samples)) => {
-                        warn!("Channel is lagged behind by {samples} messages. Expect degraded performance on the mavlink responsiviness.");
+                        warn!(
+                            "Channel is lagged behind by {samples} messages. Expect degraded performance on the mavlink responsiviness."
+                        );
                         continue;
                     }
                 };

src/lib/mavlink/mavlink_camera.rs

@@ -1,7 +1,7 @@
 use std::sync::Arc;
 
-use anyhow::{anyhow, Context, Result};
-use mavlink::{common::MavMessage, MavHeader};
+use anyhow::{Context, Result, anyhow};
+use mavlink::{MavHeader, common::MavMessage};
 use tokio::sync::broadcast;
 use tracing::*;
 use url::Url;
@@ -187,7 +187,9 @@ impl MavlinkCameraInner {
                 }
                 Ok(Message::ToBeSent(_)) => (),
                 Err(error) => {
-                    error!("Failed receiving from broadcast channel: {error:#?}. Resubscribing to the channel...");
+                    error!(
+                        "Failed receiving from broadcast channel: {error:#?}. Resubscribing to the channel..."
+                    );
 
                     receiver = receiver.resubscribe();
                 }
@@ -444,7 +446,10 @@ impl MavlinkCameraInner {
                 let result = match crate::video::video_source::reset_controls(source_string).await {
                     Ok(_) => mavlink::common::MavResult::MAV_RESULT_ACCEPTED,
                     Err(error) => {
-                        error!("Failed to reset {source_string:?} controls with its default values as {:#?}:{:#?}. Reason: {error:?}", camera.component.system_id, camera.component.component_id);
+                        error!(
+                            "Failed to reset {source_string:?} controls with its default values as {:#?}:{:#?}. Reason: {error:?}",
+                            camera.component.system_id, camera.component.component_id
+                        );
                         mavlink::common::MavResult::MAV_RESULT_DENIED
                     }
                 };
@@ -514,7 +519,10 @@ impl MavlinkCameraInner {
                     }
                     VIDEO_STREAM_INFORMATION_ID => {
                         if !validate_stream_id(camera, data.param2) {
-                            warn!("MAV_CMD_REQUEST_MESSAGE(VIDEO_STREAM_INFORMATION): unknown stream id: {:#?}.", data.param2);
+                            warn!(
+                                "MAV_CMD_REQUEST_MESSAGE(VIDEO_STREAM_INFORMATION): unknown stream id: {:#?}.",
+                                data.param2
+                            );
                             send_ack(
                                 camera,
                                 &sender,
@@ -622,7 +630,10 @@ impl MavlinkCameraInner {
         {
             Ok(_) => mavlink::common::ParamAck::PARAM_ACK_ACCEPTED,
             Err(error) => {
-                error!("Failed to set parameter {control_id:?} with value {control_value:?} for {:#?}. Reason: {error:?}", camera.component.component_id);
+                error!(
+                    "Failed to set parameter {control_id:?} with value {control_value:?} for {:#?}. Reason: {error:?}",
+                    camera.component.component_id
+                );
                 mavlink::common::ParamAck::PARAM_ACK_FAILED
             }
         };

src/lib/server/error.rs

@@ -1,4 +1,4 @@
-use actix_web::{http::StatusCode, ResponseError};
+use actix_web::{ResponseError, http::StatusCode};
 
 use paperclip::actix::api_v2_errors;
 use validator::ValidationErrors;

src/lib/server/manager.rs

@@ -1,11 +1,11 @@
 use actix_cors::Cors;
 use actix_extensible_rate_limit::{
-    backend::{memory::InMemoryBackend, SimpleInputFunctionBuilder},
     RateLimiter,
+    backend::{SimpleInputFunctionBuilder, memory::InMemoryBackend},
 };
-use actix_web::{error::JsonPayloadError, App, HttpRequest, HttpServer};
+use actix_web::{App, HttpRequest, HttpServer, error::JsonPayloadError};
 use paperclip::{
-    actix::{web, OpenApiExt},
+    actix::{OpenApiExt, web},
     v2::models::{Api, Info},
 };
 use tracing::*;

src/lib/server/pages.rs

@@ -1,12 +1,12 @@
 use actix_web::{
+    HttpRequest, HttpResponse,
     http::header,
     rt,
     web::{self, Json},
-    HttpRequest, HttpResponse,
 };
 use actix_ws::Message;
 use futures::StreamExt;
-use paperclip::actix::{api_v2_operation, Apiv2Schema, CreatedJson};
+use paperclip::actix::{Apiv2Schema, CreatedJson, api_v2_operation};
 use serde::{Deserialize, Serialize};
 use serde_json::json;
 use tokio::time::Duration;
@@ -149,7 +149,7 @@ pub struct UnauthenticateOnvifDeviceRequest {
 
 use std::{ffi::OsStr, path::Path};
 
-use include_dir::{include_dir, Dir};
+use include_dir::{Dir, include_dir};
 
 static DIST: Dir<'_> = include_dir!("frontend/dist");