Function summarize

crates/opencode-session/src/summary.rs:203–229

Summarize a session: compute diffs and update session summary. This mirrors the TS `SessionSummary.summarize` which runs both `summarizeSession` and `summarizeMessage` in parallel.

(
    input: &SummarizeInput,
    messages: &[MessageWithParts],
    worktree: &std::path::Path,
    bus: Option<&Bus>,
)

/// This mirrors the TS `SessionSummary.summarize` which runs both
/// `summarizeSession` and `summarizeMessage` in parallel.
pub async fn summarize(
    input: &SummarizeInput,
    messages: &[MessageWithParts],
    worktree: &std::path::Path,
    bus: Option<&Bus>,
) -> SessionSummaryData {
    let diffs = clean_diffs(compute_diff(messages, worktree));

    let summary = SessionSummaryData {
        additions: diffs.iter().map(|d| d.additions).sum(),
        deletions: diffs.iter().map(|d| d.deletions).sum(),
        files: diffs.len() as u64,
        diffs: diffs.clone(),
    };

    // Publish diff event if bus is available
    if let Some(bus) = bus {
        let diff_event = opencode_core::bus::define_event("session.diff");
        let diff_data = serde_json::json!({
            "sessionID": input.session_id,
            "diff": diffs,
        });
        bus.publish(&diff_event, diff_data).await;
    }

    summary
}

fn session_diff_storage_key(session_id: &str) -> String {
    format!("{}{}", SESSION_DIFF_STORAGE_KEY_PREFIX, session_id)