harn_vm/
stdlib.rs

1//! Standard library builtins for the Harn VM.
2
3mod agent_sessions;
4pub mod agent_state;
5mod agents;
6mod agents_daemon;
7mod bytes;
8mod concurrency;
9mod connectors;
10mod crypto;
11mod datetime;
12mod fs;
13pub(crate) mod hitl;
14mod hitl_read;
15pub mod host;
16mod io;
17mod iter;
18pub(crate) mod json;
19mod logging;
20mod math;
21mod monitors;
22mod path;
23pub mod process;
24mod project;
25mod project_catalog;
26mod project_enrich;
27mod regex;
28mod review;
29pub mod secret_scan;
30mod sets;
31mod shapes;
32mod skills;
33mod strings;
34pub mod template;
35mod testing;
36pub(crate) mod tools;
37pub mod tracing;
38mod transcript_compact;
39mod triggers_stdlib;
40mod types;
41mod vision;
42pub(crate) mod waitpoint;
43mod waitpoints;
44pub mod workflow_messages;
45
46use crate::http::register_http_builtins;
47use crate::llm::register_llm_builtins;
48use crate::mcp::register_mcp_builtins;
49use crate::mcp_server::register_mcp_server_builtins;
50use crate::vm::Vm;
51
52pub(crate) use crate::schema::{json_to_vm_value, schema_result_value};
53pub(crate) fn set_thread_source_dir(dir: &std::path::Path) {
54    process::set_thread_source_dir(dir);
55}
56
57/// Register core builtins: pure/deterministic, no I/O.
58pub fn register_core_stdlib(vm: &mut Vm) {
59    types::register_type_builtins(vm);
60    math::register_math_builtins(vm);
61    strings::register_string_builtins(vm);
62    json::register_json_builtins(vm);
63    datetime::register_datetime_builtins(vm);
64    regex::register_regex_builtins(vm);
65    bytes::register_bytes_builtins(vm);
66    crypto::register_crypto_builtins(vm);
67    path::register_path_helper_builtins(vm);
68    sets::register_set_builtins(vm);
69    iter::register_iter_builtins(vm);
70    shapes::register_shape_builtins(vm);
71    testing::register_testing_builtins(vm);
72}
73
74/// Register I/O builtins (requires OS access).
75pub fn register_io_stdlib(vm: &mut Vm) {
76    io::register_io_builtins(vm);
77    host::register_host_builtins(vm);
78    fs::register_fs_builtins(vm);
79    vision::register_vision_builtins(vm);
80    agent_state::register_agent_state_builtins(vm);
81    process::register_process_builtins(vm);
82    process::register_path_builtins(vm);
83    project::register_project_builtins(vm);
84    tracing::register_tracing_builtins(vm);
85}
86
87/// Register agent builtins (requires network access and async runtime).
88pub fn register_agent_stdlib(vm: &mut Vm) {
89    concurrency::register_concurrency_builtins(vm);
90    connectors::register_connector_builtins(vm);
91    review::register_review_builtins(vm);
92    secret_scan::register_secret_scan_builtins(vm);
93    tools::register_tool_builtins(vm);
94    skills::register_skill_builtins(vm);
95    agents_daemon::register_daemon_builtins(vm);
96    triggers_stdlib::register_trigger_builtins(vm);
97    waitpoints::register_waitpoint_builtins(vm);
98    monitors::register_monitor_builtins(vm);
99    hitl::register_hitl_builtins(vm);
100    hitl_read::register_hitl_read_builtins(vm);
101    waitpoint::register_waitpoint_builtins(vm);
102    agents::register_agent_builtins(vm);
103    agent_sessions::register_agent_session_builtins(vm);
104    workflow_messages::register_workflow_message_builtins(vm);
105    transcript_compact::register_transcript_compaction_builtins(vm);
106    register_http_builtins(vm);
107    register_llm_builtins(vm);
108    register_mcp_builtins(vm);
109    register_mcp_server_builtins(vm);
110}
111
112/// Register all standard builtins on a VM (core + io + agent).
113pub fn register_vm_stdlib(vm: &mut Vm) {
114    register_core_stdlib(vm);
115    register_io_stdlib(vm);
116    register_agent_stdlib(vm);
117}
118
119/// Return the canonical list of all stdlib builtin names. Used by
120/// harn-lint and harn-lsp to avoid hardcoded duplicate lists.
121pub fn stdlib_builtin_names() -> Vec<String> {
122    let mut vm = Vm::new();
123    register_vm_stdlib(&mut vm);
124    let tmp = std::path::PathBuf::from("/tmp");
125    crate::store::register_store_builtins(&mut vm, &tmp);
126    crate::checkpoint::register_checkpoint_builtins(&mut vm, &tmp, "default");
127    crate::metadata::register_metadata_builtins(&mut vm, &tmp);
128    crate::metadata::register_scan_builtins(&mut vm);
129    let mut names = vm.builtin_names();
130    // Special opcodes/keywords, not registered builtins, but linter
131    // should recognize them as valid function calls.
132    for extra in [
133        "spawn",
134        "await",
135        "cancel",
136        "cancel_graceful",
137        "is_cancelled",
138    ] {
139        names.push(extra.to_string());
140    }
141    names
142}
143
144/// Reset thread-local stdlib state. Call between test runs.
145pub fn reset_stdlib_state() {
146    logging::reset_logging_state();
147    process::reset_process_state();
148    fs::reset_fs_state();
149    json::reset_json_state();
150    host::reset_host_state();
151    hitl::reset_hitl_state();
152    monitors::reset_monitor_state();
153    waitpoints::reset_waitpoint_state();
154    waitpoint::reset_waitpoint_state();
155    agents::records::reset_eval_metrics();
156    tools::clear_current_tool_registry();
157    vision::reset_vision_state();
158    crate::skills::clear_current_skill_registry();
159    template::reset_prompt_registry();
160}
harn_vm/stdlib.rs

harn_vm/
stdlib.rs
