From 57db4dc94dbf571ac8a393f61549def5afaa0209 Mon Sep 17 00:00:00 2001 From: main Date: Tue, 24 Mar 2026 19:26:58 -0400 Subject: Predeclare and stream consult session ids --- crates/phone-opus/src/mcp/fault.rs | 11 ++++++++--- 1 file changed, 8 insertions(+), 3 deletions(-) (limited to 'crates/phone-opus/src/mcp/fault.rs') diff --git a/crates/phone-opus/src/mcp/fault.rs b/crates/phone-opus/src/mcp/fault.rs index 4d438e3..c2d4a6c 100644 --- a/crates/phone-opus/src/mcp/fault.rs +++ b/crates/phone-opus/src/mcp/fault.rs @@ -14,10 +14,11 @@ pub(crate) struct FaultContext { pub(crate) struct ConsultFaultContext { pub(crate) cwd: String, pub(crate) context_mode: String, + pub(crate) planned_session_id: String, #[serde(skip_serializing_if = "Option::is_none")] pub(crate) reused_session_id: Option, #[serde(skip_serializing_if = "Option::is_none")] - pub(crate) downstream_session_id: Option, + pub(crate) observed_session_id: Option, #[serde(skip_serializing_if = "Option::is_none")] pub(crate) resume_session_id: Option, #[serde(default, skip_serializing_if = "is_false")] @@ -202,12 +203,16 @@ impl FaultRecord { let mut fields: BTreeMap = BTreeMap::from([ ("cwd".to_owned(), consult.cwd.clone()), ("context_mode".to_owned(), consult.context_mode.clone()), + ( + "planned_session".to_owned(), + consult.planned_session_id.clone(), + ), ]); if let Some(session_id) = consult.reused_session_id.as_ref() { let _ = fields.insert("reused_session".to_owned(), session_id.clone()); } - if let Some(session_id) = consult.downstream_session_id.as_ref() { - let _ = fields.insert("downstream_session".to_owned(), session_id.clone()); + if let Some(session_id) = consult.observed_session_id.as_ref() { + let _ = fields.insert("observed_session".to_owned(), session_id.clone()); } if let Some(session_id) = consult.resume_session_id.as_ref() { let _ = fields.insert("resume_session".to_owned(), session_id.clone()); -- cgit v1.2.3