Update Rust crate tucana to 0.0.54

Cargo.toml

@@ -10,8 +10,8 @@ log = "0.4.26"
 env_logger = "0.11.8"
 prost = "0.14.1"
 tonic = "0.14.1"
-tucana = { version = "0.0.52", features = ["all"] }
-code0-flow = { version = "0.0.25", features = ["flow_health", "flow_validator"] }
+tucana = { version = "0.0.54", features = ["all"] }
+code0-flow = { version = "0.0.26", features = ["flow_health"] }
 serde_json = "1.0.140"
 async-nats = "0.46.0"
 tonic-health = "0.14.1"

src/sagittarius/flow_service_client_impl.rs

@@ -147,6 +147,9 @@ impl SagittariusFlowClient {
                     };
                 }
             }
+            Data::ActionConfigurations(_action_configurations) => unimplemented!(
+                "This will be implemented in the alpha edition. Do not use while service is in MVP!"
+            ),
         }
     }
 

src/sagittarius/mod.rs

@@ -1,4 +1,3 @@
-pub mod action_service_client_impl;
 pub mod data_type_service_client_impl;
 pub mod flow_service_client_impl;
 pub mod flow_type_service_client_impl;

src/sagittarius/test_execution_client_impl.rs

@@ -4,7 +4,6 @@
    In some conditions Sagittarius can't connect to Aquila
    Thus Aquila sends a `Logon` request to connect to Sagittarius establishing the connection
 */
-use code0_flow::flow_validator::verify_flow;
 use futures::StreamExt;
 use prost::Message;
 use std::sync::Arc;
@@ -100,39 +99,8 @@ impl SagittariusTestExecutionServiceClient {
 
                 let uuid = uuid::Uuid::new_v4().to_string();
 
-                if let Some(body) = &request.body
-                    && let Err(rule_violations) = verify_flow(validation_flow.clone(), body.clone())
-                {
-                    let now = SystemTime::now()
-                        .duration_since(SystemTime::UNIX_EPOCH)
-                        .unwrap()
-                        .as_millis()
-                        .to_string();
-                    let log = Log {
-                        kind: Some(tucana::sagittarius::log::Kind::ApplicationLog(
-                            ApplicationLog {
-                                message: rule_violations.to_string(),
-                                level: String::from("error"),
-                                timestamp: now,
-                            },
-                        )),
-                    };
-
-                    let execution_result = ExecutionLogonRequest {
-                        data: Some(Data::Response(TestExecutionResponse {
-                            flow_id: request.flow_id,
-                            execution_uuid: uuid,
-                            result: None,
-                            logs: vec![log],
-                        })),
-                    };
-
-                    if let Err(err) = tx.send(execution_result).await {
-                        log::error!("Failed to send ExecutionLogonResponse: {:?}", err);
-                    }
-                    continue;
-                }
-
+                // TODO: When triangulum is ready, validate the body with this service
+                // Task: Add back body validation using triangulum
                 let execution_flow = ExecutionFlow {
                     flow_id: request.flow_id,
                     input_value: request.body,