Function wait_for_turn_summary

src/sessions/codex_app_server.rs:309–343

(
    line_rx: &mpsc::Receiver<std::io::Result<String>>,
    deadline: Instant,
)

}

fn wait_for_turn_summary(
    line_rx: &mpsc::Receiver<std::io::Result<String>>,
    deadline: Instant,
) -> Result<CodexAppServerSummary> {
    let mut text = String::new();
    let mut model = None;
    loop {
        let line = recv_line(line_rx, deadline)?;
        let value: Value = serde_json::from_str(&line)?;
        if model.is_none() {
            model = find_model_id(&value);
        }
        if let Some(error) = value.get("error") {
            return Err(TraceDecayError::Config {
                message: format!("codex app-server turn failed: {error}"),
            });
        }
        match value.get("method").and_then(Value::as_str) {
            Some("item/agentMessage/delta") => {
                if let Some(delta) = value.pointer("/params/delta").and_then(Value::as_str) {
                    text.push_str(delta);
                }
            }
            Some("item/completed") if text.trim().is_empty() => {
                if let Some(item_text) = collect_item_text(value.get("params")) {
                    text.push_str(&item_text);
                }
            }
            Some("turn/completed") => {
                return Ok(CodexAppServerSummary { text, model });
            }
            _ => {}
        }
    }
}

fn recv_line(
    line_rx: &mpsc::Receiver<std::io::Result<String>>,