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

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

pub(in crate::runtime) fn run_float<Plan: ExecutableRuntimePlan>(
    plan: &Plan,
    state: &mut RuntimeStateFor<'_, Plan>,
    mut function: FloatFunctionId,
    mut origin: HostCallOrigin,
    mut inputs: RetainedValues,
) -> ExecutionResult<f64> {
    loop {
        let exit = evaluate_entry(plan, state, plan.float_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 float_parameter_locals<Plan: ExecutableRuntimePlan>(
    plan: &Plan,
    function: FloatFunctionId,
) -> Vec<ParamLocal> {
    parameter_locals(plan, plan.float_function(function))
}

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

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

pub fn main() {
  identity(1.5)
}
"#;
        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!(
            float_parameter_locals(&execution, FloatFunctionId(1)),
            [ParamLocal::Float(FloatLocalId(0))],
        );
        assert_eq!(run_main(&execution, &mut Vec::new()), Ok(Value::Float(1.5)),);
    }

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

fn identity(value: Float) {
  value
}

pub fn main() {
  identity(numbers.identity(1.5))
}
"#;
        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!(
            float_parameter_locals(&execution, FloatFunctionId(2)),
            [ParamLocal::Float(FloatLocalId(0))],
        );
        assert_eq!(
            float_parameter_locals(&execution, FloatFunctionId(1)),
            [ParamLocal::Float(FloatLocalId(0))],
        );
        assert_eq!(
            execution.run_main(&mut (), &mut Vec::new()),
            Ok(Value::Float(1.5)),
        );
    }
}