diff --git a/crates/wasm-actor/tests/wasm_actor.rs b/crates/wasm-actor/tests/wasm_actor.rs index a84860f..0290749 100644 --- a/crates/wasm-actor/tests/wasm_actor.rs +++ b/crates/wasm-actor/tests/wasm_actor.rs @@ -11258,4 +11258,123 @@ fn actor_replacement_cycle() { rt.stop_actor(addr); rt.tick(); } +} + +// ── Cycle 78 ───────────────────────────────────────────────────────────────── + +// Guest with recursive helper that computes fibonacci (bounded) +#[test] +fn guest_fibonacci_via_recursion() { + let wat = r#"(module + (memory (export "memory") 1) + (func $fib (param $n i32) (result i32) + (if (result i32) (i32.le_u (local.get $n) (i32.const 1)) + (then (local.get $n)) + (else + (i32.add + (call $fib (i32.sub (local.get $n) (i32.const 1))) + (call $fib (i32.sub (local.get $n) (i32.const 2))) + ) + ) + ) + ) + (func (export "alloc") (param $len i32) (result i32) i32.const 1024) + (func (export "handle") (param $ptr i32) (param $len i32) + ;; Compute fib(10) = 55, store at ptr + (i32.store (local.get $ptr) (call $fib (i32.const 10))) + ) + )"#; + let engine = SharedEngine::new().unwrap(); + let actor = WasmActorBuilder::new(engine, wat::parse_str(wat).unwrap()) + .build().unwrap(); + let rt = Runtime::new(RuntimeConfig::default()); + let addr = rt.spawn(actor).unwrap(); + rt.send_to(addr, ByteMessage(vec![0u8; 4])).unwrap(); + rt.tick(); +} + +// Inbox receives messages from multiple WASM actors simultaneously +#[test] +fn single_inbox_receives_from_five_actors() { + let engine = SharedEngine::new().unwrap(); + let rt = Runtime::new(RuntimeConfig::default()); + let inbox = rt.new_inbox::().unwrap(); + + for i in 0..5u8 { + let actor = WasmActorBuilder::new(engine.clone(), guest_wasm("echo")).build().unwrap(); + let addr = rt.spawn(actor).unwrap(); + rt.send_to(addr, framed_msg(inbox.addr(), &[i])).unwrap(); + } + rt.tick(); + + let mut msgs: Vec> = std::iter::from_fn(|| inbox.try_recv().map(|m| m.0)).collect(); + msgs.sort(); + assert_eq!(msgs.len(), 5); + for i in 0..5u8 { + assert_eq!(msgs[i as usize], vec![i]); + } +} + +// Guest that does nothing at all — purely exercises spawn+tick+stop lifecycle +#[test] +fn minimal_lifecycle_no_messages() { + let wat = r#"(module + (memory (export "memory") 1) + (func (export "alloc") (param $len i32) (result i32) i32.const 0) + (func (export "handle") (param $ptr i32) (param $len i32)) + )"#; + let engine = SharedEngine::new().unwrap(); + let actor = WasmActorBuilder::new(engine, wat::parse_str(wat).unwrap()) + .build().unwrap(); + let rt = Runtime::new(RuntimeConfig::default()); + let addr = rt.spawn(actor).unwrap(); + rt.tick(); + rt.tick(); + rt.stop_actor(addr); + rt.tick(); +} + +// Same message bytes reused for multiple sends — no aliasing issues +#[test] +fn reuse_message_bytes_for_multiple_sends() { + let engine = SharedEngine::new().unwrap(); + let actor = WasmActorBuilder::new(engine, guest_wasm("echo")).build().unwrap(); + let rt = Runtime::new(RuntimeConfig::default()); + let inbox = rt.new_inbox::().unwrap(); + let addr = rt.spawn(actor).unwrap(); + + let msg = framed_msg(inbox.addr(), b"reuse"); + for _ in 0..5 { + // Clone the same message each time + rt.send_to(addr, msg.clone()).unwrap(); + } + rt.tick(); + + let msgs: Vec> = std::iter::from_fn(|| inbox.try_recv().map(|m| m.0)).collect(); + assert_eq!(msgs.len(), 5); + assert!(msgs.iter().all(|m| m == b"reuse")); +} + +// Guest uses block with result value +#[test] +fn guest_block_with_result_value() { + let wat = r#"(module + (memory (export "memory") 1) + (func (export "alloc") (param $len i32) (result i32) i32.const 1024) + (func (export "handle") (param $ptr i32) (param $len i32) + ;; Block that produces a value + (i32.store (local.get $ptr) + (block (result i32) + (i32.add (local.get $len) (i32.const 42)) + ) + ) + ) + )"#; + let engine = SharedEngine::new().unwrap(); + let actor = WasmActorBuilder::new(engine, wat::parse_str(wat).unwrap()) + .build().unwrap(); + let rt = Runtime::new(RuntimeConfig::default()); + let addr = rt.spawn(actor).unwrap(); + rt.send_to(addr, ByteMessage(vec![0u8; 4])).unwrap(); + rt.tick(); } \ No newline at end of file