swamp_script_vm_test/

util.rs

use seq_map::SeqMap;
use std::ptr;
use swamp_script_code_gen::alloc::ConstantMemoryRegion;
use swamp_script_code_gen::alloc_util::type_size_and_alignment;
use swamp_script_code_gen::{CodeGenState, Error, GenOptions};
use swamp_script_compile::Program;
use swamp_script_compile::compile_string;
use swamp_script_semantic::{ConstantId, Function};
use swamp_script_types::Type;
use swamp_vm::host::HostArgs;
use swamp_vm::{Vm, VmSetup};
use swamp_vm_disasm::{disasm_instructions_color, disasm_instructions_no_color};
use swamp_vm_types::ConstantMemoryAddress;
use tracing::info;

fn gen_internal(code: &str) -> Result<(CodeGenState, Program), Error> {
    let (program, main_module, _source_map) = compile_string(code).unwrap();

    let mut code_gen = CodeGenState::new();

    code_gen.reserve_space_for_constants(&program.state.constants_in_dependency_order)?;

    let debug_expr = main_module.main_expression.as_ref().unwrap();
    let main_expression = main_module.main_expression.as_ref().unwrap();
    let halt_function = GenOptions {
        is_halt_function: true,
    };

    code_gen.gen_main_function(main_expression, &halt_function)?;

    let normal_function = GenOptions {
        is_halt_function: false,
    };

    for internal_function_def in &main_module.symbol_table.internal_functions() {
        code_gen.gen_function_def(internal_function_def, &normal_function)?;
    }

    for (associated_on_type, impl_functions) in
        &program.state.instantiator.associated_impls.functions
    {
        if !associated_on_type.is_concrete() {
            continue;
        }
        if associated_on_type == &Type::Int
            || associated_on_type == &Type::Float
            || associated_on_type == &Type::Bool
            || associated_on_type == &Type::String
        {
            continue;
        }

        for (_name, func) in &impl_functions.functions {
            if func.name().clone().starts_with("instantiated ") {
                continue;
            }
            match &**func {
                Function::Internal(int_fn) => {
                    code_gen.gen_function_def(int_fn, &normal_function)?;
                }

                Function::External(_ext_fn) => {}
            }
        }
    }

    code_gen.gen_constants_expression_functions_in_order(
        &program.state.constants_in_dependency_order,
    )?;

    code_gen.finalize();

    Ok((code_gen, program))
}

fn gen_internal_debug(code: &str) -> Result<(CodeGenState, Program), Error> {
    let (code_gen, program) = gen_internal(code)?;
    let disassembler_output = disasm_instructions_color(
        code_gen.instructions(),
        code_gen.comments(),
        &code_gen.create_function_sections(),
    );

    eprintln!("{disassembler_output}");

    Ok((code_gen, program))
}

fn exec_code_gen_state(code_gen_state: CodeGenState) -> Vm {
    let (instructions, mut constants_memory, constant_functions) =
        code_gen_state.take_instructions_and_constants();

    for (_constant_id, constant_func) in constant_functions {
        let setup = VmSetup {
            frame_memory_size: 1024,
            heap_memory_size: 1024,
            constant_memory: constants_memory.clone(),
        };

        let mut vm = Vm::new(instructions.clone(), setup);

        vm.execute_from_ip(&constant_func.ip);

        unsafe {
            ptr::copy_nonoverlapping(
                vm.frame_memory().as_ptr(),
                constants_memory
                    .as_mut_ptr()
                    .add(constant_func.target_constant_memory.addr.0 as usize),
                constant_func.target_constant_memory.size.0 as usize,
            );
        }
    }

    let setup = VmSetup {
        frame_memory_size: 1024,
        heap_memory_size: 1024,
        constant_memory: constants_memory,
    };
    let mut vm = Vm::new(instructions, setup);

    vm.execute();

    vm
}

pub fn exec_internal(code: &str) -> Result<Vm, Error> {
    let (code_gen, _program) = gen_internal_debug(code)?;

    Ok(exec_code_gen_state(code_gen))
}

fn exec_internal_debug(code: &str) -> Result<Vm, Error> {
    exec_internal(code)
}

fn trim_lines(text: &str) -> String {
    text.lines()
        .map(|line| {
            // Ignore comments that starts with ;
            line.split(';').next().unwrap_or("").trim()
        })
        .filter(|line| !line.is_empty())
        .collect::<Vec<_>>()
        .join("\n")
}

fn compare_line_outputs(encountered: &str, expected: &str) {
    let encountered_trimmed = trim_lines(encountered);
    let expected_trimmed = trim_lines(expected);

    eprintln!("{encountered}");
    assert_eq!(encountered_trimmed, expected_trimmed);
}

fn compare_hex_outputs(memory: &[u8], expected_hex: &str) {
    let encountered_hexed = hexify::format_hex(memory);
    let expected_hex_trimmed = expected_hex.trim();

    compare_line_outputs(&encountered_hexed, expected_hex_trimmed);
}

fn exec(code: &str, expected_hex: &str) {
    let vm = exec_internal_debug(code).expect("should work");

    compare_hex_outputs(&vm.stack_memory()[..16], expected_hex);
}

pub fn exec_with_assembly(code: &str, expected_assembly: &str, expected_hex: &str) {
    let (generator, _program) = gen_internal_debug(code).expect("should work");

    let disassembler_output = disasm_instructions_no_color(
        generator.instructions(),
        generator.comments(),
        &generator.create_function_sections(),
        false,
    );
    compare_line_outputs(&disassembler_output, expected_assembly);

    let vm = exec_code_gen_state(generator);

    compare_hex_outputs(&vm.frame_memory()[..16], expected_hex);
}

/// # Panics
///
pub fn exec_with_host_function<F>(
    code: &str,
    expected_assembly: &str,
    expected_hex: &str,
    id: &str,
    callback: F,
) where
    F: 'static + FnMut(HostArgs),
{
    let vm = exec_with_host_function_internal(code, expected_assembly, id, callback);
    compare_hex_outputs(&vm.frame_memory()[..16], expected_hex);
}

/// # Panics
///
pub fn exec_with_host_function_internal<F>(
    code: &str,
    expected_assembly: &str,
    id: &str,
    callback: F,
) -> Vm
where
    F: 'static + FnMut(HostArgs),
{
    let (generator, program) = gen_internal_debug(code).expect("should work");

    let disassembler_output = disasm_instructions_no_color(
        generator.instructions(),
        generator.comments(),
        &generator.create_function_sections(),
        false,
    );
    compare_line_outputs(&disassembler_output, expected_assembly);

    let module = program
        .modules
        .get(&["crate".to_string(), "test".to_string()])
        .unwrap();

    let external_id = module
        .symbol_table
        .get_external_function_declaration(id)
        .unwrap();

    let (instructions, constants, constant_infos) = generator.take_instructions_and_constants();
    let setup = VmSetup {
        frame_memory_size: 1024,
        heap_memory_size: 1024,
        constant_memory: constants,
    };
    let mut vm = Vm::new(instructions, setup);

    vm.add_host_function(external_id.id as u16, callback);

    vm.execute();

    vm
}

/// # Panics
///
pub fn exec_with_host_function_show_heap<F>(
    code: &str,
    expected_assembly: &str,
    start: usize,
    count: usize,
    expected_hex: &str,
    id: &str,
    callback: F,
) where
    F: 'static + FnMut(HostArgs),
{
    let vm = exec_with_host_function_internal(code, expected_assembly, id, callback);
    compare_hex_outputs(&vm.heap_memory()[start..start + count], expected_hex);
}

fn exec_vars(code: &str, expected_hex: &str) {
    let vm = exec_internal_debug(code);

    compare_hex_outputs(&vm.unwrap().frame_memory()[..16], expected_hex);
}

fn gen_code(code: &str, expected_output: &str) {
    let (generator, _program) = gen_internal_debug(code).expect("should work");

    let disassembler_output = disasm_instructions_no_color(
        generator.instructions(),
        generator.comments(),
        &generator.create_function_sections(),
        false,
    );

    compare_line_outputs(&disassembler_output, expected_output);
}

pub fn exec_show_constants(code: &str, expected_hex: &str, expected_constants: &str) {
    let vm = exec_internal_debug(code).unwrap();

    compare_hex_outputs(&vm.stack_memory()[..16], expected_hex);
    compare_hex_outputs(&vm.constants()[..16], expected_constants);
}