1mod agent_sessions;
4pub mod agent_state;
5mod agents;
6mod agents_daemon;
7mod concurrency;
8mod connectors;
9mod crypto;
10mod datetime;
11mod fs;
12pub(crate) mod hitl;
13mod hitl_read;
14pub mod host;
15mod io;
16mod iter;
17pub(crate) mod json;
18mod logging;
19mod math;
20mod path;
21pub mod process;
22mod project;
23mod project_catalog;
24mod project_enrich;
25mod regex;
26pub mod secret_scan;
27mod sets;
28mod shapes;
29mod skills;
30mod strings;
31pub mod template;
32mod testing;
33pub(crate) mod tools;
34pub mod tracing;
35mod transcript_compact;
36mod triggers_stdlib;
37mod types;
38
39use crate::http::register_http_builtins;
40use crate::llm::register_llm_builtins;
41use crate::mcp::register_mcp_builtins;
42use crate::mcp_server::register_mcp_server_builtins;
43use crate::vm::Vm;
44
45pub(crate) use crate::schema::{json_to_vm_value, schema_result_value};
46pub(crate) fn set_thread_source_dir(dir: &std::path::Path) {
47 process::set_thread_source_dir(dir);
48}
49
50pub fn register_core_stdlib(vm: &mut Vm) {
52 types::register_type_builtins(vm);
53 math::register_math_builtins(vm);
54 strings::register_string_builtins(vm);
55 json::register_json_builtins(vm);
56 datetime::register_datetime_builtins(vm);
57 regex::register_regex_builtins(vm);
58 crypto::register_crypto_builtins(vm);
59 path::register_path_helper_builtins(vm);
60 sets::register_set_builtins(vm);
61 iter::register_iter_builtins(vm);
62 shapes::register_shape_builtins(vm);
63 testing::register_testing_builtins(vm);
64}
65
66pub fn register_io_stdlib(vm: &mut Vm) {
68 io::register_io_builtins(vm);
69 host::register_host_builtins(vm);
70 fs::register_fs_builtins(vm);
71 agent_state::register_agent_state_builtins(vm);
72 process::register_process_builtins(vm);
73 process::register_path_builtins(vm);
74 project::register_project_builtins(vm);
75 tracing::register_tracing_builtins(vm);
76}
77
78pub fn register_agent_stdlib(vm: &mut Vm) {
80 concurrency::register_concurrency_builtins(vm);
81 connectors::register_connector_builtins(vm);
82 secret_scan::register_secret_scan_builtins(vm);
83 tools::register_tool_builtins(vm);
84 skills::register_skill_builtins(vm);
85 agents_daemon::register_daemon_builtins(vm);
86 triggers_stdlib::register_trigger_builtins(vm);
87 hitl::register_hitl_builtins(vm);
88 hitl_read::register_hitl_read_builtins(vm);
89 agents::register_agent_builtins(vm);
90 agent_sessions::register_agent_session_builtins(vm);
91 transcript_compact::register_transcript_compaction_builtins(vm);
92 register_http_builtins(vm);
93 register_llm_builtins(vm);
94 register_mcp_builtins(vm);
95 register_mcp_server_builtins(vm);
96}
97
98pub fn register_vm_stdlib(vm: &mut Vm) {
100 register_core_stdlib(vm);
101 register_io_stdlib(vm);
102 register_agent_stdlib(vm);
103}
104
105pub fn stdlib_builtin_names() -> Vec<String> {
108 let mut vm = Vm::new();
109 register_vm_stdlib(&mut vm);
110 let tmp = std::path::PathBuf::from("/tmp");
111 crate::store::register_store_builtins(&mut vm, &tmp);
112 crate::checkpoint::register_checkpoint_builtins(&mut vm, &tmp, "default");
113 crate::metadata::register_metadata_builtins(&mut vm, &tmp);
114 crate::metadata::register_scan_builtins(&mut vm);
115 let mut names = vm.builtin_names();
116 for extra in [
119 "spawn",
120 "await",
121 "cancel",
122 "cancel_graceful",
123 "is_cancelled",
124 ] {
125 names.push(extra.to_string());
126 }
127 names
128}
129
130pub fn reset_stdlib_state() {
132 logging::reset_logging_state();
133 process::reset_process_state();
134 fs::reset_fs_state();
135 json::reset_json_state();
136 host::reset_host_state();
137 hitl::reset_hitl_state();
138 agents::records::reset_eval_metrics();
139 tools::clear_current_tool_registry();
140 crate::skills::clear_current_skill_registry();
141 template::reset_prompt_registry();
142}