geam 0.1.1

Experimental Rust-embedded execution runtime for typed Gleam programs
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127

use super::super::{EvaluatedFunctionExit, evaluate_entry, parameter_locals};
use crate::plan::execution::function::BitArrayFunctionId;
use crate::plan::execution::graph::ParamLocal;
use crate::runtime::ExecutableRuntimePlan;
use crate::runtime::error::{ExecutionResult, HostCallOrigin};
use crate::runtime::evaluated::EvaluatedBitArray;
use crate::runtime::graph::RetainedValues;
use crate::runtime::state::RuntimeStateFor;

pub(in crate::runtime) fn run_bit_array<Plan: ExecutableRuntimePlan>(
    plan: &Plan,
    state: &mut RuntimeStateFor<'_, Plan>,
    mut function: BitArrayFunctionId,
    mut origin: HostCallOrigin,
    mut inputs: RetainedValues,
) -> ExecutionResult<EvaluatedBitArray> {
    loop {
        let exit = evaluate_entry(
            plan,
            state,
            plan.bit_array_function(function),
            origin,
            inputs,
        )?;
        match exit {
            EvaluatedFunctionExit::Return(value) => return Ok(value),
            EvaluatedFunctionExit::TailCall {
                function: target,
                args,
            } => {
                origin = HostCallOrigin::source(target.site().clone());
                function = *target.function();
                inputs = args;
            }
        }
    }
}

pub(in crate::runtime) fn bit_array_parameter_locals<Plan: ExecutableRuntimePlan>(
    plan: &Plan,
    function: BitArrayFunctionId,
) -> Vec<ParamLocal> {
    parameter_locals(plan, plan.bit_array_function(function))
}

#[cfg(test)]
mod tests {
    use super::bit_array_parameter_locals;
    use crate::plan::execution::function::BitArrayFunctionId;
    use crate::plan::execution::graph::{BitArrayLocalId, ParamLocal};
    use crate::{
        BitArrayValue, HostModule, HostProviderSet, HostedExecution, ModuleSource, PackageSource,
        Value, compile_typed_host_program, compile_typed_module, plan_host_program, plan_module,
        run_main,
    };

    #[test]
    fn plain_bit_array_function_protocol_executes_graph_entries() {
        let source = r#"
fn identity(value: BitArray) {
  value
}

pub fn main() {
  identity(<<1, 2>>)
}
"#;
        let typed =
            compile_typed_module("main", "main.gleam", source).expect("source should compile");
        let plan = plan_module(typed).expect("source should plan");
        let execution = crate::ExecutionPlan::from_module_plan(plan);
        assert_eq!(
            bit_array_parameter_locals(&execution, BitArrayFunctionId(1)),
            [ParamLocal::BitArray(BitArrayLocalId(0))],
        );
        assert_eq!(
            run_main(&execution, &mut Vec::new()),
            Ok(Value::BitArray(BitArrayValue::from_bytes(vec![1, 2]))),
        );
    }

    #[test]
    fn hosted_bit_array_function_protocol_executes_graph_and_host_entries() {
        let binaries = HostModule::new("host_support", "host/binaries")
            .expect("host module should be valid")
            .with_function("identity", |value: BitArrayValue| value)
            .expect("host function should be valid");
        let hosts = HostProviderSet::new([binaries]).expect("host modules should be unique");
        let source = r#"
import host/binaries

fn identity(value: BitArray) {
  value
}

pub fn main() {
  identity(binaries.identity(<<1, 2>>))
}
"#;
        let typed = compile_typed_host_program(
            "application",
            "main",
            [PackageSource::new(
                "application",
                ["host_support"],
                [ModuleSource::new("main", "main.gleam", source)],
            )],
            hosts,
        )
        .expect("host source should compile");
        let plan = plan_host_program(typed).expect("host source should plan");
        let execution =
            HostedExecution::try_from_module_plan(plan).expect("hosted execution should seal");
        assert_eq!(
            bit_array_parameter_locals(&execution, BitArrayFunctionId(2)),
            [ParamLocal::BitArray(BitArrayLocalId(0))],
        );
        assert_eq!(
            bit_array_parameter_locals(&execution, BitArrayFunctionId(1)),
            [ParamLocal::BitArray(BitArrayLocalId(0))],
        );
        assert_eq!(
            execution.run_main(&mut (), &mut Vec::new()),
            Ok(Value::BitArray(BitArrayValue::from_bytes(vec![1, 2]))),
        );
    }
}