Function row_to_memory

core/src/memory/store.rs:261–300

(row: &rusqlite::Row<'_>)

// ---------------------------------------------------------------------------

fn row_to_memory(row: &rusqlite::Row<'_>) -> GraphBitResult<Memory> {
    let id_str: String = row.get(0)?;
    let content: String = row.get(1)?;
    let user_id: Option<String> = row.get(2)?;
    let agent_id: Option<String> = row.get(3)?;
    let run_id: Option<String> = row.get(4)?;
    let hash: String = row.get(5)?;
    let metadata_json: String = row.get(6)?;
    let created_at_str: String = row.get(7)?;
    let updated_at_str: String = row.get(8)?;

    let id = MemoryId(Uuid::parse_str(&id_str).map_err(|e| {
        GraphBitError::memory(format!("Invalid UUID in database: {e}"))
    })?);

    let metadata: HashMap<String, serde_json::Value> =
        serde_json::from_str(&metadata_json).unwrap_or_default();

    let created_at = DateTime::parse_from_rfc3339(&created_at_str)
        .map(|dt| dt.with_timezone(&Utc))
        .unwrap_or_else(|_| Utc::now());

    let updated_at = DateTime::parse_from_rfc3339(&updated_at_str)
        .map(|dt| dt.with_timezone(&Utc))
        .unwrap_or_else(|_| Utc::now());

    Ok(Memory {
        id,
        content,
        scope: MemoryScope {
            user_id,
            agent_id,
            run_id,
        },
        metadata,
        created_at,
        updated_at,
        hash,
    })
}

fn row_to_history(row: &rusqlite::Row<'_>) -> GraphBitResult<MemoryHistory> {
    let memory_id_str: String = row.get(0)?;