ankurah-storage-postgres 0.8.0

Ankurah storage engine using Postgres
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
101
102
103
104
105
106
107
108
109
110
111
112
113
114

mod common;

use ankurah::property::YrsString;
use ankurah::Model;
use ankurah::{policy::DEFAULT_CONTEXT as c, Node, PermissiveAgent};
use anyhow::Result;
use serde::{Deserialize, Serialize};
use std::sync::Arc;

#[derive(Model, Debug, Serialize, Deserialize)]
pub struct Album {
    #[active_type(YrsString)]
    pub name: String,
}

#[tokio::test]
async fn pg_repeatable_read() -> Result<()> {
    let (_container, postgres) = common::create_postgres_container().await?;
    let node = Node::new_durable(Arc::new(postgres), PermissiveAgent::new());
    node.system.create().await?;
    let ctx = node.context(c)?;

    let id;
    {
        let trx = ctx.begin();
        let album_rw = trx.create(&Album { name: "I love cats".into() }).await?;
        assert_eq!(album_rw.name().value(), Some("I love cats".to_string()));
        id = album_rw.id();
        trx.commit().await?;
    }

    // TODO: implement Mutable.read() -> View
    let album_ro: AlbumView = ctx.get(id).await?;

    let trx2 = ctx.begin();
    let album_rw2 = album_ro.edit(&trx2)?;

    let trx3 = ctx.begin();
    let album_rw3 = album_ro.edit(&trx3)?;

    // tx2 cats -> tofu
    album_rw2.name().delete(7, 4)?;
    album_rw2.name().insert(7, "tofu")?;
    assert_eq!(album_rw2.name().value(), Some("I love tofu".to_string()));

    // tx3 love -> devour
    album_rw3.name().delete(2, 4)?;
    album_rw3.name().insert(2, "devour")?;
    assert_eq!(album_rw3.name().value(), Some("I devour cats".to_string()));

    // trx2 and 3 are uncommited, so the value should not be updated
    assert_eq!(album_ro.name().unwrap(), "I love cats");
    trx2.commit().await?;

    // FAIL - the value must be updated now
    assert_eq!(album_ro.name().unwrap(), "I love tofu");

    trx3.commit().await?;

    // FAIL - the value must be updated now
    assert_eq!(album_ro.name().unwrap(), "I devour tofu");

    Ok(())
}

#[tokio::test]
async fn pg_events() -> Result<()> {
    let (_container, postgres) = common::create_postgres_container().await?;
    let node = Node::new_durable(Arc::new(postgres), PermissiveAgent::new());
    node.system.create().await?;
    let ctx = node.context(c)?;

    let id;
    {
        let trx = ctx.begin();
        let album_rw = trx.create(&Album { name: "I love cats".into() }).await?;
        assert_eq!(album_rw.name().value(), Some("I love cats".to_string()));
        id = album_rw.id();
        trx.commit().await?;
    }

    // TODO: implement Mutable.read() -> View
    let album_ro: AlbumView = ctx.get(id).await?;

    let trx2 = ctx.begin();
    let album_rw2 = album_ro.edit(&trx2)?;

    let trx3 = ctx.begin();
    let album_rw3 = album_ro.edit(&trx3)?;

    // tx2 cats -> tofu
    album_rw2.name().delete(7, 4)?;
    album_rw2.name().insert(7, "tofu")?;
    assert_eq!(album_rw2.name().value(), Some("I love tofu".to_string()));

    // tx3 love -> devour
    album_rw3.name().delete(2, 4)?;
    album_rw3.name().insert(2, "devour")?;
    assert_eq!(album_rw3.name().value(), Some("I devour cats".to_string()));

    // trx2 and 3 are uncommited, so the value should not be updated
    assert_eq!(album_ro.name().unwrap(), "I love cats");
    trx2.commit().await?;

    // FAIL - the value must be updated now
    assert_eq!(album_ro.name().unwrap(), "I love tofu");

    trx3.commit().await?;

    // FAIL - the value must be updated now
    assert_eq!(album_ro.name().unwrap(), "I devour tofu");

    Ok(())
}