harn-stdlib 0.10.126

Embedded Harn standard library source catalog
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
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

// @harn-entrypoint-category agent.stdlib
import { AgentResult } from "std/agent/contracts"
import { __agent_loop_run } from "std/agent/loop_run"
import "std/agent/loop_support"
import {
  __agent_loop_fire_resume_continuity,
  __loop_progress_nudge_text,
} from "std/agent/loop_turn_options"
import { agent_tool_format_override_warning_text } from "std/agent/options"
import {
  agent_purpose_label_config,
  agent_purpose_label_prompt_fragment,
} from "std/agent/purpose_labels"

pub fn __progress_nudge_text(
  depth: int,
  has_tools: any,
  paradigm: dict,
  made_tool_calls: bool = false,
) {
  return __loop_progress_nudge_text(depth, has_tools, paradigm, made_tool_calls)
}

/**
 * agent_loop.
 *
 * @effects: [host, agent]
 * @errors: []
 * @api_stability: experimental
 */
pub fn agent_loop(
  harness: Harness,
  message: any,
  system_prompt: any = nil,
  options: any = nil,
) -> AgentResult {
  let opts = agent_loop_options(harness, agent_progress_apply_options(harness.agent, options))
  // Lifecycle composition owns the agent projection so direct callers and
  // this default path share one validated, closure-preserving boundary.
  opts = opts + {tools: agent_lifecycle_tools(harness.agent, opts?.tools, opts)}
  // Teaching the declaration grammar is part of the mechanism, so it lives
  // with the mechanism rather than in each host's prompt prose. The fragment
  // is empty unless the caller turned purpose labels on.
  const purpose_fragment = agent_purpose_label_prompt_fragment(
    agent_purpose_label_config(opts?.purpose_labels),
  )
  const effective_system = if purpose_fragment == "" {
    system_prompt
  } else if system_prompt == nil || system_prompt == "" {
    purpose_fragment
  } else {
    to_string(system_prompt) + "\n\n" + purpose_fragment
  }
  if effective_system != nil && effective_system != "" {
    opts = opts + {_primary_system: effective_system}
  }
  const session = agent_session_init(harness.agent, message, effective_system, opts)
  if session.done {
    return schema_expect(session.result, schema_of(AgentResult))
  }
  agent_scratchpad_init(harness.agent, session, opts)
  if opts?._tool_format_override != nil {
    agent_emit_event(
      harness.agent,
      session.session_id,
      "tool_format_override",
      opts._tool_format_override,
    )
    const warning = agent_tool_format_override_warning_text(opts._tool_format_override)
    if warning != nil {
      harness.stdio.eprintln(warning)
    }
  }
  if opts?._tool_format_capability_gap != nil {
    agent_emit_event(
      harness.agent,
      session.session_id,
      "capability_gap",
      opts._tool_format_capability_gap,
    )
  }
  defer {
    try {
      __host_mcp_disconnect(session.session_id)
    } catch (e) {
    }
  }
  opts = __agent_loop_fire_resume_continuity(harness.agent, session, opts)
  opts = agent_stance_prepare(harness, session, message, opts)
  return __agent_loop_run(harness, message, session, opts)
}