feat: replaced rabbitmq with nats

Author: raphael-goetz

src/implementation/control.rs

@@ -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/mod.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
 }