harn-vm 0.10.170

Async bytecode virtual machine for the Harn programming language
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

//! Read back the typed control words a session accepted.
//!
//! `crate::agent_sessions::control_events` is the reader for the rows
//! `record_control_event` writes at acceptance. This exposes it to the
//! stdlib so an exit authority can see a stop.
//!
//! A stop is why this exists. A steer arrives as a delivered user message and
//! is therefore recoverable from transcript history; a stop unwinds the loop
//! and delivers nothing, so without these rows an authority reading the
//! transcript alone reports a stopped run as still owing its whole task.

use super::*;

/// Return every typed control event recorded for an agent session, oldest
/// first. An unknown session and a session nobody used a control word on both
/// return an empty list, so a caller must not read emptiness as proof that no
/// control happened.
#[harn_builtin(
    exposure = "runtime_internal",
    effects = [],
    sig = "__host_agent_session_control_events(session_id: string) -> list",
    category = "agent.host",
    runtime_only = true
)]
fn host_agent_session_control_events_builtin(
    args: &[VmValue],
    _out: &mut String,
) -> Result<VmValue, VmError> {
    let session_id = args.first().map(|v| v.display()).unwrap_or_default();
    let events = crate::agent_sessions::control_events(&session_id)
        .iter()
        .map(|event| crate::schema::json_to_vm_value(&event.to_payload()))
        .collect::<Vec<_>>();
    Ok(VmValue::list(events))
}

pub(super) fn register_control_history_primitives(vm: &mut Vm) {
    harn_vm_core::builtin_support::register_module_builtins(vm, module_path!());
}