taskchampion 3.0.1

Personal task-tracking
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
98
99
100

#![cfg(all(feature = "server-local", not(target_arch = "wasm32")))]

use pretty_assertions::assert_eq;
use proptest::prelude::*;
use taskchampion::storage::inmemory::InMemoryStorage;
use taskchampion::{Operations, Replica, ServerConfig, TaskData, Uuid};
use tempfile::TempDir;

#[derive(Debug, Clone)]
enum Action {
    Create,
    Update(String, String),
    Delete,
    Sync,
}

fn action() -> impl Strategy<Value = Action> {
    prop_oneof![
        Just(Action::Create),
        ("(description|project|due)", "(a|b|c)").prop_map(|(p, v)| Action::Update(p, v)),
        Just(Action::Delete),
        Just(Action::Sync),
    ]
}

fn actions() -> impl Strategy<Value = Vec<(Action, u8)>> {
    proptest::collection::vec((action(), (0..3u8)), 0..100)
}

proptest! {
#[test]
    /// Check that various sequences of operations on mulitple db's do not get the db's into an
    /// incompatible state.  The main concern here is that there might be a sequence of operations
    /// that results in a task being in different states in different replicas. Different tasks
    /// cannot interfere with one another, so this focuses on a single task.
    fn multi_replica_sync(action_sequence in actions()) {
        let tmp_dir = TempDir::new().expect("TempDir failed");
        let uuid = Uuid::parse_str("83a2f9ef-f455-4195-b92e-a54c161eebfc").unwrap();
        let server_config = ServerConfig::Local {
            server_dir: tmp_dir.path().to_path_buf(),
        };

        tokio::runtime::Builder::new_current_thread()
            .enable_all()
            .build()
            .unwrap()
            .block_on(async {
                let mut server = server_config.into_server().await.unwrap();
                let mut replicas = [
                    Replica::new(InMemoryStorage::new()),
                    Replica::new(InMemoryStorage::new()),
                    Replica::new(InMemoryStorage::new()),
                ];

                for (action, rep) in action_sequence {
                    println!("{action:?} on rep {rep}");

                    let rep = &mut replicas[rep as usize];
                    match action {
                        Action::Create => {
                            if rep.get_task_data(uuid).await.unwrap().is_none() {
                                let mut ops = Operations::new();
                                TaskData::create(uuid, &mut ops);
                                rep.commit_operations(ops).await.unwrap();
                            }
                        }
                        Action::Update(p, v) => {
                            if let Some(mut t) = rep.get_task_data(uuid).await.unwrap() {
                                let mut ops = Operations::new();
                                t.update(p, Some(v), &mut ops);
                                rep.commit_operations(ops).await.unwrap();
                            }
                        }
                        Action::Delete => {
                            if let Some(mut t) = rep.get_task_data(uuid).await.unwrap() {
                                let mut ops = Operations::new();
                                t.delete(&mut ops);
                                rep.commit_operations(ops).await.unwrap();
                            }
                        }
                        Action::Sync => rep.sync(&mut server, false).await.unwrap(),
                    }
                }

                // Sync all of the replicas, twice, to flush out any un-synced changes.
                for rep in &mut replicas {
                    rep.sync(&mut server, false).await.unwrap()
                }
                for rep in &mut replicas {
                    rep.sync(&mut server, false).await.unwrap()
                }

                let t0 = replicas[0].get_task_data(uuid).await.unwrap();
                let t1 = replicas[1].get_task_data(uuid).await.unwrap();
                let t2 = replicas[2].get_task_data(uuid).await.unwrap();
                assert_eq!(t0, t1);
                assert_eq!(t1, t2);
            });
    }
}