diff --git a/Cargo.lock b/Cargo.lock index 3d9e98b..e54b455 100644 --- a/Cargo.lock +++ b/Cargo.lock @@ -272,9 +272,9 @@ dependencies = [ [[package]] name = "code0-flow" -version = "0.0.25" +version = "0.0.26" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "53e10d39ec0c673c18749c0ff66c033806b68d1a99ec49cf1f4657fcd7c9d4b5" +checksum = "c27759004bf304f21b1d65677fbafd0a3e97a1be471fbe7a3aac5556eed3bc44" dependencies = [ "async-nats", "async-trait", @@ -2124,9 +2124,9 @@ dependencies = [ [[package]] name = "tucana" -version = "0.0.52" +version = "0.0.54" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "63e1cec14d8140417b330fffd1fb07f52cbd69063a4bd5688e63511b5bf8c8aa" +checksum = "31e81f5598a25b6a8f1618fcb25d1a8b2ddbfa38c8a9dcba16a798efe425a36e" dependencies = [ "pbjson", "pbjson-build", diff --git a/Cargo.toml b/Cargo.toml index f8079cb..c6b90c3 100644 --- a/Cargo.toml +++ b/Cargo.toml @@ -7,8 +7,8 @@ version = "0.0.0" edition = "2024" [workspace.dependencies] -code0-flow = { version = "0.0.25" } -tucana = { version = "0.0.52", features = ["aquila"] } +code0-flow = { version = "0.0.26" } +tucana = { version = "0.0.54", features = ["aquila"] } serde_json = { version = "1.0.138" } log = "0.4.27" env_logger = "0.11.8" diff --git a/crates/base/src/store.rs b/crates/base/src/store.rs index f222d35..58718fe 100644 --- a/crates/base/src/store.rs +++ b/crates/base/src/store.rs @@ -1,6 +1,5 @@ use crate::traits::IdentifiableFlow; use async_nats::jetstream::kv::Config; -use code0_flow::flow_validator::verify_flow; use futures_lite::StreamExt; use prost::Message; use tucana::shared::{ExecutionFlow, ValidationFlow, Value}; @@ -119,17 +118,7 @@ impl AdapterStore { flow: ValidationFlow, input_value: Option, ) -> Option { - if let Some(body) = input_value.clone() { - let verify_result = verify_flow(flow.clone(), body); - - match verify_result { - Ok(()) => {} - Err(_err) => { - return None; - } - }; - } - + // 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);