ref: cargo fmt

Author: raphael-goetz

adapter/rest/src/content_type.rs

@@ -75,9 +75,10 @@ pub fn parse_body(
         BodyFormat::Unknown => {
             // If there is no content type
             if content_type.is_none()
-                && let Ok(value) = parse_text_body(body) {
-                    return Ok(value);
-                }
+                && let Ok(value) = parse_text_body(body)
+            {
+                return Ok(value);
+            }
 
             Err(BodyParseError::UnsupportedContentType {
                 observed: content_type.unwrap_or("<missing>").to_string(),

adapter/rest/src/main.rs

@@ -90,19 +90,19 @@ async fn execute_flow_to_hyper_response(
                     })),
             } = &result
                 && result_fields.contains_key("name")
-                    && result_fields.contains_key("message")
-                    && !result_fields.contains_key("payload")
-                    && !result_fields.contains_key("headers")
-                {
-                    log::debug!("Detected a RuntimeError");
-                    let name = get_string("name", &result);
-                    let message = get_string("message", &result);
-
-                    return error_to_http_response(
-                        StatusCode::INTERNAL_SERVER_ERROR,
-                        format!("{}: {}", name.unwrap(), message.unwrap()).as_str(),
-                    );
-                }
+                && result_fields.contains_key("message")
+                && !result_fields.contains_key("payload")
+                && !result_fields.contains_key("headers")
+            {
+                log::debug!("Detected a RuntimeError");
+                let name = get_string("name", &result);
+                let message = get_string("message", &result);
+
+                return error_to_http_response(
+                    StatusCode::INTERNAL_SERVER_ERROR,
+                    format!("{}: {}", name.unwrap(), message.unwrap()).as_str(),
+                );
+            }
 
             value_to_http_response(result)
         }

crates/base/src/store.rs

@@ -121,7 +121,8 @@ impl AdapterStore {
         // TODO: Replace body vaidation with triangulus when its ready
         let uuid = uuid::Uuid::new_v4().to_string();
         let flow_id = flow.flow_id;
-        let execution_flow: ExecutionFlow = Self::convert_validation_flow(flow, input_value.clone());
+        let execution_flow: ExecutionFlow =
+            Self::convert_validation_flow(flow, input_value.clone());
         let bytes = execution_flow.encode_to_vec();
         let topic = format!("execution.{}", uuid);
         log::info!(