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

Move MVP status onto Epiphany view

Browse source
This commit is contained in:
Meta Vens 2026-05-12 03:53:15 +01:00
commit 5f6fe64dc7
2 changed files with 36 additions and 26 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -510,26 +510,30 @@ fn collect_coordinator_status(
Some(json!({"threadId": thread_id, "includeTurns": false})),
true,
)?;
let scene = client.send(
"thread/epiphany/scene",
Some(json!({"threadId": thread_id})),
true,
)?;
let pressure = client.send(
"thread/epiphany/pressure",
Some(json!({"threadId": thread_id})),
let view = client.send(
"thread/epiphany/view",
Some(json!({"threadId": thread_id, "lenses": ["scene", "pressure", "jobs"]})),
true,
)?;
let scene = json!({
"threadId": thread_id,
"scene": view.get("scene").cloned().unwrap_or_else(|| json!(null)),
});
let pressure = json!({
"threadId": thread_id,
"source": "live",
"pressure": view.get("pressure").cloned().unwrap_or_else(|| json!(null)),
});
let reorient = client.send(
"thread/epiphany/reorient",
Some(json!({"threadId": thread_id})),
true,
)?;
let jobs = client.send(
"thread/epiphany/jobs",
Some(json!({"threadId": thread_id})),
true,
)?;
let jobs = json!({
"threadId": thread_id,
"source": "live",
"jobs": view.get("jobs").cloned().unwrap_or_else(|| json!([])),
});
let roles = client.send(
"thread/epiphany/roles",
Some(json!({"threadId": thread_id})),
@ -589,6 +593,7 @@ fn collect_coordinator_status(
Ok(json!({
"threadId": thread_id,
"read": read,
"view": view,
"scene": scene,
"pressure": pressure,
"reorient": reorient,

31
epiphany-core/src/bin/epiphany-mvp-status.rs
View file

@ -159,26 +159,30 @@ fn run_status(args: &Args) -> Result<Value> {
Some(json!({"threadId": thread_id, "includeTurns": false})),
true,
)?;
let scene = client.send(
"thread/epiphany/scene",
Some(json!({"threadId": thread_id})),
true,
)?;
let pressure = client.send(
"thread/epiphany/pressure",
Some(json!({"threadId": thread_id})),
let view = client.send(
"thread/epiphany/view",
Some(json!({"threadId": thread_id, "lenses": ["scene", "pressure", "jobs"]})),
true,
)?;
let scene = json!({
"threadId": thread_id,
"scene": view.get("scene").cloned().unwrap_or_else(|| json!(null)),
});
let pressure = json!({
"threadId": thread_id,
"source": "live",
"pressure": view.get("pressure").cloned().unwrap_or_else(|| json!(null)),
});
let reorient = client.send(
"thread/epiphany/reorient",
Some(json!({"threadId": thread_id})),
true,
)?;
let jobs = client.send(
"thread/epiphany/jobs",
Some(json!({"threadId": thread_id})),
true,
)?;
let jobs = json!({
"threadId": thread_id,
"source": "live",
"jobs": view.get("jobs").cloned().unwrap_or_else(|| json!([])),
});
let roles = client.send(
"thread/epiphany/roles",
Some(json!({"threadId": thread_id})),
@ -251,6 +255,7 @@ fn run_status(args: &Args) -> Result<Value> {
let status = json!({
"threadId": thread_id,
"read": read,
"view": view,
"scene": scene,
"pressure": pressure,
"reorient": reorient,