aven-core 0.1.12

Core library for the Aven local-first task manager
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36

use anyhow::Result;
use sqlx::{Row, SqliteConnection};

#[derive(Debug, Clone, Default, PartialEq, Eq)]
pub struct SyncHistoryStats {
    pub total_change_rows: i64,
    pub pending_change_rows: i64,
    pub synced_change_rows: i64,
    pub min_server_seq: Option<i64>,
    pub max_server_seq: Option<i64>,
    pub payload_bytes: i64,
}

pub async fn sync_history_stats(conn: &mut SqliteConnection) -> Result<SyncHistoryStats> {
    let row = sqlx::query(
        "SELECT
         COUNT(*) AS total_change_rows,
         COALESCE(SUM(CASE WHEN server_seq IS NULL THEN 1 ELSE 0 END), 0) AS pending_change_rows,
         COALESCE(SUM(CASE WHEN server_seq IS NOT NULL THEN 1 ELSE 0 END), 0) AS synced_change_rows,
         MIN(server_seq) AS min_server_seq,
         MAX(server_seq) AS max_server_seq,
         COALESCE(SUM(length(CAST(payload AS BLOB))), 0) AS payload_bytes
         FROM changes",
    )
    .fetch_one(&mut *conn)
    .await?;

    Ok(SyncHistoryStats {
        total_change_rows: row.get("total_change_rows"),
        pending_change_rows: row.get("pending_change_rows"),
        synced_change_rows: row.get("synced_change_rows"),
        min_server_seq: row.get("min_server_seq"),
        max_server_seq: row.get("max_server_seq"),
        payload_bytes: row.get("payload_bytes"),
    })
}