luars 0.17.0

// Tests for async function support
//
// These tests verify that Rust async functions can be registered and called
// from Lua code via the AsyncThread mechanism.

use crate::lua_value::LuaUserdata;
use crate::lua_vm::async_thread::AsyncReturnValue;
use crate::*;
use std::fmt;

/// Helper: create a VM with stdlib loaded
fn new_vm() -> Box<LuaVM> {
    let mut vm = LuaVM::new(SafeOption::default());
    vm.open_stdlib(Stdlib::All).unwrap();
    vm
}

// ============ Basic async function tests ============

#[tokio::test]
async fn test_async_basic_return() {
    let mut vm = new_vm();

    // Register an async function that returns a single value
    vm.register_async("async_add", |args| async move {
        let a = args[0].as_integer().unwrap_or(0);
        let b = args[1].as_integer().unwrap_or(0);
        Ok(vec![AsyncReturnValue::integer(a + b)])
    })
    .unwrap();

    let results = vm.execute_async("return async_add(10, 20)").await.unwrap();

    assert_eq!(results.len(), 1);
    assert_eq!(results[0].as_integer(), Some(30));
}

#[tokio::test]
async fn test_async_no_args() {
    let mut vm = new_vm();

    vm.register_async("async_hello", |_args| async move {
        Ok(vec![AsyncReturnValue::string("hello")])
    })
    .unwrap();

    let results = vm.execute_async("return async_hello()").await.unwrap();

    assert_eq!(results.len(), 1);
    assert_eq!(results[0].as_str(), Some("hello"));
}

#[tokio::test]
async fn test_async_typed_no_args() {
    let mut vm = new_vm();

    vm.register_async_typed("async_hello_typed", || async move { Ok("hello") })
        .unwrap();

    let results = vm
        .execute_async("return async_hello_typed()")
        .await
        .unwrap();
    assert_eq!(results.len(), 1);
    assert_eq!(results[0].as_str(), Some("hello"));
}

#[tokio::test]
async fn test_async_multiple_returns() {
    let mut vm = new_vm();

    vm.register_async("async_multi", |_args| async move {
        Ok(vec![
            AsyncReturnValue::integer(1),
            AsyncReturnValue::integer(2),
            AsyncReturnValue::integer(3),
        ])
    })
    .unwrap();

    let results = vm.execute_async("return async_multi()").await.unwrap();

    assert_eq!(results.len(), 3);
    assert_eq!(results[0].as_integer(), Some(1));
    assert_eq!(results[1].as_integer(), Some(2));
    assert_eq!(results[2].as_integer(), Some(3));
}

#[tokio::test]
async fn test_async_typed_multiple_returns() {
    let mut vm = new_vm();

    vm.register_async_typed(
        "async_multi_typed",
        || async move { Ok((1_i64, 2_i64, 3_i64)) },
    )
    .unwrap();

    let results = vm
        .execute_async("return async_multi_typed()")
        .await
        .unwrap();

    assert_eq!(results.len(), 3);
    assert_eq!(results[0].as_integer(), Some(1));
    assert_eq!(results[1].as_integer(), Some(2));
    assert_eq!(results[2].as_integer(), Some(3));
}

#[tokio::test]
async fn test_async_nil_return() {
    let mut vm = new_vm();

    // Async function that returns exactly one nil value
    vm.register_async("async_nil", |_args| async move {
        Ok(vec![AsyncReturnValue::nil()])
    })
    .unwrap();

    let results = vm
        .execute_async(
            r#"
        local x = async_nil()
        assert(x == nil)
        return true
    "#,
        )
        .await
        .unwrap();

    assert_eq!(results.len(), 1);
}

// ============ Multiple async calls in sequence ============

#[tokio::test]
async fn test_async_sequential_calls() {
    let mut vm = new_vm();

    vm.register_async("async_double", |args| async move {
        let n = args[0].as_integer().unwrap_or(0);
        Ok(vec![AsyncReturnValue::integer(n * 2)])
    })
    .unwrap();

    let results = vm
        .execute_async(
            r#"
        local a = async_double(5)
        local b = async_double(a)
        local c = async_double(b)
        return c
    "#,
        )
        .await
        .unwrap();

    assert_eq!(results.len(), 1);
    assert_eq!(results[0].as_integer(), Some(40)); // 5*2*2*2
}

#[tokio::test]
async fn test_async_typed_high_arity() {
    let mut vm = new_vm();

    vm.register_async_typed(
        "async_sum8",
        |a: i64, b: i64, c: i64, d: i64, e: i64, f: i64, g: i64, h: i64| async move {
            Ok(a + b + c + d + e + f + g + h)
        },
    )
    .unwrap();

    let results = vm
        .execute_async("return async_sum8(1, 2, 3, 4, 5, 6, 7, 8)")
        .await
        .unwrap();
    assert_eq!(results.len(), 1);
    assert_eq!(results[0].as_integer(), Some(36));
}

// ============ Async with actual .await (tokio::time::sleep) ============

#[tokio::test]
async fn test_async_with_sleep() {
    let mut vm = new_vm();

    vm.register_async("async_sleep_and_return", |args| async move {
        let val = args[0].as_integer().unwrap_or(0);
        // Actually await something
        tokio::time::sleep(std::time::Duration::from_millis(1)).await;
        Ok(vec![AsyncReturnValue::integer(val + 100)])
    })
    .unwrap();

    let results = vm
        .execute_async("return async_sleep_and_return(42)")
        .await
        .unwrap();

    assert_eq!(results.len(), 1);
    assert_eq!(results[0].as_integer(), Some(142));
}

// ============ Error handling ============

#[tokio::test]
async fn test_async_error_propagation() {
    let mut vm = new_vm();

    vm.register_async("async_fail", |_args| async move {
        Err(lua_vm::LuaError::RuntimeError)
    })
    .unwrap();

    let result = vm.execute_async("return async_fail()").await;

    assert!(result.is_err());
}

// ============ Interaction with normal Lua code ============

#[tokio::test]
async fn test_async_mixed_with_sync() {
    let mut vm = new_vm();

    vm.register_async("async_get", |args| async move {
        let key = args[0].as_str().unwrap_or("?").to_string();
        Ok(vec![AsyncReturnValue::string(format!("value_{}", key))])
    })
    .unwrap();

    let results = vm
        .execute_async(
            r#"
        local function sync_process(s)
            return string.upper(s)
        end
        local val = async_get("test")
        return sync_process(val)
    "#,
        )
        .await
        .unwrap();

    assert_eq!(results.len(), 1);
    assert_eq!(results[0].as_str(), Some("VALUE_TEST"));
}

#[tokio::test]
async fn test_async_in_loop() {
    let mut vm = new_vm();

    vm.register_async("async_inc", |args| async move {
        let n = args[0].as_integer().unwrap_or(0);
        Ok(vec![AsyncReturnValue::integer(n + 1)])
    })
    .unwrap();

    let results = vm
        .execute_async(
            r#"
        local sum = 0
        for i = 1, 5 do
            sum = sum + async_inc(i)
        end
        return sum
    "#,
        )
        .await
        .unwrap();

    // sum = (1+1) + (2+1) + (3+1) + (4+1) + (5+1) = 2+3+4+5+6 = 20
    assert_eq!(results.len(), 1);
    assert_eq!(results[0].as_integer(), Some(20));
}

// ============ create_async_thread API ============

#[tokio::test]
async fn test_create_async_thread_directly() {
    let mut vm = new_vm();

    vm.register_async("async_square", |args| async move {
        let n = args[0].as_integer().unwrap_or(0);
        Ok(vec![AsyncReturnValue::integer(n * n)])
    })
    .unwrap();

    let chunk = vm.compile("return async_square(7)").unwrap();
    let thread = vm.create_async_thread(chunk, vec![]).unwrap();
    let results = thread.await.unwrap();

    assert_eq!(results.len(), 1);
    assert_eq!(results[0].as_integer(), Some(49));
}

// ============ Async UserData return tests ============

/// Test struct returned from async functions
#[derive(LuaUserData)]
#[lua_impl(Display)]
struct AsyncPoint {
    pub x: f64,
    pub y: f64,
}

impl fmt::Display for AsyncPoint {
    fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
        write!(f, "AsyncPoint({}, {})", self.x, self.y)
    }
}

#[lua_methods]
impl AsyncPoint {
    pub fn sum(&self) -> f64 {
        self.x + self.y
    }
}

#[derive(LuaUserData)]
struct AsyncCounter {
    pub count: i64,
}

#[tokio::test]
async fn test_async_return_userdata() {
    let mut vm = new_vm();

    // Register an async function that returns a UserData
    vm.register_async("make_point", |args| async move {
        let x = args[0].as_number().unwrap_or(0.0);
        let y = args[1].as_number().unwrap_or(0.0);
        Ok(vec![AsyncReturnValue::userdata(AsyncPoint { x, y })])
    })
    .unwrap();

    // Test field access on the returned userdata
    let results = vm
        .execute_async("local p = make_point(3.0, 4.0); return p.x, p.y")
        .await
        .unwrap();

    assert_eq!(results.len(), 2);
    assert_eq!(results[0].as_number(), Some(3.0));
    assert_eq!(results[1].as_number(), Some(4.0));
}

#[tokio::test]
async fn test_async_return_userdata_method() {
    let mut vm = new_vm();

    vm.register_async("make_point", |args| async move {
        let x = args[0].as_number().unwrap_or(0.0);
        let y = args[1].as_number().unwrap_or(0.0);
        Ok(vec![AsyncReturnValue::userdata(AsyncPoint { x, y })])
    })
    .unwrap();

    // Test method call on the returned userdata
    let results = vm
        .execute_async("local p = make_point(10, 20); return p:sum()")
        .await
        .unwrap();

    assert_eq!(results.len(), 1);
    assert_eq!(results[0].as_number(), Some(30.0));
}

#[tokio::test]
async fn test_async_return_userdata_tostring() {
    let mut vm = new_vm();

    vm.register_async("make_point", |args| async move {
        let x = args[0].as_number().unwrap_or(0.0);
        let y = args[1].as_number().unwrap_or(0.0);
        Ok(vec![AsyncReturnValue::userdata(AsyncPoint { x, y })])
    })
    .unwrap();

    // Test __tostring metamethod
    let results = vm
        .execute_async("local p = make_point(1, 2); return tostring(p)")
        .await
        .unwrap();

    assert_eq!(results.len(), 1);
    assert_eq!(results[0].as_str(), Some("AsyncPoint(1, 2)"));
}

#[tokio::test]
async fn test_async_return_userdata_via_from() {
    let mut vm = new_vm();

    // Test using From<LuaUserdata> conversion
    vm.register_async("make_point", |_args| async move {
        let ud = LuaUserdata::new(AsyncPoint { x: 5.0, y: 6.0 });
        Ok(vec![AsyncReturnValue::from(ud)])
    })
    .unwrap();

    let results = vm
        .execute_async("local p = make_point(); return p.x + p.y")
        .await
        .unwrap();

    assert_eq!(results.len(), 1);
    assert_eq!(results[0].as_number(), Some(11.0));
}

#[tokio::test]
async fn test_async_return_mixed_userdata_and_values() {
    let mut vm = new_vm();

    // Return userdata alongside other types
    vm.register_async("make_result", |_args| async move {
        Ok(vec![
            AsyncReturnValue::userdata(AsyncPoint { x: 1.0, y: 2.0 }),
            AsyncReturnValue::string("ok"),
            AsyncReturnValue::integer(42),
        ])
    })
    .unwrap();

    let results = vm
        .execute_async("local p, s, n = make_result(); return p.x, s, n")
        .await
        .unwrap();

    assert_eq!(results.len(), 3);
    assert_eq!(results[0].as_number(), Some(1.0));
    assert_eq!(results[1].as_str(), Some("ok"));
    assert_eq!(results[2].as_integer(), Some(42));
}

#[tokio::test]
async fn test_async_typed_userdata_ref_arg() {
    let mut vm = new_vm();

    let counter = vm.push_any(AsyncCounter { count: 5 }).unwrap();
    vm.set_global("counter", counter).unwrap();

    vm.register_async_typed(
        "async_increment_counter",
        |mut counter: UserDataRef<AsyncCounter>, delta: i64| async move {
            tokio::time::sleep(std::time::Duration::from_millis(1)).await;
            let counter_ref = counter.get_mut().unwrap();
            counter_ref.count += delta;
            Ok(counter_ref.count)
        },
    )
    .unwrap();

    let results = vm
        .execute_async("return async_increment_counter(counter, 7)")
        .await
        .unwrap();

    assert_eq!(results.len(), 1);
    assert_eq!(results[0].as_integer(), Some(12));

    let counter: UserDataRef<AsyncCounter> = vm.get_global_as("counter").unwrap().unwrap();
    assert_eq!(counter.get().unwrap().count, 12);
}

// ============ call_async tests ============

#[tokio::test]
async fn test_call_async_basic() {
    let mut vm = new_vm();

    vm.execute("function add(a, b) return a + b end").unwrap();

    let func = vm.get_global("add").unwrap().unwrap();
    let results = vm
        .call_async(func, vec![LuaValue::integer(10), LuaValue::integer(20)])
        .await
        .unwrap();

    assert_eq!(results.len(), 1);
    assert_eq!(results[0].as_integer(), Some(30));
}

#[tokio::test]
async fn test_call_async_with_async_function() {
    let mut vm = new_vm();

    vm.register_async("async_double", |args| async move {
        let n = args[0].as_integer().unwrap_or(0);
        Ok(vec![AsyncReturnValue::integer(n * 2)])
    })
    .unwrap();

    vm.execute("function process(x) return async_double(x) end")
        .unwrap();

    let func = vm.get_global("process").unwrap().unwrap();
    let results = vm
        .call_async(func, vec![LuaValue::integer(21)])
        .await
        .unwrap();

    assert_eq!(results.len(), 1);
    assert_eq!(results[0].as_integer(), Some(42));
}

#[tokio::test]
async fn test_call_async_global() {
    let mut vm = new_vm();

    vm.execute("function greet(name) return 'Hello, ' .. name end")
        .unwrap();

    let name = vm.create_string("World").unwrap();
    let results = vm.call_async_global("greet", vec![name]).await.unwrap();

    assert_eq!(results.len(), 1);
    assert_eq!(results[0].as_str(), Some("Hello, World"));
}

#[tokio::test]
async fn test_call_async_global_not_found() {
    let mut vm = new_vm();

    let result = vm.call_async_global("nonexistent", vec![]).await;
    assert!(result.is_err());
}

// ============ AsyncCallHandle tests ============

#[tokio::test]
async fn test_async_call_handle_basic() {
    let mut vm = new_vm();

    vm.execute("function add(a, b) return a + b end").unwrap();

    let mut handle = vm.create_async_call_handle_global("add").unwrap();

    // First call
    let r1 = handle
        .call(vec![LuaValue::integer(1), LuaValue::integer(2)])
        .await
        .unwrap();
    assert_eq!(r1[0].as_integer(), Some(3));

    // Second call (reuses the coroutine)
    let r2 = handle
        .call(vec![LuaValue::integer(10), LuaValue::integer(20)])
        .await
        .unwrap();
    assert_eq!(r2[0].as_integer(), Some(30));

    // Third call
    let r3 = handle
        .call(vec![LuaValue::integer(100), LuaValue::integer(200)])
        .await
        .unwrap();
    assert_eq!(r3[0].as_integer(), Some(300));

    assert!(handle.is_alive());
}

#[tokio::test]
async fn test_async_call_handle_error_recovery() {
    let mut vm = new_vm();

    vm.execute(
        r#"
        function maybe_fail(x)
            if x < 0 then
                error("negative!")
            end
            return x * 2
        end
    "#,
    )
    .unwrap();

    let mut handle = vm.create_async_call_handle_global("maybe_fail").unwrap();

    // Successful call
    let r1 = handle.call(vec![LuaValue::integer(5)]).await.unwrap();
    assert_eq!(r1[0].as_integer(), Some(10));

    // Failed call (pcall catches it, handle stays alive)
    let r2 = handle.call(vec![LuaValue::integer(-1)]).await;
    assert!(r2.is_err());
    assert!(handle.is_alive()); // Still alive!

    // Successful call after error
    let r3 = handle.call(vec![LuaValue::integer(7)]).await.unwrap();
    assert_eq!(r3[0].as_integer(), Some(14));
}

#[tokio::test]
async fn test_async_call_handle_with_async() {
    let mut vm = new_vm();

    vm.register_async("async_add", |args| async move {
        let a = args[0].as_integer().unwrap_or(0);
        let b = args[1].as_integer().unwrap_or(0);
        Ok(vec![AsyncReturnValue::integer(a + b)])
    })
    .unwrap();

    vm.execute("function process(a, b) return async_add(a, b) end")
        .unwrap();

    let mut handle = vm.create_async_call_handle_global("process").unwrap();

    let r1 = handle
        .call(vec![LuaValue::integer(3), LuaValue::integer(4)])
        .await
        .unwrap();
    assert_eq!(r1[0].as_integer(), Some(7));

    let r2 = handle
        .call(vec![LuaValue::integer(10), LuaValue::integer(20)])
        .await
        .unwrap();
    assert_eq!(r2[0].as_integer(), Some(30));
}

#[tokio::test]
async fn test_async_call_handle_multiple_returns() {
    let mut vm = new_vm();

    vm.execute("function multi(x) return x, x*2, x*3 end")
        .unwrap();

    let mut handle = vm.create_async_call_handle_global("multi").unwrap();

    let results = handle.call(vec![LuaValue::integer(5)]).await.unwrap();
    assert_eq!(results.len(), 3);
    assert_eq!(results[0].as_integer(), Some(5));
    assert_eq!(results[1].as_integer(), Some(10));
    assert_eq!(results[2].as_integer(), Some(15));
}

#[tokio::test]
async fn test_async_call_handle_no_args_no_returns() {
    let mut vm = new_vm();

    vm.execute("x = 0; function inc() x = x + 1 end").unwrap();

    let mut handle = vm.create_async_call_handle_global("inc").unwrap();

    let r = handle.call(vec![]).await.unwrap();
    assert!(r.is_empty());

    handle.call(vec![]).await.unwrap();
    handle.call(vec![]).await.unwrap();

    let results = vm.execute("return x").unwrap();
    assert_eq!(results[0].as_integer(), Some(3));
}