ref: cargo fmt

Author: raphael-goetz

crates/cli/src/command/mod.rs

@@ -1,6 +1,6 @@
-pub mod search;
 pub mod download;
 pub mod feature;
+pub mod push;
 pub mod report;
+pub mod search;
 pub mod watch;
-pub mod push;

crates/cli/src/command/push/auth.rs

@@ -12,4 +12,4 @@ pub fn get_authorization_metadata(token: &str) -> MetadataMap {
     let mut map = MetadataMap::new();
     map.insert("authorization", metadata_value);
     map
-}
+}

crates/cli/src/command/push/data_type_client_impl.rs

@@ -27,16 +27,11 @@ impl SagittariusDataTypeServiceClient {
         Self { client, token }
     }
 
-    pub async fn update_data_types(
-        &mut self,
-        data_types: Vec<DefinitionDataType>,
-    ) {
+    pub async fn update_data_types(&mut self, data_types: Vec<DefinitionDataType>) {
         let request = Request::from_parts(
             get_authorization_metadata(&self.token),
             Extensions::new(),
-            SagittariusDataTypeUpdateRequest {
-                data_types,
-            },
+            SagittariusDataTypeUpdateRequest { data_types },
         );
 
         match self.client.update(request).await {

crates/cli/src/command/push/flow_type_client_impl.rs

@@ -1,10 +1,10 @@
+use crate::command::push::auth::get_authorization_metadata;
 use tonic::Extensions;
 use tonic::Request;
 use tonic::transport::Channel;
 use tucana::sagittarius::FlowTypeUpdateRequest as SagittariusFlowTypeUpdateRequest;
 use tucana::sagittarius::flow_type_service_client::FlowTypeServiceClient;
 use tucana::shared::FlowType;
-use crate::command::push::auth::get_authorization_metadata;
 
 pub struct SagittariusFlowTypeServiceClient {
     client: FlowTypeServiceClient<Channel>,
@@ -27,19 +27,14 @@ impl SagittariusFlowTypeServiceClient {
         Self { client, token }
     }
 
-    pub async fn update_flow_types(
-        &mut self,
-        flow_types: Vec<FlowType>,
-    ) {
+    pub async fn update_flow_types(&mut self, flow_types: Vec<FlowType>) {
         let request = Request::from_parts(
             get_authorization_metadata(&self.token),
             Extensions::new(),
-            SagittariusFlowTypeUpdateRequest {
-                flow_types,
-            },
+            SagittariusFlowTypeUpdateRequest { flow_types },
         );
 
-       match self.client.update(request).await {
+        match self.client.update(request).await {
             Ok(response) => {
                 log::info!(
                     "Successfully transferred FlowTypes. Did Sagittarius updated them? {:?}",
@@ -51,4 +46,4 @@ impl SagittariusFlowTypeServiceClient {
             }
         };
     }
-}
+}

crates/cli/src/command/push/function_client_impl.rs

@@ -1,10 +1,10 @@
+use crate::command::push::auth::get_authorization_metadata;
 use tonic::Extensions;
 use tonic::Request;
 use tonic::transport::Channel;
 use tucana::sagittarius::RuntimeFunctionDefinitionUpdateRequest as SagittariusRuntimeFunctionUpdateRequest;
 use tucana::sagittarius::runtime_function_definition_service_client::RuntimeFunctionDefinitionServiceClient;
 use tucana::shared::RuntimeFunctionDefinition;
-use crate::command::push::auth::get_authorization_metadata;
 
 pub struct SagittariusRuntimeFunctionServiceClient {
     client: RuntimeFunctionDefinitionServiceClient<Channel>,
@@ -30,13 +30,11 @@ impl SagittariusRuntimeFunctionServiceClient {
     pub async fn update_runtime_function_definitions(
         &mut self,
         runtime_functions: Vec<RuntimeFunctionDefinition>,
-    )  {
+    ) {
         let request = Request::from_parts(
             get_authorization_metadata(&self.token),
             Extensions::new(),
-            SagittariusRuntimeFunctionUpdateRequest {
-                runtime_functions,
-            },
+            SagittariusRuntimeFunctionUpdateRequest { runtime_functions },
         );
 
         match self.client.update(request).await {
@@ -51,4 +49,4 @@ impl SagittariusRuntimeFunctionServiceClient {
             }
         };
     }
-}
+}