GameCult/Epiphany
Archived
Watch
9
0
Fork
You've already forked Epiphany
 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Seal coordinator step artifacts

Browse source
This commit is contained in:
Meta Vens 2026-05-30 23:35:19 +01:00
commit eee3533479
5 changed files with 18 additions and 12 deletions
Download patch file Download diff file Expand all files Collapse all files

28
epiphany-core/src/bin/epiphany-mvp-coordinator.rs
View file

@ -354,12 +354,12 @@ fn run_coordinator(args: &Args) -> Result<Value> {
final_action = coordinator.clone();
if args.mode == "plan" {
append_jsonl(&steps_path, &step)?;
append_operator_step_jsonl(&steps_path, &step)?;
steps.push(step);
break;
}
if is_stop_action(&action) && !args.auto_review && !is_result_review_action(&action) {
append_jsonl(&steps_path, &step)?;
append_operator_step_jsonl(&steps_path, &step)?;
steps.push(step);
break;
}
@ -386,7 +386,7 @@ fn run_coordinator(args: &Args) -> Result<Value> {
"action": wait_action_for_role(role_id),
"reason": result["note"],
});
append_jsonl(&steps_path, &step)?;
append_operator_step_jsonl(&steps_path, &step)?;
steps.push(step);
break;
}
@ -398,7 +398,7 @@ fn run_coordinator(args: &Args) -> Result<Value> {
"action": review_action_for_role(role_id),
"reason": result["note"]
});
append_jsonl(&steps_path, &step)?;
append_operator_step_jsonl(&steps_path, &step)?;
steps.push(step);
break;
}
@ -434,12 +434,12 @@ fn run_coordinator(args: &Args) -> Result<Value> {
) {
final_action =
json!({"action": "waitForReorientResult", "reason": result["note"]});
append_jsonl(&steps_path, &step)?;
append_operator_step_jsonl(&steps_path, &step)?;
steps.push(step);
break;
}
final_action = json!({"action": "reviewReorientResult", "reason": result["note"]});
append_jsonl(&steps_path, &step)?;
append_operator_step_jsonl(&steps_path, &step)?;
steps.push(step);
break;
}
@ -490,7 +490,7 @@ fn run_coordinator(args: &Args) -> Result<Value> {
"action": wait_action_for_role(role_id),
"reason": result["note"],
});
append_jsonl(&steps_path, &step)?;
append_operator_step_jsonl(&steps_path, &step)?;
steps.push(step);
break;
}
@ -499,7 +499,7 @@ fn run_coordinator(args: &Args) -> Result<Value> {
"action": review_action_for_role(role_id),
"reason": result["note"],
});
append_jsonl(&steps_path, &step)?;
append_operator_step_jsonl(&steps_path, &step)?;
steps.push(step);
break;
}
@ -542,14 +542,14 @@ fn run_coordinator(args: &Args) -> Result<Value> {
) {
final_action =
json!({"action": "waitForReorientResult", "reason": result["note"]});
append_jsonl(&steps_path, &step)?;
append_operator_step_jsonl(&steps_path, &step)?;
steps.push(step);
break;
}
if !args.auto_review {
final_action =
json!({"action": "reviewReorientResult", "reason": result["note"]});
append_jsonl(&steps_path, &step)?;
append_operator_step_jsonl(&steps_path, &step)?;
steps.push(step);
break;
}
@ -560,7 +560,7 @@ fn run_coordinator(args: &Args) -> Result<Value> {
&mut step,
json!({"type": "dryCompact", "threadId": thread_id}),
);
append_jsonl(&steps_path, &step)?;
append_operator_step_jsonl(&steps_path, &step)?;
steps.push(step);
continue;
}
@ -571,7 +571,7 @@ fn run_coordinator(args: &Args) -> Result<Value> {
}
_ => {}
}
append_jsonl(&steps_path, &step)?;
append_operator_step_jsonl(&steps_path, &step)?;
steps.push(step);
}
@ -1405,6 +1405,10 @@ fn append_jsonl(path: &Path, value: &Value) -> Result<()> {
Ok(())
}
fn append_operator_step_jsonl(path: &Path, step: &Value) -> Result<()> {
append_jsonl(path, &status_cli::sanitize_for_operator(step.clone()))
}
fn text_at(value: &Value, path: &[&str]) -> Result<String> {
let mut cursor = value;
for key in path {

1
epiphany-tool-codex-mcp-spine/Cargo.lock generated
View file

@ -2253,6 +2253,7 @@ dependencies = [
"serde",
"serde_json",
"sha1",
"toml",
"tracing",
"uuid",
]

BIN
state/agent-heartbeats.msgpack
View file

Binary file not shown.

BIN
state/ledgers.msgpack
View file

Binary file not shown.

1
vendor/codex/codex-rs/Cargo.lock generated vendored
View file

@ -5092,6 +5092,7 @@ dependencies = [
name = "epiphany-codex-bridge"
version = "0.1.0"
dependencies = [
"allocative",
"anyhow",
"chrono",
"codex-app-server-protocol",