use std::io::{Read, Write};
use std::path::PathBuf;
use borg_trace::fingerprint::bash_read_paths;
use serde_json::{Value, json};
use crate::harness::{self, Harness};
use crate::learn::learning;
use crate::{collective, conscience, learn, live, outcome, predict, prefilter};
pub(crate) fn state_file(session: &str) -> PathBuf {
let dir = std::env::var_os("BORG_STATE").map_or_else(|| PathBuf::from("/tmp/borg"), PathBuf::from);
let _ = std::fs::create_dir_all(&dir);
let safe: String = session.chars().filter(|c| c.is_ascii_alphanumeric() || *c == '-').collect();
dir.join(format!("{safe}.ctx"))
}
pub(crate) fn append(session: &str, text: &str) {
if let Ok(mut f) = std::fs::OpenOptions::new().create(true).append(true).open(state_file(session)) {
let _ = f.write_all(format!("{text}\n").as_bytes());
}
}
pub(crate) fn touched(input: &Value, tool: &str) -> String {
let s = |k: &str| input.get(k).and_then(Value::as_str).unwrap_or_default().to_string();
match tool {
"Bash" => {
let cmd = s("command");
let paths = bash_read_paths(&cmd);
if paths.is_empty() { cmd.chars().take(COMMAND_CHARS).collect() } else { paths.join(" ") }
}
"Grep" => format!("{} {}", s("pattern"), s("path")),
"Glob" => s("pattern"),
_ => {
let mut t = [s("file_path"), s("notebook_path"), s("path")].join(" ").trim().to_string();
for p in further_files(input) {
if !t.is_empty() {
t.push(' ');
}
t.push_str(p);
}
t
}
}
}
const COMMAND_CHARS: usize = borg_trace::dialogue::TOUCH_CHARS;
pub(crate) fn further_files(input: &Value) -> impl Iterator<Item = &str> {
input.get("edits").and_then(Value::as_array).into_iter().flatten().filter_map(|e| e.get("file_path").and_then(Value::as_str)).filter(|p| !p.is_empty())
}
pub(crate) fn repo_of(cwd: &str) -> String {
borg_trace::repo_key(cwd).rsplit('/').next().unwrap_or_default().to_string()
}
fn stat(session: &str, input: &Value, kind: &str, fill: impl FnOnce(&mut crate::stats::Event)) {
let home = learn::home();
let mut ev = crate::stats::Event::new(kind, learn::now_ms());
ev.session = session.into();
ev.repo = repo_of(input.get("cwd").and_then(Value::as_str).unwrap_or_default());
ev.engineer = crate::presence::read(&home, session).map(|p| p.engineer).unwrap_or_default();
fill(&mut ev);
crate::stats::record(&home, &ev);
}
fn prompts_file(session: &str) -> PathBuf {
state_file(session).with_extension("prompts")
}
fn turn_id(session: &str) -> u64 {
std::fs::metadata(prompts_file(session)).map_or(0, |m| m.len())
}
fn where_file(session: &str) -> PathBuf {
state_file(session).with_extension("where")
}
fn where_now(session: &str) -> String {
let paths = std::fs::read_to_string(where_file(session)).unwrap_or_default();
let latest = std::fs::read_to_string(state_file(session).with_extension("lastprompt")).unwrap_or_default();
format!("{paths}\n{latest}")
}
fn note_where(session: &str, text: &str) {
if text.trim().is_empty() {
return;
}
if let Ok(mut f) = std::fs::OpenOptions::new().create(true).append(true).open(where_file(session)) {
let _ = writeln!(f, "{text}");
}
}
fn task_file(session: &str) -> PathBuf {
state_file(session).with_extension("task")
}
fn denied_file(session: &str) -> PathBuf {
state_file(session).with_extension("denied")
}
fn capture_prompt(h: &dyn Harness, session: &str, input: &Value, prompt: &str) {
if !learning() {
return;
}
let task = std::fs::read_to_string(task_file(session)).unwrap_or_default();
if let Ok(tool) = std::fs::read_to_string(denied_file(session)) {
let _ = std::fs::remove_file(denied_file(session));
let said = prompt.trim();
if said.len() > 3 && !said.starts_with('<') {
record(session, input, task, proposal(h, input), Some(tool), said.chars().take(learn::EXCERPT_CHARS).collect());
return;
}
}
if !learn::is_correction(prompt) || task.is_empty() {
let task: String = prompt.chars().take(learn::TASK_CHARS).collect();
let _ = std::fs::write(task_file(session), task);
return;
}
record(session, input, task, proposal(h, input), None, prompt.chars().take(learn::EXCERPT_CHARS).collect());
}
fn veto(h: &dyn Harness, session: &str, input: &Value, reason: &str) {
let _ = std::fs::remove_file(denied_file(session));
let cwd = input.get("cwd").and_then(Value::as_str).unwrap_or_default();
let task = std::fs::read_to_string(task_file(session)).unwrap_or_default();
let said = crate::veto::Said {
session,
repo: &repo_of(cwd),
engineer: &learn::engineer(cwd),
task: &task,
agent: &proposal(h, input),
reason,
ms: learn::now_ms(),
via: "prompt",
};
if let Ok(v) = crate::veto::record(&learn::home(), &said) {
append(session, &format!("#borg-episode {}", v.episode));
}
}
fn capture_rejection(h: &dyn Harness, session: &str, input: &Value) {
if !learning() {
return;
}
let error = input.get("error").and_then(Value::as_str).unwrap_or_default();
let tool = format!(
"{} {}",
input.get("tool_name").and_then(Value::as_str).unwrap_or_default(),
input.get("tool_input").map(|v| v.to_string()).unwrap_or_default().chars().take(learn::EXCERPT_CHARS).collect::<String>()
);
let Some(said) = learn::rejection(error) else {
if learn::denied(error) {
let _ = std::fs::write(denied_file(session), tool);
}
return;
};
let task = std::fs::read_to_string(task_file(session)).unwrap_or_default();
record(session, input, task, proposal(h, input), Some(tool), said);
}
fn proposal(h: &dyn Harness, input: &Value) -> String {
let t = full_proposal(h, input);
t.chars().rev().take(learn::PROPOSAL_CHARS).collect::<Vec<_>>().into_iter().rev().collect()
}
fn full_proposal(h: &dyn Harness, input: &Value) -> String {
harness::last_message(h.caps(), input)
}
fn record(session: &str, input: &Value, task: String, agent: String, rejected_tool: Option<String>, correction: String) {
let ms = learn::now_ms();
let cwd = input.get("cwd").and_then(Value::as_str).unwrap_or_default();
let e = learn::Episode {
id: format!("{}-{ms}", session.chars().take(8).collect::<String>()),
ms,
repo: repo_of(cwd),
session: session.into(),
task,
agent,
rejected_tool,
correction,
engineer: learn::engineer(cwd),
..learn::Episode::default()
};
let _ = learn::record_episode(&e);
append(session, &format!("#borg-episode {}", e.id));
}
fn lessons(session: &str) -> Vec<conscience::Challenge> {
loaded(session).0
}
fn judged(all: &[conscience::Challenge], withheld: Vec<conscience::Challenge>) -> std::borrow::Cow<'_, [conscience::Challenge]> {
if withheld.is_empty() { all.into() } else { all.iter().cloned().chain(withheld).collect::<Vec<_>>().into() }
}
fn loaded(session: &str) -> (Vec<conscience::Challenge>, Vec<conscience::Challenge>) {
let before = std::env::var("BORG_BEFORE").ok().and_then(|v| v.parse().ok());
let mut all = conscience::load_for(&lessons_path(), before, Some(session));
let where_text = std::fs::read_to_string(where_file(session)).unwrap_or_default();
let repos = crate::systems::work_repos(&where_text);
if crate::systems::on() {
crate::systems::gate(&mut all, &repos);
}
all.retain(|c| crate::reach::deliverable(c, &repos));
let withheld = crate::absorb::withhold_beside(&lessons_path(), &mut all, before);
if crate::concepts::on() {
let where_text = std::fs::read_to_string(where_file(session)).unwrap_or_default();
let edits = std::fs::read_to_string(edits_file(session)).unwrap_or_default();
let latest = std::fs::read_to_string(state_file(session).with_extension("lastprompt")).unwrap_or_default();
crate::concepts::apply(&mut all, &crate::concepts::of_work(&edits, &where_text, &latest), crate::concepts::beta());
}
(all, withheld)
}
fn lessons_path() -> PathBuf {
std::env::var_os("BORG_CONSCIENCE").map(PathBuf::from).unwrap_or_else(|| learn::home().join("lessons.jsonl"))
}
fn edits_file(session: &str) -> PathBuf {
state_file(session).with_extension("edits")
}
fn cost_file(session: &str) -> PathBuf {
state_file(session).with_extension("cost")
}
fn changes_file(session: &str) -> PathBuf {
state_file(session).with_extension("changes")
}
fn log_cost(session: &str, line: &str) {
if let Ok(mut f) = std::fs::OpenOptions::new().create(true).append(true).open(cost_file(session)) {
let _ = writeln!(f, "{line}");
}
}
fn early_acted(session: &str, all: &[conscience::Challenge], final_msg: &str) -> std::collections::HashSet<String> {
let edits = std::fs::read_to_string(edits_file(session)).unwrap_or_default();
let state = std::fs::read_to_string(state_file(session)).unwrap_or_default();
let lines: Vec<&str> = edits.lines().filter(|l| !l.starts_with(WORK)).collect();
let mut out = std::collections::HashSet::new();
for (p, l) in lines.iter().enumerate() {
let Some(list) = l.strip_prefix("#borg-early ").or_else(|| l.strip_prefix("#borg-queued ")) else { continue };
let ids: std::collections::HashSet<&str> = ids_in(list).collect();
let asked: Vec<&conscience::Challenge> = all.iter().filter(|c| ids.contains(c.id.as_str())).collect();
let after: Vec<&str> = lines[p + 1..].iter().copied().filter(|l| !l.starts_with("#borg-")).collect();
let upto = state.find(&format!("{l}\n")).map_or(state.as_str(), |i| &state[..i]);
let before = format!("{upto}\n{}", lines[..p].join("\n"));
out.extend(crate::memory::resolve(&asked, all, &before, &after.join("\n"), final_msg, crate::memory::NOVEL_WORDS).0);
}
out
}
fn done_in<'a>(state: &'a str, acted: &std::collections::HashSet<String>) -> std::collections::HashSet<&'a str> {
let mut done = listed(state, "#borg-asked ");
done.extend(listed(state, "#borg-early ").into_iter().chain(listed(state, "#borg-queued ")).filter(|i| acted.contains(*i)));
done
}
fn had_in(state: &str) -> std::collections::HashSet<&str> {
let mut had = listed(state, "#borg-asked ");
had.extend(listed(state, "#borg-early "));
had.extend(listed(state, "#borg-queued "));
had
}
const WORK: &str = "#borg-work ";
pub(crate) fn edit_text(tool: &str, input: &Value) -> Option<String> {
if !["edit", "write", "multiedit", "notebookedit"].contains(&tool.to_ascii_lowercase().as_str()) {
return None;
}
let s = |v: &Value, k: &str| v.get(k).and_then(Value::as_str).unwrap_or_default().to_string();
let mut text = [s(input, "file_path"), s(input, "notebook_path")].join(" ");
for p in further_files(input) {
text.push(' ');
text.push_str(p);
}
for k in ["new_string", "content", "new_source"] {
text.push(' ');
text.push_str(&s(input, k));
}
for e in input.get("edits").and_then(Value::as_array).into_iter().flatten() {
text.push(' ');
text.push_str(&s(e, "new_string"));
}
Some(text.split_whitespace().collect::<Vec<_>>().join(" ").chars().take(EDIT_CHARS).collect())
}
const EDIT_CHARS: usize = 600;
const EVIDENCE_CHARS: usize = 4000;
const _: () = assert!(EVIDENCE_CHARS >= 3 * predict::JUDGE_PART);
pub(crate) fn one_line(text: &str, n: usize) -> String {
text.split_whitespace().collect::<Vec<_>>().join(" ").chars().take(n).collect()
}
fn note_answer(h: &dyn Harness, session: &str, input: &Value) {
let edits = std::fs::read_to_string(edits_file(session)).unwrap_or_default();
let lines: Vec<&str> = edits.lines().collect();
let Some(i) = lines.iter().rposition(|l| l.starts_with("#borg-asked ")) else { return };
if lines[i + 1..].iter().any(|l| l.starts_with("#borg-answer ")) {
return;
}
if let Ok(mut f) = std::fs::OpenOptions::new().create(true).append(true).open(edits_file(session)) {
let _ = writeln!(f, "#borg-answer {}", one_line(&full_proposal(h, input), EVIDENCE_CHARS));
}
}
const MAX_PENDING: usize = conscience::CAP;
const MAX_JUDGE_TRIES: usize = 2;
const DELIVERED: [&str; 4] = ["#borg-asked ", "#borg-early ", "#borg-queued ", "#borg-placebo "];
const ROUTED: &str = "#borg-routed ";
fn is_marker(line: &str) -> bool {
DELIVERED.iter().any(|m| line.starts_with(m)) || line.starts_with("#borg-live ") || line.starts_with(ROUTED)
}
#[must_use]
pub fn stripped(check: &str, lesson: &str) -> bool {
let mut h = blake3::Hasher::new();
h.update(b"borg-strip-v1\0");
h.update(format!("{check}\0{lesson}").as_bytes());
h.finalize().as_bytes()[0] & 1 == 1
}
struct Judging<'a> {
pending: Vec<predict::Pending<'a>>,
question: bool,
crowded: Vec<String>,
}
fn pending<'a>(session: &str, state: &str, all: &'a [conscience::Challenge], final_msg: &str, answered_only: bool, judging: &str) -> Judging<'a> {
let mut tries: std::collections::HashMap<&str, usize> = std::collections::HashMap::new();
let mut settled = std::collections::HashSet::new();
for l in state.lines() {
if let Some(l) = l.strip_prefix("#borg-judged ") {
let (id, label) = l.split_once('=').unwrap_or((l, ""));
*tries.entry(id).or_default() += 1;
if label.trim() != "pending" {
settled.insert(id);
}
} else if let Some(list) = DELIVERED.iter().find_map(|m| l.strip_prefix(m)) {
for id in ids_in(list) {
tries.remove(id);
settled.remove(id);
}
}
}
let edits = std::fs::read_to_string(edits_file(session)).unwrap_or_default();
let lines: Vec<&str> = edits.lines().collect();
let part = predict::JUDGE_PART;
struct Delivery<'l> {
channel: &'static str,
question: bool,
before: &'l str,
answers: Vec<&'l str>,
work: Vec<&'l str>,
fresh: Vec<(&'l str, &'l str, bool)>,
}
let mut deliveries: Vec<Delivery> = Vec::new();
for (p, l) in lines.iter().enumerate() {
let Some((marker, list)) = DELIVERED.iter().find_map(|m| l.strip_prefix(m).map(|rest| (*m, rest))) else { continue };
let question = marker == "#borg-asked ";
let later = &lines[p + 1..];
let channel = match marker {
"#borg-asked " if later.first().is_some_and(|n| n.starts_with("#borg-live ")) => "live",
"#borg-asked " => "stop",
"#borg-early " => "early",
"#borg-queued " => "queued",
_ => outcome::PLACEBO,
};
let answers: Vec<&str> = if question { later.iter().filter_map(|l| l.strip_prefix("#borg-answer ")).collect() } else { Vec::new() };
if answered_only && question && answers.is_empty() {
continue;
}
let before = match lines[..p].iter().rev().find(|b| !is_marker(b)) {
Some(b) if b.starts_with(WORK) => &b[WORK.len()..],
Some(b) if !b.starts_with("#borg-") => b,
_ => "",
};
let work: Vec<&str> = later.iter().copied().filter(|l| !l.starts_with("#borg-")).collect();
let (list, tag) = tagged(list);
let routed: std::collections::HashMap<&str, &str> =
later.first().and_then(|n| n.strip_prefix(ROUTED)).into_iter().flat_map(|r| r.split(',')).filter_map(|it| it.split_once('=')).collect();
let fresh: Vec<&str> = list
.split(',')
.map(str::trim)
.filter(|i| !i.is_empty() && !settled.contains(i) && tries.get(i).copied().unwrap_or(0) < MAX_JUDGE_TRIES)
.filter(|i| all.iter().any(|c| c.id == *i))
.collect();
let check_of = |id: &str| routed.get(id).copied().or(tag).unwrap_or_default();
let fresh =
fresh.into_iter().map(|id| (id, check_of(id), question && stripped(if check_of(id).is_empty() { judging } else { check_of(id) }, id))).collect();
deliveries.push(Delivery { channel, question, before, answers, work, fresh });
}
let strip: Vec<&str> = deliveries.iter().flat_map(|d| &d.fresh).filter(|f| f.2).map(|f| f.0).collect();
let blind = |text: &str| strip.iter().fold(text.to_string(), |t, id| crate::memory::strip_declaration(&t, id));
let turn = predict::clip(&one_line(&blind(final_msg), part + 1), part);
let mut out: Vec<(predict::Pending, bool)> = Vec::new();
for d in deliveries {
let answer = blind(&d.answers.join(" "));
let said = answer.to_lowercase();
let since: Vec<&str> = std::iter::once(answer.as_str()).filter(|a| !a.is_empty()).chain(d.work.iter().copied()).collect();
let after = format!("work since: {}\nthis turn: {turn}", predict::clip(&blind(&since.join(" | ")), 2 * part));
let before = blind(d.before);
for (id, check, stripped) in d.fresh {
let Some(c) = all.iter().find(|c| c.id == id) else { continue };
out.retain(|x| x.0.lesson.id != id);
let declared = if stripped { None } else { crate::memory::declared(&said, &id.to_lowercase()) };
let pending =
predict::Pending { lesson: c, before: before.clone(), after: after.clone(), declared, check: check.to_string(), channel: d.channel, stripped };
out.push((pending, d.question));
}
}
let questions = out.iter().filter(|x| x.1).count().min(MAX_PENDING);
let mut room = [MAX_PENDING - questions, questions];
let (mut kept, mut crowded): (Vec<(predict::Pending, bool)>, Vec<String>) = (Vec::new(), Vec::new());
for x in out.into_iter().rev() {
let r = &mut room[usize::from(x.1)];
if *r > 0 {
*r -= 1;
kept.push(x);
} else {
crowded.push(x.0.lesson.id.clone());
}
}
kept.reverse();
crowded.sort();
Judging { pending: kept.into_iter().map(|x| x.0).collect(), question: questions > 0, crowded }
}
fn without_declarations<'t>(text: &'t str, pending: &[predict::Pending]) -> std::borrow::Cow<'t, str> {
pending.iter().filter(|p| p.stripped).fold(std::borrow::Cow::Borrowed(text), |t, p| crate::memory::strip_declaration(&t, &p.lesson.id).into())
}
fn note_unjudged(session: &str, ids: &[String], why: &str) {
if !ids.is_empty() {
append(session, &format!("#borg-unjudged {} why={why}", ids.join(",")));
}
}
pub(crate) fn unjudged(state: &str) -> std::collections::HashMap<String, &'static str> {
let mut why: std::collections::HashMap<String, &'static str> = std::collections::HashMap::new();
let mut tries: std::collections::HashMap<&str, usize> = std::collections::HashMap::new();
for l in state.lines() {
if let Some(list) = DELIVERED.iter().find_map(|m| l.strip_prefix(m)) {
for id in ids_in(list) {
tries.remove(id);
why.insert(id.to_string(), outcome::UNJUDGED_NO_CALL);
}
} else if let Some(l) = l.strip_prefix("#borg-judged ") {
let (id, label) = l.split_once('=').unwrap_or((l, ""));
if label.trim() == "pending" {
let n = tries.entry(id).or_default();
*n += 1;
if *n >= MAX_JUDGE_TRIES {
why.insert(id.to_string(), outcome::UNJUDGED_TRIES);
}
}
} else if let Some(rest) = l.strip_prefix("#borg-unjudged ") {
let (list, reason) = rest.rsplit_once(" why=").unwrap_or((rest, ""));
let reason = match reason.trim() {
"slots" => outcome::UNJUDGED_SLOTS,
"failed" => outcome::UNJUDGED_FAILED,
_ => continue,
};
for id in list.split(',').map(str::trim).filter(|i| !i.is_empty()) {
if tries.get(id).copied().unwrap_or(0) < MAX_JUDGE_TRIES {
why.insert(id.to_string(), reason);
}
}
}
}
why
}
fn record_verdicts(session: &str, input: &Value, pending: &[predict::Pending], resolved: &[predict::Judged], chars: usize, call: usize) {
let mut records: std::collections::BTreeMap<(&str, &str, &str, bool), Vec<String>> = std::collections::BTreeMap::new();
let mut settled = 0;
for p in pending {
let judged = resolved.iter().find(|j| j.id == p.lesson.id);
let label = judged.and_then(predict::Judged::label);
let word = match label {
Some(outcome::CHANGED) => "changed",
Some(_) => "ignored",
None => "pending",
};
append(session, &format!("#borg-judged {}={word}", p.lesson.id));
let kind = match (label, judged) {
(Some(kind), _) => kind,
(None, Some(_)) => outcome::UNCLEAR,
(None, None) => continue,
};
settled += usize::from(label.is_some());
records.entry((kind, p.channel, p.check.as_str(), p.stripped)).or_default().push(p.lesson.id.clone());
}
log_cost(session, &format!("judge call={call} pending={} resolved={settled} chars={chars}", pending.len()));
if learning() {
let cwd = input.get("cwd").and_then(Value::as_str).unwrap_or_default();
let (home, ms) = (learn::home(), learn::now_ms());
let mut counted: std::collections::BTreeMap<(&str, &str), Vec<String>> = std::collections::BTreeMap::new();
for ((kind, channel, check, stripped), lessons) in records {
counted.entry((kind, channel)).or_default().extend(lessons.iter().cloned());
let o = outcome::Outcome {
kind: kind.into(),
session: session.into(),
lessons,
ms,
repo: repo_of(cwd),
channel: channel.into(),
check: check.into(),
judge: predict::JUDGE_VERSION,
stripped,
..Default::default()
};
let _ = learn::append_jsonl(&home.join("outcomes.jsonl"), &o);
}
for ((kind, channel), lessons) in counted {
outcome::count_result(
&home,
&outcome::Outcome {
kind: kind.into(),
session: session.into(),
lessons,
ms,
repo: repo_of(cwd),
channel: channel.into(),
..Default::default()
},
);
}
}
}
pub(crate) fn listed<'a>(context: &'a str, marker: &str) -> std::collections::HashSet<&'a str> {
context.lines().filter_map(|l| l.strip_prefix(marker)).flat_map(ids_in).collect()
}
fn ids_in(list: &str) -> impl Iterator<Item = &str> {
tagged(list).0.split(',').map(str::trim).filter(|i| !i.is_empty())
}
fn tag(check: &str) -> String {
if check.is_empty() { String::new() } else { format!(" @{check}") }
}
const MAX_EARLY_DELIVERIES: usize = 3;
fn early(h: &dyn Harness, so_far: &SoFar, hook_event: &str, session: &str, input: &Value, text: &str) -> Option<String> {
if text.trim().is_empty()
|| std::env::var("BORG_EARLY").is_ok_and(|v| v.trim().eq_ignore_ascii_case("off"))
|| std::env::var_os("BORG_ONLY").is_some()
|| std::env::var_os("BORG_CRITIC").is_some()
{
return None;
}
let challenges = lessons(session);
let context = std::fs::read_to_string(state_file(session)).unwrap_or_default();
let plain = h.caps().early_delivery && context.lines().filter(|l| l.starts_with("#borg-early ")).count() < MAX_EARLY_DELIVERIES;
let standing = challenges.iter().any(conscience::Challenge::standing);
if !standing && (!plain || challenges.iter().all(|c| c.scope.is_empty() && !c.consolidated)) {
return None;
}
let settled = listed(&context, "#borg-topic ");
let named = conscience::named_scopes(&challenges, &where_now(session));
let mut topics: Vec<String> = if plain { named.iter().filter(|t| !settled.contains(t.as_str())).cloned().collect() } else { Vec::new() };
if plain
&& topics.is_empty()
&& hook_event == "UserPromptSubmit"
&& !settled.contains(conscience::ANY)
&& challenges.iter().any(|c| c.consolidated && !c.standing())
{
topics.push(conscience::ANY.into());
}
let mut standing_topics = named;
if hook_event == "UserPromptSubmit" {
standing_topics.push(conscience::ANY.into());
}
let done = had_in(&context);
let mut pool = if standing { conscience::standing_pool(&challenges, &standing_topics, &done) } else { Vec::new() };
if !topics.is_empty() {
pool.extend(conscience::early_pool(&challenges, &conscience::work_text(&context), &topics, &done));
}
let mut shown_topics = topics.clone();
for t in standing_topics.into_iter().filter(|t| pool.iter().any(|(_, c)| c.standing() && c.scope.contains(t))) {
if !shown_topics.contains(&t) {
shown_topics.push(t);
}
}
let selected: Vec<&conscience::Challenge> = conscience::explored(pool.iter().copied()).into_iter().take(conscience::EARLY_CAP).collect();
let shown = conscience::render_early(&selected, &shown_topics);
let delivered = &selected[..shown.as_ref().map_or(0, |(_, n)| *n)];
let now_settled: Vec<&str> = topics
.iter()
.filter(|t| {
!delivered.is_empty()
|| !challenges.iter().any(|c| {
!c.standing()
&& (c.scope.contains(t) || (t.as_str() == conscience::ANY && c.consolidated))
&& !done.contains(c.id.as_str())
&& !delivered.iter().any(|d| d.id == c.id)
})
})
.map(String::as_str)
.collect();
if !now_settled.is_empty() {
append(session, &format!("#borg-topic {}", now_settled.join(",")));
}
let (text, _) = shown?;
let ids = delivered.iter().map(|c| c.id.as_str()).collect::<Vec<_>>().join(",");
let check = crate::select::check_id(session, "early", learn::now_ms(), std::process::id());
let line = format!("#borg-early {ids} @{check}");
append(session, &line);
note_work(session, so_far, &line);
let p = conscience::early_propensity(&pool, session, &shown_topics);
let p: Vec<f64> = delivered.iter().map(|c| p.get(&c.id).copied().unwrap_or(0.0)).collect();
record_delivery(session, input, delivered, "early", &check, p, early_rel(&challenges, &conscience::work_text(&context), &topics, delivered));
log_cost(session, &format!("free event={hook_event} lessons={} chars={}", delivered.len(), text.len()));
crate::stats::count(&learn::home(), crate::stats::EARLY, session, |e| {
e.n = delivered.len() as u64;
e.lessons = delivered.iter().map(|c| c.id.clone()).collect();
e.channel = "early".into();
});
Some(text)
}
fn early_rel(challenges: &[conscience::Challenge], work: &str, topics: &[String], delivered: &[&conscience::Challenge]) -> Vec<f64> {
let Some(&(top, _)) = conscience::early_pool(challenges, work, topics, &std::collections::HashSet::new()).first() else { return Vec::new() };
let ranked = conscience::rank(challenges, work);
delivered.iter().map(|c| outcome::round_p(ranked.iter().find(|(_, x)| x.id == c.id).map_or(0.0, |(s, _)| *s) / top)).collect()
}
fn note_work(session: &str, so_far: &SoFar, lines: &str) {
if let Ok(mut f) = std::fs::OpenOptions::new().create(true).append(true).open(edits_file(session)) {
let _ = writeln!(f, "{WORK}{}\n{lines}", one_line(so_far.get(), EVIDENCE_CHARS));
}
}
fn record_delivery(session: &str, input: &Value, delivered: &[&conscience::Challenge], channel: &str, check: &str, p: Vec<f64>, rel: Vec<f64>) {
if !learning() || delivered.is_empty() {
return;
}
let lessons: Vec<String> = delivered.iter().map(|c| c.id.clone()).collect();
let (grades, ranks, applied) = graded_of(session, &lessons);
let asked = outcome::Outcome {
kind: outcome::ASKED.into(),
session: session.into(),
lessons,
ms: learn::now_ms(),
repo: repo_of(input.get("cwd").and_then(Value::as_str).unwrap_or_default()),
groups: conscience::disagreement_ids(delivered),
channel: channel.into(),
grades,
ranks,
applied,
p: p.into_iter().map(outcome::round_p).collect(),
check: check.into(),
rel,
..Default::default()
};
let _ = outcome::append(&learn::home().join("outcomes.jsonl"), &asked);
}
fn record_route(session: &str, input: &Value, check: &str, lessons: Vec<String>, channel: &str, route: &str, reason: &str) {
if !learning() || lessons.is_empty() {
return;
}
let o = outcome::Outcome {
kind: outcome::DELIVERY.into(),
session: session.into(),
lessons,
ms: learn::now_ms(),
repo: repo_of(input.get("cwd").and_then(Value::as_str).unwrap_or_default()),
channel: channel.into(),
check: check.into(),
route: route.into(),
reason: reason.into(),
..Default::default()
};
let _ = outcome::append(&learn::home().join("outcomes.jsonl"), &o);
}
fn record_routes(session: &str, input: &Value, routed: &[(&conscience::Challenge, &str)], channel: &str, route: &str, reason: &str) {
for (check, ids) in by_check(routed) {
record_route(session, input, check, ids.into_iter().map(String::from).collect(), channel, route, reason);
}
}
fn by_check<'a>(routed: &[(&'a conscience::Challenge, &'a str)]) -> Vec<(&'a str, Vec<&'a str>)> {
let mut out: Vec<(&str, Vec<&str>)> = Vec::new();
for (c, check) in routed {
match out.iter_mut().find(|(k, _)| k == check) {
Some((_, ids)) => ids.push(c.id.as_str()),
None => out.push((check, vec![c.id.as_str()])),
}
}
out
}
fn queued_file(session: &str) -> PathBuf {
state_file(session).with_extension("queued")
}
#[derive(Debug, Clone, Copy, PartialEq, Eq, PartialOrd, Ord)]
enum Queued {
Ask,
Instead,
Free,
Placebo,
}
const INSTEAD: &str = "instead ";
const INSTEAD_NEXT: &str = "instead-next ";
const LIVE_NEXT: &str = "live-next ";
const ASKED_INSTEAD: &str = "in place of a hand-over";
fn queue_line(line: &str) -> (Queued, Vec<&str>, &str) {
let ask = line.strip_prefix("live ").or_else(|| line.strip_prefix(LIVE_NEXT));
let instead = line.strip_prefix(INSTEAD).or_else(|| line.strip_prefix(INSTEAD_NEXT));
let (route, list) = match (ask, line.strip_prefix("placebo "), instead) {
(Some(l), _, _) => (Queued::Ask, l),
(_, Some(l), _) => (Queued::Placebo, l),
(_, _, Some(l)) => (Queued::Instead, l),
_ => (Queued::Free, line),
};
(route, ids_in(list).collect(), tagged(list).1.unwrap_or_default())
}
fn enqueue(session: &str, line: &str) {
let q = queued_file(session);
live::locked(&q, || {
let _ = std::fs::OpenOptions::new().create(true).append(true).open(&q).and_then(|mut f| f.write_all(format!("{line}\n").as_bytes()));
});
}
fn take_queue(session: &str) -> Option<String> {
let q = queued_file(session);
let taken = state_file(session).with_extension(format!("queued.{}", std::process::id()));
live::locked(&q, || std::fs::rename(&q, &taken)).ok()?;
let text = std::fs::read_to_string(&taken).unwrap_or_default();
let _ = std::fs::remove_file(&taken);
Some(text)
}
fn take_live(session: &str) -> Taken {
let Some(text) = take_queue(session) else { return Taken::default() };
let mut taken = Taken::default();
for line in text.lines() {
let to = match (line.starts_with("live "), line.starts_with(INSTEAD)) {
(true, _) => &mut taken.asks,
(_, true) => &mut taken.instead,
_ => {
enqueue(session, line);
continue;
}
};
let (_, ids, check) = queue_line(line);
to.extend(ids.into_iter().map(|i| (i.to_string(), check.to_string())));
}
taken
}
#[derive(Default)]
struct Taken {
asks: Vec<(String, String)>,
instead: Vec<(String, String)>,
}
fn waiting_in(text: &str) -> impl Iterator<Item = &str> {
text.lines().map(queue_line).filter(|(route, _, _)| *route != Queued::Placebo).flat_map(|(_, ids, _)| ids)
}
fn note_never_delivered(session: &str, input: &Value) {
let text = std::fs::read_to_string(queued_file(session)).unwrap_or_default();
for line in text.lines() {
let (route, ids, check) = queue_line(line);
let channel = match route {
Queued::Ask => "live",
Queued::Instead | Queued::Free => "queued",
Queued::Placebo => outcome::PLACEBO,
};
record_route(session, input, check, ids.into_iter().map(String::from).collect(), channel, outcome::ROUTE_NEVER, "session ended");
}
}
fn tagged_p(state: &str, prefix: &str, check: &str, ids: &[&str]) -> Vec<f64> {
let mut seen: std::collections::HashMap<&str, f64> = std::collections::HashMap::new();
for line in state.lines().filter_map(|l| l.strip_prefix(prefix)) {
let (items, at) = tagged(line);
if at != Some(check) {
continue;
}
for (id, p) in items.split(',').filter_map(|it| it.rsplit_once('=')) {
if let Ok(p) = p.trim().parse::<f64>() {
seen.insert(id.trim(), p);
}
}
}
ids.iter().map(|i| seen.get(i).copied()).collect::<Option<Vec<f64>>>().unwrap_or_default()
}
type Pairs<'a> = Vec<(&'a conscience::Challenge, &'a str)>;
type Drop<'a> = (&'a str, &'static str, &'static str, &'static str);
fn queued(so_far: &SoFar, hook_event: &str, session: &str, input: &Value) -> Option<String> {
let text = take_queue(session)?;
let all = lessons(session);
let state = std::fs::read_to_string(state_file(session)).unwrap_or_default();
let had = had_in(&state);
let mut done: Option<std::collections::HashSet<&str>> = None;
let mut lines: Vec<(Queued, Vec<&str>, &str)> = text.lines().map(queue_line).collect();
lines.sort_by_key(|l| l.0);
let placebos = lines.iter().position(|l| l.0 == Queued::Placebo).unwrap_or(lines.len());
let (mut firm, mut wanted, mut placebo): (Pairs, Pairs, Pairs) = (Vec::new(), Vec::new(), Vec::new());
let mut dropped: Vec<(Drop, &str)> = Vec::new();
let mut owed = 0;
for (route, ids, check) in &lines[..placebos] {
let channel = if *route == Queued::Ask { "live" } else { "queued" };
for &id in ids {
let Some(c) = all.iter().find(|c| c.id == id) else {
dropped.push(((check, channel, outcome::ROUTE_DROPPED_DONE, "not deliverable"), id));
continue;
};
let why = if firm.iter().chain(&wanted).any(|(c, _)| c.id == id) {
Some("queued twice")
} else if *route == Queued::Ask {
done.get_or_insert_with(|| done_in(&state, &early_acted(session, &all, ""))).contains(id).then_some("done")
} else {
had.contains(id).then_some("given before")
};
match why {
Some(why) => dropped.push(((check, channel, outcome::ROUTE_DROPPED_DONE, why), id)),
None if *route == Queued::Ask => firm.push((c, check)),
None => {
owed += usize::from(*route == Queued::Instead);
wanted.push((c, check));
}
}
}
}
let free: Vec<&conscience::Challenge> = wanted.iter().map(|(c, _)| *c).collect();
let shown = conscience::render_owing(&free, &[], owed);
let n = shown.as_ref().map_or(0, |(_, n)| *n);
dropped.extend(wanted[n..].iter().map(|(c, check)| ((*check, "queued", outcome::ROUTE_DROPPED_CHARS, "budget"), c.id.as_str())));
for (_, ids, check) in &lines[placebos..] {
for &id in ids {
let Some(c) = all.iter().find(|c| c.id == id) else {
dropped.push(((check, outcome::PLACEBO, outcome::ROUTE_DROPPED_DONE, "not deliverable"), id));
continue;
};
let why = if placebo.iter().any(|(c, _)| c.id == id) {
Some("queued twice")
} else {
(firm.iter().chain(&wanted[..n]).any(|(c, _)| c.id == id) || had.contains(id)).then_some("delivered")
};
match why {
Some(why) => dropped.push(((check, outcome::PLACEBO, outcome::ROUTE_DROPPED_DONE, why), id)),
None => placebo.push((c, check)),
}
}
}
let mut parts: Vec<String> = Vec::new();
if !firm.is_empty() {
parts.push(ask_live(so_far, hook_event, session, input, &mut firm));
}
let mut markers: Vec<String> = Vec::new();
if let Some((text, n)) = shown {
for (check, ids) in by_check(&wanted[..n]) {
markers.push(format!("#borg-queued {}{}", ids.join(","), tag(check)));
let delivered: Vec<&conscience::Challenge> = ids.iter().filter_map(|i| free.iter().find(|c| c.id == *i).copied()).collect();
let p = if check.is_empty() { vec![1.0; ids.len()] } else { tagged_p(&state, "#borg-pf ", check, &ids) };
record_delivery(session, input, &delivered, "queued", check, p, Vec::new());
}
record_routes(session, input, &wanted[..n], "queued", outcome::ROUTE_FREE, "");
log_cost(session, &format!("free event={hook_event} lessons={n} chars={} graded dropped={}", text.len(), wanted.len() - n));
crate::stats::count(&learn::home(), crate::stats::QUEUED_FREE, session, |e| {
e.n = n as u64;
e.lessons = wanted[..n].iter().map(|(c, _)| c.id.clone()).collect();
e.channel = "queued".into();
});
parts.push(text);
}
for (check, ids) in by_check(&placebo) {
markers.push(format!("#borg-placebo {}{}", ids.join(","), tag(check)));
}
record_routes(session, input, &placebo, outcome::PLACEBO, outcome::ROUTE_PLACEBO, "");
if !markers.is_empty() {
let markers = markers.join("\n");
append(session, &markers);
note_work(session, so_far, &markers);
}
let mut groups: Vec<(Drop, Vec<String>)> = Vec::new();
for (key, id) in dropped {
match groups.iter_mut().find(|(k, _)| *k == key) {
Some((_, ids)) => ids.push(id.to_string()),
None => groups.push((key, vec![id.to_string()])),
}
}
for ((check, channel, route, why), ids) in groups {
record_route(session, input, check, ids, channel, route, why);
}
(!parts.is_empty()).then(|| parts.join("\n\n"))
}
fn ask_live(so_far: &SoFar, hook_event: &str, session: &str, input: &Value, firm: &mut [(&conscience::Challenge, &str)]) -> String {
crate::memory::shuffle(firm, session);
let groups = by_check(firm);
let now = learn::now_ms();
let lines: Vec<String> = groups
.iter()
.map(|(check, ids)| {
let ids = ids.join(",");
format!("#borg-asked {ids}{}\n#borg-live {ids} ms={now}", tag(check))
})
.collect();
let lines = lines.join("\n");
append(session, &lines);
note_work(session, so_far, &lines);
let cwd = input.get("cwd").and_then(Value::as_str).unwrap_or_default();
let lessons: Vec<&conscience::Challenge> = firm.iter().map(|(c, _)| *c).collect();
if learning() {
let state = std::fs::read_to_string(state_file(session)).unwrap_or_default();
for (check, ids) in &groups {
let members: Vec<&conscience::Challenge> = lessons.iter().copied().filter(|c| ids.contains(&c.id.as_str())).collect();
let ids: Vec<String> = members.iter().map(|c| c.id.clone()).collect();
let (grades, ranks, applied) = graded_of(session, &ids);
let p = if check.is_empty() {
propensity_in(&state, &ids)
} else {
tagged_p(&state, "#borg-p ", check, &members.iter().map(|c| c.id.as_str()).collect::<Vec<_>>())
};
let (pool, base, scoped) = pool_in(&state, &ids);
let asked = outcome::Outcome {
kind: outcome::ASKED.into(),
session: session.into(),
lessons: ids,
ms: now,
repo: repo_of(cwd),
groups: conscience::disagreement_ids(&members),
channel: "live".into(),
grades,
ranks,
applied,
p,
pool,
base,
scoped,
check: check.to_string(),
..Default::default()
};
let _ = outcome::append(&learn::home().join("outcomes.jsonl"), &asked);
}
}
record_routes(session, input, firm, "live", outcome::ROUTE_ASKED, "");
let text = conscience::render_live(&lessons);
log_cost(session, &format!("free event={hook_event} lessons={} chars={} live", lessons.len(), text.len()));
stat(session, input, crate::stats::LIVE_ASK, |e| {
e.n = lessons.len() as u64;
e.lessons = lessons.iter().map(|c| c.id.clone()).collect();
e.channel = "live".into();
});
text
}
fn work_so_far(h: &dyn Harness, input: &Value) -> String {
let session = input.get("session_id").and_then(Value::as_str).unwrap_or("unknown");
harness::work_so_far(h.caps(), input, &turn_file(session), LIVE_WORK_CHARS)
}
struct SoFar<'a> {
h: &'a dyn Harness,
input: &'a Value,
text: std::cell::OnceCell<String>,
}
impl<'a> SoFar<'a> {
fn new(h: &'a dyn Harness, input: &'a Value) -> Self {
SoFar { h, input, text: std::cell::OnceCell::new() }
}
fn get(&self) -> &str {
self.text.get_or_init(|| work_so_far(self.h, self.input))
}
}
fn turn_file(session: &str) -> PathBuf {
state_file(session).with_extension("turn")
}
const LIVE_WORK_CHARS: usize = EVIDENCE_CHARS;
fn queen_ask(h: &dyn Harness, session: &str, cwd: &str) -> Option<String> {
if !learning() || !crate::queen::ask_enabled() || std::env::var_os("BORG_ONLY").is_some() || std::env::var_os("BORG_CRITIC").is_some() {
return None;
}
let repos = || {
let mut repos = crate::systems::work_repos(&std::fs::read_to_string(where_file(session)).unwrap_or_default());
let here = repo_of(cwd);
if !here.is_empty() && !repos.contains(&here) {
repos.insert(0, here);
}
repos
};
let scope = if cwd.is_empty() { String::new() } else { format!(" --dir {}", crate::queen::sh_quote(cwd)) };
let mut q = crate::queen::deliver(&learn::home(), session, repos, &scope, learn::now_ms())?;
if let Ok(exe) = std::env::current_exe() {
q = q.run_by(&crate::queen::sh_quote(&exe.display().to_string()));
}
let text = crate::queen::render_delivery(&q, h.caps().question_dialog);
log_cost(session, &format!("free event=UserPromptSubmit queen={} chars={}", q.id, text.len()));
Some(text)
}
fn free_context(h: &dyn Harness, hook_event: &str, session: &str, input: &Value, text: &str) -> Option<Value> {
free_context_with(h, hook_event, session, input, text, None)
}
fn free_context_with(h: &dyn Harness, hook_event: &str, session: &str, input: &Value, text: &str, extra: Option<String>) -> Option<Value> {
let so_far = SoFar::new(h, input);
let parts: Vec<String> =
[queued(&so_far, hook_event, session, input), early(h, &so_far, hook_event, session, input, text), extra].into_iter().flatten().collect();
(!parts.is_empty()).then(|| json!({"hookSpecificOutput": {"hookEventName": hook_event, "additionalContext": parts.join("\n\n")}}))
}
enum Verdict {
Skip(String),
Failed,
Ask(Vec<String>, bool),
}
struct Work<'a> {
all: &'a [conscience::Challenge],
judged: &'a [conscience::Challenge],
challenges: &'a [conscience::Challenge],
done: &'a std::collections::HashSet<&'a str>,
state: &'a str,
context: &'a str,
scope_text: &'a str,
message: &'a str,
changed: bool,
judge: bool,
budget: Option<std::time::Duration>,
started: std::time::Instant,
check: &'a str,
summary: &'a crate::select::summary::Summary,
}
struct Call<'a> {
eligible: usize,
order: &'a [&'a conscience::Challenge],
tail: &'a [(usize, &'a conscience::Challenge)],
pt: f64,
model: &'a str,
prompt_hash: String,
dur_ms: u64,
usd: f64,
}
fn check(session: &str, input: &Value, w: &Work, live: bool) -> Verdict {
let skip = if live {
None
} else if prefilter::edits_gate() {
(!w.changed).then(|| "noedit".to_string())
} else {
prefilter::skip(w.challenges, w.context).map(|score| format!("{score:.2}"))
};
if let Some(score) = skip {
return Verdict::Skip(score);
}
let text = conscience::work_text(w.context);
let text = text.as_ref();
let started = std::time::Instant::now();
let shortlist_now = || {
let (list, added) = crate::vectors::shortlist(&lessons_path(), w.challenges, text, w.scope_text, crate::vectors::SHORTLIST);
if crate::vectors::enabled() {
log_cost(session, &format!("vectors added={added} ms={}", started.elapsed().as_millis()));
}
list
};
let whole = crate::whole::on();
let (shortlist, eligible, order, tail, pt) = if whole {
let ranked = conscience::rank_scoped(w.challenges, text, w.scope_text);
let eligible = crate::whole::eligible(w.challenges, &ranked, w.scope_text);
let n = eligible.len();
let tokens = match std::env::var_os("BORG_STOP_POOL_TOKENS") {
Some(_) => crate::whole::tokens(),
None => {
let limit = live::call_limit(w.budget, w.started.elapsed());
crate::select::pool_tokens(w.summary, Some(u64::try_from(limit.as_millis()).unwrap_or(u64::MAX)), session)
}
};
let f = crate::whole::select_filled(eligible, shortlist_now, &ranked, tokens);
let (drawn, pt) = if f.order.is_empty() { (Vec::new(), 0.0) } else { crate::whole::tail(&f.dropped, tail_seed(session, w.check, live, w.summary)) };
let tail: Vec<(usize, &conscience::Challenge)> = drawn.into_iter().map(|(i, c)| (f.order.len() + i, c)).collect();
let sampled = if tail.is_empty() { String::new() } else { format!(" tail={}", tail.len()) };
log_cost(session, &format!("pool mode=all eligible={n} shown={} budget={}{sampled}", f.shown.len(), if f.fell { "full" } else { "fits" }));
let mut shown = f.shown;
shown.extend(tail.iter().map(|(_, c)| *c));
(shown, n, f.order, tail, pt)
} else {
let list = shortlist_now();
(list.clone(), list.len(), list, Vec::new(), 0.0)
};
let model = std::env::var("BORG_PREDICT_MODEL").unwrap_or_default();
let judging = if w.judge {
pending(session, w.state, w.judged, w.message, live, w.check)
} else {
Judging { pending: Vec::new(), question: false, crowded: Vec::new() }
};
let pend = &judging.pending;
if shortlist.is_empty() && !judging.question {
return Verdict::Skip("empty".into());
}
let extra = predict::judge_section(pend).len();
let graded = crate::whole::graded();
let compact = whole && !crate::whole::classic();
let timeout = live::call_limit(w.budget, w.started.elapsed());
let shown_work = without_declarations(text, pend);
let called = std::time::Instant::now();
let pred = if compact {
predict::predict_whole(&shown_work, &shortlist, pend, &model, graded, timeout)
} else {
predict::predict(&shown_work, &shortlist, pend, &model, graded, timeout)
};
let dur_ms = called.elapsed().as_millis() as u64;
stat(session, input, if live { crate::stats::LIVE_CHECK } else { crate::stats::CHECK }, |e| {
e.n = shortlist.len() as u64;
e.dur_ms = dur_ms;
e.usd = pred.as_ref().map_or(0.0, |p| p.cost);
if pred.is_none() {
e.why = "failed".into();
}
});
let usd = pred.as_ref().map_or(0.0, |p| p.cost);
let call = Call { eligible, order: &order, tail: &tail, pt, model: &model, prompt_hash: predict::template_hash(compact, graded), dur_ms, usd };
note_unjudged(session, &judging.crowded, "slots");
let Some(pred) = pred else {
if graded {
record_graded(session, input, w, live, &[], None, &call);
}
note_unjudged(session, &pend.iter().map(|p| p.lesson.id.clone()).collect::<Vec<_>>(), "failed");
return Verdict::Failed;
};
append(session, &format!("#borg-predict-cost {:.4}", pred.cost));
if live {
log_cost(session, &format!("live usd={:.4} lessons={}", pred.cost, shortlist.len()));
}
if !pend.is_empty() {
let call = w.state.lines().filter(|l| l.starts_with("#borg-predict-cost")).count() + 1;
record_verdicts(session, input, pend, &pred.resolved, extra, call);
}
let applied: Vec<(&conscience::Challenge, u8)> =
pred.applies.iter().zip(&pred.grades).filter_map(|(i, g)| shortlist.iter().find(|c| &c.id == i).map(|c| (*c, *g))).collect();
let ids = |cs: &[&conscience::Challenge]| cs.iter().map(|c| c.id.clone()).collect::<Vec<_>>();
if graded {
let lessons = lessons_path();
let at = Decide {
session,
check: w.check,
channel: if live { "live" } else { "stop" },
lessons: &lessons,
tokens: crate::select::shown_tokens(call.order),
recorded: records_reach_gate(&lessons),
};
let r = decide(crate::select::policy(), &applied, &at, w.summary, DECIDE_WAIT, |r, basis| {
record_graded(session, input, w, live, &applied, Some((r, basis)), &call)
});
let routed = |cs: &[&conscience::Challenge], p: &[f64]| -> Vec<(&str, f64)> {
applied.iter().zip(p).filter(|((c, _), _)| cs.iter().any(|x| x.id == c.id)).map(|((c, _), p)| (c.id.as_str(), *p)).collect()
};
let mut lines = vec![graded_line(&applied), r.log.line(applied.len(), w.check)];
lines.extend(r.log.attention.clone());
lines.extend(p_line("#borg-p", routed(&r.ask, &r.p), Some(w.check)));
lines.extend(p_line("#borg-pf", routed(&r.free, &r.pf), Some(w.check)));
append(session, &lines.join("\n"));
let queue = !r.free.is_empty();
log_cost(session, &format!("graded applied={} ask={} free={} {}", applied.len(), r.ask.len(), r.free.len(), if queue { "queued" } else { "dropped" }));
if queue {
let asks = if r.log.policy == crate::select::Policy::Learned.name() { conscience::graded_without(&applied, None, &[]).0 } else { Vec::new() };
let (owed, rest): (Vec<&conscience::Challenge>, Vec<&conscience::Challenge>) = r.free.iter().partition(|c| asks.iter().any(|a| a.id == c.id));
if !owed.is_empty() {
let prefix = if live && r.log.source == crate::select::policy::EXPERIMENT { INSTEAD } else { INSTEAD_NEXT };
enqueue(session, &format!("{prefix}{}{}", ids(&owed).join(","), tag(w.check)));
}
if !rest.is_empty() {
enqueue(session, &format!("{}{}", ids(&rest).join(","), tag(w.check)));
}
}
if !r.placebo.is_empty() {
enqueue(session, &format!("placebo {}{}", ids(&r.placebo).join(","), tag(w.check)));
}
Verdict::Ask(ids(&r.ask), applied.iter().any(|(_, g)| *g == 3))
} else {
let predicted: Vec<&conscience::Challenge> = applied.iter().map(|(c, _)| *c).collect();
let pool = conscience::widen_pool(&conscience::rank_scoped(w.all, text, w.scope_text), &predicted, w.done);
let widened: Vec<&conscience::Challenge> =
conscience::in_scope_first(conscience::explored(pool.iter().copied())).into_iter().filter(|c| w.challenges.iter().any(|x| x.id == c.id)).collect();
append_p_of(session, &pool, &widened, w.check);
Verdict::Ask(ids(&widened), true)
}
}
struct Decide<'x> {
session: &'x str,
check: &'x str,
channel: &'static str,
lessons: &'x std::path::Path,
tokens: u32,
recorded: bool,
}
struct Basis<'s> {
summary: &'s crate::select::summary::Summary,
had: &'s [String],
why: &'static str,
}
const DECIDE_WAIT: std::time::Duration = std::time::Duration::from_millis(live::AFTER_CALL.as_millis() as u64 / 3);
const DECIDE_POLL: std::time::Duration = std::time::Duration::from_millis(5);
fn decide_lock(lessons: &std::path::Path) -> PathBuf {
crate::select::summary::cache_path(lessons).with_extension("json.lock")
}
fn lock_within(file: &std::path::Path, wait: std::time::Duration) -> Result<std::fs::File, &'static str> {
let lock = std::fs::OpenOptions::new().create(true).truncate(false).write(true).open(file).map_err(|_| outcome::DECIDED_NO_LOCK)?;
let until = std::time::Instant::now() + wait;
loop {
match lock.try_lock() {
Ok(()) => return Ok(lock),
Err(std::fs::TryLockError::WouldBlock) if std::time::Instant::now() < until => std::thread::sleep(DECIDE_POLL),
Err(std::fs::TryLockError::WouldBlock) => return Err(outcome::DECIDED_BUSY),
Err(std::fs::TryLockError::Error(_)) => return Err(outcome::DECIDED_NO_LOCK),
}
}
}
fn decide<'a>(
policy: crate::select::Policy,
applied: &[(&'a conscience::Challenge, u8)],
at: &Decide,
stale: &crate::select::summary::Summary,
wait: std::time::Duration,
mut record: impl FnMut(&crate::select::Routed<'a>, &Basis) -> bool,
) -> crate::select::Routed<'a> {
use crate::select::Policy;
let state = std::fs::read_to_string(state_file(at.session)).unwrap_or_default();
let queue = std::fs::read_to_string(queued_file(at.session)).unwrap_or_default();
let mut had: Vec<String> = had_in(&state).into_iter().chain(waiting_in(&queue)).map(str::to_string).collect();
had.sort_unstable();
had.dedup();
let alpha = crate::select::alpha(at.lessons);
let mut on = |summary: &crate::select::summary::Summary, policy: Policy, why: &'static str| {
let ctx =
crate::select::Ctx { session: at.session, check: at.check, channel: at.channel, lessons: at.lessons, summary, tokens: at.tokens, had: &had, alpha };
let r = crate::select::graded_under(policy, applied, &ctx);
let landed = record(&r, &Basis { summary, had: &had, why });
(r, landed)
};
if policy != Policy::Learned {
return on(stale, policy, "").0;
}
if !at.recorded {
return on(stale, Policy::Fixed, outcome::DECIDED_NO_RECORD).0;
}
match lock_within(&decide_lock(at.lessons), wait) {
Ok(_held) => {
let summary = crate::select::summary::refresh(at.lessons);
match on(&summary, policy, "") {
(r, true) => r,
(_, false) => on(&summary, Policy::Fixed, outcome::DECIDED_NO_RECORD).0,
}
}
Err(why) => on(stale, Policy::Fixed, why).0,
}
}
fn records_reach_gate(lessons: &std::path::Path) -> bool {
learning() && outcome::path_beside(lessons) == graded_log()
}
fn graded_log() -> PathBuf {
learn::home().join("outcomes.jsonl")
}
fn tail_seed(session: &str, check: &str, live: bool, summary: &crate::select::summary::Summary) -> u64 {
let channel = if live { "live" } else { "stop" };
let ctx =
crate::select::Ctx { session, check, channel, lessons: std::path::Path::new(""), summary, tokens: 0, had: &[], alpha: crate::select::policy::ALPHA };
crate::select::seed(&ctx) ^ u64::from_be_bytes(*b"tailpool")
}
fn record_graded(
session: &str,
input: &Value,
w: &Work,
live: bool,
applied: &[(&conscience::Challenge, u8)],
decided: Option<(&crate::select::Routed, &Basis)>,
call: &Call,
) -> bool {
if !learning() {
return false;
}
let repo = repo_of(input.get("cwd").and_then(Value::as_str).unwrap_or_default());
let o = graded_outcome(session, &repo, w.check, live, applied, decided, w.summary, call);
outcome::append(&graded_log(), &o).is_ok()
}
#[allow(clippy::too_many_arguments)] fn graded_outcome(
session: &str,
repo: &str,
check: &str,
live: bool,
applied: &[(&conscience::Challenge, u8)],
decided: Option<(&crate::select::Routed, &Basis)>,
read: &crate::select::summary::Summary,
call: &Call,
) -> outcome::Outcome {
let ids = |cs: &[&conscience::Challenge]| cs.iter().map(|c| c.id.clone()).collect::<Vec<_>>();
let rounded = |p: &[f64]| p.iter().map(|x| outcome::round_p(*x)).collect::<Vec<_>>();
let (routed, basis) = (decided.map(|d| d.0), decided.map(|d| d.1));
let shown: u32 = call.order.len().try_into().unwrap_or(u32::MAX);
let place = |id: &str| call.order.iter().position(|x| x.id == id).or_else(|| call.tail.iter().find(|(_, x)| x.id == id).map(|(at, _)| *at));
outcome::Outcome {
kind: outcome::GRADED.into(),
session: session.into(),
lessons: applied.iter().map(|(c, _)| c.id.clone()).collect(),
ms: learn::now_ms(),
repo: repo.into(),
channel: if live { "live" } else { "stop" }.into(),
grades: applied.iter().map(|(_, g)| *g).collect(),
ranks: (0..applied.len()).map(|r| u16::try_from(r).unwrap_or(u16::MAX)).collect(),
applied: u16::try_from(applied.len()).unwrap_or(u16::MAX),
chosen: routed.map(|r| ids(&r.ask)).unwrap_or_default(),
explore: routed.is_some_and(|r| r.log.source == "explore"),
p: routed.map(|r| rounded(&r.p)).unwrap_or_default(),
check: check.into(),
policy: routed.map_or_else(|| crate::select::policy().name(), |r| r.log.policy).into(),
fit: routed.map_or_else(|| read.fit.key.clone(), |r| r.log.fit.clone()),
seen: basis.map(|b| b.summary.key()).unwrap_or_default(),
source: routed.map(|r| r.log.source).unwrap_or_default().into(),
free: routed.map(|r| ids(&r.free)).unwrap_or_default(),
pf: routed.map(|r| rounded(&r.pf)).unwrap_or_default(),
placebo: routed.map(|r| ids(&r.placebo)).unwrap_or_default(),
psi: routed.map_or(0.0, |r| r.log.psi),
nofree: basis.map(|b| crate::select::nofree(applied, b.had)).unwrap_or_default(),
xk: routed.and_then(|r| r.log.xk),
xs: routed.and_then(|r| r.log.xs),
alpha: routed.and_then(|r| r.log.alpha),
tail: call.tail.iter().map(|(_, c)| c.id.clone()).collect(),
pt: call.pt,
reason: basis.map(|b| b.why).unwrap_or_default().into(),
eligible: call.eligible.try_into().unwrap_or(u32::MAX),
shown,
tokens: crate::select::shown_tokens(call.order),
fill: applied
.iter()
.map(|(c, _)| place(&c.id))
.chain(call.tail.iter().map(|(at, _)| Some(*at)))
.map(|i| i.map_or(u16::MAX, |i| u16::try_from(i).unwrap_or(u16::MAX)))
.collect(),
model: call.model.into(),
prompt_hash: call.prompt_hash.clone(),
harness: std::env::var("BORG_HARNESS").unwrap_or_default(),
version: env!("CARGO_PKG_VERSION").into(),
dur_ms: call.dur_ms,
failed: routed.is_none(),
usd: call.usd,
..Default::default()
}
}
fn live_trigger(session: &str, input: &Value, tool: &str, changed: bool) {
let ctx = state_file(session);
if let Some(why) = live::unsupported() {
if std::fs::OpenOptions::new().write(true).create_new(true).open(ctx.with_extension("live.off")).is_ok() {
eprintln!("borg: live mode needs the consequence model, which {why} replaces; this session stays in hook mode");
}
return;
}
if changed {
live::bump(&ctx, tool);
}
let now = learn::now_ms();
let home = learn::home();
if crate::steer::active(&home) && crate::steer::paused(&home, session, crate::presence::read(&home, session).map(|p| p.started), now) {
return;
}
let lock = live::lock_state(&ctx, now, live::stale_ms(), live::alive);
if live::decide(live::Mode::Live, lock, live::count(&ctx), live::read_mark(&ctx), now, live::debounce_ms()).is_err() {
return;
}
let s = |k: &str| input.get(k).and_then(Value::as_str).unwrap_or_default().to_string();
if let Ok(exe) = std::env::current_exe() {
let _ = std::process::Command::new(exe)
.args(["check", "--session", session, "--transcript", &s("transcript_path"), "--cwd", &s("cwd")])
.stdin(std::process::Stdio::null())
.stdout(std::process::Stdio::null())
.stderr(std::process::Stdio::null())
.spawn();
}
}
pub fn live_check(h: &dyn Harness, session: &str, input: &Value) {
let ctx = state_file(session);
let started = learn::now_ms();
let Some(_lock) = live::acquire(&ctx, started) else { return };
let n = live::count(&ctx);
let mark = live::read_mark(&ctx);
if live::unsupported().is_some() || live::decide(live::current(), live::Lock::Free, n, mark, started, live::debounce_ms()).is_err() {
return;
}
let turn = turn_id(session);
let (all, withheld) = loaded(session);
let judged = judged(&all, withheld);
let state = std::fs::read_to_string(&ctx).unwrap_or_default();
let message = work_so_far(h, input);
let acted = early_acted(session, &judged, &message);
let mut done = done_in(&state, &acted);
let waiting = std::fs::read_to_string(queued_file(session)).unwrap_or_default();
done.extend(waiting_in(&waiting));
let challenges: Vec<conscience::Challenge> = all.iter().filter(|c| !done.contains(c.id.as_str()) && !c.off_system).cloned().collect();
let context = format!("{state}{message}");
let scope_text = format!("{}\n{message}", where_now(session));
let check_id = crate::select::check_id(session, "live", started, std::process::id());
let summary = crate::select::summary::refresh(&lessons_path());
let work = Work {
all: &all,
judged: &judged,
challenges: &challenges,
done: &done,
state: &state,
context: &context,
scope_text: &scope_text,
message: &message,
changed: true,
judge: true,
budget: None,
started: std::time::Instant::now(),
check: &check_id,
summary: &summary,
};
let before = mark.map_or(0, |m| m.covered);
let covered = match check(session, input, &work, true) {
Verdict::Skip(score) => {
append(session, &format!("#borg-live-skip {score}"));
before
}
Verdict::Failed => before,
Verdict::Ask(ids, blocks) => {
if !ids.is_empty() {
let prefix = if blocks { "live " } else { LIVE_NEXT };
enqueue(session, &format!("{prefix}{}{}", ids.join(","), tag(&check_id)));
}
n
}
};
live::write_mark(&ctx, live::Mark { covered, started_ms: started, turn: Some(turn) });
}
pub fn dispatch(h: &dyn Harness, event: &str, input: &Value) -> Option<Value> {
let session = input.get("session_id").and_then(Value::as_str).unwrap_or("unknown");
match event {
"prompt" => on_prompt(h, session, input),
"post_tool_failure" => {
capture_test(session, input, true);
if h.caps().deny_capture {
capture_rejection(h, session, input);
}
None
}
"end" => {
on_end(h, session, input);
None
}
"post_tool" => {
capture_test(session, input, false);
on_post_tool(h, session, input)
}
"stop" => on_stop(h, session, input),
_ => None,
}
}
fn on_prompt(h: &dyn Harness, session: &str, input: &Value) -> Option<Value> {
let prompt = input.get("prompt").and_then(Value::as_str).unwrap_or_default();
append(session, prompt);
if learning() {
crate::notes::remember_start(&crate::notes::state_dir(), session, input.get("cwd").and_then(Value::as_str).unwrap_or_default());
crate::notes::mark(&crate::notes::state_dir(), session, "prompt");
}
if let Ok(mut f) = std::fs::OpenOptions::new().create(true).append(true).open(prompts_file(session)) {
let _ = writeln!(f, "{prompt}");
}
let vetoed = (learning() && crate::veto::enabled()).then(|| crate::veto::reason_in(prompt)).flatten();
match &vetoed {
Some(reason) => veto(h, session, input, reason),
None => capture_prompt(h, session, input, prompt),
}
note_where(session, &repo_of(input.get("cwd").and_then(Value::as_str).unwrap_or_default()));
let _ = std::fs::write(state_file(session).with_extension("lastprompt"), prompt);
let checked = crate::update::maybe_check(learn::now_ms());
let out = (h.caps().prompt_context && input.get("context") != Some(&Value::Bool(false))).then(|| {
let cwd = input.get("cwd").and_then(Value::as_str).unwrap_or_default();
let ask = queen_ask(h, session, cwd);
let update = crate::update::notice(checked.as_ref(), &learn::home(), &state_file(session).with_extension("update"));
let extra: Vec<String> = [ask, vetoed.as_deref().map(crate::veto::render), update].into_iter().flatten().collect();
free_context_with(h, "UserPromptSubmit", session, input, prompt, (!extra.is_empty()).then(|| extra.join("\n\n")))
});
if harness::transcript(h.caps(), input).is_none() {
let _ = std::fs::write(turn_file(session), "");
}
out.flatten()
}
fn capture_test(session: &str, input: &Value, failed: bool) {
if !learning() || input.get("tool_name").and_then(Value::as_str) != Some("Bash") {
return;
}
let command = input.pointer("/tool_input/command").and_then(Value::as_str).unwrap_or_default();
if !crate::notes::regress_signals::runs_tests(command) {
return;
}
let output = crate::notes::regress_signals::tool_output(input);
if !failed && output.trim().is_empty() {
return;
}
if let Some(what) = crate::notes::regress_signals::test_outcome(command, &output, failed)
&& let Ok(mut f) = std::fs::OpenOptions::new().create(true).append(true).open(state_file(session).with_extension("tests"))
{
let _ = writeln!(f, "{what} {}", learn::now_ms());
}
}
fn on_end(h: &dyn Harness, session: &str, input: &Value) {
let _ = std::fs::remove_file(denied_file(session));
if !learning() {
return;
}
crate::notes::remember_proposal(&crate::notes::state_dir(), session, &full_proposal(h, input));
crate::notes::mark(&crate::notes::state_dir(), session, "stop");
note_never_delivered(session, input);
let end = outcome::Outcome {
kind: outcome::ENDED.into(),
session: session.into(),
ms: learn::now_ms(),
repo: repo_of(input.get("cwd").and_then(Value::as_str).unwrap_or_default()),
..Default::default()
};
let _ = outcome::append(&learn::home().join("outcomes.jsonl"), &end);
if !crate::notes::on_end(session, input)
&& let Ok(exe) = std::env::current_exe()
{
let _ = std::process::Command::new(exe)
.args(["learn", "--session", session])
.stdin(std::process::Stdio::null())
.stdout(std::process::Stdio::null())
.stderr(std::process::Stdio::null())
.spawn();
}
}
fn on_post_tool(h: &dyn Harness, session: &str, input: &Value) -> Option<Value> {
let _ = std::fs::remove_file(denied_file(session));
let tool = input.get("tool_name").and_then(Value::as_str).unwrap_or_default();
let tool_input = input.get("tool_input").unwrap_or(&Value::Null);
let touch = touched(tool_input, tool);
append(session, &touch);
note_where(
session,
&if tool == "Bash" { bash_read_paths(tool_input.get("command").and_then(Value::as_str).unwrap_or_default()).join(" ") } else { touch.clone() },
);
if prefilter::edits_gate() && prefilter::changes(tool, tool_input) {
let _ = std::fs::OpenOptions::new().create(true).append(true).open(changes_file(session)).and_then(|mut f| writeln!(f, "{tool}"));
}
let edit = edit_text(tool, tool_input);
if let Some(edit) = &edit
&& let Ok(mut f) = std::fs::OpenOptions::new().create(true).append(true).open(edits_file(session))
{
let _ = writeln!(f, "{edit}");
}
if harness::transcript(h.caps(), input).is_none()
&& let Ok(mut f) = std::fs::OpenOptions::new().create(true).append(true).open(turn_file(session))
{
let _ = writeln!(f, "[{tool}] {touch}");
if let Some(edit) = &edit {
let _ = writeln!(f, "{edit}");
}
}
if live::current() == live::Mode::Live {
live_trigger(session, input, tool, prefilter::changes(tool, tool_input));
}
(h.caps().tool_context && !subagent(input)).then(|| free_context(h, "PostToolUse", session, input, &touch)).flatten()
}
fn subagent(input: &Value) -> bool {
input.get("agent_id").and_then(Value::as_str).is_some_and(|a| !a.is_empty())
}
struct StopLive {
on: bool,
budget: Option<std::time::Duration>,
lock: live::Lock,
guard: Option<live::Guard>,
waiting: Vec<(String, String)>,
instead: Vec<(String, String)>,
}
impl StopLive {
fn take(h: &dyn Harness, session: &str) -> StopLive {
let on = live::current() == live::Mode::Live;
let budget = crate::expert_route::stop_budget(h);
let lock = if on { live::wait_free(&state_file(session), live::stop_wait(budget).as_millis() as u64) } else { live::Lock::Free };
let guard = if on && lock != live::Lock::Held { live::acquire(&state_file(session), learn::now_ms()) } else { None };
let lock = if on && guard.is_none() { live::Lock::Held } else { lock };
let Taken { asks: waiting, instead } = if on { take_live(session) } else { Taken::default() };
StopLive { on, budget, lock, guard, waiting, instead }
}
}
fn on_stop(h: &dyn Harness, session: &str, input: &Value) -> Option<Value> {
let started = std::time::Instant::now();
let started_ms = learn::now_ms();
if learning() {
crate::notes::remember_proposal(&crate::notes::state_dir(), session, &full_proposal(h, input));
crate::notes::mark(&crate::notes::state_dir(), session, "stop");
crate::sweep::turn_end(h, session, input);
}
let second_round = input.get("stop_hook_active").and_then(Value::as_bool) == Some(true);
if std::env::var("BORG_CRITIC").as_deref() == Ok("generic") {
return (!second_round).then(|| json!({"decision": "block", "reason": conscience::GENERIC}));
}
let (all, withheld) = loaded(session);
let judged = judged(&all, withheld);
note_answer(h, session, input);
let changed = std::fs::remove_file(changes_file(session)).is_ok();
if second_round {
return None;
}
stat(session, input, crate::stats::TURN_END, |_| {});
let live = StopLive::take(h, session);
let state = std::fs::read_to_string(state_file(session)).unwrap_or_default();
let proposal = full_proposal(h, input);
let acted = early_acted(session, &judged, &proposal);
let only = std::env::var_os("BORG_ONLY").is_some();
let done = if only { std::collections::HashSet::new() } else { done_in(&state, &acted) };
let queue = if only { String::new() } else { std::fs::read_to_string(queued_file(session)).unwrap_or_default() };
let waiting: std::collections::HashSet<&str> =
if only { Default::default() } else { live.waiting.iter().chain(&live.instead).map(|(id, _)| id.as_str()).chain(waiting_in(&queue)).collect() };
let challenges: Vec<conscience::Challenge> =
all.iter().filter(|c| !done.contains(c.id.as_str()) && !waiting.contains(c.id.as_str()) && !c.off_system).cloned().collect();
let message = input.get("last_assistant_message").and_then(Value::as_str).unwrap_or_default();
let context = format!("{state}{message}");
let scope_text = format!("{}\n{message}", where_now(session));
let check_id = crate::select::check_id(session, "stop", started_ms, std::process::id());
let summary = crate::select::summary::refresh(&lessons_path());
let work = Work {
all: &all,
judged: &judged,
challenges: &challenges,
done: &done,
state: &state,
context: &context,
scope_text: &scope_text,
message: &proposal,
changed,
judge: !live.on || live.guard.is_some(),
budget: live.budget,
started,
check: &check_id,
summary: &summary,
};
match stop_select(h, session, input, &work, &live) {
Ok(selected) => stop_ask(h, session, input, selected, &check_id, &live.instead),
Err(out) => out,
}
}
type Asks<'a> = Vec<(&'a conscience::Challenge, String)>;
fn stop_select<'a>(h: &dyn Harness, session: &str, input: &Value, w: &Work<'a>, live: &StopLive) -> Result<Asks<'a>, Option<Value>> {
let own = |cs: Vec<&'a conscience::Challenge>| cs.into_iter().map(|c| (c, w.check.to_string())).collect();
match std::env::var("BORG_ONLY") {
Ok(ids) => Ok(own(w.challenges.iter().filter(|c| ids.split(',').any(|i| i == c.id)).collect())),
Err(_) if std::env::var("BORG_MATCH").as_deref() != Ok("bm25") => stop_check(h, session, input, w, live),
Err(_) => {
let pool = conscience::budget_pool(&conscience::rank_scoped(w.all, &conscience::work_text(w.context), w.scope_text), w.done);
let asked: Vec<&conscience::Challenge> = conscience::in_scope_first(conscience::explored(pool.iter().copied()))
.into_iter()
.filter_map(|c| w.challenges.iter().find(|x| x.id == c.id))
.collect();
append_p_of(session, &pool, &asked, w.check);
Ok(own(asked))
}
}
}
fn stop_check<'a>(h: &dyn Harness, session: &str, input: &Value, w: &Work<'a>, live: &StopLive) -> Result<Asks<'a>, Option<Value>> {
let skip = |why: &str| {
append(session, &format!("#borg-skip {why}"));
stat(session, input, crate::stats::GATE_SKIP, |e| e.why = why.to_string());
let prompts = std::fs::read_to_string(prompts_file(session)).unwrap_or_default();
Err(crate::queen::stop(session, input, &|| harness::plan(h.caps(), input), &prompts, &[]))
};
let mut waiting: Vec<(&conscience::Challenge, String)> = Vec::new();
let instead = live.instead.iter().map(|(id, check)| (id, check, "queued"));
for (id, check, channel) in live.waiting.iter().map(|(id, check)| (id, check, "live")).chain(instead) {
let why = match w.all.iter().find(|c| &c.id == id).filter(|c| !c.off_system) {
Some(_) if waiting.iter().any(|(c, _)| &c.id == id) => "queued twice",
Some(_) if w.done.contains(id.as_str()) => "done at the stop",
Some(c) => {
waiting.push((c, check.clone()));
continue;
}
None => "not deliverable",
};
record_route(session, input, check, vec![id.clone()], channel, outcome::ROUTE_DROPPED_DONE, why);
}
let ctx = state_file(session);
if live.on && live::covered(live.lock, live::count(&ctx), live::read_mark(&ctx), turn_id(session)) {
return if waiting.is_empty() { skip("live_covered") } else { Ok(waiting) };
}
let mut asked: Asks = match check(session, input, w, false) {
Verdict::Skip(_) | Verdict::Failed if !waiting.is_empty() => Vec::new(),
Verdict::Skip(score) => return skip(&score),
Verdict::Failed => return Err(None),
Verdict::Ask(ids, _) => ids.iter().filter_map(|i| w.challenges.iter().find(|c| &c.id == i)).map(|c| (c, w.check.to_string())).collect(),
};
asked.extend(waiting);
Ok(asked)
}
fn graded_line(applied: &[(&conscience::Challenge, u8)]) -> String {
let items: Vec<String> = applied.iter().enumerate().map(|(r, (c, g))| format!("{}:{g}:{r}", c.id)).collect();
format!("#borg-graded n={} {}", applied.len(), items.join(","))
}
fn p_line<'a>(prefix: &str, chosen: impl IntoIterator<Item = (&'a str, f64)>, check: Option<&str>) -> Option<String> {
let items: Vec<String> = chosen.into_iter().map(|(id, p)| format!("{id}={}", outcome::round_p(p))).collect();
(!items.is_empty()).then(|| format!("{prefix} {}{}", items.join(","), tag(check.unwrap_or_default())))
}
fn append_p_of(session: &str, pool: &[(f64, &conscience::Challenge)], asked: &[&conscience::Challenge], check: &str) {
if asked.is_empty() {
return;
}
let p = conscience::propensity(pool, session);
let chosen: Vec<(&str, f64)> = asked.iter().filter_map(|c| p.get(&c.id).map(|p| (c.id.as_str(), *p))).collect();
let items: Vec<String> =
pool.iter().map(|(s, c)| format!("{}={}{}", c.id, conscience::pool_base(*s, c), if c.scope.is_empty() { "" } else { ":s" })).collect();
let pool = format!("#borg-pool {}{}", items.join(","), tag(check));
append(session, &p_line("#borg-p", chosen, Some(check)).map_or(pool.clone(), |p| format!("{p}\n{pool}")));
}
fn tagged(line: &str) -> (&str, Option<&str>) {
match line.rsplit_once(" @") {
Some((items, check)) if !check.is_empty() && check.bytes().all(|b| b.is_ascii_hexdigit()) => (items, Some(check)),
_ => (line, None),
}
}
fn pool_in(state: &str, ids: &[String]) -> (Vec<String>, Vec<f64>, Vec<bool>) {
let parse = |line: &str| -> Option<(Vec<String>, Vec<f64>, Vec<bool>)> {
let mut out = (Vec::new(), Vec::new(), Vec::new());
for item in line.split(',') {
let (id, rest) = item.rsplit_once('=')?;
let (base, scoped) = match rest.strip_suffix(":s") {
Some(b) => (b, true),
None => (rest, false),
};
out.0.push(id.trim().to_string());
out.1.push(base.trim().parse::<f64>().ok()?);
out.2.push(scoped);
}
Some(out)
};
let mut check: std::collections::HashMap<&str, Option<&str>> = std::collections::HashMap::new();
for line in state.lines().filter_map(|l| l.strip_prefix("#borg-p ")) {
let (items, tag) = tagged(line);
for (id, _) in items.split(',').filter_map(|it| it.rsplit_once('=')) {
check.insert(id.trim(), tag);
}
}
let Some(Some(tag)) = ids.first().and_then(|i| check.get(i.as_str())).copied() else { return Default::default() };
if !ids.iter().all(|i| check.get(i.as_str()).copied().flatten() == Some(tag)) {
return Default::default();
}
state
.lines()
.rev()
.filter_map(|l| l.strip_prefix("#borg-pool "))
.map(tagged)
.filter(|(_, t)| *t == Some(tag))
.find_map(|(items, _)| parse(items).filter(|(pool, _, _)| ids.iter().all(|i| pool.contains(i))))
.unwrap_or_default()
}
fn propensity_in(state: &str, ids: &[String]) -> Vec<f64> {
let mut seen: std::collections::HashMap<&str, f64> = std::collections::HashMap::new();
for line in state.lines().filter_map(|l| l.strip_prefix("#borg-p ")) {
for (id, p) in tagged(line).0.split(',').filter_map(|it| it.rsplit_once('=')) {
if let Ok(p) = p.trim().parse::<f64>() {
seen.insert(id.trim(), p);
}
}
}
ids.iter().map(|i| seen.get(i.as_str()).copied()).collect::<Option<Vec<f64>>>().unwrap_or_default()
}
fn graded_of(session: &str, ids: &[String]) -> (Vec<u8>, Vec<u16>, u16) {
let state = std::fs::read_to_string(state_file(session)).unwrap_or_default();
let mut seen: std::collections::HashMap<String, (u8, u16, u16)> = std::collections::HashMap::new();
for line in state.lines().filter_map(|l| l.strip_prefix("#borg-graded n=")) {
let Some((n, items)) = line.split_once(' ') else { continue };
let n: u16 = n.parse().unwrap_or(0);
for it in items.split(',') {
let mut p = it.rsplitn(3, ':');
let (Some(r), Some(g), Some(id)) = (p.next(), p.next(), p.next()) else { continue };
seen.insert(id.to_string(), (g.parse().unwrap_or(0), r.parse().unwrap_or(0), n));
}
}
let got: Vec<(u8, u16, u16)> = ids.iter().map(|i| seen.get(i).copied().unwrap_or((0, 0, 0))).collect();
(got.iter().map(|g| g.0).collect(), got.iter().map(|g| g.1).collect(), got.iter().map(|g| g.2).max().unwrap_or(0))
}
fn stop_ask(h: &dyn Harness, session: &str, input: &Value, mut selected: Asks, check: &str, instead: &[(String, String)]) -> Option<Value> {
crate::memory::shuffle(&mut selected, session);
let lessons: Vec<&conscience::Challenge> = selected.iter().map(|(c, _)| *c).collect();
let log = lessons.iter().map(|c| c.id.as_str()).collect::<Vec<_>>().join(",");
let others: Vec<String> = selected.iter().filter(|(_, k)| k != check).map(|(c, k)| format!("{}={k}", c.id)).collect();
let mut marker = if lessons.is_empty() { "#borg-asked ".to_string() } else { format!("#borg-asked {log}{}", tag(check)) };
if !others.is_empty() {
marker.push_str(&format!("\n{ROUTED}{}", others.join(",")));
}
append(session, &marker);
if !lessons.is_empty()
&& let Ok(mut f) = std::fs::OpenOptions::new().create(true).append(true).open(edits_file(session))
{
let _ = writeln!(f, "{}\n{marker}", one_line(&full_proposal(h, input), EVIDENCE_CHARS));
}
let prompts = std::fs::read_to_string(prompts_file(session)).unwrap_or_default();
let queen = crate::queen::stop(session, input, &|| harness::plan(h.caps(), input), &prompts, &lessons);
if lessons.is_empty() {
return queen;
}
if learning() {
let cwd = input.get("cwd").and_then(Value::as_str).unwrap_or_default();
let state = std::fs::read_to_string(state_file(session)).unwrap_or_default();
let ms = learn::now_ms();
let disagree = conscience::disagreement_ids(&lessons);
let (handed, routed): (Vec<(&conscience::Challenge, &str)>, Vec<_>) =
selected.iter().map(|(c, k)| (*c, k.as_str())).partition(|(c, k)| instead.iter().any(|(id, at)| *id == c.id && at == k));
let groups = by_check(&routed).into_iter().map(|g| (g, false)).chain(by_check(&handed).into_iter().map(|g| (g, true)));
for ((k, members), handed) in groups {
let ids: Vec<String> = members.iter().map(|i| (*i).to_string()).collect();
let (grades, ranks, applied) = graded_of(session, &ids);
let p = match handed {
true => Vec::new(),
false if k.is_empty() => propensity_in(&state, &ids),
false => tagged_p(&state, "#borg-p ", k, &members),
};
let (pool, base, scoped) = if handed { Default::default() } else { pool_in(&state, &ids) };
let asked = outcome::Outcome {
kind: outcome::ASKED.into(),
session: session.into(),
lessons: ids.clone(),
ms,
repo: repo_of(cwd),
groups: disagree.iter().filter(|g| g.iter().any(|x| ids.contains(x))).cloned().collect(),
channel: "stop".into(),
grades,
ranks,
applied,
p,
pool,
base,
scoped,
check: k.into(),
..Default::default()
};
let _ = outcome::append(&learn::home().join("outcomes.jsonl"), &asked);
let reason = match (handed, k == check) {
(true, _) => ASKED_INSTEAD,
(false, true) => "",
(false, false) => "at the stop",
};
record_route(session, input, k, ids, "stop", outcome::ROUTE_ASKED, reason);
}
}
let out = queen.or_else(|| Some(json!({"decision": "block", "reason": conscience::render(&lessons)})));
let chars = out.as_ref().and_then(|o| o["reason"].as_str()).map_or(0, str::len);
log_cost(session, &format!("block questions={} chars={chars}", lessons.len()));
stat(session, input, crate::stats::BLOCK, |e| {
e.n = lessons.len() as u64;
e.lessons = lessons.iter().map(|c| c.id.clone()).collect();
e.channel = "stop".into();
});
out
}
pub fn main(name: &str, event: &str) {
let Some(h) = harness::by_name(name) else { return };
let mut raw = String::new();
let _ = std::io::stdin().read_to_string(&mut raw);
let mut input = h.normalise(serde_json::from_str(&raw).unwrap_or(Value::Null));
if !h.caps().sends_pid
&& let Some(m) = input.as_object_mut()
{
m.shift_remove("pid");
}
let cwd = input.get("cwd").and_then(Value::as_str).unwrap_or_default();
let cfg = collective::load();
let route = match &cfg {
Ok(cfg) => collective::route(cfg.as_ref(), cwd, &learn::home()),
Err(_) => collective::Route::Off,
};
let collective::Route::Collective { home, name, .. } = route else { return };
let mode = live::of(cfg.as_ref().ok().and_then(Option::as_ref), &name).mode;
unsafe {
std::env::set_var("BORG_HOME", &home);
std::env::set_var("BORG_MODE", mode.name());
std::env::set_var("BORG_HARNESS", h.name());
if std::env::var_os("BORG_STATE").is_none() {
std::env::set_var("BORG_STATE", home.join("state"));
}
}
let now = learn::now_ms();
let session = input.get("session_id").and_then(Value::as_str).unwrap_or("unknown");
crate::listen::touch(&home, event, session, now);
if matches!(event, "start" | "halted") {
return;
}
let me = match event {
"pre_tool" => {
if !crate::steer::active(&home) {
return;
}
crate::presence::read(&home, session)
}
_ => crate::presence::touch(&home, &name, h.name(), event, &input, now),
};
let started = me.map(|p| p.started);
let stopping = crate::listen::stopping(&home, event, session, now);
let out = crate::steer::around(&home, event, &input, started, now, || crate::expert_route::checkpoint(h, event, &input, || dispatch(h, event, &input)));
let out = crate::listen::after_stop(&home, h, stopping.as_ref(), &input, out);
let out = harness::with_budgets(h, &input, out);
if let Some(out) = crate::msg::deliver(&home, h.caps(), event, &input, started, now, out) {
println!("{}", for_harness(h, out));
}
}
fn for_harness(h: &dyn Harness, mut out: Value) -> Value {
if matches!(h.wiring(), harness::Wiring::CommandHooks { .. })
&& let Some(o) = out.as_object_mut()
{
o.shift_remove("shown_ids");
}
out
}
#[cfg(test)]
mod tests {
use super::*;
#[test]
fn every_file_of_an_edit_survives_the_cut_of_its_text() {
let long = "x".repeat(700);
let input = json!({"file_path": "/w/a.rs", "new_string": long, "edits": [{"file_path": "/w/b.rs", "new_string": "more"}]});
let text = edit_text("Edit", &input).unwrap();
assert!(text.starts_with("/w/a.rs /w/b.rs x"), "{}", &text[..40]);
assert_eq!(text.chars().count(), 600);
let multi = json!({"file_path": "/w/a.rs", "edits": [{"old_string": "a", "new_string": "b"}, {"old_string": "c", "new_string": "d"}]});
assert_eq!(edit_text("MultiEdit", &multi).as_deref(), Some("/w/a.rs b d"), "Claude's MultiEdit reads as before");
assert_eq!(touched(&input, "Edit"), "/w/a.rs /w/b.rs");
}
#[test]
fn propensity_in_takes_the_latest_entry_and_nothing_when_one_is_missing() {
let state = "#borg-p A=1,B=0.25\n#borg-asked A,B\n#borg-p B=0.5,C=0.1\n";
let ids = |v: &[&str]| v.iter().map(|x| x.to_string()).collect::<Vec<_>>();
assert_eq!(propensity_in(state, &ids(&["B", "A"])), [0.5, 1.0]);
assert_eq!(propensity_in(state, &ids(&["C"])), [0.1]);
assert!(propensity_in(state, &ids(&["A", "D"])).is_empty(), "D unknown: no guess");
assert!(propensity_in("", &ids(&["A"])).is_empty());
}
#[test]
fn pool_in_takes_the_pool_of_the_check_that_logged_each_p() {
let state = "#borg-p A=0.6,B=0.4 @c1\n#borg-pool A=1.5:s,B=0.25,C=2 @c1\n#borg-asked A,B\n#borg-p B=0.5 @c2\n#borg-pool B=0.5,D=0.125:s @c2\n";
let ids = |v: &[&str]| v.iter().map(|x| x.to_string()).collect::<Vec<_>>();
assert_eq!(pool_in(state, &ids(&["B"])), (ids(&["B", "D"]), vec![0.5, 0.125], vec![false, true]), "B's latest p is check 2's");
assert_eq!(pool_in(state, &ids(&["A"])), (ids(&["A", "B", "C"]), vec![1.5, 0.25, 2.0], vec![true, false, false]));
assert_eq!(pool_in(state, &ids(&["A", "B"])), Default::default(), "A's p from check 1, B's from check 2: no pairing");
assert_eq!(pool_in("", &ids(&["A"])), Default::default());
assert_eq!(pool_in(state, &[]), Default::default());
let graded = "#borg-p A=1\n#borg-p B=0.5 @c3\n#borg-pool A=1,B=1 @c3\n";
assert_eq!(pool_in(graded, &ids(&["A"])), Default::default());
assert_eq!(pool_in(graded, &ids(&["B"])).0, ids(&["A", "B"]));
assert_eq!(pool_in("#borg-p A=1\n#borg-pool A=1,B=2\n", &ids(&["A"])), Default::default());
}
#[test]
fn a_queue_line_names_its_route_its_ids_and_its_check() {
let c = "0123456789ab";
assert_eq!(queue_line(&format!("A,B @{c}")), (Queued::Free, vec!["A", "B"], c));
assert_eq!(queue_line(&format!("live A @{c}")), (Queued::Ask, vec!["A"], c));
assert_eq!(queue_line(&format!("placebo X,Y @{c}")), (Queued::Placebo, vec!["X", "Y"], c));
assert_eq!(queue_line(&format!("instead G0,G1 @{c}")), (Queued::Instead, vec!["G0", "G1"], c));
assert_eq!(queue_line(&format!("instead-next G2 @{c}")), (Queued::Instead, vec!["G2"], c));
assert_eq!(queue_line("A,B"), (Queued::Free, vec!["A", "B"], ""));
assert_eq!(queue_line("live A"), (Queued::Ask, vec!["A"], ""));
assert_eq!(queue_line(&format!("live-next A,B @{c}")), (Queued::Ask, vec!["A", "B"], c));
assert_eq!(listed(&format!("#borg-asked A,B @{c}\n#borg-asked C\n"), "#borg-asked "), ["A", "B", "C"].into_iter().collect());
}
#[test]
fn a_tagged_propensity_is_its_checks_never_another_checks() {
let state = "#borg-pf A=1,B=0.5 @c1\n#borg-pf A=0.25 @c2\n#borg-p A=0.75 @c1\n#borg-pf B=0.9\n";
assert_eq!(tagged_p(state, "#borg-pf ", "c1", &["A", "B"]), [1.0, 0.5]);
assert_eq!(tagged_p(state, "#borg-pf ", "c2", &["A"]), [0.25]);
assert!(tagged_p(state, "#borg-pf ", "c2", &["A", "B"]).is_empty(), "B has none at c2: no guess");
assert_eq!(tagged_p(state, "#borg-p ", "c1", &["A"]), [0.75], "#borg-p and #borg-pf are separate lines");
assert_eq!(p_line("#borg-pf", [("A", 1.0), ("B", 0.33333)], Some("c1")).as_deref(), Some("#borg-pf A=1,B=0.3333 @c1"));
assert_eq!(p_line("#borg-p", [], Some("c1")), None);
}
#[test]
fn unjudged_says_why_each_delivered_lesson_has_no_verdict() {
let c = "0123456789ab";
let state = format!(
"#borg-asked A,B,C,D @{c}\n#borg-judged A=pending\n#borg-unjudged B why=slots\n#borg-judged A=pending\n#borg-unjudged D why=failed\n\
#borg-queued E @{c}\n#borg-judged B=pending\n#borg-asked D\n"
);
let why = unjudged(&state);
assert_eq!(why["A"], outcome::UNJUDGED_TRIES, "two unclear tries");
assert_eq!(why["B"], outcome::UNJUDGED_SLOTS, "one try is not all of them; the last call left it out");
assert_eq!(why["C"], outcome::UNJUDGED_NO_CALL);
assert_eq!(why["D"], outcome::UNJUDGED_NO_CALL, "delivered again after its failed call");
assert_eq!(why["E"], outcome::UNJUDGED_NO_CALL);
}
#[test]
fn the_declaration_coin_is_fixed_per_check_and_lesson_and_fair() {
assert_eq!(stripped("0123456789ab", "L1"), stripped("0123456789ab", "L1"));
let heads = (0..1000).filter(|i| stripped("0123456789ab", &format!("L{i}"))).count();
assert!((400..600).contains(&heads), "{heads} of 1000");
let checks = (0..1000).filter(|i| stripped(&format!("{i:012x}"), "L1")).count();
assert!((400..600).contains(&checks), "{checks} of 1000");
}
#[test]
fn pending_gives_every_route_the_same_evidence_and_its_own_check() {
let session = format!("pending-v2-{}", std::process::id());
let c = |id: &str| conscience::Challenge { id: id.into(), ..Default::default() };
let all = [c("A"), c("B"), c("C"), c("D"), c("E")];
let edits = "Plan: the blocked message\n#borg-asked A,B @0000000000c1\n#borg-routed B=0000000000c2\n#borg-answer A: applies. B: skip.\n\
edit one\n#borg-work the work so far\n#borg-queued C @0000000000c3\n#borg-placebo D @0000000000c4\nedit two\n\
#borg-work later work\n#borg-asked E @0000000000c5\n";
let _ = std::fs::write(edits_file(&session), edits);
let state: String = edits.lines().filter(|l| DELIVERED.iter().any(|m| l.starts_with(m))).map(|l| format!("{l}\n")).collect();
let j = pending(&session, &state, &all, "the final message", false, "00000000cafe");
let got: Vec<(&str, &str, &str)> = j.pending.iter().map(|p| (p.lesson.id.as_str(), p.channel, p.check.as_str())).collect();
assert_eq!(
got,
[
("A", "stop", "0000000000c1"),
("B", "stop", "0000000000c2"),
("C", "queued", "0000000000c3"),
("D", outcome::PLACEBO, "0000000000c4"),
("E", "stop", "0000000000c5")
]
);
let p = |id: &str| j.pending.iter().find(|p| p.lesson.id == id).unwrap();
assert_eq!(
(p("A").before.as_str(), p("C").before.as_str(), p("D").before.as_str()),
("Plan: the blocked message", "the work so far", "the work so far")
);
assert_eq!(p("C").after, "work since: edit two\nthis turn: the final message");
assert_eq!(p("D").after, p("C").after, "a placebo is judged as a free delivery");
assert!(p("A").after.starts_with("work since: ") && p("A").after.contains("edit one | edit two"), "{}", p("A").after);
assert_eq!(p("A").after, p("B").after, "delivered together, one shared evidence");
for (id, word) in [("A", "applies"), ("B", "skip")] {
let x = p(id);
assert_eq!(x.stripped, stripped(&x.check, id));
match x.stripped {
true => assert!(x.declared.is_none() && !x.after.contains(&format!("{id}: {word}")), "{x:?}"),
false => assert!(x.declared.is_some() && x.after.contains(&format!("{id}: {word}")), "{x:?}"),
}
}
assert!(!p("C").stripped && !p("D").stripped, "only questions are stripped");
let live = pending(&session, &state, &all, "", true, "00000000cafe");
let ids: Vec<&str> = live.pending.iter().map(|p| p.lesson.id.as_str()).collect();
assert_eq!(ids, ["A", "B", "C", "D"], "E is not answered yet");
assert!(j.question && j.crowded.is_empty());
let _ = std::fs::remove_file(edits_file(&session));
}
#[test]
fn a_stripped_declaration_leaves_every_evidence_of_the_call() {
let session = format!("pending-strip-{}", std::process::id());
let c = |id: &str| conscience::Challenge { id: id.into(), ..Default::default() };
let all = [c("A"), c("F"), c("G")];
let check = |lesson: &str, strip: bool| (0u64..).map(|i| format!("{i:012x}")).find(|k| stripped(k, lesson) == strip).unwrap();
let (ca, cf, cg) = (check("A", false), check("F", true), check("G", false));
let answer = "Fixed the arc. F: applies";
let edits = format!(
"Plan: the blocked message\n#borg-asked A @{ca}\n#borg-answer A: applies\nedit one\n#borg-work the work so far\n\
#borg-asked F @{cf}\n#borg-live F ms=1\n#borg-answer {answer}\n{answer}\n#borg-asked G @{cg}\n"
);
let _ = std::fs::write(edits_file(&session), &edits);
let state: String = edits.lines().filter(|l| DELIVERED.iter().any(|m| l.starts_with(m))).map(|l| format!("{l}\n")).collect();
let j = pending(&session, &state, &all, answer, false, "00000000cafe");
let p = |id: &str| j.pending.iter().find(|p| p.lesson.id == id).unwrap();
assert!(p("F").stripped && p("F").declared.is_none(), "{:?}", p("F"));
for x in &j.pending {
assert!(!format!("{} {}", x.before, x.after).to_lowercase().contains("f: applies"), "{x:?}");
}
assert!(p("F").after.contains("this turn: Fixed the arc."), "the rest of the message stays: {}", p("F").after);
assert!(!p("A").stripped && p("A").declared == Some(true) && p("A").after.contains("A: applies"), "{:?}", p("A"));
assert_eq!(without_declarations(&format!("work\n{answer}"), &j.pending), "work\nFixed the arc. ");
assert_eq!(without_declarations("A: applies", &j.pending), "A: applies");
let _ = std::fs::remove_file(edits_file(&session));
}
#[test]
fn a_merged_ask_of_two_draws_carries_no_pool() {
let session = format!("pool-merge-{}", std::process::id());
let _ = std::fs::remove_file(state_file(&session));
let c = |id: &str| conscience::Challenge { id: id.into(), ..Default::default() };
let (a, b, cc, d, e, f) = (c("A"), c("B"), c("C"), c("D"), c("E"), c("F"));
let live: Vec<(f64, &conscience::Challenge)> = vec![(1.0, &a), (0.9, &b), (0.8, &cc), (0.7, &d)];
append_p_of(&session, &live, &[&a, &b], "c1");
let stop: Vec<(f64, &conscience::Challenge)> = vec![(1.0, &a), (0.9, &e), (0.8, &f)];
append_p_of(&session, &stop, &[&a], "c2");
let state = std::fs::read_to_string(state_file(&session)).unwrap_or_default();
let merged = vec!["A".to_string(), "B".to_string()];
assert_eq!(propensity_in(&state, &merged).len(), 2, "each id has its latest p");
assert_eq!(pool_in(&state, &merged), Default::default());
assert_eq!(pool_in(&state, &["A".to_string()]).0, ["A", "E", "F"], "A alone: the stop check's pool");
assert_eq!(pool_in(&state, &["B".to_string()]).0, ["A", "B", "C", "D"], "B alone: the live check's");
assert_eq!(tagged_p(&state, "#borg-p ", "c1", &["B"]).len(), 1, "B's record carries its own check's p");
let _ = std::fs::remove_file(state_file(&session));
}
#[test]
fn an_early_lessons_relative_score_is_its_share_of_the_best_on_topic_match() {
let c = |id: &str, q: &str| conscience::Challenge { id: id.into(), question: q.into(), scope: vec!["Orion".into()], ..Default::default() };
let standing = conscience::Challenge { source: conscience::CONSTRAINT.into(), ..c("S", "harpsichord tuning") };
let all = vec![c("A", "orion budget place reset arc drain"), c("B", "orion budget place"), c("C", "telescope glaciers"), standing];
let work = "drain the orion budget place, never with a reset arc";
let topics = vec!["Orion".to_string()];
let ranked = conscience::rank(&all, work);
let score = |id: &str| ranked.iter().find(|(_, x)| x.id == id).map_or(0.0, |(s, _)| *s);
assert!(score("A") > score("B") && score("B") > 0.0, "{ranked:?}");
let rel = early_rel(&all, work, &topics, &[&all[1], &all[3]]);
assert_eq!(rel, [outcome::round_p(score("B") / score("A")), 0.0]);
assert!(rel[0] < 1.0);
assert_eq!(early_rel(&all, work, &topics, &[&all[0]]), [1.0]);
assert!(early_rel(&all, work, &["Beacon".to_string()], &[&all[3]]).is_empty());
}
fn decide_store(name: &str) -> std::path::PathBuf {
decide_store_with(name, true)
}
fn decide_store_with(name: &str, sure: bool) -> std::path::PathBuf {
use crate::select::{policy, summary};
let d = std::env::temp_dir().join(format!("borg-decide-{name}-{}", std::process::id()));
let _ = std::fs::remove_dir_all(&d);
std::fs::create_dir_all(&d).unwrap();
let lessons = d.join("lessons.jsonl");
std::fs::write(&lessons, "").unwrap();
std::fs::write(outcome::path_beside(&lessons), "").unwrap();
let at = |name: &str| policy::NAMES.iter().position(|n| *n == name).unwrap();
let mut beta = vec![0.0; policy::P];
beta[at("intercept")] = -0.5;
if sure {
beta[at("ask")] = -3.0;
beta[at("not")] = -1.0;
}
let mut chol = vec![0.0; policy::P * policy::P];
for k in 0..policy::P {
chol[k * policy::P + k] = 0.05;
}
let model = policy::Model { beta, chol, sd: vec![1.0; policy::P], spread: [0.1; 3], ..policy::Model::default() };
let rates = policy::Rates { free_stop: 1.0, free_live: 1.0, later: 0.0, wait: 0.0, ask_live: 1.0 };
let fit = policy::Fit { key: "9-abcdef01".into(), model: Some(model), rates, ..policy::Fit::default() };
let gate = summary::Gate { gain: vec![0.0; policy::DRAWS], allowance: 5.0, ..summary::Gate::default() };
summary::save(&lessons, &summary::Summary { fit, gate, ..summary::Summary::default() }).unwrap();
lessons
}
fn record_beside(lessons: &std::path::Path, applied: &[(&conscience::Challenge, u8)], check: &str, r: &crate::select::Routed, basis: &Basis) -> bool {
let order: Vec<&conscience::Challenge> = applied.iter().map(|(c, _)| *c).collect();
let call = Call { eligible: order.len(), order: &order, tail: &[], pt: 0.0, model: "", prompt_hash: String::new(), dur_ms: 1, usd: 0.0 };
let o = graded_outcome("decide-s", "r", check, true, applied, Some((r, basis)), basis.summary, &call);
outcome::append(&outcome::path_beside(lessons), &o).is_ok()
}
#[test]
fn the_graded_record_carries_the_question_count_tests_draw() {
use crate::select::{Log, Routed, policy, summary};
let c = |id: &str| conscience::Challenge { id: id.into(), ..Default::default() };
let ls = [c("A"), c("B")];
let applied: Vec<(&conscience::Challenge, u8)> = ls.iter().zip([2, 1]).collect();
let order: Vec<&conscience::Challenge> = ls.iter().collect();
let call = Call { eligible: 2, order: &order, tail: &[], pt: 0.0, model: "", prompt_hash: String::new(), dur_ms: 1, usd: 0.0 };
let s = summary::Summary::default();
let basis = Basis { summary: &s, had: &[], why: "" };
let routed = |source: &'static str, xk: Option<u32>, xs: Option<u32>| Routed {
ask: Vec::new(),
free: vec![&ls[0], &ls[1]],
placebo: Vec::new(),
p: vec![0.0, 0.0],
pf: vec![1.0, 1.0],
log: Log { policy: "learned", source, xk, xs, ..Log::default() },
};
let record = |r: Option<&Routed>| graded_outcome("s", "r", "0123456789ab", true, &applied, r.map(|r| (r, &basis)), &s, &call);
let drawn = record(Some(&routed(policy::EXPERIMENT_CONTROL, Some(2), Some(0))));
assert_eq!((drawn.source.as_str(), drawn.xk, drawn.xs), (policy::EXPERIMENT_CONTROL, Some(2), Some(0)));
let outside = record(Some(&routed(policy::EVIDENCE, None, None)));
assert_eq!((outside.source.as_str(), outside.xk, outside.xs), (policy::EVIDENCE, None, None));
let failed = record(None);
assert_eq!((failed.failed, failed.xk, failed.xs), (true, None, None));
}
fn graded_records(lessons: &std::path::Path) -> Vec<outcome::Outcome> {
outcome::read(&outcome::path_beside(lessons)).into_iter().filter(|o| o.kind == outcome::GRADED).collect()
}
#[test]
fn a_check_decides_on_the_summary_under_the_lock_with_every_decision_before_it() {
use crate::select::{Policy, policy, summary};
let lessons = decide_store("fresh");
let stale = summary::refresh(&lessons);
let c = |id: &str| conscience::Challenge { id: id.into(), ..Default::default() };
let ls = [c("A"), c("B"), c("C"), c("D")];
let applied: Vec<(&conscience::Challenge, u8)> = ls.iter().zip([3, 1, 2, 1]).collect();
let mut gates = Vec::new();
for check in ["0000000000a1", "0000000000b2"] {
let at = Decide { session: "decide-fresh", check, channel: "live", lessons: &lessons, tokens: 0, recorded: true };
let r = decide(Policy::Learned, &applied, &at, &stale, DECIDE_WAIT, |r, b| record_beside(&lessons, &applied, check, r, b));
gates.push(r.log.gate);
}
let g = graded_records(&lessons);
assert_eq!(g.len(), 2);
assert!(g.iter().all(|o| o.policy == "learned" && o.reason.is_empty()), "{g:?}");
assert_ne!(g[0].free, Vec::<String>::new(), "the first deviates: everything free at a live check, {:?}", g[0]);
assert_eq!(g[0].seen, stale.key(), "nothing was decided before the first");
let log = std::fs::read_to_string(outcome::path_beside(&lessons)).unwrap();
let first = log.lines().next().unwrap();
let after = summary::fold(&format!("{first}\n"), stale.clone());
assert_eq!(after.gate.checks, stale.gate.checks + 1, "the first's decision is in the gate's ledger");
assert_eq!(g[1].seen, after.key(), "decided on the summary loaded under the lock, not the one read at its start");
assert_eq!(gates[1], policy::remaining(&after.gate).max(0.0), "against the gate with the first's entry");
let _ = std::fs::remove_dir_all(lessons.parent().unwrap());
}
#[test]
fn two_checks_deciding_at_once_never_both_take_the_gate() {
use crate::select::{Policy, policy, summary};
let c = |id: &str| conscience::Challenge { id: id.into(), ..Default::default() };
let ls = [c("A"), c("B"), c("C"), c("D")];
let applied: Vec<(&conscience::Challenge, u8)> = ls.iter().zip([3, 1, 2, 1]).collect();
let mut stores = Vec::new();
for (name, sure, sources) in [("race", true, &[policy::EVIDENCE][..]), ("race-test", false, &[policy::EXPERIMENT, policy::EXPERIMENT_CONTROL][..])] {
let lessons = decide_store_with(name, sure);
let stale = summary::refresh(&lessons);
let both = std::sync::Barrier::new(2);
std::thread::scope(|s| {
for check in ["0000000000c1", "0000000000c2"] {
let (applied, lessons, stale, both) = (&applied, &lessons, &stale, &both);
s.spawn(move || {
let at = Decide { session: "decide-race", check, channel: "live", lessons, tokens: 0, recorded: true };
decide(Policy::Learned, applied, &at, stale, std::time::Duration::ZERO, |r, b| {
both.wait();
record_beside(lessons, applied, check, r, b)
});
});
}
});
let mut got: Vec<(String, String, String, bool)> =
graded_records(&lessons).into_iter().map(|o| (o.policy, o.source, o.reason, o.xk.is_some())).collect();
got.sort();
assert_eq!(got.len(), 2, "{name}: {got:?}");
assert_eq!(got[0], ("fixed".to_string(), "fixed".to_string(), outcome::DECIDED_BUSY.to_string(), false), "{name}: the other took the fixed rule");
let (policy, source, reason, drawn) = &got[1];
assert!(policy == "learned" && sources.contains(&source.as_str()) && reason.is_empty(), "{name}: one decided under the lock: {got:?}");
assert_eq!(*drawn, !sure, "{name}: the test's draw on its record alone");
assert!(policy::remaining(&summary::refresh(&lessons).gate) >= -1e-9, "{name}: the gate never overspent");
stores.push(lessons);
}
let stale = summary::refresh(&stores[0]);
let gone = std::path::Path::new("/nonexistent/borg-decide/lessons.jsonl");
let at = Decide { session: "decide-race", check: "0000000000c3", channel: "live", lessons: gone, tokens: 0, recorded: true };
let mut why = "";
let r = decide(Policy::Learned, &applied, &at, &stale, DECIDE_WAIT, |_, b| {
why = b.why;
true
});
assert_eq!((r.log.policy, why), ("fixed", outcome::DECIDED_NO_LOCK));
for lessons in stores {
let _ = std::fs::remove_dir_all(lessons.parent().unwrap());
}
}
#[test]
fn a_policy_that_reads_no_gate_decides_by_itself_whoever_holds_the_lock() {
use crate::select::{Ctx, Policy, graded_under, summary};
let lessons = decide_store("nolock");
let stale = summary::refresh(&lessons);
let c = |id: &str| conscience::Challenge { id: id.into(), ..Default::default() };
let ls = [c("A"), c("B"), c("C"), c("D")];
let applied: Vec<(&conscience::Challenge, u8)> = ls.iter().zip([3, 1, 3, 2]).collect();
let ids = |cs: &[&conscience::Challenge]| cs.iter().map(|c| c.id.clone()).collect::<Vec<_>>();
let held = lock_within(&decide_lock(&lessons), std::time::Duration::ZERO).unwrap();
let check = "0000000000e1";
let at = Decide { session: "decide-nolock", check, channel: "stop", lessons: &lessons, tokens: 0, recorded: true };
let ctx = Ctx {
session: at.session,
check,
channel: at.channel,
lessons: &lessons,
summary: &stale,
tokens: 0,
had: &[],
alpha: crate::select::alpha(&lessons),
};
let fixed = ids(&graded_under(Policy::Fixed, &applied, &ctx).ask);
for policy in [Policy::Fixed, Policy::Cap(1), Policy::Attention] {
let own = graded_under(policy, &applied, &ctx);
let mut got = None;
let r = decide(policy, &applied, &at, &stale, std::time::Duration::ZERO, |r, b| {
got = Some((r.log.policy, b.why, b.summary.key()));
true
});
assert_eq!(got, Some((policy.name(), "", stale.key())), "{policy:?}");
assert_eq!((ids(&r.ask), ids(&r.free)), (ids(&own.ask), ids(&own.free)), "{policy:?}: its own rule");
}
assert_ne!(ids(&graded_under(Policy::Cap(1), &applied, &ctx).ask), fixed);
let mut why = "";
let r = decide(Policy::Learned, &applied, &at, &stale, std::time::Duration::ZERO, |_, b| {
why = b.why;
true
});
assert_eq!((r.log.policy, why), ("fixed", outcome::DECIDED_BUSY), "the learned policy alone waits for the lock");
drop(held);
let _ = std::fs::remove_dir_all(lessons.parent().unwrap());
}
#[test]
fn a_learned_decision_whose_record_cannot_land_takes_the_fixed_rule() {
use crate::select::{Ctx, Policy, graded_under, policy, summary};
let lessons = decide_store("unrecorded");
let c = |id: &str| conscience::Challenge { id: id.into(), ..Default::default() };
let ls = [c("A"), c("B"), c("C"), c("D")];
let applied: Vec<(&conscience::Challenge, u8)> = ls.iter().zip([3, 1, 2, 1]).collect();
let ids = |cs: &[&conscience::Challenge]| cs.iter().map(|c| c.id.clone()).collect::<Vec<_>>();
let at = |check: &'static str, recorded: bool| Decide { session: "decide-unrecorded", check, channel: "live", lessons: &lessons, tokens: 0, recorded };
let fixed = |check: &str, s: &summary::Summary| {
let ctx = Ctx {
session: "decide-unrecorded",
check,
channel: "live",
lessons: &lessons,
summary: s,
tokens: 0,
had: &[],
alpha: crate::select::alpha(&lessons),
};
let r = graded_under(Policy::Fixed, &applied, &ctx);
(ids(&r.ask), ids(&r.free), ids(&r.placebo))
};
let stale = summary::refresh(&lessons);
let r = decide(Policy::Learned, &applied, &at("0000000000f1", true), &stale, std::time::Duration::ZERO, |r, b| {
record_beside(&lessons, &applied, "0000000000f1", r, b)
});
assert_eq!(r.log.source, policy::EVIDENCE, "{:?}", r.log);
let (ask, free, _) = fixed("0000000000f1", &stale);
assert_ne!((ids(&r.ask), ids(&r.free)), (ask, free), "it deviated");
let gate = summary::refresh(&lessons).gate;
for check in ["0000000000f2", "0000000000f3"] {
let stale = summary::refresh(&lessons);
let mut tried = Vec::new();
let r = decide(Policy::Learned, &applied, &at(check, false), &stale, std::time::Duration::ZERO, |r, b| {
tried.push((r.log.policy, b.why));
false
});
assert_eq!(tried, [("fixed", outcome::DECIDED_NO_RECORD)], "{check}");
assert_eq!((ids(&r.ask), ids(&r.free), ids(&r.placebo)), fixed(check, &stale), "{check}");
}
let stale = summary::refresh(&lessons);
let mut tried = Vec::new();
let r = decide(Policy::Learned, &applied, &at("0000000000f4", true), &stale, DECIDE_WAIT, |r, b| {
tried.push((r.log.policy, b.why));
false
});
assert_eq!(tried, [("learned", ""), ("fixed", outcome::DECIDED_NO_RECORD)]);
assert_eq!((ids(&r.ask), ids(&r.free), ids(&r.placebo)), fixed("0000000000f4", &stale));
assert_eq!(graded_records(&lessons).len(), 1, "only the first check's record");
assert_eq!(summary::refresh(&lessons).gate, gate, "no unrecorded decision moved the gate");
let _ = std::fs::remove_dir_all(lessons.parent().unwrap());
}
#[test]
fn a_lesson_waiting_in_the_queue_never_takes_a_free_or_placebo_slot() {
use crate::select::{Policy, summary};
let lessons = decide_store("queued");
let stale = summary::refresh(&lessons);
let session = format!("decide-queued-{}", std::process::id());
let _ = std::fs::remove_file(state_file(&session));
std::fs::write(queued_file(&session), "X @0000000000d0\nlive Y @0000000000d0\nplacebo Z @0000000000d0\n").unwrap();
let c = |id: &str| conscience::Challenge { id: id.into(), ..Default::default() };
let named: Vec<String> = (1..=10).map(|i| format!("L{i:02}")).collect();
let ls: Vec<conscience::Challenge> = ["X", "Y", "Z"].iter().map(|i| c(i)).chain(named.iter().map(|i| c(i))).collect();
let ids = |cs: &[&conscience::Challenge]| cs.iter().map(|c| c.id.clone()).collect::<Vec<_>>();
let first: Vec<(&conscience::Challenge, u8)> = ls.iter().map(|c| (c, if ["X", "Y"].contains(&c.id.as_str()) { 2 } else { 1 })).collect();
let last: Vec<(&conscience::Challenge, u8)> = ls.iter().map(|c| (c, if c.id.starts_with('L') { 2 } else { 1 })).collect();
let waits = |l: &[String]| l.iter().any(|i| i == "X" || i == "Y");
for (check, applied) in [("0000000000d1", &first), ("0000000000d2", &last)] {
let at = Decide { session: &session, check, channel: "stop", lessons: &lessons, tokens: 0, recorded: true };
let r = decide(Policy::Fixed, applied, &at, &stale, std::time::Duration::ZERO, |r, b| record_beside(&lessons, applied, check, r, b));
let (free, placebo) = (ids(&r.free), ids(&r.placebo));
assert_eq!(free.len(), conscience::CAP, "{check}: every free slot taken: {free:?}");
assert!(!waits(&free) && !waits(&placebo), "{check}: free {free:?}, placebo {placebo:?}");
}
assert_eq!(graded_records(&lessons)[1].placebo, ["Z"], "waiting as a placebo, Z is still drawn");
assert!(graded_records(&lessons)[0].free.contains(&"Z".to_string()), "and still goes free");
let g = graded_records(&lessons);
assert_eq!(g.iter().map(|o| o.nofree.clone()).collect::<Vec<_>>(), [["X", "Y"], ["X", "Y"]], "{g:?}");
let _ = std::fs::remove_file(queued_file(&session));
let _ = std::fs::remove_dir_all(lessons.parent().unwrap());
}
#[test]
fn only_an_adapter_reads_which_messages_an_answer_showed() {
let out = json!({"hookSpecificOutput": {"additionalContext": "[borg] Message from s1: hi"}, "shown_ids": ["m0123456789ab"]});
for name in ["claude", "codex"] {
let h = harness::by_name(name).unwrap();
assert_eq!(for_harness(h, out.clone()), json!({"hookSpecificOutput": out["hookSpecificOutput"]}), "{name}");
}
for name in ["omp", "opencode"] {
assert_eq!(for_harness(harness::by_name(name).unwrap(), out.clone()), out, "{name}");
}
}
}