Function read_parts

atomic-agent/src/transcript/opencode.rs:199–225

Content parts of the session in chronological order: `(message_id, data)`.

(conn: &Connection, session_id: &str)

/// Content parts of the session in chronological order:
/// `(message_id, data)`.
fn read_parts(conn: &Connection, session_id: &str) -> Option<Vec<(String, Value)>> {
    let mut stmt = conn
        .prepare(
            "SELECT message_id, data FROM part \
             WHERE session_id = ?1 ORDER BY time_created, id",
        )
        .ok()?;
    let rows = stmt
        .query_map([session_id], |row| {
            Ok((row.get::<_, String>(0)?, row.get::<_, String>(1)?))
        })
        .ok()?;

    let mut out = Vec::new();
    for row in rows {
        match row {
            Ok((message_id, data)) => match serde_json::from_str::<Value>(&data) {
                Ok(v) => out.push((message_id, v)),
                Err(e) => log::debug!("opencode store: skipping unparseable part: {}", e),
            },
            Err(e) => {
                log::debug!("opencode store: skipping part row: {}", e);
            }
        }
    }
    Some(out)
}

/// Fold messages and parts into [`TurnData`].
///