Change: formatting

rust/models/src/scan.rs

@@ -23,4 +23,3 @@ pub struct Scan {
     /// List of VTs to execute for the target
     pub vts: Vec<VT>,
 }
-

rust/openvas/src/lib.rs

@@ -5,8 +5,8 @@
 pub mod cmd;
 pub mod config;
 pub mod error;
+pub mod openvas;
 pub mod openvas_redis;
 pub mod pref_handler;
 pub mod result_collector;
-pub mod openvas;
 pub use openvas::Scanner;

rust/openvas/src/result_collector.rs

@@ -269,7 +269,8 @@ mod tests {
                     .as_ref()
                     .lock()
                     .unwrap()
-                    .results.first()
+                    .results
+                    .first()
                     .unwrap()
             ),
             single_r

rust/openvasd/src/controller/context.rs

@@ -156,7 +156,11 @@ impl<S, DB> ContextBuilder<S, DB, NoScanner> {
 
 impl<S, DB> ContextBuilder<S, DB, Scanner<S>> {
     pub fn build(self) -> Context<S, DB> {
-        let scheduler = scheduling::Scheduler::new(self.scheduler_config.unwrap_or_default(), self.scanner.0, self.storage);
+        let scheduler = scheduling::Scheduler::new(
+            self.scheduler_config.unwrap_or_default(),
+            self.scanner.0,
+            self.storage,
+        );
         Context {
             response: self.response,
             scheduler,

rust/openvasd/src/controller/entry.rs

@@ -293,9 +293,11 @@ where
                                 Err(scheduling::Error::NotFound) => {
                                     Ok(ctx.response.not_found("scan", &id))
                                 }
-                                Err(scheduling::Error::QueueFull) => Ok(ctx
-                                    .response
-                                    .service_unavailable("Queue is already full. Try again later.")),
+                                Err(scheduling::Error::QueueFull) => {
+                                    Ok(ctx.response.service_unavailable(
+                                        "Queue is already full. Try again later.",
+                                    ))
+                                }
                                 Err(e) => Ok(ctx.response.internal_server_error(&e)),
                             }
                         }

rust/openvasd/src/controller/mod.rs

@@ -499,7 +499,7 @@ mod tests {
         let controller = Arc::new(ctx);
         let resp = post_scan(&scan, Arc::clone(&controller)).await;
 
-       assert_eq!(resp.status(), 201);
+        assert_eq!(resp.status(), 201);
 
         let req: Request<Full<Bytes>> = Request::builder()
             .uri("/scans")

rust/openvasd/src/main.rs

@@ -161,8 +161,6 @@ async fn main() -> Result<(), Box<dyn std::error::Error + Send + Sync>> {
             )
             .await
         }
-        config::ScannerType::Openvas => {
-            run(openvas::Scanner::default(), &config).await
-        }
+        config::ScannerType::Openvas => run(openvas::Scanner::default(), &config).await,
     }
 }