Function forward_server_event

crates/opencode-tui/src/app/app.rs:3682–3756

(data_lines: &[String], event_tx: &Sender<Event>)

}

fn forward_server_event(data_lines: &[String], event_tx: &Sender<Event>) {
    if data_lines.is_empty() {
        return;
    }
    let payload = data_lines.join("\n");
    let Ok(value) = serde_json::from_str::<serde_json::Value>(&payload) else {
        return;
    };
    let event_type = value.get("type").and_then(|item| item.as_str());
    let session_id = value
        .get("sessionID")
        .and_then(|item| item.as_str())
        .or_else(|| value.get("sessionId").and_then(|item| item.as_str()));
    match event_type {
        Some("session.updated") => {
            let Some(session_id) = session_id else {
                return;
            };
            let _ = event_tx.send(Event::Custom(CustomEvent::StateChanged(
                StateChange::SessionUpdated(session_id.to_string()),
            )));
        }
        Some("session.status") => {
            let Some(session_id) = session_id else {
                return;
            };
            let status_type = value
                .get("status")
                .and_then(|status| status.get("type"))
                .and_then(|item| item.as_str())
                .or_else(|| value.get("status").and_then(|item| item.as_str()));
            match status_type {
                Some("busy") => {
                    let _ = event_tx.send(Event::Custom(CustomEvent::StateChanged(
                        StateChange::SessionStatusBusy(session_id.to_string()),
                    )));
                }
                Some("idle") => {
                    let _ = event_tx.send(Event::Custom(CustomEvent::StateChanged(
                        StateChange::SessionStatusIdle(session_id.to_string()),
                    )));
                }
                Some("retry") => {
                    let attempt = value
                        .get("status")
                        .and_then(|status| status.get("attempt"))
                        .and_then(|item| item.as_u64())
                        .and_then(|v| u32::try_from(v).ok())
                        .unwrap_or(0);
                    let message = value
                        .get("status")
                        .and_then(|status| status.get("message"))
                        .and_then(|item| item.as_str())
                        .unwrap_or_default()
                        .to_string();
                    let next = value
                        .get("status")
                        .and_then(|status| status.get("next"))