harn-vm 0.5.49

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

/// runtime_task.
pub fn runtime_task() -> string {
  return host_call("runtime.task", {}) ?? ""
}

/// runtime_pipeline_input.
pub fn runtime_pipeline_input() {
  return host_call("runtime.pipeline_input", {})
}

/// runtime_dry_run.
pub fn runtime_dry_run() -> bool {
  return host_call("runtime.dry_run", {}) ?? false
}

/// runtime_approved_plan.
pub fn runtime_approved_plan() -> string {
  return host_call("runtime.approved_plan", {}) ?? ""
}

/// process_exec.
pub fn process_exec(command) {
  return host_call("process.exec", {command: command})
}

/// process_exec_with_timeout.
pub fn process_exec_with_timeout(command, timeout_ms) {
  return host_call("process.exec", {command: command, timeout: timeout_ms})
}

/// interaction_ask.
pub fn interaction_ask(question) -> string {
  return host_call("interaction.ask", {question: question}) ?? ""
}

/// interaction_ask_with_kind.
pub fn interaction_ask_with_kind(question, kind) -> string {
  return host_call("interaction.ask", {question: question, type: kind}) ?? ""
}

/// record_run_metadata.
pub fn record_run_metadata(run, workflow_name) {
  if run?.path {
    host_call(
      "runtime.record_run",
      {
      workflow: workflow_name,
      path: run?.path,
      status: run?.status ?? "",
      fixture_type: run?.run?.replay_fixture?._type,
      usage: run?.usage,
      persisted_path: run?.persisted_path,
      summary: transcript_summary(run?.transcript),
      transcript_state: run?.transcript?.state ?? "",
      message_count: len(transcript_messages(run?.transcript)),
      event_count: len(transcript_events(run?.transcript)),
      asset_count: len(transcript_assets(run?.transcript)),
    },
    )
  }
}