1use super::FnVariant;
2use crate::JITRunTime;
3use crate::memory::{alloc_dynamic, alloc_struct_bytes, take_dynamic_return};
4use anyhow::{Result, anyhow};
5use cranelift::prelude::AbiParam;
6use cranelift_module::{Linkage, Module};
7use dynamic::{Dynamic, Type};
8use parser::{BinaryOp, Expr, ExprKind, Span};
9use rand::RngExt;
10use std::borrow::Cow;
11use std::collections::BTreeMap;
12use std::fmt::Write as _;
13use std::sync::{RwLock, Weak};
14
15#[derive(Clone, Debug)]
16pub struct ZustCallback {
17 pub fn_ptr: usize,
18 pub ret_ty: Type,
19 pub explicit_arg_len: usize,
20 pub captures: Vec<Dynamic>,
21}
22
23impl ZustCallback {
24 pub fn new(fn_ptr: usize, ret_ty: Type, captures: Vec<Dynamic>) -> Self {
25 Self { fn_ptr, ret_ty, explicit_arg_len: usize::MAX, captures }
26 }
27
28 pub fn new_with_arg_len(fn_ptr: usize, ret_ty: Type, explicit_arg_len: usize, captures: Vec<Dynamic>) -> Self {
29 Self { fn_ptr, ret_ty, explicit_arg_len, captures }
30 }
31
32 pub fn call0(&self) -> Result<Dynamic> {
33 self.call(Vec::new())
34 }
35
36 pub fn call1(&self, arg: Dynamic) -> Result<Dynamic> {
37 self.call(vec![arg])
38 }
39
40 pub fn call(&self, mut args: Vec<Dynamic>) -> Result<Dynamic> {
41 if self.explicit_arg_len != usize::MAX {
42 args.truncate(self.explicit_arg_len);
43 while args.len() < self.explicit_arg_len {
44 args.push(Dynamic::Null);
45 }
46 }
47 let args: Vec<Box<Dynamic>> = args.into_iter().map(Box::new).collect();
48 let mut ptrs: Vec<*const Dynamic> = args.iter().map(|arg| arg.as_ref() as *const Dynamic).collect();
49 ptrs.extend(self.captures.iter().map(|value| value as *const Dynamic));
50 call_jit_isolated(|| unsafe { call_callback(self.fn_ptr as *const u8, &self.ret_ty, &ptrs) })
51 }
52}
53
54extern "C" fn any_clone(addr: *const Dynamic) -> *const Dynamic {
55 unsafe {
57 let cloned_value = (*addr).deep_clone();
58 alloc_dynamic(cloned_value)
59 }
60}
61
62extern "C" fn any_null() -> *const Dynamic {
63 alloc_dynamic(Dynamic::Null)
65}
66
67extern "C" fn print(addr: *const Dynamic) {
68 if !addr.is_null() {
69 unsafe {
70 println!("{}", (*addr).to_string());
71 }
72 }
73}
74
75extern "C" fn sqrt(value: f64) -> f64 {
76 value.sqrt()
77}
78
79extern "C" fn log_any(addr: *const Dynamic) {
80 if addr.is_null() {
81 log::debug!("{:?}", Dynamic::Null);
82 } else {
83 log::debug!("{:?}", unsafe { &*addr });
84 }
85}
86
87extern "C" fn any_is_map(addr: *const Dynamic) -> bool {
88 !addr.is_null() && unsafe { (*addr).is_map() }
89}
90
91extern "C" fn any_is_list(addr: *const Dynamic) -> bool {
92 !addr.is_null() && unsafe { (*addr).is_list() }
93}
94
95extern "C" fn any_is_string(addr: *const Dynamic) -> bool {
96 !addr.is_null() && unsafe { (*addr).is_str() }
97}
98
99extern "C" fn any_is_null(addr: *const Dynamic) -> bool {
100 addr.is_null() || unsafe { (*addr).is_null() }
101}
102
103extern "C" fn random(start: *const Dynamic, stop: *const Dynamic) -> *const Dynamic {
104 if !start.is_null() && !stop.is_null() {
105 let mut rng = rand::rng();
106 unsafe {
107 if (&*start).is_int() {
108 let start = (*start).as_int().unwrap_or(0);
109 let stop = (*stop).as_int().unwrap_or(100);
110 return alloc_dynamic(Dynamic::I64(rng.random_range(start..stop)));
111 } else if (&*start).is_f32() || (&*start).is_f64() {
112 let start = (*start).as_float().unwrap_or(0.0);
113 let stop = (*stop).as_float().unwrap_or(1.0);
114 return alloc_dynamic(Dynamic::F64(rng.random_range(start..stop)));
115 }
116 }
117 }
118 alloc_dynamic(Dynamic::Null)
119}
120
121extern "C" fn uuid() -> *const Dynamic {
122 alloc_dynamic(uuid::Uuid::new_v4().to_string().into())
123}
124
125pub(crate) extern "C" fn struct_alloc(size: i64) -> *mut u8 {
126 let size = size.max(0) as usize;
127 let ptr = alloc_struct_bytes(size);
128 unsafe {
129 std::ptr::write_bytes(ptr, 0, size);
130 }
131 ptr
132}
133
134pub(crate) extern "C" fn repeat_fill(dst: *mut u8, pattern: u64, width: i64, len: i64) {
135 if dst.is_null() || width <= 0 || len <= 0 {
136 return;
137 }
138 let width = width as usize;
139 let len = len as usize;
140 let bytes = pattern.to_le_bytes();
141 unsafe {
142 if width == 1 {
143 std::ptr::write_bytes(dst, bytes[0], len);
144 return;
145 }
146 if !matches!(width, 2 | 4 | 8) {
147 return;
148 }
149 for idx in 0..len {
150 std::ptr::copy_nonoverlapping(bytes.as_ptr(), dst.add(idx * width), width);
151 }
152 }
153}
154
155pub(crate) extern "C" fn strcat(left: *const Dynamic, right: *const Dynamic) -> *const Dynamic {
156 let left = if left.is_null() { "" } else { unsafe { (&*left).as_str() } };
157 let right = if right.is_null() { "" } else { unsafe { (&*right).as_str() } };
158 let mut out = String::with_capacity(left.len() + right.len());
159 out.push_str(left);
160 out.push_str(right);
161 alloc_dynamic(Dynamic::StringBuf(out))
162}
163
164pub(crate) extern "C" fn strcat_i64(left: *const Dynamic, right: i64) -> *const Dynamic {
165 let left = if left.is_null() { "" } else { unsafe { (&*left).as_str() } };
166 let mut out = String::with_capacity(left.len() + 20);
167 out.push_str(left);
168 let _ = write!(&mut out, "{right}");
169 alloc_dynamic(Dynamic::StringBuf(out))
170}
171
172pub(crate) extern "C" fn strcat_assign(left: *mut Dynamic, right: *const Dynamic) -> *const Dynamic {
173 if left.is_null() {
174 return strcat(left, right);
175 }
176 let suffix = if right.is_null() {
177 Cow::Borrowed("")
178 } else if std::ptr::eq(left as *const Dynamic, right) {
179 Cow::Owned(unsafe { (&*right).to_string() })
180 } else {
181 let right = unsafe { &*right };
182 if right.is_str() { Cow::Borrowed(right.as_str()) } else { Cow::Owned(right.to_string()) }
183 };
184 unsafe {
185 match &mut *left {
186 Dynamic::StringBuf(text) => text.push_str(suffix.as_ref()),
187 Dynamic::String(text) => {
188 let mut out = String::with_capacity(text.len() + suffix.len());
189 out.push_str(text.as_str());
190 out.push_str(suffix.as_ref());
191 *left = Dynamic::StringBuf(out);
192 }
193 value => {
194 let prefix = value.to_string();
195 let mut out = String::with_capacity(prefix.len() + suffix.len());
196 out.push_str(&prefix);
197 out.push_str(suffix.as_ref());
198 *value = Dynamic::StringBuf(out);
199 }
200 }
201 }
202 left
203}
204
205pub(crate) extern "C" fn struct_from_ptr(addr: i64, ty: i64) -> *const Dynamic {
206 let ty = unsafe { (&*(ty as *const Type)).clone() };
207 alloc_dynamic(Dynamic::Struct { addr: addr as usize, ty })
208}
209
210pub(crate) extern "C" fn array_from_ptr(addr: i64, ty: i64) -> *const Dynamic {
211 if addr == 0 || ty == 0 {
212 return alloc_dynamic(Dynamic::Null);
213 }
214 let ty = unsafe { &*(ty as *const Type) };
215 alloc_dynamic(dynamic_from_ptr(addr as *const u8, ty))
216}
217
218pub(crate) extern "C" fn array_to_ptr(dst: *mut u8, value: *const Dynamic, ty: i64) {
219 if dst.is_null() || value.is_null() || ty == 0 {
220 return;
221 }
222 let ty = unsafe { &*(ty as *const Type) };
223 write_dynamic_to_ptr(dst, unsafe { &*value }, ty);
224}
225
226fn dynamic_from_ptr(addr: *const u8, ty: &Type) -> Dynamic {
227 if addr.is_null() {
228 return Dynamic::Null;
229 }
230 match ty {
231 Type::Bool => Dynamic::Bool(unsafe { std::ptr::read_unaligned(addr) } != 0),
232 Type::I8 => Dynamic::I8(unsafe { std::ptr::read_unaligned(addr as *const i8) }),
233 Type::U8 => Dynamic::U8(unsafe { std::ptr::read_unaligned(addr) }),
234 Type::I16 => Dynamic::I16(unsafe { std::ptr::read_unaligned(addr as *const i16) }),
235 Type::U16 => Dynamic::U16(unsafe { std::ptr::read_unaligned(addr as *const u16) }),
236 Type::I32 => Dynamic::I32(unsafe { std::ptr::read_unaligned(addr as *const i32) }),
237 Type::U32 => Dynamic::U32(unsafe { std::ptr::read_unaligned(addr as *const u32) }),
238 Type::I64 => Dynamic::I64(unsafe { std::ptr::read_unaligned(addr as *const i64) }),
239 Type::U64 => Dynamic::U64(unsafe { std::ptr::read_unaligned(addr as *const u64) }),
240 Type::F32 => Dynamic::F32(unsafe { std::ptr::read_unaligned(addr as *const f32) }),
241 Type::F64 => Dynamic::F64(unsafe { std::ptr::read_unaligned(addr as *const f64) }),
242 Type::Array(elem_ty, len) => {
243 let width = elem_ty.storage_width() as usize;
244 let values = (0..*len as usize).map(|idx| unsafe { dynamic_from_ptr(addr.add(idx * width), elem_ty) }).collect();
245 Dynamic::list(values)
246 }
247 Type::Struct { fields, .. } => {
248 let mut map = BTreeMap::new();
249 let (_, offsets) = Type::struct_layout(fields);
250 for ((name, field_ty), offset) in fields.iter().zip(offsets) {
251 let value = unsafe { dynamic_from_ptr(addr.add(offset as usize), field_ty) };
252 map.insert(name.clone(), value);
253 }
254 Dynamic::map(map)
255 }
256 _ => {
257 let ptr = unsafe { std::ptr::read_unaligned(addr as *const *const Dynamic) };
258 if ptr.is_null() { Dynamic::Null } else { unsafe { (&*ptr).deep_clone() } }
259 }
260 }
261}
262
263fn write_dynamic_to_ptr(dst: *mut u8, value: &Dynamic, ty: &Type) {
264 if dst.is_null() {
265 return;
266 }
267 match ty {
268 Type::Bool => unsafe { std::ptr::write_unaligned(dst, if value.is_true() { 1 } else { 0 }) },
269 Type::I8 => unsafe { std::ptr::write_unaligned(dst as *mut i8, value.clone().try_into().unwrap_or_default()) },
270 Type::U8 => unsafe { std::ptr::write_unaligned(dst, value.clone().try_into().unwrap_or_default()) },
271 Type::I16 => unsafe { std::ptr::write_unaligned(dst as *mut i16, value.clone().try_into().unwrap_or_default()) },
272 Type::U16 => unsafe { std::ptr::write_unaligned(dst as *mut u16, value.clone().try_into().unwrap_or_default()) },
273 Type::I32 => unsafe { std::ptr::write_unaligned(dst as *mut i32, value.clone().try_into().unwrap_or_default()) },
274 Type::U32 => unsafe { std::ptr::write_unaligned(dst as *mut u32, value.clone().try_into().unwrap_or_default()) },
275 Type::I64 => unsafe { std::ptr::write_unaligned(dst as *mut i64, value.clone().try_into().unwrap_or_default()) },
276 Type::U64 => unsafe { std::ptr::write_unaligned(dst as *mut u64, value.clone().try_into().unwrap_or_default()) },
277 Type::F32 => unsafe { std::ptr::write_unaligned(dst as *mut f32, f32::try_from(value.clone()).unwrap_or_default()) },
278 Type::F64 => unsafe { std::ptr::write_unaligned(dst as *mut f64, value.clone().try_into().unwrap_or_default()) },
279 Type::Array(elem_ty, len) => {
280 let width = elem_ty.storage_width() as usize;
281 for idx in 0..*len as usize {
282 let item = value.get_idx(idx).unwrap_or(Dynamic::Null);
283 unsafe { write_dynamic_to_ptr(dst.add(idx * width), &item, elem_ty) };
284 }
285 }
286 Type::Struct { fields, .. } => {
287 let (_, offsets) = Type::struct_layout(fields);
288 for ((name, field_ty), offset) in fields.iter().zip(offsets) {
289 let item = value.get_dynamic(name.as_str()).unwrap_or(Dynamic::Null);
290 unsafe { write_dynamic_to_ptr(dst.add(offset as usize), &item, field_ty) };
291 }
292 }
293 _ => {
294 let ptr = alloc_dynamic(value.deep_clone());
295 unsafe { std::ptr::write_unaligned(dst as *mut usize, ptr as usize) };
296 }
297 }
298}
299
300pub(crate) extern "C" fn import_with_vm(context: *const Weak<RwLock<JITRunTime>>, addr: *const Dynamic, path: *const Dynamic) -> bool {
301 if addr.is_null() || path.is_null() {
302 return false;
303 }
304 super::with_vm_context(context, |jit| {
305 let name = unsafe { &*addr }.as_str();
306 let path = unsafe { &*path }.as_str();
307 jit.import(name, path)
308 })
309 .map_err(|e| log::error!("import failed: {e:#}"))
310 .is_ok()
311}
312
313pub(crate) extern "C" fn spawn_with_vm(context: *const Weak<RwLock<JITRunTime>>, fn_name: *const Dynamic, args: *const Dynamic) -> bool {
314 if context.is_null() || fn_name.is_null() {
315 return false;
316 }
317 let fn_name = unsafe { (&*fn_name).as_str().to_string() };
318 if fn_name.is_empty() {
319 return false;
320 }
321 let args = if args.is_null() { Dynamic::Null } else { unsafe { (&*args).deep_clone() } };
322 let context = unsafe { (&*context).clone() };
323 std::thread::Builder::new()
324 .name(format!("zust:{fn_name}"))
325 .spawn(move || {
326 if let Err(err) = spawn_run(context, fn_name.as_str(), args) {
327 log::error!("spawn {fn_name} failed: {err:?}");
328 }
329 })
330 .is_ok()
331}
332
333fn spawn_args(args: Dynamic) -> Vec<Dynamic> {
334 match args {
335 Dynamic::Null => Vec::new(),
336 Dynamic::List(values) => values.read().unwrap().iter().map(Dynamic::deep_clone).collect(),
337 value => vec![value],
338 }
339}
340
341fn spawn_run(context: Weak<RwLock<JITRunTime>>, fn_name: &str, args: Dynamic) -> Result<()> {
342 let args = spawn_args(args);
343 if args.len() > 16 {
344 anyhow::bail!("spawn supports at most 16 args, got {}", args.len());
345 }
346 let arg_tys = vec![Type::Any; args.len()];
347 let (ptr, ret_ty) = super::with_vm_context(&context as *const Weak<RwLock<JITRunTime>>, |vm| vm.jit.write().unwrap().get_fn_ptr(fn_name, &arg_tys))?;
348 let args: Vec<Box<Dynamic>> = args.into_iter().map(Box::new).collect();
349 let ptrs: Vec<*const Dynamic> = args.iter().map(|arg| arg.as_ref() as *const Dynamic).collect();
350 call_jit_isolated(|| unsafe { call_spawned(ptr, &ret_ty, &ptrs) })
351}
352
353pub(crate) extern "C" fn spawn_ptr(fn_ptr: i64, ret_ty: i64, args: *const Dynamic) -> bool {
354 if fn_ptr == 0 || ret_ty == 0 {
355 return false;
356 }
357 let fn_ptr = fn_ptr as usize;
358 let ret_ty = unsafe { (&*(ret_ty as *const Type)).clone() };
359 let args = if args.is_null() { Dynamic::Null } else { unsafe { (&*args).deep_clone() } };
360 std::thread::Builder::new()
361 .name("zust:closure".to_string())
362 .spawn(move || {
363 if let Err(err) = spawn_run_ptr(fn_ptr, ret_ty, args) {
364 log::error!("spawn closure failed: {err:?}");
365 }
366 })
367 .is_ok()
368}
369
370pub(crate) extern "C" fn callback_new(fn_ptr: i64, ret_ty: i64, explicit_arg_len: i64, captures: *const Dynamic) -> *const Dynamic {
371 if fn_ptr == 0 || ret_ty == 0 {
372 return alloc_dynamic(Dynamic::Null);
373 }
374 let ret_ty = unsafe { (&*(ret_ty as *const Type)).clone() };
375 let explicit_arg_len = usize::try_from(explicit_arg_len).unwrap_or(usize::MAX);
376 let captures = if captures.is_null() {
377 Vec::new()
378 } else {
379 match unsafe { &*captures } {
382 Dynamic::List(values) => values.read().unwrap().to_vec(),
383 value => vec![value.clone()],
384 }
385 };
386 alloc_dynamic(Dynamic::custom(ZustCallback::new_with_arg_len(fn_ptr as usize, ret_ty, explicit_arg_len, captures)))
387}
388
389fn spawn_run_ptr(fn_ptr: usize, ret_ty: Type, args: Dynamic) -> Result<()> {
390 let args = spawn_args(args);
391 if args.len() > 16 {
392 anyhow::bail!("spawn supports at most 16 args, got {}", args.len());
393 }
394 let args: Vec<Box<Dynamic>> = args.into_iter().map(Box::new).collect();
395 let ptrs: Vec<*const Dynamic> = args.iter().map(|arg| arg.as_ref() as *const Dynamic).collect();
396 call_jit_isolated(|| unsafe { call_spawned(fn_ptr as *const u8, &ret_ty, &ptrs) })
397}
398
399pub(crate) fn call_jit_isolated<T>(f: impl FnOnce() -> Result<T>) -> Result<T> {
411 let _ = dynamic::take_fault();
412 let outcome = std::panic::catch_unwind(std::panic::AssertUnwindSafe(f));
413 match outcome {
414 Ok(inner) => match dynamic::take_fault() {
415 Some(reason) => Err(anyhow!("脚本运行期错误: {}", reason)),
416 None => inner,
417 },
418 Err(_) => Err(anyhow!("脚本执行 panic,已隔离")),
419 }
420}
421
422unsafe fn call_callback(ptr: *const u8, ret_ty: &Type, args: &[*const Dynamic]) -> Result<Dynamic> {
423 macro_rules! callback_arg_ty {
424 ($arg:ident) => {
425 *const Dynamic
426 };
427 }
428
429 macro_rules! callback_args {
430 ($body:ident $(, $extra:tt)*) => {
431 match args {
432 [] => $body!($($extra),*;),
433 [a] => $body!($($extra),*; a),
434 [a, b] => $body!($($extra),*; a, b),
435 [a, b, c] => $body!($($extra),*; a, b, c),
436 [a, b, c, d] => $body!($($extra),*; a, b, c, d),
437 [a, b, c, d, e] => $body!($($extra),*; a, b, c, d, e),
438 [a, b, c, d, e, f] => $body!($($extra),*; a, b, c, d, e, f),
439 [a, b, c, d, e, f, g] => $body!($($extra),*; a, b, c, d, e, f, g),
440 [a, b, c, d, e, f, g, h] => $body!($($extra),*; a, b, c, d, e, f, g, h),
441 [a, b, c, d, e, f, g, h, i] => $body!($($extra),*; a, b, c, d, e, f, g, h, i),
442 [a, b, c, d, e, f, g, h, i, j] => $body!($($extra),*; a, b, c, d, e, f, g, h, i, j),
443 [a, b, c, d, e, f, g, h, i, j, k] => $body!($($extra),*; a, b, c, d, e, f, g, h, i, j, k),
444 [a, b, c, d, e, f, g, h, i, j, k, l] => $body!($($extra),*; a, b, c, d, e, f, g, h, i, j, k, l),
445 [a, b, c, d, e, f, g, h, i, j, k, l, m] => $body!($($extra),*; a, b, c, d, e, f, g, h, i, j, k, l, m),
446 [a, b, c, d, e, f, g, h, i, j, k, l, m, n] => $body!($($extra),*; a, b, c, d, e, f, g, h, i, j, k, l, m, n),
447 [a, b, c, d, e, f, g, h, i, j, k, l, m, n, o] => $body!($($extra),*; a, b, c, d, e, f, g, h, i, j, k, l, m, n, o),
448 [a, b, c, d, e, f, g, h, i, j, k, l, m, n, o, p] => $body!($($extra),*; a, b, c, d, e, f, g, h, i, j, k, l, m, n, o, p),
449 [a, b, c, d, e, f, g, h, i, j, k, l, m, n, o, p, q] => $body!($($extra),*; a, b, c, d, e, f, g, h, i, j, k, l, m, n, o, p, q),
450 [a, b, c, d, e, f, g, h, i, j, k, l, m, n, o, p, q, r] => $body!($($extra),*; a, b, c, d, e, f, g, h, i, j, k, l, m, n, o, p, q, r),
451 [a, b, c, d, e, f, g, h, i, j, k, l, m, n, o, p, q, r, s] => $body!($($extra),*; a, b, c, d, e, f, g, h, i, j, k, l, m, n, o, p, q, r, s),
452 [a, b, c, d, e, f, g, h, i, j, k, l, m, n, o, p, q, r, s, t] => $body!($($extra),*; a, b, c, d, e, f, g, h, i, j, k, l, m, n, o, p, q, r, s, t),
453 [a, b, c, d, e, f, g, h, i, j, k, l, m, n, o, p, q, r, s, t, u] => $body!($($extra),*; a, b, c, d, e, f, g, h, i, j, k, l, m, n, o, p, q, r, s, t, u),
454 [a, b, c, d, e, f, g, h, i, j, k, l, m, n, o, p, q, r, s, t, u, v] => $body!($($extra),*; a, b, c, d, e, f, g, h, i, j, k, l, m, n, o, p, q, r, s, t, u, v),
455 [a, b, c, d, e, f, g, h, i, j, k, l, m, n, o, p, q, r, s, t, u, v, w] => $body!($($extra),*; a, b, c, d, e, f, g, h, i, j, k, l, m, n, o, p, q, r, s, t, u, v, w),
456 [a, b, c, d, e, f, g, h, i, j, k, l, m, n, o, p, q, r, s, t, u, v, w, x] => $body!($($extra),*; a, b, c, d, e, f, g, h, i, j, k, l, m, n, o, p, q, r, s, t, u, v, w, x),
457 _ => anyhow::bail!("callback supports at most 24 args including captures, got {}", args.len()),
458 }
459 };
460 }
461
462 macro_rules! call_void_body {
463 (; $($arg:ident),*) => {{
464 let fn_ptr: extern "C" fn($(callback_arg_ty!($arg)),*) = unsafe { std::mem::transmute(ptr) };
465 fn_ptr($(*$arg),*)
466 }};
467 }
468
469 macro_rules! call_void {
470 () => {
471 callback_args!(call_void_body)
472 };
473 }
474
475 macro_rules! call_ret_body {
476 ($ret:ty, $dynamic:expr; $($arg:ident),*) => {{
477 let fn_ptr: extern "C" fn($(callback_arg_ty!($arg)),*) -> $ret = unsafe { std::mem::transmute(ptr) };
478 $dynamic(fn_ptr($(*$arg),*))
479 }};
480 }
481
482 macro_rules! call_ret {
483 ($ret:ty, $dynamic:expr) => {{ callback_args!(call_ret_body, $ret, $dynamic) }};
484 }
485
486 if ret_ty.is_void() {
487 call_void!();
488 Ok(Dynamic::Null)
489 } else if ret_ty.is_bool() {
490 call_ret!(bool, |value| Ok(Dynamic::Bool(value)))
491 } else if ret_ty.is_float() {
492 if ret_ty.is_f64() { call_ret!(f64, |value| Ok(Dynamic::F64(value))) } else { call_ret!(f32, |value| Ok(Dynamic::F32(value))) }
493 } else if ret_ty.is_int() || ret_ty.is_uint() {
494 match ret_ty {
495 Type::I8 => call_ret!(i8, |value| Ok(Dynamic::I8(value))),
496 Type::U8 => call_ret!(u8, |value| Ok(Dynamic::U8(value))),
497 Type::I16 => call_ret!(i16, |value| Ok(Dynamic::I16(value))),
498 Type::U16 => call_ret!(u16, |value| Ok(Dynamic::U16(value))),
499 Type::I32 => call_ret!(i32, |value| Ok(Dynamic::I32(value))),
500 Type::U32 => call_ret!(u32, |value| Ok(Dynamic::U32(value))),
501 Type::I64 => call_ret!(i64, |value| Ok(Dynamic::I64(value))),
502 Type::U64 => call_ret!(u64, |value| Ok(Dynamic::U64(value))),
503 _ => unreachable!(),
504 }
505 } else if ret_ty.is_struct() || ret_ty.is_array() || ret_ty.is_vec() {
506 log::warn!("callback returns {ret_ty:?} — not supported, discarding");
507 call_ret!(*const u8, |_| Ok(Dynamic::Null))
508 } else {
509 call_ret!(*const Dynamic, |ptr| unsafe { Ok((*take_dynamic_return(ptr)).deep_clone()) })
510 }
511}
512
513unsafe fn call_spawned(ptr: *const u8, ret_ty: &Type, args: &[*const Dynamic]) -> Result<()> {
514 macro_rules! call_void {
515 () => {
516 match args {
517 [] => unsafe { std::mem::transmute::<_, extern "C" fn()>(ptr)() },
518 [a] => unsafe { std::mem::transmute::<_, extern "C" fn(*const Dynamic)>(ptr)(*a) },
519 [a, b] => unsafe { std::mem::transmute::<_, extern "C" fn(*const Dynamic, *const Dynamic)>(ptr)(*a, *b) },
520 [a, b, c] => unsafe { std::mem::transmute::<_, extern "C" fn(*const Dynamic, *const Dynamic, *const Dynamic)>(ptr)(*a, *b, *c) },
521 [a, b, c, d] => unsafe { std::mem::transmute::<_, extern "C" fn(*const Dynamic, *const Dynamic, *const Dynamic, *const Dynamic)>(ptr)(*a, *b, *c, *d) },
522 [a, b, c, d, e] => unsafe { std::mem::transmute::<_, extern "C" fn(*const Dynamic, *const Dynamic, *const Dynamic, *const Dynamic, *const Dynamic)>(ptr)(*a, *b, *c, *d, *e) },
523 [a, b, c, d, e, f] => unsafe { std::mem::transmute::<_, extern "C" fn(*const Dynamic, *const Dynamic, *const Dynamic, *const Dynamic, *const Dynamic, *const Dynamic)>(ptr)(*a, *b, *c, *d, *e, *f) },
524 [a, b, c, d, e, f, g] => unsafe {
525 std::mem::transmute::<_, extern "C" fn(*const Dynamic, *const Dynamic, *const Dynamic, *const Dynamic, *const Dynamic, *const Dynamic, *const Dynamic)>(ptr)(*a, *b, *c, *d, *e, *f, *g)
526 },
527 [a, b, c, d, e, f, g, h] => unsafe {
528 std::mem::transmute::<_, extern "C" fn(*const Dynamic, *const Dynamic, *const Dynamic, *const Dynamic, *const Dynamic, *const Dynamic, *const Dynamic, *const Dynamic)>(ptr)(
529 *a, *b, *c, *d, *e, *f, *g, *h,
530 )
531 },
532 [a, b, c, d, e, f, g, h, i] => unsafe {
533 std::mem::transmute::<_, extern "C" fn(*const Dynamic, *const Dynamic, *const Dynamic, *const Dynamic, *const Dynamic, *const Dynamic, *const Dynamic, *const Dynamic, *const Dynamic)>(ptr)(
534 *a, *b, *c, *d, *e, *f, *g, *h, *i,
535 )
536 },
537 [a, b, c, d, e, f, g, h, i, j] => unsafe {
538 std::mem::transmute::<_, extern "C" fn(*const Dynamic, *const Dynamic, *const Dynamic, *const Dynamic, *const Dynamic, *const Dynamic, *const Dynamic, *const Dynamic, *const Dynamic, *const Dynamic)>(
539 ptr,
540 )(*a, *b, *c, *d, *e, *f, *g, *h, *i, *j)
541 },
542 [a, b, c, d, e, f, g, h, i, j, k] => unsafe {
543 std::mem::transmute::<
544 _,
545 extern "C" fn(*const Dynamic, *const Dynamic, *const Dynamic, *const Dynamic, *const Dynamic, *const Dynamic, *const Dynamic, *const Dynamic, *const Dynamic, *const Dynamic, *const Dynamic),
546 >(ptr)(*a, *b, *c, *d, *e, *f, *g, *h, *i, *j, *k)
547 },
548 [a, b, c, d, e, f, g, h, i, j, k, l] => unsafe {
549 std::mem::transmute::<
550 _,
551 extern "C" fn(
552 *const Dynamic,
553 *const Dynamic,
554 *const Dynamic,
555 *const Dynamic,
556 *const Dynamic,
557 *const Dynamic,
558 *const Dynamic,
559 *const Dynamic,
560 *const Dynamic,
561 *const Dynamic,
562 *const Dynamic,
563 *const Dynamic,
564 ),
565 >(ptr)(*a, *b, *c, *d, *e, *f, *g, *h, *i, *j, *k, *l)
566 },
567 [a, b, c, d, e, f, g, h, i, j, k, l, m] => unsafe {
568 std::mem::transmute::<
569 _,
570 extern "C" fn(
571 *const Dynamic,
572 *const Dynamic,
573 *const Dynamic,
574 *const Dynamic,
575 *const Dynamic,
576 *const Dynamic,
577 *const Dynamic,
578 *const Dynamic,
579 *const Dynamic,
580 *const Dynamic,
581 *const Dynamic,
582 *const Dynamic,
583 *const Dynamic,
584 ),
585 >(ptr)(*a, *b, *c, *d, *e, *f, *g, *h, *i, *j, *k, *l, *m)
586 },
587 [a, b, c, d, e, f, g, h, i, j, k, l, m, n] => unsafe {
588 std::mem::transmute::<
589 _,
590 extern "C" fn(
591 *const Dynamic,
592 *const Dynamic,
593 *const Dynamic,
594 *const Dynamic,
595 *const Dynamic,
596 *const Dynamic,
597 *const Dynamic,
598 *const Dynamic,
599 *const Dynamic,
600 *const Dynamic,
601 *const Dynamic,
602 *const Dynamic,
603 *const Dynamic,
604 *const Dynamic,
605 ),
606 >(ptr)(*a, *b, *c, *d, *e, *f, *g, *h, *i, *j, *k, *l, *m, *n)
607 },
608 [a, b, c, d, e, f, g, h, i, j, k, l, m, n, o] => unsafe {
609 std::mem::transmute::<
610 _,
611 extern "C" fn(
612 *const Dynamic,
613 *const Dynamic,
614 *const Dynamic,
615 *const Dynamic,
616 *const Dynamic,
617 *const Dynamic,
618 *const Dynamic,
619 *const Dynamic,
620 *const Dynamic,
621 *const Dynamic,
622 *const Dynamic,
623 *const Dynamic,
624 *const Dynamic,
625 *const Dynamic,
626 *const Dynamic,
627 ),
628 >(ptr)(*a, *b, *c, *d, *e, *f, *g, *h, *i, *j, *k, *l, *m, *n, *o)
629 },
630 [a, b, c, d, e, f, g, h, i, j, k, l, m, n, o, p] => unsafe {
631 std::mem::transmute::<
632 _,
633 extern "C" fn(
634 *const Dynamic,
635 *const Dynamic,
636 *const Dynamic,
637 *const Dynamic,
638 *const Dynamic,
639 *const Dynamic,
640 *const Dynamic,
641 *const Dynamic,
642 *const Dynamic,
643 *const Dynamic,
644 *const Dynamic,
645 *const Dynamic,
646 *const Dynamic,
647 *const Dynamic,
648 *const Dynamic,
649 *const Dynamic,
650 ),
651 >(ptr)(*a, *b, *c, *d, *e, *f, *g, *h, *i, *j, *k, *l, *m, *n, *o, *p)
652 },
653 _ => unreachable!(),
654 }
655 };
656 }
657
658 if ret_ty.is_void() {
659 call_void!();
660 return Ok(());
661 }
662
663 macro_rules! call_ret {
664 ($ret:ty, $drop_result:expr) => {
665 match args {
666 [] => {
667 let fn_ptr: extern "C" fn() -> $ret = unsafe { std::mem::transmute(ptr) };
668 $drop_result(fn_ptr());
669 }
670 [a] => {
671 let fn_ptr: extern "C" fn(*const Dynamic) -> $ret = unsafe { std::mem::transmute(ptr) };
672 $drop_result(fn_ptr(*a));
673 }
674 [a, b] => {
675 let fn_ptr: extern "C" fn(*const Dynamic, *const Dynamic) -> $ret = unsafe { std::mem::transmute(ptr) };
676 $drop_result(fn_ptr(*a, *b));
677 }
678 [a, b, c] => {
679 let fn_ptr: extern "C" fn(*const Dynamic, *const Dynamic, *const Dynamic) -> $ret = unsafe { std::mem::transmute(ptr) };
680 $drop_result(fn_ptr(*a, *b, *c));
681 }
682 [a, b, c, d] => {
683 let fn_ptr: extern "C" fn(*const Dynamic, *const Dynamic, *const Dynamic, *const Dynamic) -> $ret = unsafe { std::mem::transmute(ptr) };
684 $drop_result(fn_ptr(*a, *b, *c, *d));
685 }
686 [a, b, c, d, e] => {
687 let fn_ptr: extern "C" fn(*const Dynamic, *const Dynamic, *const Dynamic, *const Dynamic, *const Dynamic) -> $ret = unsafe { std::mem::transmute(ptr) };
688 $drop_result(fn_ptr(*a, *b, *c, *d, *e));
689 }
690 [a, b, c, d, e, f] => {
691 let fn_ptr: extern "C" fn(*const Dynamic, *const Dynamic, *const Dynamic, *const Dynamic, *const Dynamic, *const Dynamic) -> $ret = unsafe { std::mem::transmute(ptr) };
692 $drop_result(fn_ptr(*a, *b, *c, *d, *e, *f));
693 }
694 [a, b, c, d, e, f, g] => {
695 let fn_ptr: extern "C" fn(*const Dynamic, *const Dynamic, *const Dynamic, *const Dynamic, *const Dynamic, *const Dynamic, *const Dynamic) -> $ret = unsafe { std::mem::transmute(ptr) };
696 $drop_result(fn_ptr(*a, *b, *c, *d, *e, *f, *g));
697 }
698 [a, b, c, d, e, f, g, h] => {
699 let fn_ptr: extern "C" fn(*const Dynamic, *const Dynamic, *const Dynamic, *const Dynamic, *const Dynamic, *const Dynamic, *const Dynamic, *const Dynamic) -> $ret = unsafe { std::mem::transmute(ptr) };
700 $drop_result(fn_ptr(*a, *b, *c, *d, *e, *f, *g, *h));
701 }
702 [a, b, c, d, e, f, g, h, i] => {
703 let fn_ptr: extern "C" fn(*const Dynamic, *const Dynamic, *const Dynamic, *const Dynamic, *const Dynamic, *const Dynamic, *const Dynamic, *const Dynamic, *const Dynamic) -> $ret =
704 unsafe { std::mem::transmute(ptr) };
705 $drop_result(fn_ptr(*a, *b, *c, *d, *e, *f, *g, *h, *i));
706 }
707 [a, b, c, d, e, f, g, h, i, j] => {
708 let fn_ptr: extern "C" fn(*const Dynamic, *const Dynamic, *const Dynamic, *const Dynamic, *const Dynamic, *const Dynamic, *const Dynamic, *const Dynamic, *const Dynamic, *const Dynamic) -> $ret =
709 unsafe { std::mem::transmute(ptr) };
710 $drop_result(fn_ptr(*a, *b, *c, *d, *e, *f, *g, *h, *i, *j));
711 }
712 [a, b, c, d, e, f, g, h, i, j, k] => {
713 let fn_ptr: extern "C" fn(
714 *const Dynamic,
715 *const Dynamic,
716 *const Dynamic,
717 *const Dynamic,
718 *const Dynamic,
719 *const Dynamic,
720 *const Dynamic,
721 *const Dynamic,
722 *const Dynamic,
723 *const Dynamic,
724 *const Dynamic,
725 ) -> $ret = unsafe { std::mem::transmute(ptr) };
726 $drop_result(fn_ptr(*a, *b, *c, *d, *e, *f, *g, *h, *i, *j, *k));
727 }
728 [a, b, c, d, e, f, g, h, i, j, k, l] => {
729 let fn_ptr: extern "C" fn(
730 *const Dynamic,
731 *const Dynamic,
732 *const Dynamic,
733 *const Dynamic,
734 *const Dynamic,
735 *const Dynamic,
736 *const Dynamic,
737 *const Dynamic,
738 *const Dynamic,
739 *const Dynamic,
740 *const Dynamic,
741 *const Dynamic,
742 ) -> $ret = unsafe { std::mem::transmute(ptr) };
743 $drop_result(fn_ptr(*a, *b, *c, *d, *e, *f, *g, *h, *i, *j, *k, *l));
744 }
745 [a, b, c, d, e, f, g, h, i, j, k, l, m] => {
746 let fn_ptr: extern "C" fn(
747 *const Dynamic,
748 *const Dynamic,
749 *const Dynamic,
750 *const Dynamic,
751 *const Dynamic,
752 *const Dynamic,
753 *const Dynamic,
754 *const Dynamic,
755 *const Dynamic,
756 *const Dynamic,
757 *const Dynamic,
758 *const Dynamic,
759 *const Dynamic,
760 ) -> $ret = unsafe { std::mem::transmute(ptr) };
761 $drop_result(fn_ptr(*a, *b, *c, *d, *e, *f, *g, *h, *i, *j, *k, *l, *m));
762 }
763 [a, b, c, d, e, f, g, h, i, j, k, l, m, n] => {
764 let fn_ptr: extern "C" fn(
765 *const Dynamic,
766 *const Dynamic,
767 *const Dynamic,
768 *const Dynamic,
769 *const Dynamic,
770 *const Dynamic,
771 *const Dynamic,
772 *const Dynamic,
773 *const Dynamic,
774 *const Dynamic,
775 *const Dynamic,
776 *const Dynamic,
777 *const Dynamic,
778 *const Dynamic,
779 ) -> $ret = unsafe { std::mem::transmute(ptr) };
780 $drop_result(fn_ptr(*a, *b, *c, *d, *e, *f, *g, *h, *i, *j, *k, *l, *m, *n));
781 }
782 [a, b, c, d, e, f, g, h, i, j, k, l, m, n, o] => {
783 let fn_ptr: extern "C" fn(
784 *const Dynamic,
785 *const Dynamic,
786 *const Dynamic,
787 *const Dynamic,
788 *const Dynamic,
789 *const Dynamic,
790 *const Dynamic,
791 *const Dynamic,
792 *const Dynamic,
793 *const Dynamic,
794 *const Dynamic,
795 *const Dynamic,
796 *const Dynamic,
797 *const Dynamic,
798 *const Dynamic,
799 ) -> $ret = unsafe { std::mem::transmute(ptr) };
800 $drop_result(fn_ptr(*a, *b, *c, *d, *e, *f, *g, *h, *i, *j, *k, *l, *m, *n, *o));
801 }
802 [a, b, c, d, e, f, g, h, i, j, k, l, m, n, o, p] => {
803 let fn_ptr: extern "C" fn(
804 *const Dynamic,
805 *const Dynamic,
806 *const Dynamic,
807 *const Dynamic,
808 *const Dynamic,
809 *const Dynamic,
810 *const Dynamic,
811 *const Dynamic,
812 *const Dynamic,
813 *const Dynamic,
814 *const Dynamic,
815 *const Dynamic,
816 *const Dynamic,
817 *const Dynamic,
818 *const Dynamic,
819 *const Dynamic,
820 ) -> $ret = unsafe { std::mem::transmute(ptr) };
821 $drop_result(fn_ptr(*a, *b, *c, *d, *e, *f, *g, *h, *i, *j, *k, *l, *m, *n, *o, *p));
822 }
823 _ => unreachable!(),
824 }
825 };
826 }
827
828 if ret_ty.is_bool() {
829 call_ret!(bool, |_| {});
830 } else if ret_ty.is_float() {
831 if ret_ty.is_f64() {
832 call_ret!(f64, |_| {});
833 } else {
834 call_ret!(f32, |_| {});
835 }
836 } else if ret_ty.is_int() || ret_ty.is_uint() {
837 match ret_ty {
838 Type::I8 => call_ret!(i8, |_| {}),
839 Type::U8 => call_ret!(u8, |_| {}),
840 Type::I16 => call_ret!(i16, |_| {}),
841 Type::U16 => call_ret!(u16, |_| {}),
842 Type::I32 => call_ret!(i32, |_| {}),
843 Type::U32 => call_ret!(u32, |_| {}),
844 Type::I64 => call_ret!(i64, |_| {}),
845 Type::U64 => call_ret!(u64, |_| {}),
846 _ => unreachable!(),
847 }
848 } else if ret_ty.is_struct() || ret_ty.is_array() || ret_ty.is_vec() {
849 log::warn!("spawned fn returns {ret_ty:?} — not supported, discarding");
850 call_ret!(*const u8, |_| {});
851 } else {
852 call_ret!(*const Dynamic, |ptr| drop(unsafe { take_dynamic_return(ptr) }));
853 }
854 Ok(())
855}
856
857extern "C" fn any_len(addr: *const Dynamic) -> i64 {
858 if addr.is_null() { 0 } else { unsafe { (&*addr).len() as i64 } }
859}
860
861extern "C" fn any_keys(addr: *const Dynamic) -> *const Dynamic {
862 if addr.is_null() {
863 return alloc_dynamic(Dynamic::list(Vec::new()));
864 }
865 let keys = match unsafe { &*addr } {
866 Dynamic::Map(map) => map.read().unwrap().keys().map(|key| Dynamic::from(key.as_str())).collect(),
867 _ => Vec::new(),
868 };
869 alloc_dynamic(Dynamic::list(keys))
870}
871
872extern "C" fn any_iter(addr: *const Dynamic) -> *const Dynamic {
873 if addr.is_null() { any_null() } else { alloc_dynamic(unsafe { (*addr).clone().into_iter() }) }
874}
875
876extern "C" fn any_next(addr: *const Dynamic) -> *const Dynamic {
877 if addr.is_null() { any_null() } else { alloc_dynamic(unsafe { (&mut *(addr as *mut Dynamic)).next().unwrap_or(Dynamic::Null) }) }
878}
879
880extern "C" fn any_next_pair(addr: *const Dynamic) -> *const Dynamic {
881 if addr.is_null() { any_null() } else { alloc_dynamic(unsafe { (&mut *(addr as *mut Dynamic)).next_pair().unwrap_or(Dynamic::Null) }) }
882}
883
884extern "C" fn any_push(addr: *mut Dynamic, value: *mut Dynamic) {
885 if !addr.is_null() && !value.is_null() {
886 unsafe {
887 (&mut *addr).push_dynamic((&*value).clone());
888 }
889 }
890}
891
892extern "C" fn any_pop(addr: *mut Dynamic) -> *const Dynamic {
893 if addr.is_null() { any_null() } else { alloc_dynamic(unsafe { (*addr).pop().unwrap_or(Dynamic::Null) }) }
894}
895
896extern "C" fn get_key(addr: *const Dynamic, key: *const Dynamic) -> *const Dynamic {
897 if addr.is_null() || key.is_null() {
898 any_null()
899 } else {
900 let key: &str = unsafe { &*key }.as_str();
901 alloc_dynamic(unsafe { (*addr).get_dynamic(key).unwrap_or(Dynamic::Null) })
902 }
903}
904
905extern "C" fn del_key(addr: *const Dynamic, key: *const Dynamic) -> *const Dynamic {
906 if addr.is_null() || key.is_null() {
907 any_null()
908 } else {
909 let key: &str = unsafe { &*key }.as_str();
910 alloc_dynamic(unsafe { (*addr).remove_dynamic(key).unwrap_or(Dynamic::Null) })
911 }
912}
913
914extern "C" fn contains(addr: *const Dynamic, key: *const Dynamic) -> bool {
915 if addr.is_null() || key.is_null() {
916 false
917 } else {
918 let key: &str = unsafe { &*key }.as_str();
919 unsafe { (*addr).contains(key) }
920 }
921}
922
923extern "C" fn starts_with(addr: *const Dynamic, prefix: *const Dynamic) -> bool {
924 if addr.is_null() || prefix.is_null() {
925 false
926 } else {
927 let prefix: &str = unsafe { &*prefix }.as_str();
928 unsafe { (*addr).starts_with(prefix) }
929 }
930}
931
932extern "C" fn get_idx(addr: *const Dynamic, idx: i64) -> *const Dynamic {
933 if addr.is_null() { any_null() } else { alloc_dynamic(unsafe { (*addr).get_idx(idx as usize).unwrap_or(Dynamic::Null) }) }
934}
935
936macro_rules! myvec_list_native {
937 ($push:ident, $get_idx:ident, $set_idx:ident, $vec:ident, $dynamic:ident, $ty:ty, $fallback:expr) => {
938 extern "C" fn $push(addr: *mut Dynamic, value: $ty) {
939 if addr.is_null() {
940 return;
941 }
942 unsafe {
943 match &mut *addr {
944 Dynamic::$vec(values) => values.push(value),
945 list => {
946 list.push_dynamic(Dynamic::$dynamic(value));
947 }
948 }
949 }
950 }
951
952 extern "C" fn $get_idx(addr: *const Dynamic, idx: i64) -> $ty {
953 if addr.is_null() {
954 return <$ty>::default();
955 }
956 let Ok(idx) = usize::try_from(idx) else {
957 return <$ty>::default();
958 };
959 unsafe {
960 match &*addr {
961 Dynamic::$vec(values) => values.get(idx).unwrap_or_default(),
962 values => values.get_idx(idx).and_then($fallback).unwrap_or_default(),
963 }
964 }
965 }
966
967 extern "C" fn $set_idx(addr: *mut Dynamic, idx: i64, value: $ty) {
968 if addr.is_null() {
969 return;
970 }
971 let Ok(idx) = usize::try_from(idx) else {
972 return;
973 };
974 unsafe {
975 match &mut *addr {
976 Dynamic::$vec(values) => values.set(idx, value),
977 list => list.set_idx(idx, Dynamic::$dynamic(value)),
978 }
979 }
980 }
981 };
982}
983
984macro_rules! stdvec_list_native {
985 ($push:ident, $get_idx:ident, $set_idx:ident, $vec:ident, $dynamic:ident, $ty:ty, $fallback:expr) => {
986 extern "C" fn $push(addr: *mut Dynamic, value: $ty) {
987 if addr.is_null() {
988 return;
989 }
990 unsafe {
991 match &mut *addr {
992 Dynamic::$vec(values) => values.push(value),
993 list => {
994 list.push_dynamic(Dynamic::$dynamic(value));
995 }
996 }
997 }
998 }
999
1000 extern "C" fn $get_idx(addr: *const Dynamic, idx: i64) -> $ty {
1001 if addr.is_null() {
1002 return <$ty>::default();
1003 }
1004 let Ok(idx) = usize::try_from(idx) else {
1005 return <$ty>::default();
1006 };
1007 unsafe {
1008 match &*addr {
1009 Dynamic::$vec(values) => values.get(idx).copied().unwrap_or_default(),
1010 values => values.get_idx(idx).and_then($fallback).unwrap_or_default(),
1011 }
1012 }
1013 }
1014
1015 extern "C" fn $set_idx(addr: *mut Dynamic, idx: i64, value: $ty) {
1016 if addr.is_null() {
1017 return;
1018 }
1019 let Ok(idx) = usize::try_from(idx) else {
1020 return;
1021 };
1022 unsafe {
1023 match &mut *addr {
1024 Dynamic::$vec(values) => {
1025 if let Some(slot) = values.get_mut(idx) {
1026 *slot = value;
1027 }
1028 }
1029 list => list.set_idx(idx, Dynamic::$dynamic(value)),
1030 }
1031 }
1032 }
1033 };
1034}
1035
1036myvec_list_native!(list_i8_push, list_i8_get_idx, list_i8_set_idx, VecI8, I8, i8, |value: Dynamic| value.as_int().map(|value| value as i8));
1037myvec_list_native!(list_u16_push, list_u16_get_idx, list_u16_set_idx, VecU16, U16, u16, |value: Dynamic| value.as_uint().map(|value| value as u16));
1038myvec_list_native!(list_i16_push, list_i16_get_idx, list_i16_set_idx, VecI16, I16, i16, |value: Dynamic| value.as_int().map(|value| value as i16));
1039myvec_list_native!(list_u32_push, list_u32_get_idx, list_u32_set_idx, VecU32, U32, u32, |value: Dynamic| value.as_uint().map(|value| value as u32));
1040myvec_list_native!(list_i32_push, list_i32_get_idx, list_i32_set_idx, VecI32, I32, i32, |value: Dynamic| value.as_int().map(|value| value as i32));
1041myvec_list_native!(list_f32_push, list_f32_get_idx, list_f32_set_idx, VecF32, F32, f32, |value: Dynamic| value.as_float().map(|value| value as f32));
1042stdvec_list_native!(list_u64_push, list_u64_get_idx, list_u64_set_idx, VecU64, U64, u64, |value: Dynamic| value.as_uint());
1043stdvec_list_native!(list_i64_push, list_i64_get_idx, list_i64_set_idx, VecI64, I64, i64, |value: Dynamic| value.as_int());
1044stdvec_list_native!(list_f64_push, list_f64_get_idx, list_f64_set_idx, VecF64, F64, f64, |value: Dynamic| value.as_float());
1045
1046extern "C" fn list_bool_push(addr: *mut Dynamic, value: bool) {
1047 if !addr.is_null() {
1048 unsafe {
1049 (&mut *addr).push_dynamic(Dynamic::Bool(value));
1050 }
1051 }
1052}
1053
1054extern "C" fn list_bool_get_idx(addr: *const Dynamic, idx: i64) -> bool {
1055 if addr.is_null() {
1056 return false;
1057 }
1058 let Ok(idx) = usize::try_from(idx) else {
1059 return false;
1060 };
1061 unsafe { (&*addr).get_idx(idx).and_then(|value| value.as_bool()).unwrap_or(false) }
1062}
1063
1064extern "C" fn list_bool_set_idx(addr: *mut Dynamic, idx: i64, value: bool) {
1065 if addr.is_null() {
1066 return;
1067 }
1068 let Ok(idx) = usize::try_from(idx) else {
1069 return;
1070 };
1071 unsafe {
1072 (&mut *addr).set_idx(idx, Dynamic::Bool(value));
1073 }
1074}
1075
1076extern "C" fn list_u8_push(addr: *mut Dynamic, value: u8) {
1077 if !addr.is_null() {
1078 unsafe {
1079 (&mut *addr).push_dynamic(Dynamic::U8(value));
1080 }
1081 }
1082}
1083
1084extern "C" fn list_u8_get_idx(addr: *const Dynamic, idx: i64) -> u8 {
1085 if addr.is_null() {
1086 return 0;
1087 }
1088 let Ok(idx) = usize::try_from(idx) else {
1089 return 0;
1090 };
1091 unsafe { (&*addr).get_idx(idx).and_then(|value| value.as_uint()).map(|value| value as u8).unwrap_or(0) }
1092}
1093
1094extern "C" fn list_u8_set_idx(addr: *mut Dynamic, idx: i64, value: u8) {
1095 if addr.is_null() {
1096 return;
1097 }
1098 let Ok(idx) = usize::try_from(idx) else {
1099 return;
1100 };
1101 unsafe {
1102 (&mut *addr).set_idx(idx, Dynamic::U8(value));
1103 }
1104}
1105
1106extern "C" fn list_str_push(addr: *mut Dynamic, value: *const Dynamic) {
1107 if addr.is_null() || value.is_null() {
1108 return;
1109 }
1110 unsafe {
1111 (&mut *addr).push_dynamic((&*value).clone());
1112 }
1113}
1114
1115extern "C" fn list_str_get_idx(addr: *const Dynamic, idx: i64) -> *const Dynamic {
1116 if addr.is_null() {
1117 return any_null();
1118 };
1119 let Ok(idx) = usize::try_from(idx) else {
1120 return any_null();
1121 };
1122 if let Some(value) = unsafe { (&*addr).get_idx(idx) } { alloc_dynamic(value) } else { any_null() }
1123}
1124
1125extern "C" fn list_str_set_idx(addr: *mut Dynamic, idx: i64, value: *const Dynamic) {
1126 if addr.is_null() || value.is_null() {
1127 return;
1128 }
1129 let Ok(idx) = usize::try_from(idx) else {
1130 return;
1131 };
1132 unsafe {
1133 (&mut *addr).set_idx(idx, (&*value).clone());
1134 }
1135}
1136
1137extern "C" fn slice(addr: *const Dynamic, start: i64, stop: *const Dynamic, inclusive: bool) -> *const Dynamic {
1138 if addr.is_null() {
1139 return any_null();
1140 }
1141
1142 let value = unsafe { &*addr };
1143 let len = value.len() as i64;
1144 let start = start.clamp(0, len) as usize;
1145 let mut stop = if stop.is_null() {
1146 len
1147 } else {
1148 let raw = unsafe { &*stop };
1149 if raw.is_null() { len } else { raw.as_int().unwrap_or(len) }
1150 };
1151 if inclusive && stop < len {
1152 stop += 1;
1153 }
1154 let stop = stop.clamp(start as i64, len) as usize;
1155
1156 let sliced = if value.is_str() {
1157 Dynamic::from(value.as_str().chars().skip(start).take(stop.saturating_sub(start)).collect::<String>())
1158 } else {
1159 match value {
1160 Dynamic::List(list) => Dynamic::list(list.read().unwrap()[start..stop].to_vec()),
1161 _ => Dynamic::Null,
1162 }
1163 };
1164 alloc_dynamic(sliced)
1165}
1166
1167extern "C" fn set_key(addr: *mut Dynamic, key: *const Dynamic, value: *const Dynamic) {
1168 if addr.is_null() || key.is_null() {
1169 return;
1170 }
1171 let key: &str = unsafe { &*key }.as_str();
1172 unsafe { (&mut *addr).set_dynamic(key.into(), (&*value).clone()) }
1173}
1174
1175extern "C" fn set_idx(addr: *mut Dynamic, idx: i64, value: *const Dynamic) {
1176 if addr.is_null() {
1177 return;
1178 }
1179 unsafe { (&mut *addr).set_idx(idx as usize, (&*value).clone()) }
1180}
1181
1182extern "C" fn any_from_i64(v: i64) -> *const Dynamic {
1183 alloc_dynamic(Dynamic::I64(v))
1184}
1185
1186extern "C" fn any_from_u64(v: u64) -> *const Dynamic {
1187 alloc_dynamic(Dynamic::U64(v))
1188}
1189
1190extern "C" fn any_from_bool(v: bool) -> *const Dynamic {
1191 alloc_dynamic(Dynamic::Bool(v))
1192}
1193
1194extern "C" fn any_to_i64(addr: *const Dynamic) -> i64 {
1195 if addr.is_null() {
1196 return 0;
1197 }
1198 unsafe {
1199 let value = &*addr;
1200 value
1201 .as_int()
1202 .or_else(|| value.as_float().map(|value| value as i64))
1203 .or_else(|| {
1204 let text = value.as_str();
1205 let text = text.trim();
1206 if text.is_empty() { None } else { text.parse::<i64>().ok().or_else(|| text.parse::<f64>().ok().map(|value| value as i64)) }
1207 })
1208 .unwrap_or(0)
1209 }
1210}
1211
1212extern "C" fn any_to_bool(addr: *const Dynamic) -> bool {
1213 if addr.is_null() {
1214 return false;
1215 }
1216 unsafe {
1217 let value = &*addr;
1218 if let Some(v) = value.as_bool() {
1219 v
1220 } else if let Some(v) = value.as_int() {
1221 v != 0
1222 } else if let Some(v) = value.as_float() {
1223 v != 0.0
1224 } else {
1225 !value.is_null()
1226 }
1227 }
1228}
1229
1230extern "C" fn any_from_f64(v: f64) -> *const Dynamic {
1231 alloc_dynamic(Dynamic::F64(v))
1232}
1233
1234extern "C" fn any_split(addr: *mut Dynamic, s: *const Dynamic) -> *const Dynamic {
1235 if addr.is_null() || s.is_null() {
1236 return any_null();
1237 }
1238 let s: &str = unsafe { &*s }.as_str();
1239 alloc_dynamic(unsafe { (&*addr).clone() }.split(s))
1240}
1241
1242extern "C" fn any_to_f64(addr: *const Dynamic) -> f64 {
1243 if addr.is_null() {
1244 return 0.0;
1245 }
1246 unsafe {
1247 let value = &*addr;
1248 value.as_float().or_else(|| value.as_str().trim().parse::<f64>().ok()).unwrap_or(0.0)
1249 }
1250}
1251
1252extern "C" fn any_to_string(addr: *const Dynamic) -> *const Dynamic {
1253 if addr.is_null() {
1254 return alloc_dynamic(Dynamic::from(""));
1255 }
1256 alloc_dynamic(Dynamic::from(unsafe { &*addr }.to_string()))
1257}
1258
1259extern "C" fn any_binary(left: *const Dynamic, op: i32, right: *const Dynamic) -> *const Dynamic {
1260 if left.is_null() {
1261 if right.is_null() {
1262 return any_null();
1263 }
1264 return alloc_dynamic(unsafe { (&*right).clone() });
1265 }
1266 if right.is_null() {
1267 return alloc_dynamic(unsafe { (&*left).clone() });
1268 }
1269 let op = BinaryOp::try_from(op).unwrap_or(BinaryOp::Unknow);
1270 if op == BinaryOp::Add {
1271 let (left_value, right_value) = unsafe { (&*left, &*right) };
1272 if left_value.is_str() || right_value.is_str() {
1273 return alloc_dynamic(left_value.clone() + right_value.clone());
1274 }
1275 }
1276 unsafe {
1277 let expr = Expr::new(
1278 ExprKind::Binary { left: Box::new(Expr::new(ExprKind::Value((&*left).clone()), Span::default())), op, right: Box::new(Expr::new(ExprKind::Value((&*right).clone()), Span::default())) },
1279 Span::default(),
1280 );
1281 alloc_dynamic(expr.compact().unwrap_or(Dynamic::Null))
1282 }
1283}
1284
1285extern "C" fn any_logic(left: *const Dynamic, op: i32, right: *const Dynamic) -> bool {
1286 let op = BinaryOp::try_from(op).unwrap_or(BinaryOp::Unknow);
1287 unsafe {
1288 let expr = Expr::new(
1289 ExprKind::Binary { left: Box::new(Expr::new(ExprKind::Value((&*left).clone()), Span::default())), op, right: Box::new(Expr::new(ExprKind::Value((&*right).clone()), Span::default())) },
1290 Span::default(),
1291 );
1292 expr.compact().and_then(|r| r.as_bool()).unwrap_or(false)
1293 }
1294}
1295
1296pub const STD: [(&str, &[Type], Type, *const u8); 5] = [
1297 ("print", &[Type::Any], Type::Void, print as *const u8),
1298 ("sqrt", &[Type::F64], Type::F64, sqrt as *const u8),
1299 ("log", &[Type::Any], Type::Void, log_any as *const u8),
1300 ("uuid", &[], Type::Any, uuid as *const u8),
1301 ("rand", &[Type::Any, Type::Any], Type::Any, random as *const u8),
1302];
1303
1304pub const ANY: [(&str, &[Type], Type, *const u8); 68] = [
1305 ("Any::null", &[], Type::Any, any_null as *const u8),
1306 ("Any::is_map", &[Type::Any], Type::Bool, any_is_map as *const u8),
1307 ("Any::is_list", &[Type::Any], Type::Bool, any_is_list as *const u8),
1308 ("Any::is_string", &[Type::Any], Type::Bool, any_is_string as *const u8),
1309 ("Any::is_null", &[Type::Any], Type::Bool, any_is_null as *const u8),
1310 ("Any::clone", &[Type::Any], Type::Any, any_clone as *const u8),
1311 ("Any::len", &[Type::Any], Type::I32, any_len as *const u8),
1312 ("Any::keys", &[Type::Any], Type::Any, any_keys as *const u8),
1313 ("Any::split", &[Type::Any, Type::Any], Type::Any, any_split as *const u8),
1314 ("Any::push", &[Type::Any, Type::Any], Type::Void, any_push as *const u8),
1315 ("Any::pop", &[Type::Any], Type::Any, any_pop as *const u8),
1316 ("Any::get_idx", &[Type::Any, Type::I64], Type::Any, get_idx as *const u8),
1317 ("Any::push_bool", &[Type::Any, Type::Bool], Type::Void, list_bool_push as *const u8),
1318 ("Any::get_idx_bool", &[Type::Any, Type::I64], Type::Bool, list_bool_get_idx as *const u8),
1319 ("Any::set_idx_bool", &[Type::Any, Type::I64, Type::Bool], Type::Void, list_bool_set_idx as *const u8),
1320 ("Any::push_u8", &[Type::Any, Type::U8], Type::Void, list_u8_push as *const u8),
1321 ("Any::get_idx_u8", &[Type::Any, Type::I64], Type::U8, list_u8_get_idx as *const u8),
1322 ("Any::set_idx_u8", &[Type::Any, Type::I64, Type::U8], Type::Void, list_u8_set_idx as *const u8),
1323 ("Any::push_i8", &[Type::Any, Type::I8], Type::Void, list_i8_push as *const u8),
1324 ("Any::get_idx_i8", &[Type::Any, Type::I64], Type::I8, list_i8_get_idx as *const u8),
1325 ("Any::set_idx_i8", &[Type::Any, Type::I64, Type::I8], Type::Void, list_i8_set_idx as *const u8),
1326 ("Any::push_u16", &[Type::Any, Type::U16], Type::Void, list_u16_push as *const u8),
1327 ("Any::get_idx_u16", &[Type::Any, Type::I64], Type::U16, list_u16_get_idx as *const u8),
1328 ("Any::set_idx_u16", &[Type::Any, Type::I64, Type::U16], Type::Void, list_u16_set_idx as *const u8),
1329 ("Any::push_i16", &[Type::Any, Type::I16], Type::Void, list_i16_push as *const u8),
1330 ("Any::get_idx_i16", &[Type::Any, Type::I64], Type::I16, list_i16_get_idx as *const u8),
1331 ("Any::set_idx_i16", &[Type::Any, Type::I64, Type::I16], Type::Void, list_i16_set_idx as *const u8),
1332 ("Any::push_u32", &[Type::Any, Type::U32], Type::Void, list_u32_push as *const u8),
1333 ("Any::get_idx_u32", &[Type::Any, Type::I64], Type::U32, list_u32_get_idx as *const u8),
1334 ("Any::set_idx_u32", &[Type::Any, Type::I64, Type::U32], Type::Void, list_u32_set_idx as *const u8),
1335 ("Any::push_i32", &[Type::Any, Type::I32], Type::Void, list_i32_push as *const u8),
1336 ("Any::get_idx_i32", &[Type::Any, Type::I64], Type::I32, list_i32_get_idx as *const u8),
1337 ("Any::set_idx_i32", &[Type::Any, Type::I64, Type::I32], Type::Void, list_i32_set_idx as *const u8),
1338 ("Any::push_f32", &[Type::Any, Type::F32], Type::Void, list_f32_push as *const u8),
1339 ("Any::get_idx_f32", &[Type::Any, Type::I64], Type::F32, list_f32_get_idx as *const u8),
1340 ("Any::set_idx_f32", &[Type::Any, Type::I64, Type::F32], Type::Void, list_f32_set_idx as *const u8),
1341 ("Any::push_u64", &[Type::Any, Type::U64], Type::Void, list_u64_push as *const u8),
1342 ("Any::get_idx_u64", &[Type::Any, Type::I64], Type::U64, list_u64_get_idx as *const u8),
1343 ("Any::set_idx_u64", &[Type::Any, Type::I64, Type::U64], Type::Void, list_u64_set_idx as *const u8),
1344 ("Any::push_i64", &[Type::Any, Type::I64], Type::Void, list_i64_push as *const u8),
1345 ("Any::get_idx_i64", &[Type::Any, Type::I64], Type::I64, list_i64_get_idx as *const u8),
1346 ("Any::set_idx_i64", &[Type::Any, Type::I64, Type::I64], Type::Void, list_i64_set_idx as *const u8),
1347 ("Any::push_f64", &[Type::Any, Type::F64], Type::Void, list_f64_push as *const u8),
1348 ("Any::get_idx_f64", &[Type::Any, Type::I64], Type::F64, list_f64_get_idx as *const u8),
1349 ("Any::set_idx_f64", &[Type::Any, Type::I64, Type::F64], Type::Void, list_f64_set_idx as *const u8),
1350 ("Any::push_str", &[Type::Any, Type::Str], Type::Void, list_str_push as *const u8),
1351 ("Any::get_idx_str", &[Type::Any, Type::I64], Type::Str, list_str_get_idx as *const u8),
1352 ("Any::set_idx_str", &[Type::Any, Type::I64, Type::Str], Type::Void, list_str_set_idx as *const u8),
1353 ("Any::slice", &[Type::Any, Type::I64, Type::Any, Type::Bool], Type::Any, slice as *const u8),
1354 ("Any::contains", &[Type::Any, Type::Any], Type::Bool, contains as *const u8),
1355 ("Any::starts_with", &[Type::Any, Type::Any], Type::Bool, starts_with as *const u8),
1356 ("Any::get_key", &[Type::Any, Type::Any], Type::Any, get_key as *const u8),
1357 ("Any::del_key", &[Type::Any, Type::Any], Type::Any, del_key as *const u8),
1358 ("Any::set_idx", &[Type::Any, Type::I64, Type::Any], Type::Void, set_idx as *const u8),
1359 ("Any::set_key", &[Type::Any, Type::Any, Type::Any], Type::Void, set_key as *const u8),
1360 ("Any::from_i64", &[Type::I64], Type::Any, any_from_i64 as *const u8),
1361 ("Any::from_u64", &[Type::U64], Type::Any, any_from_u64 as *const u8),
1362 ("Any::from_bool", &[Type::Bool], Type::Any, any_from_bool as *const u8),
1363 ("Any::to_i64", &[Type::Any], Type::I64, any_to_i64 as *const u8),
1364 ("Any::to_bool", &[Type::Any], Type::Bool, any_to_bool as *const u8),
1365 ("Any::from_f64", &[Type::F64], Type::Any, any_from_f64 as *const u8),
1366 ("Any::to_f64", &[Type::Any], Type::F64, any_to_f64 as *const u8),
1367 ("Any::to_string", &[Type::Any], Type::Str, any_to_string as *const u8),
1368 ("Any::binary", &[Type::Any, Type::I32, Type::Any], Type::Any, any_binary as *const u8),
1369 ("Any::logic", &[Type::Any, Type::I32, Type::Any], Type::Bool, any_logic as *const u8),
1370 ("Any::iter", &[Type::Any], Type::Any, any_iter as *const u8),
1371 ("Any::next", &[Type::Any], Type::Any, any_next as *const u8),
1372 ("Any::next_pair", &[Type::Any], Type::Any, any_next_pair as *const u8),
1373];
1374
1375use std::rc::Rc;
1376impl JITRunTime {
1377 pub fn add_native_ptr(&mut self, full_name: &str, name: &str, arg_tys: &[Type], ret_ty: Type, fn_ptr: *const u8) -> Result<u32> {
1378 self.native_symbols.write().unwrap().insert(full_name.to_string(), fn_ptr as usize);
1379 self.add_native(full_name, name, arg_tys, ret_ty)
1380 }
1381
1382 pub(crate) fn add_context_native_ptr(&mut self, full_name: &str, name: &str, arg_tys: &[Type], ret_ty: Type, fn_ptr: *const u8) -> Result<u32> {
1383 self.native_symbols.write().unwrap().insert(full_name.to_string(), fn_ptr as usize);
1384 self.add_context_native(full_name, name, arg_tys, ret_ty)
1385 }
1386
1387 pub fn add_native(&mut self, full_name: &str, name: &str, arg_tys: &[Type], ret_ty: Type) -> Result<u32> {
1388 let fn_ty = Type::Fn { tys: arg_tys.to_vec(), ret: Rc::new(ret_ty.clone()) };
1389 let id = self.compiler.add_symbol(name, compiler::Symbol::Native(fn_ty.clone()));
1390 let sig = self.get_sig(arg_tys, ret_ty)?;
1391 let fn_id = self.module.declare_function(full_name, Linkage::Import, &sig)?;
1392 self.fns.insert(id, FnVariant::Native { ty: fn_ty, fn_id, context: None });
1393 Ok(id)
1394 }
1395
1396 pub(crate) fn add_context_native(&mut self, full_name: &str, name: &str, arg_tys: &[Type], ret_ty: Type) -> Result<u32> {
1397 let fn_ty = Type::Fn { tys: arg_tys.to_vec(), ret: Rc::new(ret_ty.clone()) };
1398 let id = self.compiler.add_symbol(name, compiler::Symbol::Native(fn_ty.clone()));
1399 let mut sig = self.module.make_signature();
1400 sig.params.push(AbiParam::new(crate::ptr_type()));
1401 for arg in arg_tys.iter() {
1402 sig.params.push(AbiParam::new(crate::get_type(arg)?));
1403 }
1404 if !ret_ty.is_void() {
1405 sig.returns.push(AbiParam::new(crate::get_type(&ret_ty)?));
1406 }
1407 let fn_id = self.module.declare_function(full_name, Linkage::Import, &sig)?;
1408 self.fns.insert(id, FnVariant::Native { ty: fn_ty, fn_id, context: Some(self.owner_context_ptr()) });
1409 Ok(id)
1410 }
1411}