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

use super::super::{EvaluatedFunctionExit, evaluate_entry, parameter_locals};
use crate::plan::execution::function::StringFunctionId;
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;
use ecow::EcoString;

pub(in crate::runtime) fn run_string<Plan: ExecutableRuntimePlan>(
    plan: &Plan,
    state: &mut RuntimeStateFor<'_, Plan>,
    mut function: StringFunctionId,
    mut origin: HostCallOrigin,
    mut inputs: RetainedValues,
) -> ExecutionResult<EcoString> {
    loop {
        let exit = evaluate_entry(plan, state, plan.string_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 string_parameter_locals<Plan: ExecutableRuntimePlan>(
    plan: &Plan,
    function: StringFunctionId,
) -> Vec<ParamLocal> {
    parameter_locals(plan, plan.string_function(function))
}

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

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

pub fn main() {
  identity("one")
}
"#;
        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!(
            string_parameter_locals(&execution, StringFunctionId(1)),
            [ParamLocal::String(StringLocalId(0))],
        );
        assert_eq!(
            run_main(&execution, &mut Vec::new()),
            Ok(Value::String("one".into())),
        );
    }

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

fn identity(value: String) {
  value
}

pub fn main() {
  identity(text.identity("one"))
}
"#;
        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!(
            string_parameter_locals(&execution, StringFunctionId(2)),
            [ParamLocal::String(StringLocalId(0))],
        );
        assert_eq!(
            string_parameter_locals(&execution, StringFunctionId(1)),
            [ParamLocal::String(StringLocalId(0))],
        );
        assert_eq!(
            execution.run_main(&mut (), &mut Vec::new()),
            Ok(Value::String("one".into())),
        );
    }
}