noatun 0.1.3

Noatun is an in-process, distributed database with materialized view support.
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

use crate::cutoff::CutOffDuration;
use crate::data_types::NoatunVec;
use crate::database::DatabaseSettings;
use crate::SavefileMessageSerializer;
use crate::{Database, Message, MessageId};
use datetime_literal::datetime;
use savefile_derive::Savefile;
use std::pin::Pin;

noatun_pod! {
    #[derive(PartialEq)]
    /// Docs for MyName
    struct MyName {
        /// Docs for name
        name: u32,
        /// Docs for age
        age: u32
    }
}

noatun_object!(
    /// Docs for customer struct
    struct Customer {
        /// Docs for customer name
        pod name: MyName,
        /// Docs for worth
        pod worth: u32,
    }
);
noatun_object!(
    struct Bank {
        pod total_money:u32,
        object customers: NoatunVec<Customer>
    }
);

#[derive(Debug, Savefile)]
pub enum BankMessage {
    AddCustomerAndMoney { money: u32, customer: u32 },
}

impl Message for BankMessage {
    type Root = Bank;
    type Serializer = SavefileMessageSerializer<Self>;

    fn apply(&self, _time: MessageId, mut root: Pin<&mut Self::Root>) {
        match self {
            BankMessage::AddCustomerAndMoney { money, customer: _ } => {
                let prev_money = root.total_money();
                root.as_mut().set_total_money(prev_money + *money);
                root.customers_mut().push(&CustomerNative {
                    name: MyName { name: 42, age: 31 },
                    worth: 100,
                });
            }
        }
    }
}

#[test]
fn init_bank_miri() {
    let mut db: Database<BankMessage> = Database::create_in_memory(
        10_000,
        DatabaseSettings {
            mock_time: Some(datetime!(2023-01-01 Z).into()),
            cutoff_interval: CutOffDuration::from_minutes(15),
            ..Default::default()
        },
    )
    .unwrap();
    let mut db = db.begin_session_mut().unwrap();
    db.append_local(BankMessage::AddCustomerAndMoney {
        money: 10,
        customer: 10,
    })
    .unwrap();

    db.append_local(BankMessage::AddCustomerAndMoney {
        money: 10,
        customer: 10,
    })
    .unwrap();
    db.with_root(|root| {
        assert_eq!(root.total_money.get(), 20);
        assert_eq!(root.customers().len(), 2);
    })
}