Merge pull request #66 from code0-tech/57-nats-execution

NATS Execution

Author: raphael-goetz

Cargo.lock

@@ -4,18 +4,18 @@ version = "0.1.0"
 edition = "2024"
 
 [dependencies]
-code0-flow = { version = "0.0.13" }
-tucana = { version = "0.0.28", features = ["aquila"] }
-lapin = "2.5.3"
+code0-flow = { version = "0.0.14" }
+tucana = { version = "0.0.33" }
 serde = "1.0.219"
 serde_json = "1.0.140"
 tokio = { version = "1.44.1", features = ["rt-multi-thread"] }
-toml = "0.9.0"
 log = "0.4.27"
 futures-lite = "2.6.0"
 rand = "0.9.1"
 base64 = "0.22.1"
 env_logger = "0.11.8"
+async-nats = "0.42.0"
+prost = "0.14.1"
 
 [dev-dependencies]
 tempfile = "3.19.1"

Cargo.toml

@@ -0,0 +1,32 @@
+use tucana::shared::Value;
+
+use crate::{context::Context, error::RuntimeError, registry::HandlerFn};
+
+pub fn collect_control_functions() -> Vec<(&'static str, HandlerFn)> {
+    vec![
+        ("std::control::break", r#break),
+        ("std::control::return", r#return),
+    ]
+}
+
+fn r#break(values: &[Value], _ctx: &mut Context) -> Result<Value, RuntimeError> {
+    let [Value { kind }] = values else {
+        return Err(RuntimeError::simple(
+            "InvalidArgumentRuntimeError",
+            format!("Expected one generic value but received {:?}", values),
+        ));
+    };
+
+    Ok(Value { kind: kind.clone() })
+}
+
+fn r#return(values: &[Value], _ctx: &mut Context) -> Result<Value, RuntimeError> {
+    let [Value { kind }] = values else {
+        return Err(RuntimeError::simple(
+            "InvalidArgumentRuntimeError",
+            format!("Expected one generic value but received {:?}", values),
+        ));
+    };
+
+    Ok(Value { kind: kind.clone() })
+}

src/implementation/control.rs

@@ -2,6 +2,7 @@ use crate::registry::HandlerFn;
 
 pub mod array;
 pub mod boolean;
+mod control;
 pub mod number;
 pub mod object;
 pub mod text;
@@ -14,6 +15,7 @@ pub fn collect() -> Vec<(&'static str, HandlerFn)> {
     result.extend(boolean::collect_boolean_functions());
     result.extend(text::collect_text_functions());
     result.extend(object::collect_object_functions());
+    result.extend(control::collect_control_functions());
 
     result
 }