aven 0.1.5

Local-first task manager CLI and sync server
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
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97

mod common;

use sqlx::sqlite::{SqliteConnectOptions, SqlitePoolOptions};

use common::{TestEnv, contains_all, ok};

fn first_token(output: &str) -> &str {
    output
        .split_whitespace()
        .next()
        .expect("output starts with ref")
}

#[tokio::test]
async fn old_schema_database_can_be_opened_and_read() {
    let env = TestEnv::new();
    let db = env.db("old.sqlite");
    let pool = SqlitePoolOptions::new()
        .max_connections(1)
        .connect_with(
            SqliteConnectOptions::new()
                .filename(&db)
                .create_if_missing(true),
        )
        .await
        .unwrap();

    sqlx::raw_sql(include_str!("../migrations/20260618000000_initial.sql"))
        .execute(&pool)
        .await
        .unwrap();
    sqlx::query(
        "INSERT INTO projects(key, name, prefix, created_at, updated_at)
         VALUES ('app', 'app', 'APP', 't', 't')",
    )
    .execute(&pool)
    .await
    .unwrap();
    sqlx::query(
        "INSERT INTO tasks(id, title, description, project_key, status, priority, created_at, updated_at)
         VALUES ('7KQ9A1X4MV2P8D6R', 'old task', '', 'app', 'inbox', 'none', 't', 't')",
    )
    .execute(&pool)
    .await
    .unwrap();
    sqlx::query(
        "INSERT INTO tasks(id, title, description, project_key, status, priority, created_at, updated_at, deleted)
         VALUES ('8KQ9A1X4MV2P8D6R', 'orphan task', '', 'missing', 'inbox', 'none', 't', 't', 1)",
    )
    .execute(&pool)
    .await
    .unwrap();
    sqlx::query("INSERT INTO project_paths(project_key, path) VALUES ('missing', '/tmp/missing')")
        .execute(&pool)
        .await
        .unwrap();
    drop(pool);

    let shown = ok(env.aven(&db, ["show", "7KQ"]));
    assert_eq!(first_token(&shown), "APP-7KQ9");
    contains_all(&shown, &["old task"]);

    let pool = SqlitePoolOptions::new()
        .max_connections(1)
        .connect_with(
            SqliteConnectOptions::new()
                .filename(&db)
                .create_if_missing(false),
        )
        .await
        .unwrap();
    let task_count: i64 = sqlx::query_scalar("SELECT count(*) FROM tasks")
        .fetch_one(&pool)
        .await
        .unwrap();
    let orphan_project_count: i64 =
        sqlx::query_scalar("SELECT count(*) FROM projects WHERE key = 'missing' AND deleted = 1")
            .fetch_one(&pool)
            .await
            .unwrap();
    let app_project_id: String = sqlx::query_scalar("SELECT id FROM projects WHERE key = 'app'")
        .fetch_one(&pool)
        .await
        .unwrap();
    let orphan_path_count: i64 = sqlx::query_scalar(
        "SELECT count(*) FROM project_paths pp
         JOIN projects p ON p.workspace_id = pp.workspace_id AND p.id = pp.project_id
         WHERE p.key = 'missing'",
    )
    .fetch_one(&pool)
    .await
    .unwrap();
    assert_eq!(task_count, 2);
    assert_eq!(orphan_project_count, 1);
    assert_eq!(orphan_path_count, 0);
    assert_eq!(app_project_id.len(), 16);
}