Function durable_analytics_rows

src/dashboard/analytics_api.rs:114–159

(
    global_db: Option<&GlobalDb>,
    lcm_conn: Option<&libsql::Connection>,
    project_id: &str,
)

}

async fn durable_analytics_rows(
    global_db: Option<&GlobalDb>,
    lcm_conn: Option<&libsql::Connection>,
    project_id: &str,
) -> Option<Vec<Value>> {
    if let Some(db) = global_db {
        if let Ok(events) = db
            .query_analytics_events(&AnalyticsEventQuery {
                provider: None,
                project_id: Some(project_id.to_string()),
                session_id: None,
                event_kind: None,
                since: None,
                limit: ANALYTICS_EVENT_LIMIT,
            })
            .await
        {
            if !events.is_empty() {
                return Some(events.iter().map(durable_analytics_event_row).collect());
            }
        }
    }

    let rows = query_rows(
        lcm_conn?,
        "SELECT provider, timestamp, event_kind, hook_name, tool_name,
                tool_category, skill_name, hint_category, outcome, metadata_json
         FROM (
             SELECT provider, timestamp, event_kind, hook_name, tool_name,
                    tool_category, skill_name, hint_category, outcome, metadata_json, id
             FROM analytics_events
             WHERE project_id = ?1
             ORDER BY timestamp DESC, id DESC
             LIMIT 10000
         )
         ORDER BY timestamp, id",
        libsql::params![project_id],
    )
    .await
    .ok()?;
    if rows.is_empty() {
        None
    } else {
        Some(rows)
    }
}

pub(crate) fn durable_analytics_event_row(event: &AnalyticsEventRecord) -> Value {
    json!({