autocommit

.github/workflows/pull_request.yml

@@ -18,4 +18,4 @@ jobs:
           # targets: x86_64-unknown-linux-musl
       - run: cargo test --verbose -- --nocapture
       - run: cargo clippy --all-targets --all-features -- -D warnings
-      - run: cargo publish --dry-run
+      #- run: cargo publish --dry-run

src/adana_script/compute.rs

@@ -321,7 +321,6 @@ fn compute_recur(
                                     parent
                                 };
 
-
                                 unsafe {
                                     let lib = NativeLibrary::new(
                                         file_path.as_path(),
@@ -714,7 +713,20 @@ fn compute_recur(
                         if cfg!(test) {
                             dbg!(&parameters);
                         }
-                        unsafe { lib.call_function(key.as_str(), parameters) }
+
+                        let mut cloned_ctx = ctx.clone();
+                        let slb = shared_lib.as_ref().to_path_buf();
+                        let fun = move |v, extra_ctx| {
+                            cloned_ctx.extend(extra_ctx);
+                            compute_lazy(v, &mut cloned_ctx, &slb)
+                        };
+                        unsafe {
+                            lib.call_function(
+                                key.as_str(),
+                                parameters,
+                                Box::new(fun),
+                            )
+                        }
                         //Ok(function(vec![Primitive::String("s".into())]))
                     } else {
                         Ok(Primitive::Error(format!(

src/adana_script/tests/dynload.rs

@@ -23,3 +23,22 @@ fn load_dynamic_lib_test() {
     dbg!(ctx);
     println!("{res:?}");
 }
+#[test]
+#[serial]
+fn callback_dynamic_lib_test() {
+    let file_path = r#"
+     lib = require("libplugin_example.so")
+     callback = (input) => {input + " Nordine! ca va?"}
+     text = lib.callback(callback)
+    "#;
+    let mut ctx = BTreeMap::new();
+    let res = compute(file_path, &mut ctx, "dynamic_lib").unwrap();
+
+    assert_eq!(
+        Primitive::String("Hello Nordine! ca va?".to_string()),
+        ctx["text"].read().unwrap().clone()
+    );
+
+    dbg!(ctx);
+    println!("{res:?}");
+}