aven-core 0.1.35

Core library for the Aven local-first task manager
Documentation 
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
37
38
39
40
41
42
43
44

use anyhow::Result;
use sqlx::{SqliteConnection, query_scalar};
use std::path::Path;

use super::{IntegrityCheck, IntegrityReport};

mod attachments;
mod database;
mod recurrence;

pub(super) async fn database_report(conn: &mut SqliteConnection) -> Result<IntegrityReport> {
    database::report_with_connection(conn).await
}

pub(super) fn ensure_ok(report: &IntegrityReport) -> Result<()> {
    database::ensure_ok(report)
}

pub(crate) async fn recurrence_integrity_checks(
    conn: &mut SqliteConnection,
) -> Result<Vec<IntegrityCheck>> {
    recurrence::recurrence_integrity_checks(conn).await
}

pub(crate) async fn attachment_integrity_checks(
    conn: &mut SqliteConnection,
    blob_dir: &Path,
    deep: bool,
) -> Result<Vec<IntegrityCheck>> {
    attachments::attachment_integrity_checks(conn, blob_dir, deep).await
}

async fn count_check(
    conn: &mut SqliteConnection,
    label: &'static str,
    query: &'static str,
) -> Result<IntegrityCheck> {
    let count: i64 = query_scalar(query).fetch_one(&mut *conn).await?;
    Ok(IntegrityCheck {
        label,
        ok: count == 0,
        value: format!("{count} orphaned"),
    })
}