cargo fmt

Author: martinzink

minifi_rust/extensions/minifi_rs_playground/src/processors/put_file.rs

@@ -1,6 +1,9 @@
 use crate::processors::put_file::relationships::{FAILURE, SUCCESS};
 use minifi_native::macros::ComponentIdentifier;
-use minifi_native::{FlowFileTransform, GetAttribute, GetControllerService, GetProperty, InputStream, Logger, MinifiError, Schedule, TransformedFlowFile, trace, warn, GetId};
+use minifi_native::{
+    FlowFileTransform, GetAttribute, GetControllerService, GetId, GetProperty, InputStream, Logger,
+    MinifiError, Schedule, TransformedFlowFile, trace, warn,
+};
 use std::path::{Path, PathBuf};
 use strum_macros::{Display, EnumString, IntoStaticStr, VariantNames};
 use walkdir::WalkDir;

minifi_rust/minifi_native/src/api/processor_wrappers/flow_file_transform.rs

@@ -1,4 +1,5 @@
 use crate::api::InputStream;
+use crate::api::flow_file::GetId;
 use crate::api::processor::Processor;
 use crate::api::processor_wrappers::utils::context_session_flowfile_bundle::ContextSessionFlowFileBundle;
 use crate::api::processor_wrappers::utils::flow_file_content::Content;
@@ -9,7 +10,6 @@ use crate::{
     ProcessContext, ProcessSession, Relationship, Schedule, info,
 };
 use std::collections::HashMap;
-use crate::api::flow_file::GetId;
 
 #[derive(Debug)]
 pub struct TransformedFlowFile<'a> {

minifi_rust/minifi_native/src/api/processor_wrappers/utils/context_session_flowfile_bundle.rs

@@ -1,10 +1,10 @@
 use crate::api::attribute::GetAttribute;
+use crate::api::flow_file::GetId;
 use crate::api::property::{GetControllerService, GetProperty};
 use crate::{
     ComponentIdentifier, EnableControllerService, MinifiError, ProcessContext, ProcessSession,
     Property,
 };
-use crate::api::flow_file::GetId;
 
 pub struct ContextSessionFlowFileBundle<'a, PC, PS>
 where
@@ -71,8 +71,10 @@ where
 }
 
 impl<'a, PC, PS> GetId for ContextSessionFlowFileBundle<'a, PC, PS>
-where PC: ProcessContext,
-    PS: ProcessSession<FlowFile = PC::FlowFile> {
+where
+    PC: ProcessContext,
+    PS: ProcessSession<FlowFile = PC::FlowFile>,
+{
     fn get_id(&self) -> Result<String, MinifiError> {
         if let Some(ff) = self.flow_file {
             self.session.get_flow_file_id(ff)

minifi_rust/minifi_native/src/lib.rs

@@ -37,8 +37,7 @@ pub use api::process_session::IoState;
 pub use api::attribute::{GetAttribute, OutputAttribute};
 
 pub use api::{
-    GetId, 
-    FlowFile, InputStream, OnTriggerResult, OutputStream, ProcessContext, ProcessSession,
+    FlowFile, GetId, InputStream, OnTriggerResult, OutputStream, ProcessContext, ProcessSession,
     ProcessorInputRequirement, Relationship, StandardPropertyValidator,
 };
 

minifi_rust/minifi_native_sys/build.rs

@@ -17,9 +17,7 @@ impl SDK {
             repo_root, canon
         );
 
-        let header_path = canon
-            .to_path_buf()
-            .join("minifi-api/include/minifi-api.h");
+        let header_path = canon.to_path_buf().join("minifi-api/include/minifi-api.h");
         let def_path = canon.to_path_buf().join("minifi-api/minifi-api.def");
         let behave_path = canon.to_path_buf().join("behave_framework");