ref: correct fmt

Author: raphael-goetz

cli/src/analyser/mod.rs

@@ -472,23 +472,25 @@ impl Analyser {
 
         // Check if input identifier exists
         if let Some(identifier) = flow.input_type_identifier
-            && !self.data_type_identifier_exists(identifier.clone(), -1) {
-                self.reporter.add_report(Diagnose::new(
-                    name.clone(),
-                    original_definition.clone(),
-                    UndefinedDataTypeIdentifier { identifier },
-                ));
-            }
+            && !self.data_type_identifier_exists(identifier.clone(), -1)
+        {
+            self.reporter.add_report(Diagnose::new(
+                name.clone(),
+                original_definition.clone(),
+                UndefinedDataTypeIdentifier { identifier },
+            ));
+        }
 
         // Check if return identifier exists
         if let Some(identifier) = flow.return_type_identifier
-            && !self.data_type_identifier_exists(identifier.clone(), -1) {
-                self.reporter.add_report(Diagnose::new(
-                    name.clone(),
-                    original_definition.clone(),
-                    UndefinedDataTypeIdentifier { identifier },
-                ));
-            }
+            && !self.data_type_identifier_exists(identifier.clone(), -1)
+        {
+            self.reporter.add_report(Diagnose::new(
+                name.clone(),
+                original_definition.clone(),
+                UndefinedDataTypeIdentifier { identifier },
+            ));
+        }
 
         // Check if flow type identifier already exists
         for flow_type in &self.flow_types {

cli/src/command/download.rs

@@ -182,13 +182,14 @@ async fn convert_bytes_to_folder(bytes: Bytes, zip_path: &str) {
         } else {
             if let Some(p) = out_path.parent()
                 && !p.exists()
-                    && let Err(e) = fs::create_dir_all(p) {
-                        panic!(
-                            "Warning: Failed to create parent directory {}: {}",
-                            p.display(),
-                            e
-                        );
-                    }
+                && let Err(e) = fs::create_dir_all(p)
+            {
+                panic!(
+                    "Warning: Failed to create parent directory {}: {}",
+                    p.display(),
+                    e
+                );
+            }
 
             match File::create(&out_path) {
                 Ok(mut outfile) => {

cli/src/command/feature.rs

@@ -21,10 +21,11 @@ pub fn search_feature(name: Option<String>, path: Option<String>) {
         Some(feature_name) => parser
             .features
             .iter()
-            .filter(|f| f.name.to_lowercase() == feature_name.to_lowercase()).cloned()
+            .filter(|f| f.name.to_lowercase() == feature_name.to_lowercase())
+            .cloned()
             .collect::<Vec<Feature>>(),
     };
-    
+
     for feature in &features {
         let (flow_type_rows, data_type_rows, function_rows) = feature_table(feature);
 

cli/src/command/watch.rs

@@ -27,15 +27,18 @@ pub async fn watch_for_changes(path: Option<String>) {
     loop {
         if let Ok(Ok(event)) = rx.recv() {
             match event.kind {
-                EventKind::Modify(modify) => if let  ModifyKind::Data(_) = modify
-                    && last_run.elapsed() > Duration::from_millis(500) {
+                EventKind::Modify(modify) => {
+                    if let ModifyKind::Data(_) = modify
+                        && last_run.elapsed() > Duration::from_millis(500)
+                    {
                         default(String::from(
                             "\n\n\n--------------------------------------------------------------------------\n\n",
                         ));
                         info(String::from("Change detected! Regenerating report..."));
                         Analyser::new(dir_path.as_str()).report(false);
                         last_run = Instant::now();
-                    },
+                    }
+                }
                 EventKind::Remove(_) => {
                     if last_run.elapsed() > Duration::from_millis(500) {
                         default(String::from(

cli/src/table.rs

@@ -1,5 +1,5 @@
 use code0_definition_reader::parser::Feature;
-use tabled::{Tabled};
+use tabled::Tabled;
 use tucana::shared::{DefinitionDataType, FlowType, RuntimeFunctionDefinition};
 
 #[derive(Tabled)]