lernie 0.0.6

A git-backed agent harness
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
92

//! `lernie prompt` — drive one root conversation (ARCH §2.3). The §2.9
//! preludes (`become_pgid_leader` + `install_stop_handler`) are the
//! binding's, run before [`run`] (ARCH §3.4 binding-preludes seam,
//! [`super::prelude`]); this entry only builds the deps and drives.

use super::{Error, Fx, Outcome};
use crate::harness_root;
use crate::prompt::inbox::AdvanceLauncher;
use crate::prompt::{self, NanoIdGen, SpawnAdapter, SpawnTool, SystemClock};
use crate::template::RealGit;
use std::path::PathBuf;

/// `lernie prompt <repo> <message> [--from <ref>] [--config <name>]
/// [--name <name>] [--pin <dest>=<src>]...`.
#[derive(clap::Args, Debug)]
pub struct Args {
    /// Path to the workspace (conversation repo) root.
    pub repo: PathBuf,
    /// Opening message for the new root conversation.
    pub message: String,
    /// Fork off this ref instead of a config lineage's head (ARCH §2.3,
    /// §7.2): any commit of any agent, a stopped tip, a config commit.
    #[arg(long)]
    pub from: Option<String>,
    /// Fork off `config/<name>`'s head instead of `config/default` (ARCH
    /// §2.2). Mutually exclusive with `--from`.
    #[arg(long)]
    pub config: Option<String>,
    /// Display name for the new agent (ARCH §2.3): one unbroken word,
    /// unique among the workspace's living agents, set here and never
    /// rewritten. `lernie message` accepts it in place of the agent id.
    #[arg(long)]
    pub name: Option<String>,
    /// Pin a caller-supplied document (ARCH §2.5): freeze `<src>`'s
    /// exact bytes at worktree-relative `<dest>` on the dispatch commit,
    /// beside `goal.md` and `soul.md`. Repeatable; validated — and
    /// refused — before any branch or ref exists
    /// ([`crate::prompt::pinned_doc`]).
    #[arg(long = "pin", value_name = "DEST=SRC")]
    pub pin: Vec<String>,
}

/// Spawn the root agent branch and drive its step loop; print the agent
/// id (§2.3) — the verb's one product. The `String`→[`Outcome::Line`]
/// map and the failure conversion are fn-pointers, so the success arm
/// carries no test-only region (its happy path needs a live provider,
/// pinned by `tests/prompt_end_to_end.rs`).
pub fn run(args: Args, fx: &mut Fx) -> Result<Outcome, Error> {
    go(args, fx)
        .map(Outcome::Line)
        .map_err(|e| Error::new("prompt", e))
}

/// No workspace scan: drivers touch only their own branch (§2.11). The
/// detached-launch and successor target is
/// [`Fx::driver_target`](super::Fx::driver_target); the stop flag is
/// [`Fx::stop`](super::Fx::stop).
fn go(args: Args, fx: &mut Fx) -> Result<String, Box<dyn std::error::Error>> {
    // Pins are validated and their sources read here, first — every
    // refusal precedes the fork, so no branch, ref or inference exists
    // when one fires (ARCH §2.5, [`crate::prompt::pinned_doc`]).
    let pins = prompt::pinned_doc::load(&args.pin)?;
    let roots = harness_root::resolve()?;
    // The binding-injected driver target (§2.11 "injected at the binding,
    // not resolved by name") serves both re-entry seams: the §3.3 tool
    // resolver's third hop and the §2.11/§6 detached launch. No
    // `current_exe` here — under a linked host it would name the host.
    let tool_executor = SpawnTool::new(&roots.data, &SystemClock, &fx.driver_target);
    let launcher = AdvanceLauncher::with_exe(fx.driver_target.clone());
    let deps = prompt::Deps {
        adapter: &SpawnAdapter,
        sleeper: &prompt::RealSleeper,
        git: &RealGit::new(),
        clock: &SystemClock,
        id_gen: &NanoIdGen,
        tool_executor: &tool_executor,
        config_root: &roots.config,
        adapter_target: fx.adapter_target.as_deref(),
        stop: fx.stop,
        launcher: &launcher,
    };
    prompt::run(
        &args.repo,
        &args.message,
        args.from.as_deref(),
        args.config.as_deref(),
        args.name.as_deref(),
        &pins,
        &deps,
    )
    .map_err(Into::into)
}